Compare commits
No commits in common. "15064a5cb09d461323a4e34905e22abb9b189269" and "7dd4dca7e5d3ae0810cd529197e5f4d3e1211270" have entirely different histories.
15064a5cb0
...
7dd4dca7e5
|
@ -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;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -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 => {
|
||||||
|
|
Loading…
Reference in New Issue