Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for tcpListeners (0.17 sec)

  1. internal/http/listener.go

    	}
    
    	if len(tcpListeners) == 0 {
    		// No listeners initialized, no need to continue
    		return
    	}
    
    	listener = &httpListener{
    		tcpListeners: tcpListeners,
    		acceptCh:     make(chan acceptResult, len(tcpListeners)),
    		opts:         opts,
    	}
    	listener.ctx, listener.ctxCanceler = context.WithCancel(ctx)
    	if opts.Trace != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  2. internal/deadlineconn/deadlineconn_test.go

    		t.Fatalf("unable to create listener. %v", err)
    	}
    	defer l.Close()
    	serverAddr := l.Addr().String()
    
    	tcpListener, ok := l.(*net.TCPListener)
    	if !ok {
    		t.Fatalf("failed to assert to net.TCPListener")
    	}
    
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    
    		tcpConn, terr := tcpListener.AcceptTCP()
    		if terr != nil {
    			t.Errorf("failed to accept new connection. %v", terr)
    			return
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Nov 05 18:09:21 GMT 2022
    - 3K bytes
    - Viewed (0)
Back to top