Compare commits

..

No commits in common. "15064a5cb09d461323a4e34905e22abb9b189269" and "7dd4dca7e5d3ae0810cd529197e5f4d3e1211270" have entirely different histories.

2 changed files with 1 additions and 9 deletions

View File

@ -51,7 +51,6 @@ class DelimiterMaster extends Delimiter {
if ((this.prefix && !key.startsWith(this.prefix)) if ((this.prefix && !key.startsWith(this.prefix))
|| (typeof this[this.nextContinueMarker] === 'string' && || (typeof this[this.nextContinueMarker] === 'string' &&
key <= this[this.nextContinueMarker])) { key <= this[this.nextContinueMarker])) {
console.log('skip 1')
return FILTER_SKIP; return FILTER_SKIP;
} }
@ -76,9 +75,8 @@ class DelimiterMaster extends Delimiter {
* */ * */
if (key === this.prvKey || key === this[this.nextContinueMarker] || if (key === this.prvKey || key === this[this.nextContinueMarker] ||
(this.delimiter && (this.delimiter &&
key.startsWith(`${this[this.nextContinueMarker]}${this.delimiter}`))) { key.startsWith(this[this.nextContinueMarker]))) {
/* master version already filtered */ /* master version already filtered */
console.log('skip 2')
return FILTER_SKIP; return FILTER_SKIP;
} }
} }
@ -91,7 +89,6 @@ class DelimiterMaster extends Delimiter {
* MongoClient). */ * MongoClient). */
this.prvKey = undefined; this.prvKey = undefined;
this.prvPHDKey = key; this.prvPHDKey = key;
console.log('accept 1')
return FILTER_ACCEPT; return FILTER_ACCEPT;
} }
if (Version.isDeleteMarker(value)) { if (Version.isDeleteMarker(value)) {
@ -105,11 +102,9 @@ class DelimiterMaster extends Delimiter {
* follow. */ * follow. */
if (key === this.prvPHDKey) { if (key === this.prvPHDKey) {
this.prvKey = undefined; this.prvKey = undefined;
console.log('accept 2')
return FILTER_ACCEPT; return FILTER_ACCEPT;
} }
this.prvKey = key; this.prvKey = key;
console.log('skip 3')
return FILTER_SKIP; return FILTER_SKIP;
} }
@ -136,10 +131,8 @@ class DelimiterMaster extends Delimiter {
if (index === this[this.nextContinueMarker].length - 1) { if (index === this[this.nextContinueMarker].length - 1) {
return this[this.nextContinueMarker]; return this[this.nextContinueMarker];
} }
console.log(`skipping: ${this[this.nextContinueMarker] + VID_SEP}`)
return this[this.nextContinueMarker] + VID_SEP; return this[this.nextContinueMarker] + VID_SEP;
} }
console.log('skipping: none')
return SKIP_NONE; return SKIP_NONE;
} }
} }

View File

@ -919,7 +919,6 @@ class MongoClientInterface {
stream stream
.on('data', e => { .on('data', e => {
console.log(JSON.stringify(e));
skip.filter(e); skip.filter(e);
}) })
.on('error', err => { .on('error', err => {