Turn down the volume on websocket send error debug messages
This commit is contained in:
parent
413f28bf20
commit
553490e77e
|
@ -210,19 +210,21 @@ function _server(host, port, httpsOptions) {
|
||||||
react {
|
react {
|
||||||
const facet = currentFacet();
|
const facet = currentFacet();
|
||||||
const id = genUuid('_wsRequest');
|
const id = genUuid('_wsRequest');
|
||||||
const guard = (f) => {
|
const guard = (context, f) => {
|
||||||
try {
|
try {
|
||||||
f()
|
f()
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
// Swallow e, which will be some kind of websocket-related exception.
|
// Swallow e, which will be some kind of websocket-related exception.
|
||||||
console.debug('WebSocket '+id+' exception in actor '+facet.actor.toString(), e);
|
console.debug(
|
||||||
|
'WebSocket '+id+' exception in actor '+facet.actor.toString()+' during '+context+':',
|
||||||
|
e.message);
|
||||||
facet.stop();
|
facet.stop();
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
assert WebSocket(id, server, pieces, url.query);
|
assert WebSocket(id, server, pieces, url.query);
|
||||||
|
|
||||||
on stop guard(() => ws.close());
|
on stop guard('close', () => ws.close());
|
||||||
|
|
||||||
ws.on('close', Dataspace.wrapExternal(() => {
|
ws.on('close', Dataspace.wrapExternal(() => {
|
||||||
facet.stop();
|
facet.stop();
|
||||||
|
@ -235,7 +237,7 @@ function _server(host, port, httpsOptions) {
|
||||||
}
|
}
|
||||||
|
|
||||||
on message DataOut(id, $message) {
|
on message DataOut(id, $message) {
|
||||||
guard(() => ws.send(Bytes.toIO(message)));
|
guard('send', () => ws.send(Bytes.toIO(message)));
|
||||||
}
|
}
|
||||||
|
|
||||||
stop on retracted Observe(WebSocket(_, server, pathPattern, _));
|
stop on retracted Observe(WebSocket(_, server, pathPattern, _));
|
||||||
|
|
Loading…
Reference in New Issue