Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for DeadlineMS (0.32 sec)

  1. internal/grid/muxserver.go

    }
    
    func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer {
    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if msg.DeadlineMS > 0 {
    		ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond)
    	} else {
    		ctx, cancel = context.WithCancel(ctx)
    	}
    	m := muxServer{
    		ID:        msg.MuxID,
    		RecvSeq:   msg.Seq + 1,
    		SendSeq:   msg.Seq,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  2. internal/grid/msg.go

    	var res []string
    	if m.MuxID != 0 {
    		res = append(res, fmt.Sprintf("MuxID: %v", m.MuxID))
    	}
    	if m.Seq != 0 {
    		res = append(res, fmt.Sprintf("Seq: %v", m.Seq))
    	}
    	if m.DeadlineMS != 0 {
    		res = append(res, fmt.Sprintf("Deadline: %vms", m.DeadlineMS))
    	}
    	if m.Handler != handlerInvalid {
    		res = append(res, fmt.Sprintf("Handler: %v", m.Handler))
    	}
    	if m.Op != 0 {
    		res = append(res, fmt.Sprintf("Op: %v", m.Op))
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 28 19:22:29 GMT 2023
    - 7.3K bytes
    - Viewed (0)
Back to top