File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
src/org/jgroups/protocols Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -130,8 +130,9 @@ public class UNICAST3 extends Protocol implements AgeOutCache.Handler<Address> {
130
130
131
131
protected final ReentrantLock recv_table_lock =new ReentrantLock ();
132
132
133
- /** Used by the retransmit task to keep the last retransmitted seqno per sender (https://issues.redhat.com/browse/JGRP-1539) */
134
- protected final Map <Address ,Long > xmit_task_map =new HashMap <>();
133
+ /** Used by the retransmit task to keep the last retransmitted seqno per member (applicable only
134
+ * for received messages (ReceiverEntry)): https://issues.redhat.com/browse/JGRP-1539 */
135
+ protected final Map <Address ,Long > xmit_task_map =new ConcurrentHashMap <>();
135
136
136
137
/** RetransmitTask running every xmit_interval ms */
137
138
protected Future <?> xmit_task ;
You can’t perform that action at this time.
0 commit comments