- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 366 for connc (0.04 sec)
-
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) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go
// frames to the server. Use this to keep idle connections through certain load // balancers alive longer. func NewClientConnectionWithPings(conn net.Conn, pingPeriod time.Duration) (httpstream.Connection, error) { spdyConn, err := spdystream.NewConnection(conn, false) if err != nil { defer conn.Close() return nil, err } return newConnection(spdyConn, httpstream.NoOpNewStreamHandler, pingPeriod, spdyConn.Ping), nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 15:04:07 UTC 2021 - 6.7K bytes - Viewed (0) -
pkg/hbone/dialer.go
go func() { defer conn.Close() defer resp.Body.Close() wg := sync.WaitGroup{} wg.Add(1) go func() { // handle upstream (hbone server) --> downstream (app) copyBuffered(conn, resp.Body, log.WithLabels("name", "body to conn")) wg.Done() }() // Copy from conn into the pipe, which will then be sent as part of the request
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/websocket.go
if err := conn.SetWriteDeadline(deadline); err != nil { return outBuffer.String(), err } if err := conn.SetReadDeadline(deadline); err != nil { return outBuffer.String(), err } start := time.Now() err = conn.WriteMessage(websocket.TextMessage, []byte(req.Message)) if err != nil { return outBuffer.String(), err } _, resp, err := conn.ReadMessage() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 11 16:27:16 UTC 2022 - 3.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/tcp.go
fwLog.Infof("TCP forwarder using PROXY protocol version %d", cfg.proxyProtocolVersion) header := proxyproto.HeaderProxyFromAddrs(byte(cfg.proxyProtocolVersion), conn.LocalAddr(), conn.RemoteAddr()) // After the connection is created, write the proxy headers first if _, err := header.WriteTo(conn); err != nil { fwLog.Warnf("TCP Proxy protocol header write failed: %v", err) return msgBuilder.String(), err } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 4.9K 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) -
tests/connpool_test.go
}, } defer func() { if !reflect.DeepEqual(conn.got, conn.expect) { t.Errorf("expect %#v but got %#v", conn.expect, conn.got) } }() db, err := gorm.Open(mysql.New(mysql.Config{Conn: conn, DisableWithReturning: true})) if err != nil { t.Fatalf("Should open db success, but got %v", err) } tx := db.Begin()
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Feb 06 02:54:40 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/tls.go
defer cancel() // Apply the deadline to the connection. deadline, _ := ctx.Deadline() if err := conn.SetWriteDeadline(deadline); err != nil { return msgBuilder.String(), err } if err := conn.SetReadDeadline(deadline); err != nil { return msgBuilder.String(), err } if err := conn.HandshakeContext(ctx); err != nil { return "", err } // Make sure the client writes something to the buffer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 11 16:27:16 UTC 2022 - 3.4K 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) -
pkg/test/echo/server/forwarder/grpc.go
getConn = func() (*grpc.ClientConn, func(), error) { conn, err := newGRPCConnection(cfg) if err != nil { return nil, nil, err } return conn, func() { _ = conn.Close() }, nil } } else { // Reuse the connection across all requests. conn, err := newGRPCConnection(cfg) if err != nil { return nil, err } defer func() { _ = conn.Close() }() getConn = func() (*grpc.ClientConn, func(), error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 14 19:45:43 UTC 2023 - 4.5K bytes - Viewed (0)