Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for debugMsg (0.37 sec)

  1. internal/grid/manager.go

    	var res []string
    	for k := range m.targets {
    		res = append(res, k)
    	}
    	return res
    }
    
    // debugMsg should *only* be used by tests.
    //
    //lint:ignore U1000 This is used by tests.
    func (m *Manager) debugMsg(d debugMsg, args ...any) {
    	for _, c := range m.targets {
    		c.debugMsg(d, args...)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  2. internal/grid/grid_test.go

    			},
    			OutCapacity: 1,
    			InCapacity:  1,
    		}))
    	}
    	register(local)
    	register(remote)
    	// Double remote DL
    	local.debugMsg(debugAddToDeadline, wantDL)
    	defer local.debugMsg(debugAddToDeadline, time.Duration(0))
    	remote.debugMsg(debugAddToDeadline, wantDL)
    	defer remote.debugMsg(debugAddToDeadline, time.Duration(0))
    
    	testHandler := func(t *testing.T, handler HandlerID) {
    		remoteConn := local.Connection(remoteHost)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    func (c *Connection) Stats() ConnectionStats {
    	return ConnectionStats{
    		IncomingStreams: c.inStream.Size(),
    		OutgoingStreams: c.outgoing.Size(),
    	}
    }
    
    func (c *Connection) debugMsg(d debugMsg, args ...any) {
    	if debugPrint {
    		fmt.Println("debug: sending message", d, args)
    	}
    
    	switch d {
    	case debugShutdown:
    		c.updateState(StateShutdown)
    	case debugKillInbound:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top