<349962 [DEBUG] TP.receive(): - received (mcast)53 bytes from 10.7.15.102:32926
<349963 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], PING=[PING: type=GET_MBRS_REQ, arg=null]}
<349963 [DEBUG] Discovery.up(): - received GET_MBRS_REQ from 10.7.15.102:32925, sending response [PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32937, coord_addr=10.7.15.103:32933, is_server=true]]
<349963 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32937), headers are {PING=[PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32937, coord_addr=10.7.15.103:32933, is_server=true]], UDP=[channel_name=wlkscluster]}
<357179 [DEBUG] TP.receive(): - received (mcast)53 bytes from 10.7.15.102:32926
<357179 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], PING=[PING: type=GET_MBRS_REQ, arg=null]}
<357179 [DEBUG] Discovery.up(): - received GET_MBRS_REQ from 10.7.15.102:32925, sending response [PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32933, coord_addr=10.7.15.103:32933, is_server=true]]
<357180 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32933), headers are {PING=[PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32933, coord_addr=10.7.15.103:32933, is_server=true]], UDP=[channel_name=wlkscluster]}
<357195 [DEBUG] TP.receive(): - received (ucast) 114 bytes from 10.7.15.102:32925
<357196 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.102:32925 (3 headers), size = 0 bytes], headers are {GMS=GmsHeader[MERGE_REQ]: merge_id=[10.7.15.102:32925|1148482913612], UNICAST=[UNICAST: DATA, seqno=1], UDP=[channel_name=wlkscluster]}
<357196 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.103:32933 <-- DATA(10.7.15.102:32925: #1
<357196 [DEBUG] UNICAST.handleDataReceived(): - removed 10.7.15.102:32925 from previous_members as we received a message from it
<357197 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.103:32933: created new connection for dst 10.7.15.102:32925
<357197 [DEBUG] AckReceiverWindow.remove(): - removed seqno=1
<357198 [DEBUG] GMS$ViewHandler.suspend(): - suspended ViewHandler
<357205 [DEBUG] CoordGmsImpl.handleMergeRequest(): - sender=10.7.15.102:32925, merge_id=[10.7.15.102:32925|1148482913612]
<357206 [DEBUG] UNICAST.down(): - removing 10.7.15.102:32925 from previous_members as result of ENABLE_UNICAST_TO event, previous_members=[10.7.15.102:32929 ]
<357207 [DEBUG] CoordGmsImpl.sendMergeResponse(): - response=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:32933: [1 : 13], 10.7.15.103:32937: [0 : 6], merge_rejected=false, merge_id=[10.7.15.102:32925|1148482913612]
<357208 [DEBUG] UNICAST.down(): - 10.7.15.103:32933 --> DATA(10.7.15.102:32925: #1
<357208 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32933), 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:32933: [1 : 13], 10.7.15.103:32937: [0 : 6], merge_rejected=false, merge_id=[10.7.15.102:32925|1148482913612], UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: DATA, seqno=1]}
<357209 [DEBUG] UNICAST.sendAck(): - 10.7.15.103:32933 --> ACK(10.7.15.102:32925: #1)
<357210 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32933), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=1]}
<357213 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.102:32925
<357213 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=1], UDP=[channel_name=wlkscluster]}
<357213 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.103:32933 <-- ACK(10.7.15.102:32925: #1)
<350016 [DEBUG] TP.receive(): - received (mcast)410 bytes from 10.7.15.102:32926
<350018 [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]}
<350018 [DEBUG] NAKACK.handleMessage(): - 10.7.15.103:32937] received 10.7.15.102:32925#30
<350018 [WARN] NAKACK.handleMessage(): - 10.7.15.103:32937] discarded message from non-member 10.7.15.102:32925
<357234 [DEBUG] TP.receive(): - received (mcast)410 bytes from 10.7.15.102:32926
<357235 [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]}
<357236 [DEBUG] NAKACK.handleMessage(): - 10.7.15.103:32933] received 10.7.15.102:32925#30
<357236 [WARN] NAKACK.handleMessage(): - 10.7.15.103:32933] discarded message from non-member 10.7.15.102:32925
<357258 [DEBUG] TP.receive(): - received (ucast) 430 bytes from 10.7.15.102:32925
<357258 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, 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=2], UDP=[channel_name=wlkscluster]}
<357259 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.103:32933 <-- DATA(10.7.15.102:32925: #2
<357259 [DEBUG] AckReceiverWindow.remove(): - removed seqno=2
<357263 [DEBUG] GMS$ViewHandler.start(): - ViewHandler started
<357264 [DEBUG] UNICAST.sendAck(): - 10.7.15.103:32933 --> ACK(10.7.15.102:32925: #2)
<357264 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32933), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=2]}
<357265 [DEBUG] TP.receive(): - received (ucast) 102 bytes from 10.7.15.102:32925
<357265 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, 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=3], UDP=[channel_name=wlkscluster]}
<357265 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.103:32933 <-- DATA(10.7.15.102:32925: #3
<357266 [DEBUG] AckReceiverWindow.remove(): - removed seqno=3
<357266 [DEBUG] CoordGmsImpl.handleMergeCancelled(): - merge was cancelled (merge_id=[10.7.15.102:32925|1148482913612], local_addr=10.7.15.103:32933)
<357267 [DEBUG] UNICAST.sendAck(): - 10.7.15.103:32933 --> ACK(10.7.15.102:32925: #3)
<357267 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32933), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=3]}
<357268 [DEBUG] GMS$ViewHandler.process(): - processing VIEW ([10.7.15.102:32925|6])
<357268 [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)

