From 160d4fd7e64f08c7bde45f2b984b3abebba63132 Mon Sep 17 00:00:00 2001 From: Klaus Pfeiffer Date: Sat, 7 Nov 2015 13:01:51 +0100 Subject: [PATCH] fixed javadoc; prepared pom for release --- pom.xml | 12 +++++++----- src/main/java/com/jfastnet/Client.java | 2 +- src/main/java/com/jfastnet/Config.java | 2 +- src/main/java/com/jfastnet/IMessageReceiver.java | 2 +- src/main/java/com/jfastnet/IMessageSender.java | 2 +- src/main/java/com/jfastnet/IPeer.java | 2 +- src/main/java/com/jfastnet/IPeerController.java | 2 +- src/main/java/com/jfastnet/IServerHooks.java | 2 +- src/main/java/com/jfastnet/ISimpleProcessable.java | 2 +- src/main/java/com/jfastnet/IStartStop.java | 2 +- src/main/java/com/jfastnet/MessageKey.java | 2 +- src/main/java/com/jfastnet/MessageLog.java | 4 ++-- src/main/java/com/jfastnet/NetStats.java | 2 +- src/main/java/com/jfastnet/PeerController.java | 2 +- src/main/java/com/jfastnet/Server.java | 2 +- .../java/com/jfastnet/config/SerialiserConfig.java | 2 +- .../idprovider/ClientIdReliableModeIdProvider.java | 2 +- .../java/com/jfastnet/idprovider/IIdProvider.java | 4 ++-- .../jfastnet/idprovider/ReliableModeIdProvider.java | 2 +- .../com/jfastnet/idprovider/SimpleIdProvider.java | 2 +- src/main/java/com/jfastnet/messages/AckMessage.java | 2 +- .../jfastnet/messages/ClientTimerSyncMessage.java | 2 +- .../java/com/jfastnet/messages/ConnectRequest.java | 2 +- .../java/com/jfastnet/messages/ConnectResponse.java | 2 +- .../java/com/jfastnet/messages/GenericMessage.java | 2 +- src/main/java/com/jfastnet/messages/IAckMessage.java | 2 +- src/main/java/com/jfastnet/messages/IBatchable.java | 2 +- src/main/java/com/jfastnet/messages/IDontFrame.java | 2 +- .../jfastnet/messages/IInstantOnSendProcessable.java | 2 +- .../com/jfastnet/messages/IInstantProcessable.java | 2 +- .../jfastnet/messages/IInstantServerProcessable.java | 2 +- .../java/com/jfastnet/messages/IOrderedMessage.java | 2 +- .../java/com/jfastnet/messages/IsReadyMessage.java | 2 +- .../java/com/jfastnet/messages/LeaveRequest.java | 2 +- src/main/java/com/jfastnet/messages/Message.java | 2 +- src/main/java/com/jfastnet/messages/MessagePart.java | 2 +- .../com/jfastnet/messages/RequestSeqIdsMessage.java | 2 +- .../com/jfastnet/messages/SequenceKeepAlive.java | 2 +- .../java/com/jfastnet/messages/TimerSyncMessage.java | 2 +- .../MessageExecutionPriorityComparator.java | 2 +- .../messages/comparators/MessageIdComparator.java | 2 +- .../jfastnet/messages/features/ChecksumFeature.java | 2 +- .../jfastnet/messages/features/MessageFeature.java | 2 +- .../jfastnet/messages/features/MessageFeatures.java | 2 +- .../jfastnet/messages/features/TimestampFeature.java | 2 +- .../java/com/jfastnet/peers/javanet/JavaNetPeer.java | 2 +- .../peers/netty/FutureGenericFutureListener.java | 2 +- .../java/com/jfastnet/peers/netty/KryoNettyPeer.java | 2 +- .../jfastnet/processors/AddChecksumProcessor.java | 2 +- .../jfastnet/processors/DiscardMessagesHandler.java | 2 +- .../DiscardWrongChecksumMessagesHandler.java | 2 +- .../processors/IMessageReceiverPostProcessor.java | 2 +- .../processors/IMessageReceiverPreProcessor.java | 2 +- .../processors/IMessageSenderPostProcessor.java | 2 +- .../processors/IMessageSenderPreProcessor.java | 2 +- .../com/jfastnet/processors/MessageLogProcessor.java | 2 +- .../com/jfastnet/processors/OrderedUdpHandler.java | 2 +- .../java/com/jfastnet/processors/ProcessFlags.java | 2 +- .../processors/ReliableModeAckProcessor.java | 2 +- .../processors/ReliableModeSequenceProcessor.java | 2 +- .../java/com/jfastnet/serialiser/ISerialiser.java | 2 +- .../java/com/jfastnet/serialiser/KryoSerialiser.java | 2 +- src/main/java/com/jfastnet/time/ITimeProvider.java | 2 +- .../java/com/jfastnet/time/SystemTimeProvider.java | 2 +- .../com/jfastnet/util/ConcurrentSizeLimitedMap.java | 2 +- src/main/java/com/jfastnet/util/NullsafeHashMap.java | 2 +- src/main/java/com/jfastnet/util/SizeLimitedList.java | 2 +- src/main/java/com/jfastnet/util/SizeLimitedMap.java | 2 +- src/main/java/com/jfastnet/util/SizeLimitedSet.java | 2 +- src/test/java/com/jfastnet/AbstractTest.java | 2 +- src/test/java/com/jfastnet/MessageLogTest.java | 2 +- src/test/java/com/jfastnet/ServerTest.java | 2 +- src/test/java/com/jfastnet/examples/HelloWorld.java | 2 +- .../java/com/jfastnet/messages/MessagePartTest.java | 2 +- .../messages/features/ChecksumFeatureTest.java | 2 +- .../jfastnet/util/ConcurrentSizeLimitedMapTest.java | 2 +- 76 files changed, 84 insertions(+), 82 deletions(-) diff --git a/pom.xml b/pom.xml index c39e475..dc0f689 100644 --- a/pom.xml +++ b/pom.xml @@ -19,10 +19,11 @@ com.jfastnet jfastnet - 0.1.2-SNAPSHOT + 0.1.2 jar jfastnet + Fast, reliable UDP messaging for Java. Designed for games. http://www.jfastnet.com @@ -64,10 +65,10 @@ + klaus7 klaus@allpiper.com Klaus Pfeiffer http://www.allpiper.com - klaus7 @@ -230,9 +231,10 @@ org.apache.maven.plugins maven-javadoc-plugin 2.9.1 - - false - + + + + attach-javadocs diff --git a/src/main/java/com/jfastnet/Client.java b/src/main/java/com/jfastnet/Client.java index 0f8b7db..449c6d1 100644 --- a/src/main/java/com/jfastnet/Client.java +++ b/src/main/java/com/jfastnet/Client.java @@ -24,7 +24,7 @@ import java.net.InetSocketAddress; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class Client extends PeerController { diff --git a/src/main/java/com/jfastnet/Config.java b/src/main/java/com/jfastnet/Config.java index e519cde..a43eeb4 100644 --- a/src/main/java/com/jfastnet/Config.java +++ b/src/main/java/com/jfastnet/Config.java @@ -34,7 +34,7 @@ import java.util.*; import java.util.concurrent.ConcurrentHashMap; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Setter @Accessors(chain = true) public class Config { diff --git a/src/main/java/com/jfastnet/IMessageReceiver.java b/src/main/java/com/jfastnet/IMessageReceiver.java index 3ead541..3d5f7bc 100644 --- a/src/main/java/com/jfastnet/IMessageReceiver.java +++ b/src/main/java/com/jfastnet/IMessageReceiver.java @@ -18,7 +18,7 @@ import com.jfastnet.messages.Message; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IMessageReceiver { /** Receive message. */ diff --git a/src/main/java/com/jfastnet/IMessageSender.java b/src/main/java/com/jfastnet/IMessageSender.java index 24eac66..853250d 100644 --- a/src/main/java/com/jfastnet/IMessageSender.java +++ b/src/main/java/com/jfastnet/IMessageSender.java @@ -19,7 +19,7 @@ import com.jfastnet.messages.GenericMessage; import com.jfastnet.messages.Message; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IMessageSender { /** diff --git a/src/main/java/com/jfastnet/IPeer.java b/src/main/java/com/jfastnet/IPeer.java index 71538ad..286dc0b 100644 --- a/src/main/java/com/jfastnet/IPeer.java +++ b/src/main/java/com/jfastnet/IPeer.java @@ -18,7 +18,7 @@ import com.jfastnet.messages.Message; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IPeer extends IStartStop, IMessageSender, ISimpleProcessable { /** After the method call message.payload should be non-null. diff --git a/src/main/java/com/jfastnet/IPeerController.java b/src/main/java/com/jfastnet/IPeerController.java index fae193b..9a598c1 100644 --- a/src/main/java/com/jfastnet/IPeerController.java +++ b/src/main/java/com/jfastnet/IPeerController.java @@ -18,5 +18,5 @@ /** Controls a peer interface by behaving like a peer, client or server. Every * peer controller can send and receive messages. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IPeerController extends IMessageSender, IMessageReceiver, ISimpleProcessable, IStartStop {} diff --git a/src/main/java/com/jfastnet/IServerHooks.java b/src/main/java/com/jfastnet/IServerHooks.java index 37fb553..ee244d3 100644 --- a/src/main/java/com/jfastnet/IServerHooks.java +++ b/src/main/java/com/jfastnet/IServerHooks.java @@ -17,7 +17,7 @@ package com.jfastnet; /** Server hooks are called on various occasions. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IServerHooks { /** Called when a client joins the server. */ diff --git a/src/main/java/com/jfastnet/ISimpleProcessable.java b/src/main/java/com/jfastnet/ISimpleProcessable.java index 36ec821..2586e14 100644 --- a/src/main/java/com/jfastnet/ISimpleProcessable.java +++ b/src/main/java/com/jfastnet/ISimpleProcessable.java @@ -16,7 +16,7 @@ package com.jfastnet; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface ISimpleProcessable { void process(); } diff --git a/src/main/java/com/jfastnet/IStartStop.java b/src/main/java/com/jfastnet/IStartStop.java index 2b50073..ec21aa8 100644 --- a/src/main/java/com/jfastnet/IStartStop.java +++ b/src/main/java/com/jfastnet/IStartStop.java @@ -16,7 +16,7 @@ package com.jfastnet; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IStartStop { /** @return true if start was successful, false otherwise. */ diff --git a/src/main/java/com/jfastnet/MessageKey.java b/src/main/java/com/jfastnet/MessageKey.java index 0f0d537..7d45e10 100644 --- a/src/main/java/com/jfastnet/MessageKey.java +++ b/src/main/java/com/jfastnet/MessageKey.java @@ -20,7 +20,7 @@ import lombok.ToString; /** Reliable mode / ClientID / MessageID - Key - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @ToString public class MessageKey implements Comparable{ public Message.ReliableMode reliableMode; diff --git a/src/main/java/com/jfastnet/MessageLog.java b/src/main/java/com/jfastnet/MessageLog.java index 572b714..aa804fb 100644 --- a/src/main/java/com/jfastnet/MessageLog.java +++ b/src/main/java/com/jfastnet/MessageLog.java @@ -27,10 +27,10 @@ /** Logs incoming and outgoing messages. Per default only reliable messages * get logged and an upper bound for the message log is used. - *
+ * * The reliable sequence processor will grab required messages from the message * log. So don't change the filter unless you know what you're doing. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class MessageLog { diff --git a/src/main/java/com/jfastnet/NetStats.java b/src/main/java/com/jfastnet/NetStats.java index e0a2405..71ff736 100644 --- a/src/main/java/com/jfastnet/NetStats.java +++ b/src/main/java/com/jfastnet/NetStats.java @@ -27,7 +27,7 @@ import java.util.concurrent.atomic.AtomicLong; /** Statistics about the network traffic. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class NetStats { public static final DateFormat FILE_DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd_HH-mm-ss_SSS"); diff --git a/src/main/java/com/jfastnet/PeerController.java b/src/main/java/com/jfastnet/PeerController.java index 22467a3..86670f9 100644 --- a/src/main/java/com/jfastnet/PeerController.java +++ b/src/main/java/com/jfastnet/PeerController.java @@ -29,7 +29,7 @@ import java.util.ArrayList; import java.util.List; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class PeerController implements IPeerController { diff --git a/src/main/java/com/jfastnet/Server.java b/src/main/java/com/jfastnet/Server.java index fb57bc5..f979b66 100644 --- a/src/main/java/com/jfastnet/Server.java +++ b/src/main/java/com/jfastnet/Server.java @@ -24,7 +24,7 @@ import java.util.Map; import java.util.concurrent.ConcurrentHashMap; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class Server extends PeerController { diff --git a/src/main/java/com/jfastnet/config/SerialiserConfig.java b/src/main/java/com/jfastnet/config/SerialiserConfig.java index f4e8fa5..65ebe8c 100644 --- a/src/main/java/com/jfastnet/config/SerialiserConfig.java +++ b/src/main/java/com/jfastnet/config/SerialiserConfig.java @@ -16,7 +16,7 @@ package com.jfastnet.config; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class SerialiserConfig { /** Use basic Java's In-/Deflater compression. Can only be used when de-/ diff --git a/src/main/java/com/jfastnet/idprovider/ClientIdReliableModeIdProvider.java b/src/main/java/com/jfastnet/idprovider/ClientIdReliableModeIdProvider.java index c83da58..f55e08b 100644 --- a/src/main/java/com/jfastnet/idprovider/ClientIdReliableModeIdProvider.java +++ b/src/main/java/com/jfastnet/idprovider/ClientIdReliableModeIdProvider.java @@ -24,7 +24,7 @@ /** Attention! This won't work with Lockstepping, because the * lockstepping impl requires the same id for messages on all clients. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class ClientIdReliableModeIdProvider implements IIdProvider { private Map> idMap = new NullsafeHashMap>() { diff --git a/src/main/java/com/jfastnet/idprovider/IIdProvider.java b/src/main/java/com/jfastnet/idprovider/IIdProvider.java index 422b9ff..7b3e116 100644 --- a/src/main/java/com/jfastnet/idprovider/IIdProvider.java +++ b/src/main/java/com/jfastnet/idprovider/IIdProvider.java @@ -22,7 +22,7 @@ /** Provides the id for messages. It depends on the use case which provider * you should choose. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IIdProvider extends Comparator { /** Get new id for message. */ @@ -33,7 +33,7 @@ public interface IIdProvider extends Comparator { /** Return true, if broadcasted messages should resolve the message id * again after setting the correct receiver id. - *
+ * * Otherwise every client receives the same id for a particular message, * which is required for the lock stepping extension implementation. */ default boolean resolveEveryClientMessage() { diff --git a/src/main/java/com/jfastnet/idprovider/ReliableModeIdProvider.java b/src/main/java/com/jfastnet/idprovider/ReliableModeIdProvider.java index ca0eb33..e91007b 100644 --- a/src/main/java/com/jfastnet/idprovider/ReliableModeIdProvider.java +++ b/src/main/java/com/jfastnet/idprovider/ReliableModeIdProvider.java @@ -24,7 +24,7 @@ import java.util.concurrent.atomic.AtomicLong; /** Ids begin with 1. Every reliable mode has its stream of ids. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ReliableModeIdProvider implements IIdProvider { diff --git a/src/main/java/com/jfastnet/idprovider/SimpleIdProvider.java b/src/main/java/com/jfastnet/idprovider/SimpleIdProvider.java index bef7ea5..b54be85 100644 --- a/src/main/java/com/jfastnet/idprovider/SimpleIdProvider.java +++ b/src/main/java/com/jfastnet/idprovider/SimpleIdProvider.java @@ -22,7 +22,7 @@ /** Provides a new id for every message. Usually not advisable to use this * provider. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class SimpleIdProvider implements IIdProvider { AtomicLong id = new AtomicLong(); diff --git a/src/main/java/com/jfastnet/messages/AckMessage.java b/src/main/java/com/jfastnet/messages/AckMessage.java index f532d5b..3bfe7f9 100644 --- a/src/main/java/com/jfastnet/messages/AckMessage.java +++ b/src/main/java/com/jfastnet/messages/AckMessage.java @@ -22,7 +22,7 @@ import java.util.Collection; import java.util.HashSet; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class AckMessage extends Message implements IBatchable, IAckMessage { diff --git a/src/main/java/com/jfastnet/messages/ClientTimerSyncMessage.java b/src/main/java/com/jfastnet/messages/ClientTimerSyncMessage.java index 82b084b..ec9f065 100644 --- a/src/main/java/com/jfastnet/messages/ClientTimerSyncMessage.java +++ b/src/main/java/com/jfastnet/messages/ClientTimerSyncMessage.java @@ -22,7 +22,7 @@ import lombok.extern.slf4j.Slf4j; /** Send the client his offsetToHost. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ClientTimerSyncMessage extends Message implements IDontFrame { diff --git a/src/main/java/com/jfastnet/messages/ConnectRequest.java b/src/main/java/com/jfastnet/messages/ConnectRequest.java index 7405e6b..8ce942c 100644 --- a/src/main/java/com/jfastnet/messages/ConnectRequest.java +++ b/src/main/java/com/jfastnet/messages/ConnectRequest.java @@ -20,7 +20,7 @@ import lombok.extern.slf4j.Slf4j; /** Sent from the client to the server. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ConnectRequest extends Message implements IDontFrame { diff --git a/src/main/java/com/jfastnet/messages/ConnectResponse.java b/src/main/java/com/jfastnet/messages/ConnectResponse.java index a75473a..c900c2e 100644 --- a/src/main/java/com/jfastnet/messages/ConnectResponse.java +++ b/src/main/java/com/jfastnet/messages/ConnectResponse.java @@ -25,7 +25,7 @@ import java.util.Set; /** Sent from the server to the client to confirm the connection. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ConnectResponse extends Message implements IDontFrame, IInstantProcessable, IAckMessage { diff --git a/src/main/java/com/jfastnet/messages/GenericMessage.java b/src/main/java/com/jfastnet/messages/GenericMessage.java index 894d1c5..811f64d 100644 --- a/src/main/java/com/jfastnet/messages/GenericMessage.java +++ b/src/main/java/com/jfastnet/messages/GenericMessage.java @@ -17,7 +17,7 @@ package com.jfastnet.messages; /** Used to send a plain object. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class GenericMessage extends Message { public Object object; diff --git a/src/main/java/com/jfastnet/messages/IAckMessage.java b/src/main/java/com/jfastnet/messages/IAckMessage.java index 0af5e9e..97ea66f 100644 --- a/src/main/java/com/jfastnet/messages/IAckMessage.java +++ b/src/main/java/com/jfastnet/messages/IAckMessage.java @@ -2,7 +2,7 @@ import java.util.Collection; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IAckMessage { /** Ids that are acknowledged. */ diff --git a/src/main/java/com/jfastnet/messages/IBatchable.java b/src/main/java/com/jfastnet/messages/IBatchable.java index b24917c..f73cd51 100644 --- a/src/main/java/com/jfastnet/messages/IBatchable.java +++ b/src/main/java/com/jfastnet/messages/IBatchable.java @@ -18,7 +18,7 @@ import java.util.Collection; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IBatchable { void set(Collection batch); } diff --git a/src/main/java/com/jfastnet/messages/IDontFrame.java b/src/main/java/com/jfastnet/messages/IDontFrame.java index 5ac7f7d..1172d27 100644 --- a/src/main/java/com/jfastnet/messages/IDontFrame.java +++ b/src/main/java/com/jfastnet/messages/IDontFrame.java @@ -18,5 +18,5 @@ /** The message implementing this marker interface will not be processed * within the boundaries of the lockstepping mechanism. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IDontFrame {} diff --git a/src/main/java/com/jfastnet/messages/IInstantOnSendProcessable.java b/src/main/java/com/jfastnet/messages/IInstantOnSendProcessable.java index acd4e0a..a6f1702 100644 --- a/src/main/java/com/jfastnet/messages/IInstantOnSendProcessable.java +++ b/src/main/java/com/jfastnet/messages/IInstantOnSendProcessable.java @@ -19,5 +19,5 @@ /** Marker interface to determine, that a message should be processed, before * sending it to the receiver. Use with caution, this will easily get you * into trouble when using the lockstep system. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IInstantOnSendProcessable {} diff --git a/src/main/java/com/jfastnet/messages/IInstantProcessable.java b/src/main/java/com/jfastnet/messages/IInstantProcessable.java index 8b1ab33..fb1483c 100644 --- a/src/main/java/com/jfastnet/messages/IInstantProcessable.java +++ b/src/main/java/com/jfastnet/messages/IInstantProcessable.java @@ -18,5 +18,5 @@ /** Message will not be forwarded to the external receiver. Instead it will * be immediately processed. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IInstantProcessable {} diff --git a/src/main/java/com/jfastnet/messages/IInstantServerProcessable.java b/src/main/java/com/jfastnet/messages/IInstantServerProcessable.java index 121cb4a..e9101aa 100644 --- a/src/main/java/com/jfastnet/messages/IInstantServerProcessable.java +++ b/src/main/java/com/jfastnet/messages/IInstantServerProcessable.java @@ -19,7 +19,7 @@ /** Marker interface for instant processable actions on the server side upon receiving. * Be cautious with concurrency! *

Can only be transferred unreliable, because all systems are skipped.

- * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IInstantServerProcessable { void process(); } diff --git a/src/main/java/com/jfastnet/messages/IOrderedMessage.java b/src/main/java/com/jfastnet/messages/IOrderedMessage.java index 2c97a1a..f3fab90 100644 --- a/src/main/java/com/jfastnet/messages/IOrderedMessage.java +++ b/src/main/java/com/jfastnet/messages/IOrderedMessage.java @@ -19,7 +19,7 @@ /** A message that needs to be received in a particular order has to implement * this interface and respect the conditions. *
Usually a better way is to use a reliable sequence instead. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IOrderedMessage { /** @return the message id this message is based on. The message with this diff --git a/src/main/java/com/jfastnet/messages/IsReadyMessage.java b/src/main/java/com/jfastnet/messages/IsReadyMessage.java index 08bb913..0847683 100644 --- a/src/main/java/com/jfastnet/messages/IsReadyMessage.java +++ b/src/main/java/com/jfastnet/messages/IsReadyMessage.java @@ -19,7 +19,7 @@ import lombok.extern.slf4j.Slf4j; /** Sent when client is ready. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class IsReadyMessage extends Message implements IDontFrame { diff --git a/src/main/java/com/jfastnet/messages/LeaveRequest.java b/src/main/java/com/jfastnet/messages/LeaveRequest.java index e43190e..067d4ee 100644 --- a/src/main/java/com/jfastnet/messages/LeaveRequest.java +++ b/src/main/java/com/jfastnet/messages/LeaveRequest.java @@ -17,7 +17,7 @@ package com.jfastnet.messages; /** Sent from the client to the server. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class LeaveRequest extends Message implements IDontFrame { @Override diff --git a/src/main/java/com/jfastnet/messages/Message.java b/src/main/java/com/jfastnet/messages/Message.java index 9cb50c0..7bbc985 100644 --- a/src/main/java/com/jfastnet/messages/Message.java +++ b/src/main/java/com/jfastnet/messages/Message.java @@ -31,7 +31,7 @@ import java.net.InetSocketAddress; /** The base class for all messages. Subclass this class for your own messages. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j @Getter @EqualsAndHashCode diff --git a/src/main/java/com/jfastnet/messages/MessagePart.java b/src/main/java/com/jfastnet/messages/MessagePart.java index 2730dd1..eac496c 100644 --- a/src/main/java/com/jfastnet/messages/MessagePart.java +++ b/src/main/java/com/jfastnet/messages/MessagePart.java @@ -25,7 +25,7 @@ import java.util.stream.Collectors; /** Used for bigger messages to be transferred in parts. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class MessagePart extends Message implements IDontFrame { diff --git a/src/main/java/com/jfastnet/messages/RequestSeqIdsMessage.java b/src/main/java/com/jfastnet/messages/RequestSeqIdsMessage.java index 5cae951..3f2c7f4 100644 --- a/src/main/java/com/jfastnet/messages/RequestSeqIdsMessage.java +++ b/src/main/java/com/jfastnet/messages/RequestSeqIdsMessage.java @@ -25,7 +25,7 @@ import java.util.List; /** This message is used to request missing sequenced ids from the other side. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class RequestSeqIdsMessage extends Message implements IDontFrame { diff --git a/src/main/java/com/jfastnet/messages/SequenceKeepAlive.java b/src/main/java/com/jfastnet/messages/SequenceKeepAlive.java index 7777773..011cb76 100644 --- a/src/main/java/com/jfastnet/messages/SequenceKeepAlive.java +++ b/src/main/java/com/jfastnet/messages/SequenceKeepAlive.java @@ -20,5 +20,5 @@ * retrieved. Without sending this message one peer could be stuck, because * it never retrieves the last message and also has no way of detecting, * because a message with an higher id is not sent. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class SequenceKeepAlive extends Message implements IDontFrame {} diff --git a/src/main/java/com/jfastnet/messages/TimerSyncMessage.java b/src/main/java/com/jfastnet/messages/TimerSyncMessage.java index 14b2e94..47cbd78 100644 --- a/src/main/java/com/jfastnet/messages/TimerSyncMessage.java +++ b/src/main/java/com/jfastnet/messages/TimerSyncMessage.java @@ -27,7 +27,7 @@ /** This message is sent from the server to the client and then back to the * server. It is used to measure the round trip time. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class TimerSyncMessage extends Message implements IInstantServerProcessable, IDontFrame { diff --git a/src/main/java/com/jfastnet/messages/comparators/MessageExecutionPriorityComparator.java b/src/main/java/com/jfastnet/messages/comparators/MessageExecutionPriorityComparator.java index 1fddf70..29a5f91 100644 --- a/src/main/java/com/jfastnet/messages/comparators/MessageExecutionPriorityComparator.java +++ b/src/main/java/com/jfastnet/messages/comparators/MessageExecutionPriorityComparator.java @@ -21,7 +21,7 @@ import java.util.Comparator; /** Higher priority messages will come first when used this comparator. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class MessageExecutionPriorityComparator implements Comparator { public static final MessageExecutionPriorityComparator INSTANCE = new MessageExecutionPriorityComparator(); diff --git a/src/main/java/com/jfastnet/messages/comparators/MessageIdComparator.java b/src/main/java/com/jfastnet/messages/comparators/MessageIdComparator.java index ffd0e17..24f7367 100644 --- a/src/main/java/com/jfastnet/messages/comparators/MessageIdComparator.java +++ b/src/main/java/com/jfastnet/messages/comparators/MessageIdComparator.java @@ -21,7 +21,7 @@ import java.util.Comparator; /** Compares the id of messages. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class MessageIdComparator implements Comparator { public static final MessageIdComparator INSTANCE = new MessageIdComparator(); diff --git a/src/main/java/com/jfastnet/messages/features/ChecksumFeature.java b/src/main/java/com/jfastnet/messages/features/ChecksumFeature.java index 32fa02a..02aed16 100644 --- a/src/main/java/com/jfastnet/messages/features/ChecksumFeature.java +++ b/src/main/java/com/jfastnet/messages/features/ChecksumFeature.java @@ -23,7 +23,7 @@ import java.util.zip.CRC32; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ChecksumFeature implements MessageFeature { diff --git a/src/main/java/com/jfastnet/messages/features/MessageFeature.java b/src/main/java/com/jfastnet/messages/features/MessageFeature.java index bae2318..45f7217 100644 --- a/src/main/java/com/jfastnet/messages/features/MessageFeature.java +++ b/src/main/java/com/jfastnet/messages/features/MessageFeature.java @@ -20,7 +20,7 @@ import java.io.Serializable; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface MessageFeature extends Serializable { /** Provide the config to the feature. */ default void resolveConfig(Config config) {} diff --git a/src/main/java/com/jfastnet/messages/features/MessageFeatures.java b/src/main/java/com/jfastnet/messages/features/MessageFeatures.java index 8945acc..e93ef10 100644 --- a/src/main/java/com/jfastnet/messages/features/MessageFeatures.java +++ b/src/main/java/com/jfastnet/messages/features/MessageFeatures.java @@ -22,7 +22,7 @@ import java.util.Map; import java.util.Set; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class MessageFeatures implements Serializable, MessageFeature { private Set features = new HashSet<>(); diff --git a/src/main/java/com/jfastnet/messages/features/TimestampFeature.java b/src/main/java/com/jfastnet/messages/features/TimestampFeature.java index f7c08dd..949494f 100644 --- a/src/main/java/com/jfastnet/messages/features/TimestampFeature.java +++ b/src/main/java/com/jfastnet/messages/features/TimestampFeature.java @@ -18,7 +18,7 @@ import com.jfastnet.Config; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class TimestampFeature implements MessageFeature { public long timestamp; diff --git a/src/main/java/com/jfastnet/peers/javanet/JavaNetPeer.java b/src/main/java/com/jfastnet/peers/javanet/JavaNetPeer.java index 1b7254b..9bb6e60 100644 --- a/src/main/java/com/jfastnet/peers/javanet/JavaNetPeer.java +++ b/src/main/java/com/jfastnet/peers/javanet/JavaNetPeer.java @@ -28,7 +28,7 @@ import java.net.InetSocketAddress; import java.util.Random; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class JavaNetPeer implements IPeer { diff --git a/src/main/java/com/jfastnet/peers/netty/FutureGenericFutureListener.java b/src/main/java/com/jfastnet/peers/netty/FutureGenericFutureListener.java index fba4440..e808b0a 100644 --- a/src/main/java/com/jfastnet/peers/netty/FutureGenericFutureListener.java +++ b/src/main/java/com/jfastnet/peers/netty/FutureGenericFutureListener.java @@ -24,7 +24,7 @@ import lombok.experimental.Accessors; import lombok.extern.slf4j.Slf4j; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j @Accessors(chain = true) public class FutureGenericFutureListener implements GenericFutureListener> { diff --git a/src/main/java/com/jfastnet/peers/netty/KryoNettyPeer.java b/src/main/java/com/jfastnet/peers/netty/KryoNettyPeer.java index ce04bc4..690af20 100644 --- a/src/main/java/com/jfastnet/peers/netty/KryoNettyPeer.java +++ b/src/main/java/com/jfastnet/peers/netty/KryoNettyPeer.java @@ -33,7 +33,7 @@ import java.util.Random; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class KryoNettyPeer implements IPeer { diff --git a/src/main/java/com/jfastnet/processors/AddChecksumProcessor.java b/src/main/java/com/jfastnet/processors/AddChecksumProcessor.java index e1d5f4a..c910485 100644 --- a/src/main/java/com/jfastnet/processors/AddChecksumProcessor.java +++ b/src/main/java/com/jfastnet/processors/AddChecksumProcessor.java @@ -19,7 +19,7 @@ import com.jfastnet.messages.Message; import com.jfastnet.messages.features.ChecksumFeature; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class AddChecksumProcessor implements IMessageSenderPreProcessor { /** WIP! */ diff --git a/src/main/java/com/jfastnet/processors/DiscardMessagesHandler.java b/src/main/java/com/jfastnet/processors/DiscardMessagesHandler.java index 0efac2d..2d592b3 100644 --- a/src/main/java/com/jfastnet/processors/DiscardMessagesHandler.java +++ b/src/main/java/com/jfastnet/processors/DiscardMessagesHandler.java @@ -22,7 +22,7 @@ import java.util.HashMap; import java.util.Map; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class DiscardMessagesHandler implements IMessageReceiverPreProcessor{ // TODO potentially growing over time diff --git a/src/main/java/com/jfastnet/processors/DiscardWrongChecksumMessagesHandler.java b/src/main/java/com/jfastnet/processors/DiscardWrongChecksumMessagesHandler.java index efd131d..e2ff2b7 100644 --- a/src/main/java/com/jfastnet/processors/DiscardWrongChecksumMessagesHandler.java +++ b/src/main/java/com/jfastnet/processors/DiscardWrongChecksumMessagesHandler.java @@ -20,7 +20,7 @@ import com.jfastnet.messages.features.ChecksumFeature; /** Check incoming messages for correct checksums. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class DiscardWrongChecksumMessagesHandler implements IMessageReceiverPreProcessor { @Override diff --git a/src/main/java/com/jfastnet/processors/IMessageReceiverPostProcessor.java b/src/main/java/com/jfastnet/processors/IMessageReceiverPostProcessor.java index 81a5fa4..783d29c 100644 --- a/src/main/java/com/jfastnet/processors/IMessageReceiverPostProcessor.java +++ b/src/main/java/com/jfastnet/processors/IMessageReceiverPostProcessor.java @@ -18,7 +18,7 @@ import com.jfastnet.messages.Message; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IMessageReceiverPostProcessor { /** Message is received and forwarded to the external receiver at this time. */ diff --git a/src/main/java/com/jfastnet/processors/IMessageReceiverPreProcessor.java b/src/main/java/com/jfastnet/processors/IMessageReceiverPreProcessor.java index d830165..000929e 100644 --- a/src/main/java/com/jfastnet/processors/IMessageReceiverPreProcessor.java +++ b/src/main/java/com/jfastnet/processors/IMessageReceiverPreProcessor.java @@ -19,7 +19,7 @@ import com.jfastnet.messages.Message; /** Called before the message is handed over to the external receiver. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IMessageReceiverPreProcessor { /** Called before the message is handed over to the external receiver. */ diff --git a/src/main/java/com/jfastnet/processors/IMessageSenderPostProcessor.java b/src/main/java/com/jfastnet/processors/IMessageSenderPostProcessor.java index 3574d73..edeef68 100644 --- a/src/main/java/com/jfastnet/processors/IMessageSenderPostProcessor.java +++ b/src/main/java/com/jfastnet/processors/IMessageSenderPostProcessor.java @@ -18,7 +18,7 @@ import com.jfastnet.messages.Message; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IMessageSenderPostProcessor { /** Called after the message was successfully sent. */ Message afterSend(Message message); diff --git a/src/main/java/com/jfastnet/processors/IMessageSenderPreProcessor.java b/src/main/java/com/jfastnet/processors/IMessageSenderPreProcessor.java index 9164afe..65b54f8 100644 --- a/src/main/java/com/jfastnet/processors/IMessageSenderPreProcessor.java +++ b/src/main/java/com/jfastnet/processors/IMessageSenderPreProcessor.java @@ -18,7 +18,7 @@ import com.jfastnet.messages.Message; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface IMessageSenderPreProcessor { /** Congestion control is not implemented until now! WIP! diff --git a/src/main/java/com/jfastnet/processors/MessageLogProcessor.java b/src/main/java/com/jfastnet/processors/MessageLogProcessor.java index f91849f..de22e63 100644 --- a/src/main/java/com/jfastnet/processors/MessageLogProcessor.java +++ b/src/main/java/com/jfastnet/processors/MessageLogProcessor.java @@ -20,7 +20,7 @@ import com.jfastnet.messages.Message; /** Puts filtered messages into the message log. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ public class MessageLogProcessor implements IMessageSenderPostProcessor, IMessageReceiverPreProcessor { Config config; diff --git a/src/main/java/com/jfastnet/processors/OrderedUdpHandler.java b/src/main/java/com/jfastnet/processors/OrderedUdpHandler.java index 9d7855d..8a55eab 100644 --- a/src/main/java/com/jfastnet/processors/OrderedUdpHandler.java +++ b/src/main/java/com/jfastnet/processors/OrderedUdpHandler.java @@ -26,7 +26,7 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; -/** @author Klaus Pfeiffer +/** @author Klaus Pfeiffer - klaus@allpiper.com * @deprecated use a ReliableSequenceMessage instead */ @Deprecated public class OrderedUdpHandler implements IMessageReceiverPreProcessor, IMessageReceiverPostProcessor { diff --git a/src/main/java/com/jfastnet/processors/ProcessFlags.java b/src/main/java/com/jfastnet/processors/ProcessFlags.java index 54772be..f00d61e 100644 --- a/src/main/java/com/jfastnet/processors/ProcessFlags.java +++ b/src/main/java/com/jfastnet/processors/ProcessFlags.java @@ -16,7 +16,7 @@ package com.jfastnet.processors; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class ProcessFlags { /** If set to true, the ReliableModeSequenceProcessor will not check a diff --git a/src/main/java/com/jfastnet/processors/ReliableModeAckProcessor.java b/src/main/java/com/jfastnet/processors/ReliableModeAckProcessor.java index 2ce9065..38d53e3 100644 --- a/src/main/java/com/jfastnet/processors/ReliableModeAckProcessor.java +++ b/src/main/java/com/jfastnet/processors/ReliableModeAckProcessor.java @@ -37,7 +37,7 @@ /** Retrieval of messages with the reliable mode set to ACK must be confirmed * by sending an ACK message. This processor controls the resending of * messages and the retrieval of ACK messages. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ReliableModeAckProcessor implements ISimpleProcessable, IMessageReceiverPreProcessor, IMessageReceiverPostProcessor, IMessageSenderPreProcessor, IServerHooks { diff --git a/src/main/java/com/jfastnet/processors/ReliableModeSequenceProcessor.java b/src/main/java/com/jfastnet/processors/ReliableModeSequenceProcessor.java index 2a26781..a1ee99e 100644 --- a/src/main/java/com/jfastnet/processors/ReliableModeSequenceProcessor.java +++ b/src/main/java/com/jfastnet/processors/ReliableModeSequenceProcessor.java @@ -32,7 +32,7 @@ import java.util.concurrent.CopyOnWriteArraySet; /** Must be thread-safe. - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ReliableModeSequenceProcessor implements ISimpleProcessable, IMessageReceiverPreProcessor, IMessageSenderPostProcessor, IServerHooks { diff --git a/src/main/java/com/jfastnet/serialiser/ISerialiser.java b/src/main/java/com/jfastnet/serialiser/ISerialiser.java index ba25057..efad2cf 100644 --- a/src/main/java/com/jfastnet/serialiser/ISerialiser.java +++ b/src/main/java/com/jfastnet/serialiser/ISerialiser.java @@ -23,7 +23,7 @@ import java.io.OutputStream; import java.util.zip.CRC32; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface ISerialiser { byte[] serialise(Message message); diff --git a/src/main/java/com/jfastnet/serialiser/KryoSerialiser.java b/src/main/java/com/jfastnet/serialiser/KryoSerialiser.java index c89c748..aa13a9b 100644 --- a/src/main/java/com/jfastnet/serialiser/KryoSerialiser.java +++ b/src/main/java/com/jfastnet/serialiser/KryoSerialiser.java @@ -33,7 +33,7 @@ import java.util.zip.InflaterInputStream; /** Blazing fast kryo serialiser. Strongly recommended! - * @author Klaus Pfeiffer */ + * @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class KryoSerialiser implements ISerialiser{ diff --git a/src/main/java/com/jfastnet/time/ITimeProvider.java b/src/main/java/com/jfastnet/time/ITimeProvider.java index f567f43..7024f56 100644 --- a/src/main/java/com/jfastnet/time/ITimeProvider.java +++ b/src/main/java/com/jfastnet/time/ITimeProvider.java @@ -16,7 +16,7 @@ package com.jfastnet.time; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public interface ITimeProvider { /** @return current time in ms. */ diff --git a/src/main/java/com/jfastnet/time/SystemTimeProvider.java b/src/main/java/com/jfastnet/time/SystemTimeProvider.java index d9cc298..c8376ee 100644 --- a/src/main/java/com/jfastnet/time/SystemTimeProvider.java +++ b/src/main/java/com/jfastnet/time/SystemTimeProvider.java @@ -16,7 +16,7 @@ package com.jfastnet.time; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class SystemTimeProvider implements ITimeProvider { @Override diff --git a/src/main/java/com/jfastnet/util/ConcurrentSizeLimitedMap.java b/src/main/java/com/jfastnet/util/ConcurrentSizeLimitedMap.java index ae6d1ec..0875eaa 100644 --- a/src/main/java/com/jfastnet/util/ConcurrentSizeLimitedMap.java +++ b/src/main/java/com/jfastnet/util/ConcurrentSizeLimitedMap.java @@ -21,7 +21,7 @@ import java.util.List; import java.util.concurrent.ConcurrentHashMap; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class ConcurrentSizeLimitedMap, V> extends ConcurrentHashMap { /** Maximum number of entries in this map. */ diff --git a/src/main/java/com/jfastnet/util/NullsafeHashMap.java b/src/main/java/com/jfastnet/util/NullsafeHashMap.java index 1c0219e..8455a03 100644 --- a/src/main/java/com/jfastnet/util/NullsafeHashMap.java +++ b/src/main/java/com/jfastnet/util/NullsafeHashMap.java @@ -19,7 +19,7 @@ import java.util.HashMap; /** If on "get" the map is null, a new object is inserted. - * @author Klaus Pfeiffer + * @author Klaus Pfeiffer - klaus@allpiper.com * @param key for this map containing another Object of entities and their ids. * @param value of this map */ public abstract class NullsafeHashMap extends HashMap { diff --git a/src/main/java/com/jfastnet/util/SizeLimitedList.java b/src/main/java/com/jfastnet/util/SizeLimitedList.java index c81e61a..25fb25a 100644 --- a/src/main/java/com/jfastnet/util/SizeLimitedList.java +++ b/src/main/java/com/jfastnet/util/SizeLimitedList.java @@ -18,7 +18,7 @@ import java.util.ArrayList; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class SizeLimitedList extends ArrayList { private int maximumSize; diff --git a/src/main/java/com/jfastnet/util/SizeLimitedMap.java b/src/main/java/com/jfastnet/util/SizeLimitedMap.java index 19b9701..e4a6d5e 100644 --- a/src/main/java/com/jfastnet/util/SizeLimitedMap.java +++ b/src/main/java/com/jfastnet/util/SizeLimitedMap.java @@ -18,7 +18,7 @@ import java.util.TreeMap; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class SizeLimitedMap extends TreeMap { private int maximumSize; diff --git a/src/main/java/com/jfastnet/util/SizeLimitedSet.java b/src/main/java/com/jfastnet/util/SizeLimitedSet.java index 668b81d..952b13d 100644 --- a/src/main/java/com/jfastnet/util/SizeLimitedSet.java +++ b/src/main/java/com/jfastnet/util/SizeLimitedSet.java @@ -18,7 +18,7 @@ import java.util.TreeSet; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class SizeLimitedSet extends TreeSet { private int maximumSize; diff --git a/src/test/java/com/jfastnet/AbstractTest.java b/src/test/java/com/jfastnet/AbstractTest.java index 40b0fe0..b5765cc 100644 --- a/src/test/java/com/jfastnet/AbstractTest.java +++ b/src/test/java/com/jfastnet/AbstractTest.java @@ -30,7 +30,7 @@ import java.util.ArrayList; import java.util.List; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public abstract class AbstractTest { public interface Callable { diff --git a/src/test/java/com/jfastnet/MessageLogTest.java b/src/test/java/com/jfastnet/MessageLogTest.java index 767f301..27ed04b 100644 --- a/src/test/java/com/jfastnet/MessageLogTest.java +++ b/src/test/java/com/jfastnet/MessageLogTest.java @@ -23,7 +23,7 @@ import static org.hamcrest.Matchers.is; import static org.junit.Assert.assertNotNull; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class MessageLogTest { private volatile int i; diff --git a/src/test/java/com/jfastnet/ServerTest.java b/src/test/java/com/jfastnet/ServerTest.java index d4388e8..af0b1a4 100644 --- a/src/test/java/com/jfastnet/ServerTest.java +++ b/src/test/java/com/jfastnet/ServerTest.java @@ -34,7 +34,7 @@ import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.Matchers.*; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ServerTest extends AbstractTest { diff --git a/src/test/java/com/jfastnet/examples/HelloWorld.java b/src/test/java/com/jfastnet/examples/HelloWorld.java index 558003c..984fbab 100644 --- a/src/test/java/com/jfastnet/examples/HelloWorld.java +++ b/src/test/java/com/jfastnet/examples/HelloWorld.java @@ -21,7 +21,7 @@ import com.jfastnet.Server; import com.jfastnet.messages.GenericMessage; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class HelloWorld { public static int received = 0; diff --git a/src/test/java/com/jfastnet/messages/MessagePartTest.java b/src/test/java/com/jfastnet/messages/MessagePartTest.java index 9e959fe..cdd29a0 100644 --- a/src/test/java/com/jfastnet/messages/MessagePartTest.java +++ b/src/test/java/com/jfastnet/messages/MessagePartTest.java @@ -25,7 +25,7 @@ import static org.junit.Assert.*; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ public class MessagePartTest extends AbstractTest { static class BigMessage extends Message { diff --git a/src/test/java/com/jfastnet/messages/features/ChecksumFeatureTest.java b/src/test/java/com/jfastnet/messages/features/ChecksumFeatureTest.java index c79193f..0cffae6 100644 --- a/src/test/java/com/jfastnet/messages/features/ChecksumFeatureTest.java +++ b/src/test/java/com/jfastnet/messages/features/ChecksumFeatureTest.java @@ -26,7 +26,7 @@ import static org.junit.Assert.assertNotEquals; import static org.junit.Assert.assertNotNull; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ChecksumFeatureTest extends AbstractTest { diff --git a/src/test/java/com/jfastnet/util/ConcurrentSizeLimitedMapTest.java b/src/test/java/com/jfastnet/util/ConcurrentSizeLimitedMapTest.java index a7df16f..f2e03a1 100644 --- a/src/test/java/com/jfastnet/util/ConcurrentSizeLimitedMapTest.java +++ b/src/test/java/com/jfastnet/util/ConcurrentSizeLimitedMapTest.java @@ -25,7 +25,7 @@ import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.Matchers.is; -/** @author Klaus Pfeiffer */ +/** @author Klaus Pfeiffer - klaus@allpiper.com */ @Slf4j public class ConcurrentSizeLimitedMapTest {