<360766 [DEBUG] Discovery.up(): - received GET_MBRS_RSP, rsp=[own_addr=10.7.15.102:32929, coord_addr=10.7.15.102:32925, is_server=true]
<360766 [DEBUG] TP.receive(): - received (ucast) 80 bytes from 10.7.15.103:32937
<360766 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.103:32937 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], PING=[PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32937, coord_addr=10.7.15.103:32933, is_server=true]]}
<360767 [DEBUG] Discovery.up(): - received GET_MBRS_RSP, rsp=[own_addr=10.7.15.103:32937, coord_addr=10.7.15.103:32933, is_server=true]
<360767 [DEBUG] TP.receive(): - received (ucast) 80 bytes from 10.7.15.103:32933
<360767 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], PING=[PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32933, coord_addr=10.7.15.103:32933, is_server=true]]}
<360768 [DEBUG] Discovery.up(): - received GET_MBRS_RSP, rsp=[own_addr=10.7.15.103:32933, coord_addr=10.7.15.103:32933, is_server=true]
<360768 [DEBUG] PingWaiter.findInitialMembers(): - initial mbrs are [[own_addr=10.7.15.102:32929, coord_addr=10.7.15.102:32925, is_server=true], [own_addr=10.7.15.103:32937, coord_addr=10.7.15.103:32933, is_server=true], [own_addr=10.7.15.103:32933, coord_addr=10.7.15.103:32933, is_server=true]]
<360769 [DEBUG] MERGE2$FindSubgroups.run(): - initial_mbrs=[[own_addr=10.7.15.102:32929, coord_addr=10.7.15.102:32925, is_server=true], [own_addr=10.7.15.103:32937, coord_addr=10.7.15.103:32933, is_server=true], [own_addr=10.7.15.103:32933, coord_addr=10.7.15.103:32933, is_server=true], [own_addr=10.7.15.102:32925, coord_addr=10.7.15.102:32925, is_server=true]]
<360769 [DEBUG] MERGE2$FindSubgroups.run(): - found multiple coordinators: [10.7.15.102:32925, 10.7.15.103:32933]; sending up MERGE event
<360769 [DEBUG] GMS$ViewHandler.start(): - ViewHandler started
<360770 [DEBUG] GMS$ViewHandler.process(): - processing MERGE([10.7.15.102:32925, 10.7.15.103:32933])
<360770 [DEBUG] CoordGmsImpl.merge(): - I (10.7.15.102:32925) will be the leader. Starting the merge task
<360772 [DEBUG] CoordGmsImpl$MergeTask.run(): - merge task started, coordinators are [10.7.15.102:32925, 10.7.15.103:32933]
<360775 [DEBUG] CoordGmsImpl.getMergeDataFromSubgroupCoordinators(): - sending MERGE_REQ to [10.7.15.102:32925, 10.7.15.103:32933]
<360776 [DEBUG] CoordGmsImpl.getMergeResponse(): - sender=10.7.15.102:32925, merge_id=[10.7.15.102:32925|1148482913612]
<360779 [DEBUG] UNICAST.down(): - removing 10.7.15.103:32933 from previous_members as result of ENABLE_UNICAST_TO event, previous_members=[10.7.15.103:32937 ]
<360779 [DEBUG] UNICAST.down(): - 10.7.15.102:32925: created new connection for dst 10.7.15.103:32933
<360780 [DEBUG] UNICAST.down(): - 10.7.15.102:32925 --> DATA(10.7.15.103:32933: #1
<360780 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.102:32925), headers are {GMS=GmsHeader[MERGE_REQ]: merge_id=[10.7.15.102:32925|1148482913612], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=1]}
<360781 [DEBUG] CoordGmsImpl.getMergeDataFromSubgroupCoordinators(): - waiting 10000 msecs for merge responses
<360795 [DEBUG] TP.receive(): - received (ucast) 228 bytes from 10.7.15.103:32933
<360796 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.103:32933 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[MERGE_RSP]: view=[10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937], digest=10.7.15.103:32937: [0 : 6], 10.7.15.103:32933: [1 : 13], merge_rejected=false, merge_id=[10.7.15.102:32925|1148482913612], UNICAST=[UNICAST: DATA, seqno=1], UDP=[channel_name=wlkscluster]}
<360796 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.102:32925 <-- DATA(10.7.15.103:32933: #1
<360797 [DEBUG] AckReceiverWindow.remove(): - removed seqno=1
<360797 [DEBUG] UNICAST.sendAck(): - 10.7.15.102:32925 --> ACK(10.7.15.103:32933: #1)
<360798 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.102:32925), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=1]}
<360798 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.103:32933
<360799 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=1], UDP=[channel_name=wlkscluster]}
<360799 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.102:32925 <-- ACK(10.7.15.103:32933: #1)
<360800 [DEBUG] CoordGmsImpl.getMergeDataFromSubgroupCoordinators(): - num_rsps_expected=2, actual responses=2
<360800 [DEBUG] CoordGmsImpl.getMergeDataFromSubgroupCoordinators(): - collected 2 merge response(s) in 25ms
<360800 [DEBUG] CoordGmsImpl.consolidateMergeData(): - merge data is sender=10.7.15.102:32925, view=[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], digest=10.7.15.102:32925: [0 : 30], 10.7.15.102:32929: [0 : 9]
<360801 [DEBUG] CoordGmsImpl.consolidateMergeData(): - merge data is sender=10.7.15.103:32933, view=[10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937], digest=10.7.15.103:32937: [0 : 6], 10.7.15.103:32933: [1 : 13]
<360802 [DEBUG] CoordGmsImpl.consolidateMergeData(): - new merged view will be MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<360802 [DEBUG] CoordGmsImpl.consolidateMergeData(): - consolidated digest=10.7.15.103:32933: [1 : 13], 10.7.15.102:32929: [0 : 9], 10.7.15.103:32937: [0 : 6], 10.7.15.102:32925: [0 : 30]
<360803 [DEBUG] GMS$ViewHandler.suspend(): - suspended ViewHandler
<360807 [DEBUG] CoordGmsImpl.sendMergeView(): - sending merge view [10.7.15.102:32925|6] to coordinators [10.7.15.102:32925, 10.7.15.103:32933]
<360808 [DEBUG] UNICAST.down(): - 10.7.15.102:32925 --> DATA(10.7.15.102:32925: #6
<360808 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.102:32925), headers are {GMS=GmsHeader[INSTALL_MERGE_VIEW]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], digest=10.7.15.103:32933: [1 : 13], 10.7.15.102:32929: [0 : 9], 10.7.15.103:32937: [0 : 6], 10.7.15.102:32925: [0 : 30], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=6]}
<360809 [DEBUG] TP.receive(): - received (ucast) 430 bytes from 10.7.15.102:32925
<360810 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.102:32925 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[INSTALL_MERGE_VIEW]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], digest=10.7.15.103:32933: [1 : 13], 10.7.15.102:32929: [0 : 9], 10.7.15.103:32937: [0 : 6], 10.7.15.102:32925: [0 : 30], UNICAST=[UNICAST: DATA, seqno=6], UDP=[channel_name=wlkscluster]}
<360810 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.102:32925 <-- DATA(10.7.15.102:32925: #6
<360811 [DEBUG] AckReceiverWindow.remove(): - removed seqno=6
<360812 [DEBUG] GMS$ViewHandler.start(): - ViewHandler started
<360812 [DEBUG] UNICAST.sendAck(): - 10.7.15.102:32925 --> ACK(10.7.15.102:32925: #6)
<360813 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.102:32925), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=6]}
<360813 [DEBUG] GMS$ViewHandler.process(): - processing VIEW ([10.7.15.102:32925|6])
<360814 [DEBUG] GMS.castViewChangeWithDest(): - mcasting view {MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]} (4 mbrs)

