diff --git a/main/src/main/java/sd/ExitNodeProcess.java b/main/src/main/java/sd/ExitNodeProcess.java index b82f275..a5868e5 100644 --- a/main/src/main/java/sd/ExitNodeProcess.java +++ b/main/src/main/java/sd/ExitNodeProcess.java @@ -40,6 +40,7 @@ import sd.protocol.SocketConnection; */ public class ExitNodeProcess { + // --- Configuration and Networking --- private final SimulationConfig config; private ServerSocket serverSocket; diff --git a/main/src/main/java/sd/protocol/MessageProtocol.java b/main/src/main/java/sd/protocol/MessageProtocol.java index 715bfc7..9a4ba27 100644 --- a/main/src/main/java/sd/protocol/MessageProtocol.java +++ b/main/src/main/java/sd/protocol/MessageProtocol.java @@ -2,7 +2,7 @@ package sd.protocol; import java.io.Serializable; -import sd.model.MessageType; // Assuming MessageType is in sd.model or sd.protocol +import sd.model.MessageType; /** * Contrato para todas as mensagens trocadas no simulador. diff --git a/main/src/main/java/sd/protocol/SocketConnection.java b/main/src/main/java/sd/protocol/SocketConnection.java index 58d843e..16dcdd4 100644 --- a/main/src/main/java/sd/protocol/SocketConnection.java +++ b/main/src/main/java/sd/protocol/SocketConnection.java @@ -30,9 +30,30 @@ import sd.serialization.SerializerFactory; */ public class SocketConnection implements Closeable { + // --- Network Resources --- + + /** + * The underlying TCP socket used for network communication. + */ private final Socket socket; + + /** + * The raw output stream for writing bytes to the network. + * Wrapped by {@link DataOutputStream} during message sending. + */ private final OutputStream outputStream; + + /** + * The raw input stream for reading bytes from the network. + * Wrapped by {@link DataInputStream} during message reception. + */ private final InputStream inputStream; + + // --- Serialization --- + + /** + * The serializer strategy used to convert objects to/from byte arrays (e.g., JSON). + */ private final MessageSerializer serializer; /** Número máximo de tentativas de ligação antes de desistir (Fail-fast). */ @@ -169,7 +190,7 @@ public class SocketConnection implements Closeable { } try { - // Lê um prefixo de 4 bytes - indicador de tamanho + DataInputStream dataIn = new DataInputStream(inputStream); int length = dataIn.readInt();