Skip to content

Commit 597f615

Browse files
committed
Use better names for backoff methods
1 parent 7ac5c1a commit 597f615

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

  • dogstatsd-http-forwarder/src/main/java/com/datadoghq/dogstatsd/http/forwarder

dogstatsd-http-forwarder/src/main/java/com/datadoghq/dogstatsd/http/forwarder/Forwarder.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -122,21 +122,21 @@ void runOnce(Map.Entry<BoundedQueue.Key, byte[]> item) throws InterruptedExcepti
122122
switch (res.statusCode()) {
123123
case 400:
124124
responseBadRequest++;
125-
onSuccess();
125+
decreaseBackoff();
126126
break;
127127
case 200:
128128
responseOk++;
129-
onSuccess();
129+
decreaseBackoff();
130130
break;
131131
default:
132132
responseOther++;
133-
onError();
133+
increaseBackoff();
134134
queue.requeue(item);
135135
}
136136
} catch (IOException ex) {
137137
logger.log(Level.WARNING, "error sending request: {0}", ex.toString());
138138
responseOther++;
139-
onError();
139+
increaseBackoff();
140140
queue.requeue(item);
141141
}
142142

@@ -145,11 +145,11 @@ void runOnce(Map.Entry<BoundedQueue.Key, byte[]> item) throws InterruptedExcepti
145145

146146
int delay;
147147

148-
void onSuccess() {
148+
void decreaseBackoff() {
149149
delay >>= 4;
150150
}
151151

152-
void onError() {
152+
void increaseBackoff() {
153153
if (delay < 64) delay <<= 1;
154154
if (delay == 0) delay = 1;
155155
}

0 commit comments

Comments
 (0)