- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 146 for connc (0.04 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) -
pkg/test/loadbalancersim/loadbalancer/leastrequest.go
edfMutex sync.Mutex } func newWeightedLeastRequest(conn *weightedConnections, activeRequestBias float64) network.Connection { lb := &weightedLeastRequest{ weightedConnections: conn, activeRequestBias: activeRequestBias, edf: NewEDF(), } // Add all endpoints to the EDF scheduler. for _, c := range conn.conns { lb.edf.Add(lb.calcEDFWeight(0, c), c) } return lb }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 3.4K bytes - Viewed (0) -
pilot/pkg/autoregistration/connections.go
m.Lock() defer m.Unlock() var conns []connection for key, connections := range m.byProxy { if key.GroupName == wg.Name && key.Namespace == wg.Namespace { conns = append(conns, maps.Values(connections)...) } } return conns } func (m *adsConnections) Connect(conn connection) { m.Lock() defer m.Unlock() k := makeProxyKey(conn.Proxy()) connections := m.byProxy[k]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/websocket.go
default: _, err = streams[constants.StreamErr].Write([]byte{}) } if err != nil { conn.Close() return nil, fmt.Errorf("write error during websocket server creation: %v", err) } ctx := &conns{ conn: conn, stdinStream: streams[constants.StreamStdIn], stdoutStream: streams[constants.StreamStdOut], stderrStream: streams[constants.StreamStdErr],
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 6.2K 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/cmd/go/internal/vcweb/svn.go
h.s <- &svnState{ listener: l, listenErr: err, conns: map[net.Conn]struct{}{}, done: done, } if err != nil { close(done) return } h.logger.Printf("serving svn on svn://%v", l.Addr()) go func() { for { c, err := l.Accept() s := <-h.s if err != nil { s.listenErr = err if len(s.conns) == 0 { close(s.done) } h.s <- s
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 25 13:44:48 UTC 2022 - 5K bytes - Viewed (0) -
interfaces.go
type Plugin interface { Name() string Initialize(*DB) error } type ParamsFilter interface { ParamsFilter(ctx context.Context, sql string, params ...interface{}) (string, []interface{}) } // ConnPool db conns pool interface type ConnPool interface { PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Sat Aug 19 13:33:31 UTC 2023 - 2.2K bytes - Viewed (0) -
src/net/textproto/textproto.go
func NewConn(conn io.ReadWriteCloser) *Conn { return &Conn{ Reader: Reader{R: bufio.NewReader(conn)}, Writer: Writer{W: bufio.NewWriter(conn)}, conn: conn, } } // Close closes the connection. func (c *Conn) Close() error { return c.conn.Close() } // Dial connects to the given address on the given network using [net.Dial] // and then returns a new [Conn] for the connection.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.7K bytes - Viewed (0) -
pilot/pkg/xds/adstest.go
) func NewAdsTest(t test.Failer, conn *grpc.ClientConn) *AdsTest { return NewXdsTest(t, conn, func(conn *grpc.ClientConn) (DiscoveryClient, error) { xds := discovery.NewAggregatedDiscoveryServiceClient(conn) return xds.StreamAggregatedResources(context.Background()) }) } func NewSdsTest(t test.Failer, conn *grpc.ClientConn) *AdsTest { return NewXdsTest(t, conn, func(conn *grpc.ClientConn) (DiscoveryClient, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6K bytes - Viewed (0)