- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for serverDone (0.15 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go
t.Errorf("server: timed out waiting for connection closure: %v", err) } serverDone <- struct{}{} } func TestConnectionCloseIsImmediateThroughAProxy(t *testing.T) { errCh := make(chan error) serverDone := make(chan struct{}, 1) backendUrlChan := make(chan string) go runServer(t, backendUrlChan, serverDone, errCh) var backendUrl string select { case err := <-errCh:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 11:58:57 UTC 2023 - 7.9K bytes - Viewed (0) -
src/net/net_test.go
t.Parallel() ln := newLocalListener(t, "tcp") serverDone := make(chan struct{}) dialed := make(chan struct{}) go func() { defer close(serverDone) cs, err := ln.Accept() if err != nil { return } <-dialed cs.(*TCPConn).SetLinger(0) cs.Close() }() defer func() { ln.Close() <-serverDone }() ss, err := Dial("tcp", ln.Addr().String())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 21:04:44 UTC 2024 - 13.3K bytes - Viewed (0) -
src/net/smtp/smtp_test.go
t.Fatalf("client error: %v", err) } } func TestTLSConnState(t *testing.T) { ln := newLocalListener(t) defer ln.Close() clientDone := make(chan bool) serverDone := make(chan bool) go func() { defer close(serverDone) c, err := ln.Accept() if err != nil { t.Errorf("Server accept: %v", err) return } defer c.Close() if err := serverHandle(c, t); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 28.5K bytes - Viewed (0) -
src/net/http/httputil/persist.go
// should not call Hijack while [ServerConn.Read] or [ServerConn.Write] is in progress. func (sc *ServerConn) Hijack() (net.Conn, *bufio.Reader) { sc.mu.Lock() defer sc.mu.Unlock() c := sc.c r := sc.r sc.c = nil sc.r = nil return c, r } // Close calls [ServerConn.Hijack] and then also closes the underlying connection. func (sc *ServerConn) Close() error { c, _ := sc.Hijack() if c != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
src/log/syslog/syslog_unix.go
package syslog import ( "errors" "net" ) // unixSyslog opens a connection to the syslog daemon running on the // local machine using a Unix domain socket. func unixSyslog() (conn serverConn, err error) { logTypes := []string{"unixgram", "unix"} logPaths := []string{"/dev/log", "/var/run/syslog", "/var/run/log"} for _, network := range logTypes { for _, path := range logPaths {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 758 bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
config.BuildNameToCertificate() clientConn, serverConn := localPipe(b) serverConn = &recordingConn{Conn: serverConn} go func() { config := testConfig.Clone() config.MaxVersion = version config.CurvePreferences = []CurveID{curve} client := Client(clientConn, config) client.Handshake() }() server := Server(serverConn, config) if err := server.Handshake(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0) -
src/crypto/tls/conn_test.go
func runDynamicRecordSizingTest(t *testing.T, config *Config) { clientConn, serverConn := localPipe(t) serverConfig := config.Clone() serverConfig.DynamicRecordSizingDisabled = false tlsConn := Server(serverConn, serverConfig) handshakeDone := make(chan struct{}) recordSizesChan := make(chan []int, 1)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 21:35:01 UTC 2023 - 10.5K bytes - Viewed (0) -
src/log/syslog/syslog.go
) // A Writer is a connection to a syslog server. type Writer struct { priority Priority tag string hostname string network string raddr string mu sync.Mutex // guards conn conn serverConn } // This interface and the separate syslog_unix.go file exist for // Solaris support as implemented by gccgo. On Solaris you cannot // simply open a TCP connection to the syslog daemon. The gccgo
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 23 22:56:07 UTC 2023 - 7.5K bytes - Viewed (0) -
src/crypto/tls/handshake_client_test.go
if i%2 == 1 { if *fast { serverConn.SetWriteDeadline(time.Now().Add(1 * time.Second)) } else { serverConn.SetWriteDeadline(time.Now().Add(1 * time.Minute)) } serverConn.Write(b) continue } bb := make([]byte, len(b)) if *fast { serverConn.SetReadDeadline(time.Now().Add(1 * time.Second)) } else { serverConn.SetReadDeadline(time.Now().Add(1 * time.Minute)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0) -
cmd/sftp-server.go
sshConfig.PasswordCallback = sshPasswordAuth } else { sshConfig.PasswordCallback = nil } sshConfig.AddHostKey(private) handleSFTPSession := func(channel ssh.Channel, sconn *ssh.ServerConn) { server := sftp.NewRequestServer(channel, NewSFTPDriver(sconn.Permissions), sftp.WithRSAllocator()) defer server.Close() server.Serve() } sftpServer, err := xsftp.NewServer(&xsftp.Options{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 16K bytes - Viewed (0)