Permalink
Browse files

made reset() unsynchronized

  • Loading branch information...
1 parent ff750c5 commit afe64e197f2fa9fa8cbe1c0fd20c9368ab66b75a @belaban committed Dec 29, 2010
Showing with 7 additions and 8 deletions.
  1. +7 −8 src/org/jgroups/protocols/RATE_LIMITER.java
View
15 src/org/jgroups/protocols/RATE_LIMITER.java
@@ -102,19 +102,18 @@ public void init() throws Exception {
public void stop() {
super.stop();
- reset();
- }
-
- protected void reset() {
lock.lock();
try {
- // blocking=false;
- num_bytes_sent=0L;
- end_of_current_period=System.currentTimeMillis() + time_period;
- block.signalAll();
+ reset();
}
finally {
lock.unlock();
}
}
+
+ protected void reset() {
+ num_bytes_sent=0L;
+ end_of_current_period=System.currentTimeMillis() + time_period;
+ block.signalAll();
+ }
}

0 comments on commit afe64e1

Please sign in to comment.