commented out backpressure messages
This commit is contained in:
parent
232f8c6a75
commit
9c51e9ac5c
1 changed files with 2 additions and 2 deletions
|
@ -99,7 +99,7 @@ class AudioServer {
|
||||||
if (this.buffer.stream === undefined || !this.buffer.stream.isPaused()) {
|
if (this.buffer.stream === undefined || !this.buffer.stream.isPaused()) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
logger.debug(client.getTag() + ' backpressure is relieved, resuming read stream...');
|
// logger.debug(client.getTag() + ' backpressure is relieved, resuming read stream...');
|
||||||
this.buffer.stream.resume();
|
this.buffer.stream.resume();
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
@ -243,7 +243,7 @@ class AudioServer {
|
||||||
for (let index = 0; index < this.clients.length; index++) {
|
for (let index = 0; index < this.clients.length; index++) {
|
||||||
const client = this.clients[index];
|
const client = this.clients[index];
|
||||||
if (client.audiosocket.write(data) !== true) {
|
if (client.audiosocket.write(data) !== true) {
|
||||||
logger.debug(client.getTag() + ' detected backpressure, pausing read stream...');
|
// logger.debug(client.getTag() + ' detected backpressure, pausing read stream...');
|
||||||
this.buffer.stream.pause();
|
this.buffer.stream.pause();
|
||||||
}
|
}
|
||||||
if (client.audiosocket.bytesWritten >= this.buffer.size) {
|
if (client.audiosocket.bytesWritten >= this.buffer.size) {
|
||||||
|
|
Loading…
Reference in a new issue