Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for Laurent (0.2 sec)

  1. internal/grid/muxserver.go

    	} else {
    		m.send(message{Op: OpDisconnectClientMux, MuxID: m.ID})
    	}
    	m.parent.deleteMux(true, m.ID)
    }
    
    func (m *muxServer) send(msg message) {
    	m.sendMu.Lock()
    	defer m.sendMu.Unlock()
    	msg.MuxID = m.ID
    	msg.Seq = m.SendSeq
    	m.SendSeq++
    	if debugPrint {
    		fmt.Printf("Mux %d, Sending %+v\n", m.ID, msg)
    	}
    	gridLogIf(m.ctx, m.parent.queueMsg(msg, nil))
    }
    
    func (m *muxServer) close() {
    	m.cancel()
    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)
Back to top