1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
/* 1: */ package gregtech.common;
/* 2: */
/* 3: */ import com.google.common.io.ByteArrayDataInput;
/* 4: */ import com.google.common.io.ByteStreams;
/* 5: */ import cpw.mods.fml.common.network.FMLEmbeddedChannel;
/* 6: */ import cpw.mods.fml.common.network.FMLOutboundHandler;
/* 7: */ import cpw.mods.fml.common.network.FMLOutboundHandler.OutboundTarget;
/* 8: */ import cpw.mods.fml.common.network.NetworkRegistry;
/* 9: */ import cpw.mods.fml.common.network.NetworkRegistry.TargetPoint;
/* 10: */ import cpw.mods.fml.common.network.internal.FMLProxyPacket;
/* 11: */ import cpw.mods.fml.relauncher.Side;
/* 12: */ import gregtech.api.enums.GT_Values;
/* 13: */ import gregtech.api.interfaces.internal.IGT_Mod;
/* 14: */ import gregtech.api.net.GT_Packet;
/* 15: */ import gregtech.api.net.GT_Packet_Block_Event;
/* 16: */ import gregtech.api.net.GT_Packet_Sound;
/* 17: */ import gregtech.api.net.GT_Packet_TileEntity;
/* 18: */ import gregtech.api.net.IGT_NetworkHandler;
/* 19: */ import gregtech.common.blocks.GT_Packet_Ores;
/* 20: */ import io.netty.buffer.ByteBuf;
/* 21: */ import io.netty.buffer.Unpooled;
/* 22: */ import io.netty.channel.Channel;
/* 23: */ import io.netty.channel.ChannelHandler;
/* 24: */ import io.netty.channel.ChannelHandler.Sharable;
/* 25: */ import io.netty.channel.ChannelHandlerContext;
/* 26: */ import io.netty.channel.SimpleChannelInboundHandler;
/* 27: */ import io.netty.handler.codec.MessageToMessageCodec;
/* 28: */ import io.netty.util.Attribute;
/* 29: */ import java.util.EnumMap;
/* 30: */ import java.util.List;
/* 31: */ import net.minecraft.entity.player.EntityPlayer;
/* 32: */ import net.minecraft.entity.player.EntityPlayerMP;
/* 33: */ import net.minecraft.server.management.PlayerManager;
/* 34: */ import net.minecraft.world.World;
/* 35: */ import net.minecraft.world.WorldServer;
/* 36: */ import net.minecraft.world.chunk.Chunk;
/* 37: */
/* 38: */ @ChannelHandler.Sharable
/* 39: */ public class GT_Network
/* 40: */ extends MessageToMessageCodec<FMLProxyPacket, GT_Packet>
/* 41: */ implements IGT_NetworkHandler
/* 42: */ {
/* 43: */ private final EnumMap<Side, FMLEmbeddedChannel> mChannel;
/* 44: */ private final GT_Packet[] mSubChannels;
/* 45: */
/* 46: */ public GT_Network()
/* 47: */ {
/* 48:32 */ this.mChannel = NetworkRegistry.INSTANCE.newChannel("GregTech", new ChannelHandler[] { this, new HandlerShared() });
/* 49:33 */ this.mSubChannels = new GT_Packet[] { new GT_Packet_TileEntity(), new GT_Packet_Sound(), new GT_Packet_Block_Event(), new GT_Packet_Ores() };
/* 50: */ }
/* 51: */
/* 52: */ protected void encode(ChannelHandlerContext aContext, GT_Packet aPacket, List<Object> aOutput)
/* 53: */ throws Exception
/* 54: */ {
/* 55:37 */ aOutput.add(new FMLProxyPacket(Unpooled.buffer().writeByte(aPacket.getPacketID()).writeBytes(aPacket.encode()).copy(), (String)aContext.channel().attr(NetworkRegistry.FML_CHANNEL).get()));
/* 56: */ }
/* 57: */
/* 58: */ protected void decode(ChannelHandlerContext aContext, FMLProxyPacket aPacket, List<Object> aOutput)
/* 59: */ throws Exception
/* 60: */ {
/* 61:42 */ ByteArrayDataInput aData = ByteStreams.newDataInput(aPacket.payload().array());
/* 62:43 */ aOutput.add(this.mSubChannels[aData.readByte()].decode(aData));
/* 63: */ }
/* 64: */
/* 65: */ public void sendToPlayer(GT_Packet aPacket, EntityPlayerMP aPlayer)
/* 66: */ {
/* 67:48 */ ((FMLEmbeddedChannel)this.mChannel.get(Side.SERVER)).attr(FMLOutboundHandler.FML_MESSAGETARGET).set(FMLOutboundHandler.OutboundTarget.PLAYER);
/* 68:49 */ ((FMLEmbeddedChannel)this.mChannel.get(Side.SERVER)).attr(FMLOutboundHandler.FML_MESSAGETARGETARGS).set(aPlayer);
/* 69:50 */ ((FMLEmbeddedChannel)this.mChannel.get(Side.SERVER)).writeAndFlush(aPacket);
/* 70: */ }
/* 71: */
/* 72: */ public void sendToAllAround(GT_Packet aPacket, NetworkRegistry.TargetPoint aPosition)
/* 73: */ {
/* 74:55 */ ((FMLEmbeddedChannel)this.mChannel.get(Side.SERVER)).attr(FMLOutboundHandler.FML_MESSAGETARGET).set(FMLOutboundHandler.OutboundTarget.ALLAROUNDPOINT);
/* 75:56 */ ((FMLEmbeddedChannel)this.mChannel.get(Side.SERVER)).attr(FMLOutboundHandler.FML_MESSAGETARGETARGS).set(aPosition);
/* 76:57 */ ((FMLEmbeddedChannel)this.mChannel.get(Side.SERVER)).writeAndFlush(aPacket);
/* 77: */ }
/* 78: */
/* 79: */ public void sendToServer(GT_Packet aPacket)
/* 80: */ {
/* 81:62 */ ((FMLEmbeddedChannel)this.mChannel.get(Side.CLIENT)).attr(FMLOutboundHandler.FML_MESSAGETARGET).set(FMLOutboundHandler.OutboundTarget.TOSERVER);
/* 82:63 */ ((FMLEmbeddedChannel)this.mChannel.get(Side.CLIENT)).writeAndFlush(aPacket);
/* 83: */ }
/* 84: */
/* 85: */ public void sendPacketToAllPlayersInRange(World aWorld, GT_Packet aPacket, int aX, int aZ)
/* 86: */ {
/* 87:68 */ if (!aWorld.isRemote) {
/* 88:68 */ for (Object tObject : aWorld.playerEntities)
/* 89: */ {
/* 90:69 */ if (!(tObject instanceof EntityPlayerMP)) {
/* 91: */ break;
/* 92: */ }
/* 93:70 */ EntityPlayerMP tPlayer = (EntityPlayerMP)tObject;
/* 94:71 */ Chunk tChunk = aWorld.getChunkFromBlockCoords(aX, aZ);
/* 95:72 */ if (tPlayer.getServerForPlayer().getPlayerManager().isPlayerWatchingChunk(tPlayer, tChunk.xPosition, tChunk.zPosition)) {
/* 96:74 */ sendToPlayer(aPacket, tPlayer);
/* 97: */ }
/* 98: */ }
/* 99: */ }
/* :0: */ }
/* :1: */
/* :2: */ @ChannelHandler.Sharable
/* :3: */ static final class HandlerShared
/* :4: */ extends SimpleChannelInboundHandler<GT_Packet>
/* :5: */ {
/* :6: */ protected void channelRead0(ChannelHandlerContext ctx, GT_Packet aPacket)
/* :7: */ throws Exception
/* :8: */ {
/* :9:86 */ EntityPlayer aPlayer = GT_Values.GT.getThePlayer();
/* ;0:87 */ aPacket.process(aPlayer == null ? null : GT_Values.GT.getThePlayer().worldObj);
/* ;1: */ }
/* ;2: */ }
/* ;3: */ }
/* Location: F:\Torrent\minecraft\jd-gui-0.3.6.windows\gregtech_1.7.10-5.07.07-dev.jar
* Qualified Name: gregtech.common.GT_Network
* JD-Core Version: 0.7.0.1
*/
|
