- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for writeMessage (0.13 sec)
-
internal/grid/connection.go
} } c.connChange.L.Unlock() if len(queue) == 0 { // Send single message without merging. err := wsw.writeMessage(&buf, c.side, ws.OpBinary, toSend) if err != nil { if !xnet.IsNetworkOrHostDown(err, true) { gridLogIf(ctx, fmt.Errorf("ws writeMessage: %w", err)) } return } PutByteBuffer(toSend) if !writeBuffer() { return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
internal/grid/manager.go
} if b, err := resp.MarshalMsg(nil); err == nil { msg := message{ Op: OpConnectResponse, Payload: b, } if b, err := msg.MarshalMsg(nil); err == nil { wsutil.WriteMessage(conn, ws.StateServerSide, ws.OpBinary, b) } } } defer conn.Close() if debugPrint { fmt.Printf("grid: Upgraded request: %v\n", remoteAddr) } msg, _, err := wsutil.ReadClientData(conn)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 10.6K bytes - Viewed (0)