Permalink
Browse files

new constructor used for RetransmitTable, passing num_rows, msgs_per_…

…row, resize_factor and max_compaction_time
  • Loading branch information...
1 parent 4355a8a commit 01c0830ad4495f7367fae8cb8bacc0954d0e305b Bela Ban committed Dec 19, 2010
Showing with 10 additions and 1 deletion.
  1. +10 −1 src/org/jgroups/stack/NakReceiverWindow.java
@@ -115,6 +115,15 @@ public NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd, lo
public NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched,
boolean use_range_based_retransmitter) {
+ this(sender, cmd, highest_delivered_seqno, lowest_seqno, sched, use_range_based_retransmitter,
+ 5, 10000, 1.2, 5 * 60 * 1000);
+ }
+
+
+ public NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd,
+ long highest_delivered_seqno, long lowest_seqno, TimeScheduler sched,
+ boolean use_range_based_retransmitter,
+ int num_rows, int msgs_per_row, double resize_factor, long max_compaction_time) {
highest_delivered=highest_delivered_seqno;
highest_received=highest_delivered;
low=Math.min(lowest_seqno, highest_delivered);
@@ -125,7 +134,7 @@ public NakReceiverWindow(Address sender, Retransmitter.RetransmitCommand cmd,
new RangeBasedRetransmitter(sender, cmd, sched) :
new DefaultRetransmitter(sender, cmd, sched);
- xmit_table=new RetransmitTable(5, 10000, low);
+ xmit_table=new RetransmitTable(num_rows, msgs_per_row, low, resize_factor, max_compaction_time);
}

0 comments on commit 01c0830

Please sign in to comment.