- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 120 for connc (0.06 sec)
-
src/net/http/transport.go
f(w) } } func (t *Transport) customDialTLS(ctx context.Context, network, addr string) (conn net.Conn, err error) { if t.DialTLSContext != nil { conn, err = t.DialTLSContext(ctx, network, addr) } else { conn, err = t.DialTLS(network, addr) } if conn == nil && err == nil { err = errors.New("net/http: Transport.DialTLS or DialTLSContext returned (nil, nil)") } return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/net/net.go
// A zero value for t means Write will not time out. SetWriteDeadline(t time.Time) error } type conn struct { fd *netFD } func (c *conn) ok() bool { return c != nil && c.fd != nil } // Implementation of the Conn interface. // Read implements the Conn Read method. func (c *conn) Read(b []byte) (int, error) { if !c.ok() { return 0, syscall.EINVAL } n, err := c.fd.Read(b)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
src/net/http/server.go
return len(p), nil } if cw.chunking { _, err = fmt.Fprintf(cw.res.conn.bufw, "%x\r\n", len(p)) if err != nil { cw.res.conn.rwc.Close() return } } n, err = cw.res.conn.bufw.Write(p) if cw.chunking && err == nil { _, err = cw.res.conn.bufw.Write(crlf) } if err != nil { cw.res.conn.rwc.Close() } return } func (cw *chunkWriter) flush() error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/net/http/h2_bundle.go
// An outflow is kept both on a conn and a per-stream. n int32 // conn points to the shared connection-level outflow that is // shared by all streams on that conn. It is nil for the outflow // that's on the conn directly. conn *http2outflow } func (f *http2outflow) setConnFlow(cf *http2outflow) { f.conn = cf } func (f *http2outflow) available() int32 { n := f.n
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/crypto/tls/tls.go
"net" "os" "strings" ) // Server returns a new TLS server side connection // using conn as the underlying transport. // The configuration config must be non-nil and must include // at least one certificate or else set GetCertificate. func Server(conn net.Conn, config *Config) *Conn { c := &Conn{ conn: conn, config: config, } c.handshakeFn = c.serverHandshake return c }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 12.2K bytes - Viewed (0) -
src/crypto/tls/quic.go
} func newQUICConn(conn *Conn, config *QUICConfig) *QUICConn { conn.quic = &quicState{ signalc: make(chan struct{}), blockedc: make(chan struct{}), enableStoreSessionEvent: config.EnableStoreSessionEvent, } conn.quic.events = conn.quic.eventArr[:0] return &QUICConn{ conn: conn, } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
src/net/sendfile_test.go
if ctx.Err() != nil { return } if _, err := io.Copy(conn, f); err != nil { b.Errorf("failed to copy: %v", err) return } } }(ln, fileName) conn, err := Dial("tcp", ln.Addr().String()) if err != nil { b.Fatalf("failed to dial: %v", err) } defer conn.Close() n, err := io.CopyN(io.Discard, conn, int64(dataSize)) if err != nil { b.Fatalf("failed to copy: %v", err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0) -
src/crypto/tls/quic_test.go
config := testConfig.Clone() config.MinVersion = VersionTLS13 cli := newTestQUICClient(t, config) cli.conn.SetTransportParameters(nil) cli.conn.Start(context.Background()) for cli.conn.NextEvent().Kind != QUICNoEvent { } err := cli.conn.Close() if !errors.Is(err, alertCloseNotify) { t.Errorf("conn.Close() = %v, want alertCloseNotify", err) } } func TestQUICCanceledWaitingForTransportParams(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 19.3K bytes - Viewed (0) -
internal/config/identity/ldap/ldap.go
l.LDAP.GetUserDNSearchBaseDistNames(), l.LDAP.GetUserDNAttributesList()) } // GetValidatedGroupDN validates the given group DN. If conn is nil, creates a // connection. The returned boolean is true iff the group DN is found under one // of the configured LDAP base DNs. func (l *Config) GetValidatedGroupDN(conn *ldap.Conn, groupDN string) (*xldap.DNSearchResult, bool, error) { if conn == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 25 13:43:06 UTC 2024 - 10.3K bytes - Viewed (1) -
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)