Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for writeMessage (0.09 sec)

  1. 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)
  2. 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)
Back to top