Comparing version 0.5.0 to 1.0.0
@@ -413,6 +413,2 @@ /* | ||
}); | ||
S.on(this.cf_conn, 'end', function () { | ||
self.cf_lastError = new mod_errors.ConnectionClosedError(self); | ||
S.gotoState('error'); | ||
}); | ||
S.on(this, 'closeAsserted', function () { | ||
@@ -498,6 +494,2 @@ S.gotoState('closed'); | ||
}); | ||
S.on(this.cf_conn, 'end', function () { | ||
self.cf_lastError = new mod_errors.ConnectionClosedError(self); | ||
S.gotoState('error'); | ||
}); | ||
S.on(this, 'closeAsserted', function () { | ||
@@ -568,6 +560,2 @@ self.cf_lastError = new mod_errors.ConnectionClosedError(self); | ||
}); | ||
S.on(this.cf_conn, 'end', function () { | ||
self.cf_lastError = new mod_errors.ConnectionClosedError(self); | ||
S.gotoState('error'); | ||
}); | ||
S.on(this.cf_conn, 'close', function () { | ||
@@ -574,0 +562,0 @@ self.cf_lastError = new mod_errors.ConnectionClosedError(self); |
@@ -24,3 +24,3 @@ /* | ||
const mod_nsc = require('named-client'); | ||
const mod_nsc = require('mname-client'); | ||
const mod_events = require('events'); | ||
@@ -308,3 +308,3 @@ const mod_net = require('net'); | ||
if (this.r_bootstrap === undefined) { | ||
this.r_bootstrap = new CueBallDNSResolver({ | ||
var res = new CueBallDNSResolver({ | ||
domain: notIp[0], | ||
@@ -316,2 +316,3 @@ service: '_dns._udp', | ||
}); | ||
this.r_bootstrap = res.r_fsm; | ||
CueBallDNSResolver.bootstrapResolvers[notIp[0]] = | ||
@@ -318,0 +319,0 @@ this.r_bootstrap; |
@@ -197,11 +197,11 @@ /* | ||
if (singleton) { | ||
return (dead[kk] !== true && ( | ||
wantedSpares[kk] === undefined || | ||
wantedSpares[kk] === 0)); | ||
return (dead[kk] !== true && | ||
wantedSpares[kk] === undefined); | ||
} else { | ||
return (dead[kk] !== true || | ||
wantedSpares[kk] === undefined || | ||
wantedSpares[kk] === 0); | ||
wantedSpares[kk] === undefined); | ||
} | ||
}); | ||
/* We have room for both this and a replacement. */ | ||
if (count + 1 <= max) { | ||
@@ -215,4 +215,19 @@ if (wantedSpares[k] === 0) { | ||
/* | ||
* We only have room for one, but there are other candidates | ||
* that might actually be up. Use one of them instead. | ||
*/ | ||
} else if (count <= max && empties.length > 0) { | ||
++replacements; | ||
/* Only room for one, everything looks dead. Use us. */ | ||
} else if (count <= max) { | ||
if (wantedSpares[k] === 0) { | ||
wantedSpares[k] = 1; | ||
++done; | ||
} | ||
/* Already met our max socket cap. Give up now. */ | ||
} else { | ||
break; | ||
} | ||
@@ -219,0 +234,0 @@ } |
{ | ||
"name": "cueball", | ||
"version": "0.5.0", | ||
"version": "1.0.0", | ||
"description": "", | ||
@@ -13,3 +13,3 @@ "main": "lib/index.js", | ||
"mooremachine": ">=2.0.0 <3.0.0", | ||
"named-client": "git+https://github.com/arekinath/node-named-client.git#v0.3.6", | ||
"mname-client": ">=0.3.6 <0.4.0", | ||
"node-uuid": ">=1.4.7 <2.0.0", | ||
@@ -16,0 +16,0 @@ "posix-getopt": ">=1.2.0 <2.0.0", |
Sorry, the diff of this file is not supported yet
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
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
Git dependency
Supply chain riskContains a dependency which resolves to a remote git URL. Dependencies fetched from git URLs are not immutable and can be used to inject untrusted code or reduce the likelihood of a reproducible install.
Found 1 instance in 1 package
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
3331
1
0
141770
+ Addedmname-client@>=0.3.6 <0.4.0
+ Addedbloomfilter@0.0.16(transitive)
+ Addedmname@1.5.1(transitive)
+ Addedmname-client@0.3.7(transitive)
+ Addedvasync@2.2.1(transitive)
+ Addedverror@1.10.0(transitive)
- Removednamed-client@git+https://github.com/arekinath/node-named-client.git#v0.3.6