Compare commits

..

No commits in common. "66bee258138116733140bbc32ae99789105b0673" and "c8f323237fbc270a25086ecc36e35023c6c28d6e" have entirely different histories.

3 changed files with 6 additions and 7 deletions

View File

@ -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;
} }

View File

@ -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;

View File

@ -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