Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for deleteMux (0.08 sec)

  1. internal/grid/muxserver.go

    	} else {
    		m.send(message{Op: OpDisconnectClientMux, MuxID: m.ID})
    	}
    	// Unlock, since we are calling deleteMux, which will call close - which will lock recvMu.
    	if locked {
    		m.recvMu.Unlock()
    		defer m.recvMu.Lock()
    	}
    	m.parent.deleteMux(true, m.ID)
    }
    
    func (m *muxServer) send(msg message) {
    	m.sendMu.Lock()
    	defer m.sendMu.Unlock()
    	msg.MuxID = m.ID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top