- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for setZeroPayloadFlag (0.29 sec)
-
internal/grid/muxclient.go
m.singleResp = false msg := message{ Op: OpConnectMux, Handler: h, Flags: FlagEOF, Payload: req, DeadlineMS: uint32(m.deadline.Milliseconds()), } msg.setZeroPayloadFlag() if m.subroute != nil { msg.Flags |= FlagSubroute } // Send... err := m.send(msg) if err != nil { out <- Response{Err: err} return } // Route directly to output.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/msg.go
sub = (*subHandlerID)(subID) // Add if more modifications to h is needed h = h[:len(h)-32] } return sub, h, nil } // setZeroPayloadFlag will clear or set the FlagPayloadIsZero if // m.Payload is length 0, but not nil. func (m *message) setZeroPayloadFlag() { m.Flags &^= FlagPayloadIsZero if len(m.Payload) == 0 && m.Payload != nil { m.Flags |= FlagPayloadIsZero } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/grid/muxserver.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/grid/connection.go
Seq: m.Seq, Op: OpResponse, Flags: FlagEOF, } if err != nil { m.Flags |= FlagPayloadIsErr m.Payload = []byte(*err) } else { m.Payload = b m.setZeroPayloadFlag() } gridLogIf(ctx, c.queueMsg(m, nil)) }(m) } func (c *Connection) handlePong(ctx context.Context, m message) { var pong pongMsg _, err := pong.UnmarshalMsg(m.Payload)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0)