- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 120 for connc (0.05 sec)
-
src/net/http/transport_internal_test.go
func TestTransportPersistConnReadLoopEOF(t *testing.T) { ln := newLocalListener(t) defer ln.Close() connc := make(chan net.Conn, 1) go func() { defer close(connc) c, err := ln.Accept() if err != nil { t.Error(err) return } connc <- c }() tr := new(Transport) req, _ := NewRequest("GET", "http://"+ln.Addr().String(), nil) req = req.WithT(t)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
src/net/http/transport_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
src/crypto/tls/conn.go
// After a Write has timed out, the TLS state is corrupt and all future writes will return the same error. func (c *Conn) SetDeadline(t time.Time) error { return c.conn.SetDeadline(t) } // SetReadDeadline sets the read deadline on the underlying connection. // A zero value for t means [Conn.Read] will not time out. func (c *Conn) SetReadDeadline(t time.Time) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0) -
internal/kms/conn.go
// MAC generates the checksum of the given req.Message using the key // with the req.Name at the KMS. MAC(context.Context, *MACRequest) ([]byte, error) } var ( // compiler checks _ conn = (*kmsConn)(nil) _ conn = (*kesConn)(nil) _ conn = secretKey{} ) // Supported KMS types const ( MinKMS Type = iota + 1 // MinIO KMS MinKES // MinIO MinKES
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 5K bytes - Viewed (0) -
src/database/sql/sql_test.go
ctx := context.Background() conn0, err := db.conn(ctx, cachedOrNewConn) if err != nil { t.Fatalf("db open conn fail: %v", err) } conn1, err := db.conn(ctx, cachedOrNewConn) if err != nil { t.Fatalf("db open conn fail: %v", err) } conn2, err := db.conn(ctx, cachedOrNewConn) if err != nil { t.Fatalf("db open conn fail: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// nolint: unparam func (z *ztunnelServer) handleConn(ctx context.Context, conn *ZtunnelConnection) error { defer conn.Close() context.AfterFunc(ctx, func() { log.Debug("context cancelled - closing conn") conn.Close() }) // before doing anything, add the connection to the list of active connections z.conns.addConn(conn) defer z.conns.deleteConn(conn) // get hello message from ztunnel
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 12.3K bytes - Viewed (0) -
src/net/http/export_test.go
return len(t.idleConn) } func (t *Transport) IdleConnStrsForTesting() []string { var ret []string t.idleMu.Lock() defer t.idleMu.Unlock() for _, conns := range t.idleConn { for _, pc := range conns { ret = append(ret, pc.conn.LocalAddr().String()+"/"+pc.conn.RemoteAddr().String()) } } slices.Sort(ret) return ret } func (t *Transport) IdleConnStrsForTesting_h2() []string { var ret []string
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 8.7K bytes - Viewed (0) -
src/net/http/httptest/server.go
oldHook := s.Config.ConnState s.Config.ConnState = func(c net.Conn, cs http.ConnState) { s.mu.Lock() defer s.mu.Unlock() switch cs { case http.StateNew: if _, exists := s.conns[c]; exists { panic("invalid state transition") } if s.conns == nil { s.conns = make(map[net.Conn]http.ConnState) } // Add c to the set of tracked conns and increment it to the // waitgroup. s.wg.Add(1)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
src/net/http/serve_test.go
h := HandlerFunc(func(w ResponseWriter, r *Request) { conn, _, err := w.(Hijacker).Hijack() if err != nil { panic(err) } conn.Close() }) conn := &rwTestConn{ Writer: io.Discard, closec: make(chan bool, 1), } ln := &oneConnListener{conn: conn} for i := 0; i < b.N; i++ { conn.Reader = bytes.NewReader(req) ln.conn = conn Serve(ln, h) <-conn.closec } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
return nil } conns := c.adsConnections.ConnectionsForGroup(key) for _, conn := range conns { proxy := conn.Proxy() entryName := autoregisteredWorkloadEntryName(proxy) if entryName == "" { continue } if err := c.registerWorkload(entryName, proxy, conn.ConnectedAt()); err != nil { log.Error(err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0)