cueball - npm Package Compare versions
Comparing version 0.4.0 to 0.4.1
@@ -74,2 +74,3 @@ /* | ||
| obj.state = pool.getState(); | ||
| obj.counters = pool.p_counters; | ||
| obj.options = {}; | ||
@@ -76,0 +77,0 @@ obj.options.domain = pool.p_resolver.r_domain; |
@@ -226,2 +226,3 @@ /* | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('error-during-connect'); | ||
| }); | ||
@@ -231,2 +232,3 @@ once(this.cf_conn, 'connectError', function (err) { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('error-during-connect'); | ||
| }); | ||
@@ -236,2 +238,3 @@ once(this.cf_conn, 'close', function () { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('close-during-connect'); | ||
| }); | ||
@@ -241,2 +244,3 @@ once(this.cf_conn, 'timeout', function () { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('timeout-during-connect'); | ||
| }); | ||
@@ -246,2 +250,3 @@ once(this.cf_conn, 'connectTimeout', function (err) { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('timeout-during-connect'); | ||
| }); | ||
@@ -266,2 +271,8 @@ once(this, 'closeAsserted', function () { | ||
| this.validTransitions(['delay', 'closed']); | ||
| var self = this; | ||
| on(this, 'closeAsserted', function () { | ||
| self.gotoState('closed'); | ||
| }); | ||
| if (this.cf_conn && this.cf_conn.destroy) | ||
@@ -305,2 +316,3 @@ this.cf_conn.destroy(); | ||
| 'backend %s (%j)', this.cf_backend.key, this.cf_backend); | ||
| this.cf_pool._incrCounter('retries-exhausted'); | ||
| this.gotoState('closed'); | ||
@@ -377,2 +389,3 @@ } | ||
| this.gotoState('closed'); | ||
| on(this, 'closeAsserted', function () { }); | ||
| return; | ||
@@ -389,2 +402,3 @@ } | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('error-during-idle'); | ||
| }); | ||
@@ -394,2 +408,3 @@ once(this.cf_conn, 'close', function () { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('close-during-idle'); | ||
| }); | ||
@@ -399,2 +414,3 @@ once(this.cf_conn, 'end', function () { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('end-during-idle'); | ||
| }); | ||
@@ -459,4 +475,4 @@ once(this, 'closeAsserted', function () { | ||
| once(this, 'releaseAsserted', function () { | ||
| if (this.cf_closeAfter === true) { | ||
| this.gotoState('closed'); | ||
| if (self.cf_closeAfter === true) { | ||
| self.gotoState('closed'); | ||
| } else { | ||
@@ -469,2 +485,3 @@ self.gotoState('idle'); | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('error-during-ping'); | ||
| }); | ||
@@ -474,2 +491,3 @@ once(this.cf_conn, 'close', function () { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('close-during-ping'); | ||
| }); | ||
@@ -479,2 +497,3 @@ once(this.cf_conn, 'end', function () { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('end-during-ping'); | ||
| }); | ||
@@ -528,4 +547,4 @@ once(this, 'closeAsserted', function () { | ||
| once(this, 'releaseAsserted', function () { | ||
| if (this.cf_closeAfter === true) { | ||
| this.gotoState('closed'); | ||
| if (self.cf_closeAfter === true) { | ||
| self.gotoState('closed'); | ||
| } else { | ||
@@ -538,6 +557,7 @@ self.gotoState('idle'); | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('error-during-busy'); | ||
| }); | ||
| once(this.cf_conn, 'end', function () { | ||
| self.cf_lastError = new mod_errors.ConnectionClosedError(self); | ||
| self.gotoState('error'); | ||
| self.cf_closeAfter = true; | ||
| self.cf_pool._incrCounter('end-during-busy'); | ||
| }); | ||
@@ -547,2 +567,3 @@ once(this.cf_conn, 'close', function () { | ||
| self.gotoState('error'); | ||
| self.cf_pool._incrCounter('close-during-busy'); | ||
| }); | ||
@@ -677,2 +698,4 @@ once(this, 'closeAsserted', function () { | ||
| this.p_counters = {}; | ||
| var self = this; | ||
@@ -716,2 +739,8 @@ if (options.resolver !== undefined && options.resolver !== null) { | ||
| CueBallConnectionPool.prototype._incrCounter = function (counter) { | ||
| if (this.p_counters[counter] === undefined) | ||
| this.p_counters[counter] = 0; | ||
| ++this.p_counters[counter]; | ||
| }; | ||
| CueBallConnectionPool.prototype.on_resolver_added = function (k, backend) { | ||
@@ -718,0 +747,0 @@ backend.key = k; |
| { | ||
| "name": "cueball", | ||
| "version": "0.4.0", | ||
| "version": "0.4.1", | ||
| "description": "", | ||
@@ -12,3 +12,3 @@ "main": "lib/index.js", | ||
| "ipaddr.js": ">=1.1.0 <2.0.0", | ||
| "mooremachine": ">=1.4.0 <2.0.0", | ||
| "mooremachine": ">=1.4.2 <2.0.0", | ||
| "named-client": "git+https://github.com/arekinath/node-named-client.git#v0.3.5", | ||
@@ -15,0 +15,0 @@ "node-uuid": ">=1.4.7 <2.0.0", |
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Improved metrics
- Total package byte prevSize
- increased by0.82%
132678
- Lines of code
- increased by0.82%
3216
Dependency changes
Updatedmooremachine@>=1.4.2 <2.0.0