comment debug logging
This commit is contained in:
parent
32c9cb0174
commit
181e3c692d
2 changed files with 3 additions and 3 deletions
|
@ -156,11 +156,11 @@ class SystemQuery extends EventEmitter {
|
|||
|
||||
let peers_seen = [];
|
||||
while(peers_seen.length < this.agent.connected_peers.length) {
|
||||
l.info(`peers_seen:`, peers_seen, `connected peers:`, this.agent.connected_peers.map(peer => peer.id));
|
||||
// l.info(`peers_seen:`, peers_seen, `connected peers:`, this.agent.connected_peers.map(peer => peer.id));
|
||||
let next = await queue.dequeue(this.config.net.table_timeout * 1000);
|
||||
if(typeof next === "undefined") // We timed out
|
||||
break;
|
||||
l.log(`fetch table DEBUG`, next);
|
||||
// l.log(`fetch table DEBUG`, next);
|
||||
if(!peers_seen.includes(next.peer.id))
|
||||
peers_seen.push(next.peer.id);
|
||||
yield next;
|
||||
|
|
|
@ -15,7 +15,7 @@ class ServerSentEventStream {
|
|||
}
|
||||
|
||||
write(event_name, data) {
|
||||
// l.log(`event #${this.next_id} ${event_name}: ${data}`);
|
||||
l.log(`event #${this.next_id} ${event_name}: ${data}`);
|
||||
this.response.write(`id: ${this.next_id++}\n`);
|
||||
this.response.write(`event: ${event_name}\n`);
|
||||
this.response.write(`data: ${data}\n\n`);
|
||||
|
|
Loading…
Reference in a new issue