<357269 [DEBUG] NAKACK.send(): - sending msg #13
<357269 [DEBUG] TP.down(): - sending msg to null (src=10.7.15.103:32933), headers are {NAKACK=[MSG, seqno=13], 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]}
<350055 [DEBUG] TP.receive(): - received (mcast)410 bytes from 10.7.15.103:32934
<350056 [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]}
<350056 [DEBUG] FD.up(): - received msg from 10.7.15.103:32933 (counts as ack)
<350056 [DEBUG] NAKACK.handleMessage(): - 10.7.15.103:32937] received 10.7.15.103:32933#13
<350057 [DEBUG] UNICAST.down(): - 10.7.15.103:32937 --> DATA(10.7.15.103:32933: #4
<350058 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.103:32937), 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]}
<350059 [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]]
<350060 [DEBUG] GMS.installView(): - [local_addr=10.7.15.103:32937] 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]]
<350060 [DEBUG] STABLE.resetDigest(): - resetting digest from NAKACK: [10.7.15.103:32933#6, 10.7.15.102:32929#-1, 10.7.15.103:32937#4, 10.7.15.102:32925#-1]
<350061 [DEBUG] FD$Broadcaster.adjustSuspectedMembers(): - suspected_mbrs: [], after adjustment: []
<357277 [DEBUG] TP.receive(): - received (mcast)410 bytes from 10.7.15.103:32934
<357278 [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]}
<357278 [DEBUG] NAKACK.handleMessage(): - 10.7.15.103:32933] received 10.7.15.103:32933#13
<357278 [DEBUG] UNICAST.down(): - 10.7.15.103:32933 --> DATA(10.7.15.103:32933: #3
<357279 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.103:32933), 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=3]}
<357280 [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]
<357281 [DEBUG] GMS.installView(): - [local_addr=10.7.15.103:32933] 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]]
<357282 [DEBUG] STABLE.resetDigest(): - resetting digest from NAKACK: [10.7.15.103:32933#6, 10.7.15.102:32929#-1, 10.7.15.103:32937#5, 10.7.15.102:32925#-1]
<357283 [DEBUG] UNICAST.down(): - removing 10.7.15.102:32929 from previous_members as result of VIEW_CHANGE event, previous_members=[]
<357283 [DEBUG] FD$Broadcaster.adjustSuspectedMembers(): - suspected_mbrs: [], after adjustment: []
<357284 [DEBUG] GMS.setImpl(): - 10.7.15.103:32933 changed role to org.jgroups.protocols.pbcast.ParticipantGmsImpl
<357285 [DEBUG] TP.receive(): - received (ucast) 259 bytes from 10.7.15.103:32937
<357286 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.103:32937 (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=4], UDP=[channel_name=wlkscluster]}
<357286 [DEBUG] FD.up(): - received msg from 10.7.15.103:32937 (counts as ack)
<357286 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.103:32933 <-- DATA(10.7.15.103:32937: #4
<357287 [DEBUG] AckReceiverWindow.remove(): - removed seqno=4
<357287 [DEBUG] UNICAST.sendAck(): - 10.7.15.103:32933 --> ACK(10.7.15.103:32937: #4)
<357288 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32937 (src=10.7.15.103:32933), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=4]}
<357288 [DEBUG] TP.receive(): - received (ucast) 259 bytes from 10.7.15.102:32925
<357289 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, 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=4], UDP=[channel_name=wlkscluster]}
<357289 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.103:32933 <-- DATA(10.7.15.102:32925: #4
<357290 [DEBUG] AckReceiverWindow.remove(): - removed seqno=4
<357290 [DEBUG] UNICAST.sendAck(): - 10.7.15.103:32933 --> ACK(10.7.15.102:32925: #4)
<357291 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32933), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=4]}
<357291 [DEBUG] TP.receive(): - received (ucast) 259 bytes from 10.7.15.103:32933
<357292 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.103:32933 (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=3], UDP=[channel_name=wlkscluster]}
<357292 [DEBUG] UNICAST.handleDataReceived(): - 10.7.15.103:32933 <-- DATA(10.7.15.103:32933: #3
<357293 [DEBUG] AckReceiverWindow.remove(): - removed seqno=3
<357293 [DEBUG] UNICAST.sendAck(): - 10.7.15.103:32933 --> ACK(10.7.15.103:32933: #3)
<357293 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.103:32933), headers are {UDP=[channel_name=wlkscluster], UNICAST=[UNICAST: ACK, seqno=3]}
<357294 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.103:32933
<357294 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=3], UDP=[channel_name=wlkscluster]}
<357295 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.103:32933 <-- ACK(10.7.15.103:32933: #3)
<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]]
<357315 [DEBUG] MERGE2$FindSubgroups.run(): - MERGE2.FindSubgroups thread terminated (local_addr=10.7.15.103:32933)
<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]]
<350101 [DEBUG] TP.receive(): - received (ucast) 63 bytes from 10.7.15.103:32933
<350102 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UNICAST=[UNICAST: ACK, seqno=4], UDP=[channel_name=wlkscluster]}
<350102 [DEBUG] UNICAST.handleAckReceived(): - 10.7.15.103:32937 <-- ACK(10.7.15.103:32933: #4)
<357889 [DEBUG] GMS.castViewChangeWithDest(): - received all ACKs (2) for [10.7.15.102:32925|6] in 620ms
<359257 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.102:32929
<359257 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.102:32929 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<359258 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.102:32929, sending response
<359258 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32929 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<359289 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.103:32937 (own address=10.7.15.103:32933)
<359289 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32937 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<352075 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.102:32925 (own address=10.7.15.103:32937)
<352075 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<352075 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.103:32933
<352076 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<352076 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.103:32933, sending response
<352076 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<359292 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.103:32937
<359292 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.103:32937 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<359293 [DEBUG] FD.up(): - received ack from 10.7.15.103:32937
<352078 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.102:32925
<352078 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<352078 [DEBUG] FD.up(): - received ack from 10.7.15.102:32925
<361267 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.102:32929
<361267 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.102:32929 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<361267 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.102:32929, sending response
<361268 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32929 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<361299 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.103:32937 (own address=10.7.15.103:32933)
<361299 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32937 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<354085 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.102:32925 (own address=10.7.15.103:32937)
<354085 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<354086 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.103:32933
<354086 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<354086 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.103:32933, sending response
<354086 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<361302 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.103:32937
<361302 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.103:32937 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<361303 [DEBUG] FD.up(): - received ack from 10.7.15.103:32937
<354088 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.102:32925
<354088 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<354089 [DEBUG] FD.up(): - received ack from 10.7.15.102:32925
<363277 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.102:32929
<363277 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.102:32929 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<363278 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.102:32929, sending response
<363278 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32929 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<363309 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.103:32937 (own address=10.7.15.103:32933)
<363309 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32937 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<356095 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.102:32925 (own address=10.7.15.103:32937)
<356095 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<356095 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.103:32933
<356096 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<356096 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.103:32933, sending response
<356096 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<363312 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.103:32937
<363312 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.103:32937 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<363313 [DEBUG] FD.up(): - received ack from 10.7.15.103:32937
<356098 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.102:32925
<356098 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<356098 [DEBUG] FD.up(): - received ack from 10.7.15.102:32925
<365287 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.102:32929
<365287 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.102:32929 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<365288 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.102:32929, sending response
<365288 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32929 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<365319 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.103:32937 (own address=10.7.15.103:32933)
<365319 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32937 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<358105 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.102:32925 (own address=10.7.15.103:32937)
<358105 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<358105 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.103:32933
<358106 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<358106 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.103:32933, sending response
<358106 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<365322 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.103:32937
<365322 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.103:32937 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<365323 [DEBUG] FD.up(): - received ack from 10.7.15.103:32937
<358108 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.102:32925
<358108 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<358108 [DEBUG] FD.up(): - received ack from 10.7.15.102:32925
<358952 [DEBUG] TP.receive(): - received (mcast)53 bytes from 10.7.15.102:32926
<358953 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], PING=[PING: type=GET_MBRS_REQ, arg=null]}
<358953 [DEBUG] Discovery.up(): - received GET_MBRS_REQ from 10.7.15.102:32925, sending response [PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32937, coord_addr=10.7.15.102:32925, is_server=true]]
<358953 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32937), headers are {PING=[PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32937, coord_addr=10.7.15.102:32925, is_server=true]], UDP=[channel_name=wlkscluster]}
<366169 [DEBUG] TP.receive(): - received (mcast)53 bytes from 10.7.15.102:32926
<366169 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], PING=[PING: type=GET_MBRS_REQ, arg=null]}
<366170 [DEBUG] Discovery.up(): - received GET_MBRS_REQ from 10.7.15.102:32925, sending response [PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32933, coord_addr=10.7.15.102:32925, is_server=true]]
<366170 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32933), headers are {PING=[PING: type=GET_MBRS_RSP, arg=[own_addr=10.7.15.103:32933, coord_addr=10.7.15.102:32925, is_server=true]], UDP=[channel_name=wlkscluster]}
<367297 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.102:32929
<367297 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.102:32929 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<367298 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.102:32929, sending response
<367298 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32929 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<367329 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.103:32937 (own address=10.7.15.103:32933)
<367329 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32937 (src=10.7.15.103:32933), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<360115 [DEBUG] FD$Monitor.run(): - sending are-you-alive msg to 10.7.15.102:32925 (own address=10.7.15.103:32937)
<360115 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat], UDP=[channel_name=wlkscluster]}
<360116 [DEBUG] TP.receive(): - received (ucast) 53 bytes from 10.7.15.103:32933
<360116 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.103:32933 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat]}
<360116 [DEBUG] FD.up(): - received are-you-alive from 10.7.15.103:32933, sending response
<360116 [DEBUG] TP.down(): - sending msg to 10.7.15.103:32933 (src=10.7.15.103:32937), headers are {FD=[FD: heartbeat ack], UDP=[channel_name=wlkscluster]}
<367332 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.103:32937
<367332 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32933, src: 10.7.15.103:32937 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<367333 [DEBUG] FD.up(): - received ack from 10.7.15.103:32937
<360118 [DEBUG] TP.receive(): - received (ucast) 65 bytes from 10.7.15.102:32925
<360118 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 10.7.15.103:32937, src: 10.7.15.102:32925 (2 headers), size = 0 bytes], headers are {UDP=[channel_name=wlkscluster], FD=[FD: heartbeat ack]}
<360119 [DEBUG] FD.up(): - received ack from 10.7.15.102:32925
<360383 [DEBUG] TP.receive(): - received (mcast)232 bytes from 10.7.15.102:32926
<360384 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (3 headers), size = 0 bytes], headers are {NAKACK=[MSG, seqno=31], STABLE=[STABLE_GOSSIP]: digest is 10.7.15.103:32933: [13 : 13 (13)], 10.7.15.102:32929: [0 : 0 (8)], 10.7.15.103:32937: [0 : 0 (5)], 10.7.15.102:32925: [0 : 30 (30)], UDP=[channel_name=wlkscluster]}
<360384 [DEBUG] FD.up(): - received msg from 10.7.15.102:32925 (counts as ack)
<360384 [DEBUG] NAKACK.handleMessage(): - 10.7.15.103:32937] received 10.7.15.102:32925#31
<367600 [DEBUG] TP.receive(): - received (mcast)232 bytes from 10.7.15.102:32926
<367600 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (3 headers), size = 0 bytes], headers are {NAKACK=[MSG, seqno=31], STABLE=[STABLE_GOSSIP]: digest is 10.7.15.103:32933: [13 : 13 (13)], 10.7.15.102:32929: [0 : 0 (8)], 10.7.15.103:32937: [0 : 0 (5)], 10.7.15.102:32925: [0 : 30 (30)], UDP=[channel_name=wlkscluster]}
<367600 [DEBUG] NAKACK.handleMessage(): - 10.7.15.103:32933] received 10.7.15.102:32925#31
<360494 [DEBUG] NAKACK.retransmit(): - 10.7.15.103:32937: sending XMIT_REQ ([30, 30]) to 10.7.15.102:32925
<360495 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32937), headers are {NAKACK=[XMIT_REQ, seqno=-1, range=[30 : 30], sender=10.7.15.102:32925], UDP=[channel_name=wlkscluster]}
<367710 [DEBUG] NAKACK.retransmit(): - 10.7.15.103:32933: sending XMIT_REQ ([30, 30]) to 10.7.15.102:32925
<367711 [DEBUG] TP.down(): - sending msg to 10.7.15.102:32925 (src=10.7.15.103:32933), headers are {NAKACK=[XMIT_REQ, seqno=-1, range=[30 : 30], sender=10.7.15.102:32925], UDP=[channel_name=wlkscluster]}
<360502 [DEBUG] TP.receive(): - received (mcast)495 bytes from 10.7.15.102:32926
<360502 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (2 headers), size = 411 bytes], headers are {UDP=[channel_name=wlkscluster], NAKACK=[XMIT_RSP, seqno=-1, range=[30 : 30]]}
<360502 [DEBUG] FD.up(): - received msg from 10.7.15.102:32925 (counts as ack)
<360503 [DEBUG] NAKACK.up(): - received missing messages [30 : 30]
<360504 [DEBUG] NAKACK.handleMessage(): - 10.7.15.103:32937] received 10.7.15.102:32925#30
<360504 [DEBUG] NakReceiverWindow.add(): - added missing msg 10.7.15.102:32925#30
<367719 [DEBUG] TP.receive(): - received (mcast)495 bytes from 10.7.15.102:32926
<367720 [DEBUG] TP.handleIncomingMessage(): - message is [dst: 224.0.119.114:45566, src: 10.7.15.102:32925 (2 headers), size = 411 bytes], headers are {UDP=[channel_name=wlkscluster], NAKACK=[XMIT_RSP, seqno=-1, range=[30 : 30]]}
<367720 [DEBUG] NAKACK.up(): - received missing messages [30 : 30]
<367721 [DEBUG] NAKACK.handleMessage(): - 10.7.15.103:32933] received 10.7.15.102:32925#30
<367722 [DEBUG] NakReceiverWindow.add(): - added missing msg 10.7.15.102:32925#30
<360524 [DEBUG] UNICAST.down(): - discarding message to 10.7.15.102:32925 as this member left the group, previous_members=[10.7.15.102:32925 10.7.15.102:32929 ]
<360525 [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]]
<360526 [DEBUG] GMS.installView(): - [local_addr=10.7.15.103:32937] 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]]
<360527 [DEBUG] STABLE.handleStableMessage(): - received stable msg from 10.7.15.102:32925: [10.7.15.103:32933#13, 10.7.15.102:32929#0, 10.7.15.103:32937#0, 10.7.15.102:32925#30]
<360527 [DEBUG] STABLE.updateLocalDigest(): - my [10.7.15.103:32937] digest before: 10.7.15.103:32933: [6 : 6 (6)], 10.7.15.103:32937: [3 : 4 (4)], 10.7.15.102:32925: [-1 : -1], 10.7.15.102:32929: [-1 : -1]