Compare commits
No commits in common. "66bee258138116733140bbc32ae99789105b0673" and "c8f323237fbc270a25086ecc36e35023c6c28d6e" have entirely different histories.
66bee25813
...
c8f323237f
|
@ -183,10 +183,8 @@ class Delimiter extends Extension {
|
||||||
this.CommonPrefixes.push(commonPrefix);
|
this.CommonPrefixes.push(commonPrefix);
|
||||||
this.NextMarker = commonPrefix;
|
this.NextMarker = commonPrefix;
|
||||||
++this.keys;
|
++this.keys;
|
||||||
console.log('key accepted');
|
|
||||||
return FILTER_ACCEPT;
|
return FILTER_ACCEPT;
|
||||||
}
|
}
|
||||||
console.log('key skipped')
|
|
||||||
return FILTER_SKIP;
|
return FILTER_SKIP;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -22,7 +22,6 @@ class DelimiterMaster extends Delimiter {
|
||||||
*/
|
*/
|
||||||
constructor(parameters) {
|
constructor(parameters) {
|
||||||
super(parameters);
|
super(parameters);
|
||||||
// non-PHD master version or a version whose master is a PHD version
|
|
||||||
this.prvPHDKey = undefined;
|
this.prvPHDKey = undefined;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -53,15 +52,18 @@ class DelimiterMaster extends Delimiter {
|
||||||
if (key !== this.prvPHDKey) {
|
if (key !== this.prvPHDKey) {
|
||||||
return FILTER_ACCEPT; // trick repd to not increase its streak
|
return FILTER_ACCEPT; // trick repd to not increase its streak
|
||||||
}
|
}
|
||||||
} else if (Version.isPHD(value)) {
|
}
|
||||||
|
if (Version.isPHD(value)) {
|
||||||
// master version is a PHD version: wait for the next version
|
// master version is a PHD version: wait for the next version
|
||||||
this.prvPHDKey = key;
|
this.prvPHDKey = key;
|
||||||
return FILTER_ACCEPT; // trick repd to not increase its streak
|
return FILTER_ACCEPT; // trick repd to not increase its streak
|
||||||
} else if (Version.isDeleteMarker(value)) {
|
}
|
||||||
|
if (Version.isDeleteMarker(value)) {
|
||||||
// version is a delete marker, ignore
|
// version is a delete marker, ignore
|
||||||
return FILTER_ACCEPT; // trick repd to not increase its streak
|
return FILTER_ACCEPT; // trick repd to not increase its streak
|
||||||
}
|
}
|
||||||
this.prvPHDKey = key;
|
// non-PHD master version or a version whose master is a PHD version
|
||||||
|
this.prvPHDKey = undefined;
|
||||||
if (this.delimiter) {
|
if (this.delimiter) {
|
||||||
// check if the key has the delimiter
|
// check if the key has the delimiter
|
||||||
const baseIndex = this.prefix ? this.prefix.length : 0;
|
const baseIndex = this.prefix ? this.prefix.length : 0;
|
||||||
|
|
|
@ -988,7 +988,6 @@ class MongoClientInterface {
|
||||||
// skipped
|
// skipped
|
||||||
if (++streakLength === MAX_STREAK_LENGTH) {
|
if (++streakLength === MAX_STREAK_LENGTH) {
|
||||||
// stop listing this key range
|
// stop listing this key range
|
||||||
console.log('skip');
|
|
||||||
stream.destroy();
|
stream.destroy();
|
||||||
// update the new listing parameters here
|
// update the new listing parameters here
|
||||||
// eslint-disable-next-line no-param-reassign
|
// eslint-disable-next-line no-param-reassign
|
||||||
|
|
Loading…
Reference in New Issue