PrivateCoffee/element-web
4
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 3

Merge pull request #4551 from matrix-org/jryans/event-logging-rm-rc

Browse source 
EventIndex: Reduce the logging the event index is producing.
This commit is contained in:
J. Ryan Stinnett 2020-05-05 10:53:15 +01:00 committed by GitHub
commit 7b131d873d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
src/indexing/EventIndex.js
View file

@ -102,9 +102,6 @@ export default class EventIndex extends EventEmitter {
const timeline = room.getLiveTimeline();
const token = timeline.getPaginationToken("b");
console.log("EventIndex: Got token for indexer",
room.roomId, token);
const backCheckpoint = {
roomId: room.roomId,
token: token,
@ -161,7 +158,6 @@ export default class EventIndex extends EventEmitter {
if (prevState === "SYNCING" && state === "SYNCING") {
// A sync was done, presumably we queued up some live events,
// commit them now.
console.log("EventIndex: Committing events");
await indexManager.commitLiveEvents();
return;
}
@ -336,8 +332,6 @@ export default class EventIndex extends EventEmitter {
async crawlerFunc() {
let cancelled = false;
console.log("EventIndex: Started crawler function");
const client = MatrixClientPeg.get();
const indexManager = PlatformPeg.get().getEventIndexingManager();
@ -366,8 +360,6 @@ export default class EventIndex extends EventEmitter {
await sleep(sleepTime);
console.log("EventIndex: Running the crawler loop.");
if (cancelled) {
break;
}
@ -386,8 +378,6 @@ export default class EventIndex extends EventEmitter {
idle = false;
console.log("EventIndex: crawling using checkpoint", checkpoint);
// We have a checkpoint, let us fetch some messages, again, very
// conservatively to not bother our homeserver too much.
const eventMapper = client.getEventMapper({preventReEmit: true});
@ -477,9 +467,6 @@ export default class EventIndex extends EventEmitter {
// decryption keys, do we want to retry this checkpoint at a later
// stage?
const filteredEvents = matrixEvents.filter(this.isValidEvent);
const undecryptableEvents = matrixEvents.filter((ev) => {
return ev.isDecryptionFailure();
});
// Collect the redaction events so we can delete the redacted events
// from the index.
@ -511,15 +498,6 @@ export default class EventIndex extends EventEmitter {
direction: checkpoint.direction,
};
console.log(
"EventIndex: Crawled room",
client.getRoom(checkpoint.roomId).name,
"and fetched total", matrixEvents.length, "events of which",
events.length, "are being added,", redactionEvents.length,
"are redacted,", matrixEvents.length - events.length,
"are being skipped, undecryptable", undecryptableEvents.length,
);
try {
for (let i = 0; i < redactionEvents.length; i++) {
const ev = redactionEvents[i];
@ -552,8 +530,6 @@ export default class EventIndex extends EventEmitter {
}
this._crawler = null;
console.log("EventIndex: Stopping crawler function");
}
/**