[
https://jira.jboss.org/jira/browse/JGRP-952?page=com.atlassian.jira.plugi...
]
Bela Ban commented on JGRP-952:
-------------------------------
Actually, the previous but 1 comment is incorrect: when acks are sent on *delivery* (not
*reception*), then for an ack N we can ack all pending seqnos <= N !
If we get ack(5) --> ack(3) --> ack(4), then ack(5) acks *all* messages up to #5.
The other acks for #3 and #4 are simply discarded, because those message have already been
removed from the sender window !
MERGE: UNICAST can lose messages on merging
-------------------------------------------
Key: JGRP-952
URL:
https://jira.jboss.org/jira/browse/JGRP-952
Project: JGroups
Issue Type: Bug
Reporter: Bela Ban
Assignee: Bela Ban
Fix For: 2.6.10, 2.8
The following use case loses messages:
- A sends #5 to B
- B expects #4 from A, but adds #5 and acks it
- A receives the ack(#5) and removes #5 from its sender window
- Now there is a partition such that B trashes its connection window form A, but A keeps
its window for B (A: {A,B}, B: {B})
- The partition heals and A sends #6 to B
- B asks A for its lowest seqno, A resends #4 (with a conn_id)
- B creates a receiver window for A with seqno=#4
- A resends #6
- B adds #6 to its window, but doesn't deliver it because it is missing #5
--> However, A will NEVER resend #5 because the ack(#5) from B removed #5 from A's
sender window !
==> Possible SOLUTION: when A gets the SEND_FIRST_SEQNO and there are (unacked)
messages in A's sender window, and they are not in order, then A will trash its
connection window and copy the pending messages into the new window (with new seqnos !)
before sending #1 (with conn_id)
==> This solution might lose the original message #5, but that's better than B
never being able to deliver any messages anymore !
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
https://jira.jboss.org/jira/secure/Administrators.jspa
-
For more information on JIRA, see:
http://www.atlassian.com/software/jira