Skip to content

Commit 6e34a1a

Browse files
committed
Added received() / sent() to FlowControl
1 parent 85564fb commit 6e34a1a

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

src/org/jgroups/protocols/FlowControl.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,8 @@ public long getReceiverCreditsFor(Address mbr) {
140140
return credits == null? 0 : credits.get();
141141
}
142142

143+
public Map<Address,Credit> received() {return received;}
144+
143145
public String printCredits() {
144146
return String.format("receivers:\n%s", printMap(received));
145147
}

src/org/jgroups/protocols/UFC.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public class UFC extends FlowControl {
3939
*/
4040
protected final Map<Address,? extends Credit> sent=Util.createConcurrentMap();
4141

42-
42+
public Map<Address,? extends Credit> sent() {return sent;}
4343

4444
@ManagedOperation(description="Print sender credits")
4545
public String printSenderCredits() {

0 commit comments

Comments
 (0)