diff --git a/257844/src/main/java/cs451/net/event/message/Message.java b/257844/src/main/java/cs451/net/event/message/Message.java index 72c9c7b..74eb9a5 100644 --- a/257844/src/main/java/cs451/net/event/message/Message.java +++ b/257844/src/main/java/cs451/net/event/message/Message.java @@ -5,7 +5,7 @@ import java.util.HashMap; /** - * Message abstraction class + * Single Message Class * * @author C. Hölzl */ diff --git a/257844/src/main/java/cs451/net/event/message/MessageBundle.java b/257844/src/main/java/cs451/net/event/message/MessageBundle.java index 960b12f..94cc551 100644 --- a/257844/src/main/java/cs451/net/event/message/MessageBundle.java +++ b/257844/src/main/java/cs451/net/event/message/MessageBundle.java @@ -8,6 +8,11 @@ import java.util.Arrays; import java.util.List; import java.util.Objects; +/** + * Bundle of Messages Class + * + * @author C. Hölzl + */ public class MessageBundle extends NetMessageAbstract { public final List messageList; diff --git a/257844/src/main/java/cs451/net/event/message/NetMessageAbstract.java b/257844/src/main/java/cs451/net/event/message/NetMessageAbstract.java index db83e5f..65528b6 100644 --- a/257844/src/main/java/cs451/net/event/message/NetMessageAbstract.java +++ b/257844/src/main/java/cs451/net/event/message/NetMessageAbstract.java @@ -4,6 +4,11 @@ import java.util.HashMap; import java.util.List; import java.util.Objects; +/** + * Message abstraction class + * + * @author C. Hölzl + */ public abstract class NetMessageAbstract implements NetMessageInterface { public final TYPE tpe; public final Integer src; diff --git a/257844/src/main/java/cs451/net/handler/NetHandlerBNDL.java b/257844/src/main/java/cs451/net/handler/NetHandlerBNDL.java index f059cd7..33bfa4f 100644 --- a/257844/src/main/java/cs451/net/handler/NetHandlerBNDL.java +++ b/257844/src/main/java/cs451/net/handler/NetHandlerBNDL.java @@ -14,7 +14,7 @@ import java.util.concurrent.PriorityBlockingQueue; /** * NetEventHandler for BLUNDLER * - * Groups Multiple messages into larger packets (and de-groups them on receive + * Groups Multiple messages into larger packets (and de-groups them on receive) * * @author C. Hölzl */ diff --git a/257844/src/main/java/cs451/net/handler/NetHandlerLCB.java b/257844/src/main/java/cs451/net/handler/NetHandlerLCB.java index 5f98a8f..0d222ee 100644 --- a/257844/src/main/java/cs451/net/handler/NetHandlerLCB.java +++ b/257844/src/main/java/cs451/net/handler/NetHandlerLCB.java @@ -11,6 +11,16 @@ import java.util.concurrent.PriorityBlockingQueue; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; +/** + * NetEventHandler for Local Causal Broadcast + * + * DeliverIf: packet from queue satisfies LCB ordering + * + * Send: add dependencies to packet + * Deliver: Add packet to received packet queue for DeliverIf + * + * @author C. Hölzl + */ public class NetHandlerLCB extends NetEventHandlerAbstract { private static Map> causality; diff --git a/257844/src/main/java/cs451/tools/ParamDetector.java b/257844/src/main/java/cs451/tools/ParamDetector.java index cbe923d..44027c5 100644 --- a/257844/src/main/java/cs451/tools/ParamDetector.java +++ b/257844/src/main/java/cs451/tools/ParamDetector.java @@ -43,7 +43,7 @@ public abstract class ParamDetector { NetManager.FD_MAX_TRIES = 10; NetManager.FD_WAIT = 1000; - NetManager.BUNDLE_SIZE = 2; + NetManager.BUNDLE_SIZE = 100; NetManager.WINDOW_WIDTH *= NetManager.BUNDLE_SIZE; } }