@@ -33,12 +33,12 @@ addToLibrary({
33
33
34
34
#if SOCKET_DEBUG
35
35
// If debug is enabled register simple default logging callbacks for each Event.
36
- SOCKFS . on ( 'error' , ( error ) => dbg ( ' websocket: error ' + error ) ) ;
37
- SOCKFS . on ( 'open' , ( fd ) => dbg ( ' websocket: open fd = ' + fd ) ) ;
38
- SOCKFS . on ( 'listen' , ( fd ) => dbg ( ' websocket: listen fd = ' + fd ) ) ;
39
- SOCKFS . on ( 'connection' , ( fd ) => dbg ( ' websocket: connection fd = ' + fd ) ) ;
40
- SOCKFS . on ( 'message' , ( fd ) => dbg ( ' websocket: message fd = ' + fd ) ) ;
41
- SOCKFS . on ( 'close' , ( fd ) => dbg ( ' websocket: close fd = ' + fd ) ) ;
36
+ SOCKFS . on ( 'error' , ( error ) => dbg ( ` websocket: error ${ error } ` ) ) ;
37
+ SOCKFS . on ( 'open' , ( fd ) => dbg ( ` websocket: open fd = ${ fd } ` ) ) ;
38
+ SOCKFS . on ( 'listen' , ( fd ) => dbg ( ` websocket: listen fd = ${ fd } ` ) ) ;
39
+ SOCKFS . on ( 'connection' , ( fd ) => dbg ( ` websocket: connection fd = ${ fd } ` ) ) ;
40
+ SOCKFS . on ( 'message' , ( fd ) => dbg ( ` websocket: message fd = ${ fd } ` ) ) ;
41
+ SOCKFS . on ( 'close' , ( fd ) => dbg ( ` websocket: close fd = ${ fd } ` ) ) ;
42
42
#endif
43
43
44
44
return FS . createNode ( null , '/' , { { { cDefs . S_IFDIR } } } | 511 /* 0777 */ , 0 ) ;
@@ -127,7 +127,7 @@ addToLibrary({
127
127
if ( ! SOCKFS . nextname . current ) {
128
128
SOCKFS . nextname . current = 0 ;
129
129
}
130
- return ' socket[' + ( SOCKFS . nextname . current ++ ) + ']' ;
130
+ return ` socket[${ SOCKFS . nextname . current ++ } ]` ;
131
131
} ,
132
132
// backend-specific stream ops
133
133
websocket_sock_ops : {
@@ -202,7 +202,7 @@ addToLibrary({
202
202
}
203
203
204
204
#if SOCKET_DEBUG
205
- dbg ( ' websocket: connect: ' + url + ', ' + subProtocols . toString ( ) ) ;
205
+ dbg ( ` websocket: connect: ${ url } , ${ subProtocols . toString ( ) } ` ) ;
206
206
#endif
207
207
// If node we use the ws library.
208
208
var WebSocketConstructor ;
@@ -222,7 +222,7 @@ addToLibrary({
222
222
}
223
223
224
224
#if SOCKET_DEBUG
225
- dbg ( ' websocket: adding peer: ' + addr + ':' + port ) ;
225
+ dbg ( ` websocket: adding peer: ${ addr } : ${ port } ` ) ;
226
226
#endif
227
227
228
228
var peer = {
@@ -240,7 +240,7 @@ addToLibrary({
240
240
// remote end.
241
241
if ( sock . type === { { { cDefs . SOCK_DGRAM } } } && typeof sock . sport != 'undefined' ) {
242
242
#if SOCKET_DEBUG
243
- dbg ( ' websocket: queuing port message (port ' + sock . sport + ')' ) ;
243
+ dbg ( ` websocket: queuing port message (port ${ sock . sport } )` ) ;
244
244
#endif
245
245
peer . msg_send_queue . push ( new Uint8Array ( [
246
246
255 , 255 , 255 , 255 ,
@@ -275,7 +275,7 @@ addToLibrary({
275
275
var queued = peer . msg_send_queue . shift ( ) ;
276
276
while ( queued ) {
277
277
#if SOCKET_DEBUG
278
- dbg ( ' websocket: sending queued data (' + queued . byteLength + ' bytes): ' + [ Array . prototype . slice . call ( new Uint8Array ( queued ) ) ] ) ;
278
+ dbg ( ` websocket: sending queued data (${ queued . byteLength } bytes): ${ new Uint8Array ( queued ) } ` ) ;
279
279
#endif
280
280
peer . socket . send ( queued ) ;
281
281
queued = peer . msg_send_queue . shift ( ) ;
@@ -303,7 +303,7 @@ addToLibrary({
303
303
}
304
304
305
305
#if SOCKET_DEBUG
306
- dbg ( ' websocket: handle message (' + data . byteLength + ' bytes): ' + [ Array . prototype . slice . call ( data ) ] ) ;
306
+ dbg ( ` websocket : handle message ( ${ data . byteLength } bytes ) : ${ data } ` ) ;
307
307
#endif
308
308
309
309
// if this is the port message, override the peer's port with it
@@ -506,7 +506,7 @@ addToLibrary({
506
506
var WebSocketServer = require ( 'ws' ) . Server ;
507
507
var host = sock . saddr ;
508
508
#if SOCKET_DEBUG
509
- dbg ( ' websocket: listen: ' + host + ':' + sock . sport ) ;
509
+ dbg ( ` websocket: listen: ${ host } : ${ sock . sport } ` ) ;
510
510
#endif
511
511
sock . server = new WebSocketServer ( {
512
512
host,
@@ -517,7 +517,7 @@ addToLibrary({
517
517
518
518
sock . server . on ( 'connection' , function ( ws ) {
519
519
#if SOCKET_DEBUG
520
- dbg ( ' websocket: received connection from: ' + ws . _socket . remoteAddress + ':' + ws . _socket . remotePort ) ;
520
+ dbg ( ` websocket: received connection from: ${ ws . _socket . remoteAddress } : ${ ws . _socket . remotePort } ` ) ;
521
521
#endif
522
522
if ( sock . type === { { { cDefs . SOCK_STREAM } } } ) {
523
523
var newsock = SOCKFS . createSocket ( sock . family , sock . type , sock . protocol ) ;
@@ -643,15 +643,15 @@ addToLibrary({
643
643
}
644
644
}
645
645
#if SOCKET_DEBUG
646
- dbg ( ' websocket: queuing (' + length + ' bytes): ' + [ Array . prototype . slice . call ( new Uint8Array ( data ) ) ] ) ;
646
+ dbg ( ` websocket: queuing (${ length } bytes): ${ new Uint8Array ( data ) } ` ) ;
647
647
#endif
648
648
dest . msg_send_queue . push ( data ) ;
649
649
return length ;
650
650
}
651
651
652
652
try {
653
653
#if SOCKET_DEBUG
654
- dbg ( ' websocket: send (' + length + ' bytes): ' + [ Array . prototype . slice . call ( new Uint8Array ( data ) ) ] ) ;
654
+ dbg ( ` websocket: send (${ length } bytes): ${ new Uint8Array ( data ) } ` ) ;
655
655
#endif
656
656
// send the actual data
657
657
dest . socket . send ( data ) ;
@@ -699,14 +699,14 @@ addToLibrary({
699
699
} ;
700
700
701
701
#if SOCKET_DEBUG
702
- dbg ( ' websocket: read (' + bytesRead + ' bytes): ' + [ Array . prototype . slice . call ( res . buffer ) ] ) ;
702
+ dbg ( ` websocket: read (${ bytesRead } bytes): ${ res . buffer } ` ) ;
703
703
#endif
704
704
705
705
// push back any unread data for TCP connections
706
706
if ( sock . type === { { { cDefs . SOCK_STREAM } } } && bytesRead < queuedLength ) {
707
707
var bytesRemaining = queuedLength - bytesRead ;
708
708
#if SOCKET_DEBUG
709
- dbg ( ' websocket: read: put back ' + bytesRemaining + ' bytes' ) ;
709
+ dbg ( ` websocket: read: put back ${ bytesRemaining } bytes` ) ;
710
710
#endif
711
711
queued . data = new Uint8Array ( queuedBuffer , queuedOffset + bytesRead , bytesRemaining ) ;
712
712
sock . recv_queue . unshift ( queued ) ;
0 commit comments