Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for forceClose (0.09 sec)

  1. pkg/test/echo/server/endpoint/util.go

    	if err != nil {
    		return nil, 0, err
    	}
    
    	port = ln.LocalAddr().(*net.UDPAddr).Port
    	return ln, port, nil
    }
    
    // forceClose the given socket.
    func forceClose(conn net.Conn) error {
    	// Close may be called more than once.
    	defer func() { _ = conn.Close() }()
    
    	// Force the connection closed (should result in sending RST)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  2. pkg/test/echo/server/endpoint/tcp.go

    			go func() {
    				select {
    				case <-done:
    					return
    				case <-time.After(requestTimeout):
    					epLog.WithLabels("id", id).Warnf("TCP forcing connection closed after request timeout")
    					_ = forceClose(conn)
    					return
    				}
    			}()
    		}
    	}()
    
    	// Notify the WaitGroup once the port has transitioned to ready.
    	go s.awaitReady(onReady, listener.Addr().String())
    
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 16:20:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
Back to top