Skip to content
This repository was archived by the owner on Mar 11, 2022. It is now read-only.

Commit 60f0c37

Browse files
committed
Add debug to retry plugin
1 parent 33f76ed commit 60f0c37

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

plugins/retry.js

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
'use strict';
1515

1616
const BasePlugin = require('./base.js');
17-
17+
const debug = require('debug')('cloudant:plugins:retry');
1818
/**
1919
* Retry plugin.
2020
*/
@@ -38,24 +38,28 @@ class RetryPlugin extends BasePlugin {
3838

3939
onResponse(state, response, callback) {
4040
if (this._cfg.retryStatusCodes.indexOf(response.statusCode) !== -1) {
41+
debug(`Received status code ${response.statusCode}; setting retry state.`);
4142
state.retry = true;
4243
if (state.attempt === 1) {
4344
state.retryDelayMsecs = this._cfg.retryInitialDelayMsecs;
4445
} else {
4546
state.retryDelayMsecs *= this._cfg.retryDelayMultiplier;
4647
}
48+
debug(`Asking for retry after ${state.retryDelayMsecs}`);
4749
}
4850
callback(state);
4951
}
5052

5153
onError(state, error, callback) {
5254
if (this._cfg.retryErrors) {
55+
debug(`Received error ${error.code} ${error.message}; setting retry state.`);
5356
state.retry = true;
5457
if (state.attempt === 1) {
5558
state.retryDelayMsecs = this._cfg.retryInitialDelayMsecs;
5659
} else {
5760
state.retryDelayMsecs *= this._cfg.retryDelayMultiplier;
5861
}
62+
debug(`Asking for retry after ${state.retryDelayMsecs}`);
5963
}
6064
callback(state);
6165
}

0 commit comments

Comments
 (0)