aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/gregtech/common/GT_Network.java
diff options
context:
space:
mode:
authorRaven Szewczyk <git@eigenraven.me>2022-08-27 10:19:57 +0100
committerGitHub <noreply@github.com>2022-08-27 11:19:57 +0200
commit6f31720697bcc351421a4d86ba3bf749375dd12c (patch)
tree3adf8f318f22c892d74cd7c9d30b6dd3f11f11bd /src/main/java/gregtech/common/GT_Network.java
parentc3eac50decd33ee2be8703dfb2ecf9cdc31c2b67 (diff)
downloadGT5-Unofficial-6f31720697bcc351421a4d86ba3bf749375dd12c.tar.gz
GT5-Unofficial-6f31720697bcc351421a4d86ba3bf749375dd12c.tar.bz2
GT5-Unofficial-6f31720697bcc351421a4d86ba3bf749375dd12c.zip
Update buildscript & apply spotless (#1306)
* Update dependencies * Update buildscript, apply spotless
Diffstat (limited to 'src/main/java/gregtech/common/GT_Network.java')
-rw-r--r--src/main/java/gregtech/common/GT_Network.java94
1 files changed, 55 insertions, 39 deletions
diff --git a/src/main/java/gregtech/common/GT_Network.java b/src/main/java/gregtech/common/GT_Network.java
index 8db38d86f7..39f50a9e04 100644
--- a/src/main/java/gregtech/common/GT_Network.java
+++ b/src/main/java/gregtech/common/GT_Network.java
@@ -1,5 +1,7 @@
package gregtech.common;
+import static gregtech.GT_Mod.GT_FML_LOGGER;
+
import com.google.common.io.ByteArrayDataInput;
import com.google.common.io.ByteStreams;
import cpw.mods.fml.common.network.FMLEmbeddedChannel;
@@ -18,16 +20,13 @@ import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.MessageToMessageCodec;
+import java.util.EnumMap;
+import java.util.List;
import net.minecraft.entity.player.EntityPlayer;
import net.minecraft.entity.player.EntityPlayerMP;
import net.minecraft.world.World;
import net.minecraft.world.chunk.Chunk;
-import java.util.EnumMap;
-import java.util.List;
-
-import static gregtech.GT_Mod.GT_FML_LOGGER;
-
@ChannelHandler.Sharable
@SuppressWarnings("deprecation")
public class GT_Network extends MessageToMessageCodec<FMLProxyPacket, GT_Packet> implements IGT_NetworkHandler {
@@ -35,49 +34,49 @@ public class GT_Network extends MessageToMessageCodec<FMLProxyPacket, GT_Packet>
private final GT_Packet[] mSubChannels;
public GT_Network() {
- this("GregTech",
- new GT_Packet_TileEntity(),
- new GT_Packet_Sound(),
- new GT_Packet_Block_Event(),
- new GT_Packet_Ores(),
- new GT_Packet_Pollution(),
- new MessageSetFlaskCapacity(),
- new GT_Packet_TileEntityCover(),
- new GT_Packet_TileEntityCoverGUI(),
- new MessageUpdateFluidDisplayItem(),
- new GT_Packet_ClientPreference(),
- new GT_Packet_WirelessRedstoneCover(),
- new GT_Packet_TileEntityCoverNew(),
- new GT_Packet_SetConfigurationCircuit(),
- new GT_Packet_UpdateItem(),
- new GT_Packet_SetLockedFluid(),
- new GT_Packet_GtTileEntityGuiRequest(),
- new GT_Packet_SendCoverData(),
- new GT_Packet_RequestCoverData()
- );
+ this(
+ "GregTech",
+ new GT_Packet_TileEntity(),
+ new GT_Packet_Sound(),
+ new GT_Packet_Block_Event(),
+ new GT_Packet_Ores(),
+ new GT_Packet_Pollution(),
+ new MessageSetFlaskCapacity(),
+ new GT_Packet_TileEntityCover(),
+ new GT_Packet_TileEntityCoverGUI(),
+ new MessageUpdateFluidDisplayItem(),
+ new GT_Packet_ClientPreference(),
+ new GT_Packet_WirelessRedstoneCover(),
+ new GT_Packet_TileEntityCoverNew(),
+ new GT_Packet_SetConfigurationCircuit(),
+ new GT_Packet_UpdateItem(),
+ new GT_Packet_SetLockedFluid(),
+ new GT_Packet_GtTileEntityGuiRequest(),
+ new GT_Packet_SendCoverData(),
+ new GT_Packet_RequestCoverData());
}
-
+
public GT_Network(String channelName, GT_Packet... packetTypes) {
this.mChannel = NetworkRegistry.INSTANCE.newChannel(channelName, this, new HandlerShared());
this.mSubChannels = new GT_Packet[packetTypes.length];
for (GT_Packet packetType : packetTypes) {
final int pId = packetType.getPacketID();
- if (this.mSubChannels[pId] == null)
- this.mSubChannels[pId] = packetType;
- else
- throw new IllegalArgumentException("Duplicate Packet ID! " + pId);
+ if (this.mSubChannels[pId] == null) this.mSubChannels[pId] = packetType;
+ else throw new IllegalArgumentException("Duplicate Packet ID! " + pId);
}
}
-
+
@Override
protected void encode(ChannelHandlerContext aContext, GT_Packet aPacket, List<Object> aOutput) throws Exception {
ByteBuf tBuf = Unpooled.buffer().writeByte(aPacket.getPacketID());
aPacket.encode(tBuf);
- aOutput.add(new FMLProxyPacket(tBuf, aContext.channel().attr(NetworkRegistry.FML_CHANNEL).get()));
+ aOutput.add(new FMLProxyPacket(
+ tBuf, aContext.channel().attr(NetworkRegistry.FML_CHANNEL).get()));
}
@Override
- protected void decode(ChannelHandlerContext aContext, FMLProxyPacket aPacket, List<Object> aOutput) throws Exception {
+ protected void decode(ChannelHandlerContext aContext, FMLProxyPacket aPacket, List<Object> aOutput)
+ throws Exception {
ByteArrayDataInput aData = ByteStreams.newDataInput(aPacket.payload().array());
GT_Packet tPacket = this.mSubChannels[aData.readByte()].decode(aData);
tPacket.setINetHandler(aPacket.handler());
@@ -94,21 +93,36 @@ public class GT_Network extends MessageToMessageCodec<FMLProxyPacket, GT_Packet>
GT_FML_LOGGER.info("player null");
return;
}
- this.mChannel.get(Side.SERVER).attr(FMLOutboundHandler.FML_MESSAGETARGET).set(FMLOutboundHandler.OutboundTarget.PLAYER);
- this.mChannel.get(Side.SERVER).attr(FMLOutboundHandler.FML_MESSAGETARGETARGS).set(aPlayer);
+ this.mChannel
+ .get(Side.SERVER)
+ .attr(FMLOutboundHandler.FML_MESSAGETARGET)
+ .set(FMLOutboundHandler.OutboundTarget.PLAYER);
+ this.mChannel
+ .get(Side.SERVER)
+ .attr(FMLOutboundHandler.FML_MESSAGETARGETARGS)
+ .set(aPlayer);
this.mChannel.get(Side.SERVER).writeAndFlush(aPacket);
}
@Override
public void sendToAllAround(GT_Packet aPacket, NetworkRegistry.TargetPoint aPosition) {
- this.mChannel.get(Side.SERVER).attr(FMLOutboundHandler.FML_MESSAGETARGET).set(FMLOutboundHandler.OutboundTarget.ALLAROUNDPOINT);
- this.mChannel.get(Side.SERVER).attr(FMLOutboundHandler.FML_MESSAGETARGETARGS).set(aPosition);
+ this.mChannel
+ .get(Side.SERVER)
+ .attr(FMLOutboundHandler.FML_MESSAGETARGET)
+ .set(FMLOutboundHandler.OutboundTarget.ALLAROUNDPOINT);
+ this.mChannel
+ .get(Side.SERVER)
+ .attr(FMLOutboundHandler.FML_MESSAGETARGETARGS)
+ .set(aPosition);
this.mChannel.get(Side.SERVER).writeAndFlush(aPacket);
}
@Override
public void sendToServer(GT_Packet aPacket) {
- this.mChannel.get(Side.CLIENT).attr(FMLOutboundHandler.FML_MESSAGETARGET).set(FMLOutboundHandler.OutboundTarget.TOSERVER);
+ this.mChannel
+ .get(Side.CLIENT)
+ .attr(FMLOutboundHandler.FML_MESSAGETARGET)
+ .set(FMLOutboundHandler.OutboundTarget.TOSERVER);
this.mChannel.get(Side.CLIENT).writeAndFlush(aPacket);
}
@@ -121,7 +135,9 @@ public class GT_Network extends MessageToMessageCodec<FMLProxyPacket, GT_Packet>
}
EntityPlayerMP tPlayer = (EntityPlayerMP) tObject;
Chunk tChunk = aWorld.getChunkFromBlockCoords(aX, aZ);
- if (tPlayer.getServerForPlayer().getPlayerManager().isPlayerWatchingChunk(tPlayer, tChunk.xPosition, tChunk.zPosition)) {
+ if (tPlayer.getServerForPlayer()
+ .getPlayerManager()
+ .isPlayerWatchingChunk(tPlayer, tChunk.xPosition, tChunk.zPosition)) {
sendToPlayer(aPacket, tPlayer);
}
}