- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for connc (0.07 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) -
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/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) -
internal/event/target/redis.go
Dial: func() (redis.Conn, error) { conn, err := redis.Dial("tcp", args.Addr.String()) if err != nil { return nil, err } if args.Password != "" { if args.User != "" { if _, err = conn.Do("AUTH", args.User, args.Password); err != nil { conn.Close() return nil, err } } else { if _, err = conn.Do("AUTH", args.Password); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/plugin.go
if ok := conn.WaitForStateChange(ctx, connectivity.Connecting); !ok { return nil, errors.New("timed out waiting for gRPC connection to be ready") } p.conn = conn return p.conn, nil } // RegistrationHandler is the handler which is fed to the pluginwatcher API. type RegistrationHandler struct { controller *nodeResourcesController } // NewPluginHandler returns new registration handler. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 6.2K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
} // WithWriteDeadline sets a new write side net.Conn deadline. func (c *DeadlineConn) WithWriteDeadline(d time.Duration) *DeadlineConn { c.writeDeadline = d return c } // New - creates a new connection object wrapping net.Conn with deadlines. func New(c net.Conn) *DeadlineConn { return &DeadlineConn{ Conn: c, }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/http.go
return func() (http.RoundTripper, func(), error) { conn := newConn() return conn, closeFn(conn), nil }, noCloseFn } // Re-use the same transport for all requests. For HTTP2, this should result // in multiplexing all requests over the same connection. conn := newConn() return func() (http.RoundTripper, func(), error) { return conn, noCloseFn, nil }, closeFn(conn) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 7.9K bytes - Viewed (0) -
security/pkg/nodeagent/caclient/providers/citadel/client.go
} conn, err := c.buildConnection() if err != nil { citadelClientLog.Errorf("Failed to connect to endpoint %s: %v", opts.CAEndpoint, err) return nil, fmt.Errorf("failed to connect to endpoint %s", opts.CAEndpoint) } c.conn = conn c.client = pb.NewIstioCertificateServiceClient(conn) return c, nil } func (c *CitadelClient) Close() { if c.conn != nil { c.conn.Close() } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 4.9K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
rt.t.Helper() <-rt.done if rt.err != nil { rt.t.Fatalf("RoundTrip %v: want success, got err %v", rt.roundTripID, rt.err) } if rt.conn != c { rt.t.Fatalf("RoundTrip %v: want on conn %v, got conn %v", rt.roundTripID, c.connID, rt.conn.connID) } } // finish completes a RoundTrip by sending the request body, consuming the response body, // and closing the response body.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
src/os/writeto_linux_test.go
} if hook.called && hook.srcfd != int(src.Fd()) { t.Fatalf("wrong source file descriptor: got %d, want %d", hook.srcfd, src.Fd()) } sc, ok := dst.(syscall.Conn) if !ok { t.Fatalf("destination is not a syscall.Conn") } rc, err := sc.SyscallConn() if err != nil { t.Fatalf("destination SyscallConn error: %v", err) } if err = rc.Control(func(fd uintptr) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 4K bytes - Viewed (0)