<360814 [DEBUG] NAKACK.send(): - sending msg #30
<360815 [DEBUG] TP.down(): - sending msg to null (src=10.7.15.102:32925), headers are {NAKACK=[MSG, seqno=30], GMS=GmsHeader[VIEW]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], UDP=[channel_name=wlkscluster]}
<360815 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.102:32925
<360816 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=6], UDP=[channel_name=wlkscluster]}
<360816 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.102:32925 <-- ACK(10.7.15.102:32925: #6)
<352915 [DEBUG] TP.receive(): - received (mcast)410 bytes from 10.7.15.102:32926
<352916 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[VIEW]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], NAKACK=[MSG, seqno=30], UDP=[channel_name=wlkscluster]}
<352917 [DEBUG] FD.up(): - received msg from 10.7.15.102:32925 (counts as ack)
<352917 [DEBUG] NAKACK.handleMessage(): - 10.7.15.102:32929] received 10.7.15.102:32925#30
<352918 [DEBUG] UNICAST.down(): - 10.7.15.102:32929 --> DATA(10.7.15.102:32925: #11
<352918 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.102:32929), headers are {GMS=GmsHeader[VIEW_ACK]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=11]}
<352919 [DEBUG] ParticipantGmsImpl.handleViewChange(): - view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<352920 [DEBUG] GMS.installView(): - [local_addr=10.7.15.102:32929] view is MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<352921 [DEBUG] STABLE.resetDigest(): - resetting digest from NAKACK: [10.7.15.103:32933#-1, 10.7.15.102:32929#6, 10.7.15.103:32937#-1, 10.7.15.102:32925#29]
<352922 [DEBUG] FD$Broadcaster.adjustSuspectedMembers(): - suspected_mbrs: [], after adjustment: []
<360825 [DEBUG] TP.receive(): - received (mcast)410 bytes from 10.7.15.102:32926
<360825 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[VIEW]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], NAKACK=[MSG, seqno=30], UDP=[channel_name=wlkscluster]}
<360826 [DEBUG] NAKACK.handleMessage(): - 10.7.15.102:32925] received 10.7.15.102:32925#30
<360826 [DEBUG] TP.receive(): - received (ucast) 259 bytes from 10.7.15.102:32929
<360827 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.102:32929 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[VIEW_ACK]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], UNICAST=[UNICAST: DATA, seqno=11], UDP=[channel_name=wlkscluster]}
<360827 [DEBUG] FD.up(): - received msg from 10.7.15.102:32929 (counts as ack)
<360827 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.102:32925 <-- DATA(10.7.15.102:32929: #11
<360828 [DEBUG] AckReceiverWindow.remove(): - removed seqno=11
<360828 [DEBUG] UNICAST.sendAck(): - 10.7.15.102:32925 --> ACK(10.7.15.102:32929: #11)
<360829 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32929 (src=10.7.15.102:32925), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=11]}
<got a new view MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<352928 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.102:32925
<352928 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32929, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=11], UDP=[channel_name=wlkscluster]}
<352929 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.102:32929 <-- ACK(10.7.15.102:32925: #11)
<360831 [DEBUG] UNICAST.down(): - 10.7.15.102:32925 --> DATA(10.7.15.102:32925: #7
<360832 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.102:32925), headers are {GMS=GmsHeader[VIEW_ACK]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=7]}
<360833 [DEBUG] CoordGmsImpl.handleViewChange(): - view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], digest=10.7.15.103:32933: [1 : 13], 10.7.15.102:32929: [0 : 9], 10.7.15.103:32937: [0 : 6], 10.7.15.102:32925: [0 : 30]
<360834 [DEBUG] GMS.installView(): - [local_addr=10.7.15.102:32925] view is MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<360835 [DEBUG] STABLE.resetDigest(): - resetting digest from NAKACK: [10.7.15.103:32933#-1, 10.7.15.102:32929#6, 10.7.15.103:32937#-1, 10.7.15.102:32925#28]
<360835 [DEBUG] UNICAST.down(): - removing 10.7.15.103:32937 from previous_members as result of VIEW_CHANGE event, previous_members=[]
<360836 [DEBUG] FD$Broadcaster.adjustSuspectedMembers(): - suspected_mbrs: [], after adjustment: []
<360837 [DEBUG] TP.receive(): - received (ucast) 259 bytes from 10.7.15.102:32925
<360838 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.102:32925 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[VIEW_ACK]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], UNICAST=[UNICAST: DATA, seqno=7], UDP=[channel_name=wlkscluster]}
<360838 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.102:32925 <-- DATA(10.7.15.102:32925: #7
<360838 [DEBUG] AckReceiverWindow.remove(): - removed seqno=7
<360839 [DEBUG] UNICAST.sendAck(): - 10.7.15.102:32925 --> ACK(10.7.15.102:32925: #7)
<360839 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.102:32925), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=7]}
<360840 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.102:32925
<360840 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=7], UDP=[channel_name=wlkscluster]}
<360841 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.102:32925 <-- ACK(10.7.15.102:32925: #7)
<got a new view MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<Wed May 24 10:01:53 CDT 2006 - Hey, I'm the coordinator!
<360842 [DEBUG] GMS.castViewChangeWithDest(): - received all ACKs (2) for [10.7.15.102:32925|6] in 28ms
<360842 [DEBUG] UNICAST.down(): - 10.7.15.102:32925 --> DATA(10.7.15.103:32933: #2
<360843 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.102:32925), headers are {GMS=GmsHeader[INSTALL_MERGE_VIEW]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], digest=10.7.15.103:32933: [1 : 13], 10.7.15.102:32929: [0 : 9], 10.7.15.103:32937: [0 : 6], 10.7.15.102:32925: [0 : 30], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=2]}
<360843 [DEBUG] UNICAST.down(): - 10.7.15.102:32925 --> DATA(10.7.15.102:32925: #8
<360844 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.102:32925), headers are {GMS=GmsHeader[CANCEL_MERGE], <merge cancelled>, merge_id=[10.7.15.102:32925|1148482913612], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=8]}
<360844 [DEBUG] TP.receive(): - received (ucast) 102 bytes from 10.7.15.102:32925
<360845 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.102:32925 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[CANCEL_MERGE], <merge cancelled>, merge_id=[10.7.15.102:32925|1148482913612], UNICAST=[UNICAST: DATA, seqno=8], UDP=[channel_name=wlkscluster]}
<360845 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.102:32925 <-- DATA(10.7.15.102:32925: #8
<360846 [DEBUG] AckReceiverWindow.remove(): - removed seqno=8
<360846 [DEBUG] CoordGmsImpl.handleMergeCancelled(): - merge was cancelled (merge_id=[10.7.15.102:32925|1148482913612], local_addr=10.7.15.102:32925)
<360847 [DEBUG] UNICAST.sendAck(): - 10.7.15.102:32925 --> ACK(10.7.15.102:32925: #8)
<360847 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.102:32925), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=8]}
<360848 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.102:32925
<360848 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=8], UDP=[channel_name=wlkscluster]}
<360848 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.102:32925 <-- ACK(10.7.15.102:32925: #8)
<360849 [DEBUG] UNICAST.down(): - 10.7.15.102:32925 --> DATA(10.7.15.103:32933: #3
<360849 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.102:32925), headers are {GMS=GmsHeader[CANCEL_MERGE], <merge cancelled>, merge_id=[10.7.15.102:32925|1148482913612], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=3]}
<360850 [DEBUG] CoordGmsImpl$MergeTask.run(): - merge task terminated
<360850 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.103:32933
<360851 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=2], UDP=[channel_name=wlkscluster]}
<360851 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.102:32925 <-- ACK(10.7.15.103:32933: #2)
<360854 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.103:32933
<360854 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=3], UDP=[channel_name=wlkscluster]}
<360855 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.102:32925 <-- ACK(10.7.15.103:32933: #3)
<352954 [DEBUG] TP.receive(): - received (mcast)410 bytes from 10.7.15.103:32934
<352955 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.103:32933 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[VIEW]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], NAKACK=[MSG, seqno=13], UDP=[channel_name=wlkscluster]}
<352955 [DEBUG] FD.up(): - received msg from 10.7.15.103:32933 (counts as ack)
<352955 [DEBUG] NAKACK.handleMessage(): - 10.7.15.102:32929] received 10.7.15.103:32933#13
<352956 [DEBUG] UNICAST.down(): - discarding message to 10.7.15.103:32933 as this member left the group, previous_members=[10.7.15.103:32933 10.7.15.103:32937 ]
<352957 [DEBUG] ParticipantGmsImpl.handleViewChange(): - view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<352958 [DEBUG] GMS.installView(): - [local_addr=10.7.15.102:32929] view is MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<360860 [DEBUG] TP.receive(): - received (mcast)410 bytes from 10.7.15.103:32934
<360861 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.103:32933 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[VIEW]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], NAKACK=[MSG, seqno=13], UDP=[channel_name=wlkscluster]}
<360861 [DEBUG] NAKACK.handleMessage(): - 10.7.15.102:32925] received 10.7.15.103:32933#13
<360862 [DEBUG] UNICAST.down(): - 10.7.15.102:32925 --> DATA(10.7.15.103:32933: #4
<360863 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.102:32925), headers are {GMS=GmsHeader[VIEW_ACK]: view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=4]}
<360864 [DEBUG] CoordGmsImpl.handleViewChange(): - view=MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]], digest=10.7.15.103:32933: [1 : 13], 10.7.15.102:32929: [0 : 9], 10.7.15.103:32937: [0 : 6], 10.7.15.102:32925: [0 : 30]
<360865 [DEBUG] GMS.installView(): - [local_addr=10.7.15.102:32925] view is MergeView::[10.7.15.102:32925|6] [10.7.15.102:32925, 10.7.15.102:32929, 10.7.15.103:32933, 10.7.15.103:32937], subgroups=[[10.7.15.102:32925|5] [10.7.15.102:32925, 10.7.15.102:32929], [10.7.15.103:32933|5] [10.7.15.103:32933, 10.7.15.103:32937]]
<360877 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.103:32933
<360878 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.102:32925, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=4], UDP=[channel_name=wlkscluster]}
<360878 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.102:32925 <-- ACK(10.7.15.103:32933: #4)