Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code | Sign in
(1121)

Unified Diff: driver-core/src/main/java/com/datastax/driver/core/policies/drc/RateController.java

Issue 328560043: -adding model load offsets (i.e., buffers) -changing file logger to be buffered (Closed)
Patch Set: Created 6 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Please Sign in to add in-line comments.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: driver-core/src/main/java/com/datastax/driver/core/policies/drc/RateController.java
diff --git a/driver-core/src/main/java/com/datastax/driver/core/policies/drc/RateController.java b/driver-core/src/main/java/com/datastax/driver/core/policies/drc/RateController.java
index 0ec947ef292c1133e4296e17597daaedea19a6b8..82d4cd26a0e1d31321328db78465c3cb8c80fc9b 100644
--- a/driver-core/src/main/java/com/datastax/driver/core/policies/drc/RateController.java
+++ b/driver-core/src/main/java/com/datastax/driver/core/policies/drc/RateController.java
@@ -148,7 +148,7 @@ public class RateController extends FileLogger implements IRateController {
default tokens for nodes that are not supposed to be contacted at all.
*/
public double tryAcquireIfPositive() {
- if (sending_rate_limiter.get_rate() > 0){
+ if (sending_rate_limiter.get_rate() > 0) {
return sending_rate_limiter.tryAcquire();
}
return 1;

Powered by Google App Engine
RSS Feeds Recent Issues | This issue
This is Rietveld f62528b