Merge branch 'GOSSIP-46' of https://github.com/edwardcapriolo/incubator-gossip
Project: http://git-wip-us.apache.org/repos/asf/incubator-gossip/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gossip/commit/bcd10510 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gossip/tree/bcd10510 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gossip/diff/bcd10510 Branch: refs/heads/master Commit: bcd10510ee7da41322bf2aece4b0ef7e4789f199 Parents: 17551c8 5199821 Author: Edward Capriolo <[email protected]> Authored: Fri Mar 10 07:23:58 2017 -0500 Committer: Edward Capriolo <[email protected]> Committed: Fri Mar 10 07:23:58 2017 -0500 ---------------------------------------------------------------------- .../java/org/apache/gossip/GossipMember.java | 166 ------------------- .../java/org/apache/gossip/GossipService.java | 135 --------------- .../org/apache/gossip/LocalGossipMember.java | 71 -------- .../java/org/apache/gossip/LocalMember.java | 71 ++++++++ src/main/java/org/apache/gossip/Member.java | 166 +++++++++++++++++++ .../org/apache/gossip/RemoteGossipMember.java | 47 ------ .../java/org/apache/gossip/RemoteMember.java | 47 ++++++ .../java/org/apache/gossip/StartupSettings.java | 8 +- .../apache/gossip/accrual/FailureDetector.java | 6 +- .../org/apache/gossip/event/GossipListener.java | 4 +- .../apache/gossip/examples/GossipExample.java | 105 ------------ .../examples/StandAloneDatacenterAndRack.java | 26 +-- .../apache/gossip/examples/StandAloneNode.java | 23 +-- .../examples/StandAloneNodeCrdtOrSet.java | 47 +++--- .../gossip/manager/AbstractActiveGossiper.java | 40 ++--- .../org/apache/gossip/manager/DataReaper.java | 12 +- .../DatacenterRackAwareActiveGossiper.java | 24 +-- .../org/apache/gossip/manager/GossipCore.java | 48 +++--- .../apache/gossip/manager/GossipManager.java | 63 ++++--- .../gossip/manager/GossipManagerBuilder.java | 152 +++++++++++++++++ .../gossip/manager/RingStatePersister.java | 6 +- .../gossip/manager/SimpleActiveGossipper.java | 8 +- .../gossip/manager/UserDataPersister.java | 16 +- .../handlers/ActiveGossipMessageHandler.java | 10 +- .../manager/handlers/DefaultMessageInvoker.java | 4 +- .../handlers/GossipDataMessageHandler.java | 31 ---- .../handlers/PerNodeDataMessageHandler.java | 31 ++++ .../handlers/SharedDataMessageHandler.java | 31 ++++ .../SharedGossipDataMessageHandler.java | 31 ---- .../handlers/ShutdownMessageHandler.java | 4 +- .../manager/random/RandomGossipManager.java | 145 ---------------- .../gossip/model/ActiveGossipMessage.java | 6 +- src/main/java/org/apache/gossip/model/Base.java | 12 +- .../apache/gossip/model/GossipDataMessage.java | 66 -------- .../org/apache/gossip/model/GossipMember.java | 87 ---------- .../java/org/apache/gossip/model/Member.java | 87 ++++++++++ .../apache/gossip/model/PerNodeDataMessage.java | 66 ++++++++ .../apache/gossip/model/SharedDataMessage.java | 64 +++++++ .../gossip/model/SharedGossipDataMessage.java | 64 ------- .../apache/gossip/udp/UdpGossipDataMessage.java | 48 ------ .../gossip/udp/UdpPerNodeDataMessage.java | 48 ++++++ .../apache/gossip/udp/UdpSharedDataMessage.java | 50 ++++++ .../gossip/udp/UdpSharedGossipDataMessage.java | 50 ------ .../apache/gossip/AbstractIntegrationBase.java | 50 ++++++ src/test/java/org/apache/gossip/DataTest.java | 86 +++++----- .../org/apache/gossip/GossipMemberTest.java | 40 ----- .../org/apache/gossip/IdAndPropertyTest.java | 46 ++--- src/test/java/org/apache/gossip/MemberTest.java | 40 +++++ .../org/apache/gossip/ShutdownDeadtimeTest.java | 45 +++-- .../org/apache/gossip/SignedMessageTest.java | 55 +++--- .../org/apache/gossip/StartupSettingsTest.java | 25 +-- .../org/apache/gossip/TenNodeThreeSeedTest.java | 29 ++-- .../gossip/accrual/FailureDetectorTest.java | 8 +- .../java/org/apache/gossip/crdt/OrSetTest.java | 21 ++- .../apache/gossip/manager/DataReaperTest.java | 25 ++- .../manager/GossipManagerBuilderTest.java | 121 ++++++++++++++ .../manager/RandomGossipManagerBuilderTest.java | 122 -------------- .../gossip/manager/RingPersistenceTest.java | 37 +++-- .../gossip/manager/UserDataPersistenceTest.java | 61 +++---- .../manager/handlers/MessageInvokerTest.java | 4 +- 60 files changed, 1446 insertions(+), 1595 deletions(-) ----------------------------------------------------------------------
