[jgroups-dev] Connection expiration timeout in UNICAST2

Pedro Ruivo <[email protected]> Sat, 31 Mar 2012 22:57:23 +0100
Newsgroups gmane.comp.java.javagroups.devel
Message-ID <[email protected]>
Hi Bela

I was running some tests when I noticed that some nodes have been 
blocked waiting for the delivery of their own messages (the messages are 
sent in total order).

I looked in the code and I've discovered that the connection to the 
coordinator is getting removed due to connection expiration timeout. 
However the send table still has "forward" messages to be delivered in 
the coordinator.

Did not it should check if the send table has or not messages before 
removing it?

The partial log is in below. Some of the messages are big, i.e. they can 
generate up to 10 fragmentation messages.

Cheers,
Pedro Ruivo

---
21:34:28,621 TRACE [SEQUENCER] forwarding msg [dst: <null>, src: 
node22-44738 (1 headers), size=53296 bytes, flags=NO_FC] (seqno 6) to 
coord (node20-1449)
21:34:28,621 TRACE [UNICAST2] node22-44738 --> DATA(node20-1449: #34, 
conn_id=0)
21:34:28,621 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are SEQUENCER: FORWARD (tag=[node22-44738|6]), UNICAST2: DATA, 
seqno=34, UDP: [channel_name=infinispan-cluster]
...
21:35:10,267 TRACE [UDP] received [dst: node22-44738, src: node20-1449 
(2 headers), size=0 bytes, flags=OOB], headers are UNICAST2: STABLE, 
seqno=32, UDP: [channel_name=infinispan-cluster]
21:35:10,267 TRACE [UNICAST2] node22-44738 <-- STABLE(node20-1449: 
32-32, conn_id=0)
21:35:10,268 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are SEQUENCER: FORWARD (tag=[node22-44738|5]), UNICAST2: DATA, 
seqno=33, UDP: [channel_name=infinispan-cluster]
21:35:10,268 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are SEQUENCER: FORWARD (tag=[node22-44738|6]), UNICAST2: DATA, 
seqno=34, UDP: [channel_name=infinispan-cluster]
...
21:36:10,268 TRACE [UDP] received [dst: node22-44738, src: node20-1449 
(2 headers), size=0 bytes, flags=OOB], headers are UNICAST2: STABLE, 
seqno=32, UDP: [channel_name=infinispan-cluster]
21:36:10,269 TRACE [UNICAST2] node22-44738 <-- STABLE(node20-1449: 
32-32, conn_id=0)
21:36:10,269 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are SEQUENCER: FORWARD (tag=[node22-44738|5]), UNICAST2: DATA, 
seqno=33, UDP: [channel_name=infinispan-cluster]
21:36:10,269 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are SEQUENCER: FORWARD (tag=[node22-44738|6]), UNICAST2: DATA, 
seqno=34, UDP: [channel_name=infinispan-cluster]
21:36:10,269 TRACE [TP$TransferQueueBundler] sending 1 msgs (54304 bytes 
(84.85% of max_bundle_size) to 1 destination(s)
21:36:10,270 TRACE [UDP] received [dst: node22-44738, src: node20-1449 
(2 headers), size=0 bytes, flags=OOB], headers are UNICAST2: STABLE, 
seqno=32, UDP: [channel_name=infinispan-cluster]
21:36:10,270 TRACE [UNICAST2] node22-44738 <-- STABLE(node20-1449: 
32-32, conn_id=0)
21:36:10,270 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are SEQUENCER: FORWARD (tag=[node22-44738|5]), UNICAST2: DATA, 
seqno=33, UDP: [channel_name=infinispan-cluster]
21:36:10,270 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are SEQUENCER: FORWARD (tag=[node22-44738|6]), UNICAST2: DATA, 
seqno=34, UDP: [channel_name=infinispan-cluster]
...
21:36:17,270 TRACE [UNICAST2] node22-44738 --> STABLE(node20-1449: 2-2, 
conn_id=2)
21:36:17,270 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are UNICAST2: STABLE, seqno=2, conn_id=2, UDP: 
[channel_name=infinispan-cluster]
21:36:17,270 DEBUG [UNICAST2] node22-44738: removed expired connection 
for node20-1449 (108649 ms old) from send_table
21:36:17,270 TRACE [UNICAST2] node22-44738 --> STABLE(node20-1449: 2-2, 
conn_id=2)
21:36:17,270 TRACE [UDP] sending msg to node20-1449, src=node22-44738, 
headers are UNICAST2: STABLE, seqno=2, conn_id=2, UDP: 
[channel_name=infinispan-cluster]
21:36:17,270 DEBUG [UNICAST2] node22-44738: removed expired connection 
for node20-1449 (119581 ms old) from recv_table


------------------------------------------------------------------------------
This SF email is sponsosred by:
Try Windows Azure free for 90 days Click Here 
http://p.sf.net/sfu/sfd2d-msazure
_______________________________________________
Javagroups-development mailing list