- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 182 for connc (0.1 sec)
-
pkg/kubelet/cm/dra/plugin/client.go
logger := klog.FromContext(ctx) logger.V(4).Info(log("calling NodePrepareResources rpc"), "request", req) conn, err := p.getOrCreateGRPCConn() if err != nil { return nil, err } ctx, cancel := context.WithTimeout(ctx, p.clientTimeout) defer cancel() nodeClient := drapb.NewNodeClient(conn) response, err := nodeClient.NodePrepareResources(ctx, req)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/status/distribution/reporter_test.go
Expect(r.reverseStatus).To(Equal(map[string]sets.String{"a": {"conB~": x}, "c": {"conC~": x}, "d": {"conD~": x, "conA~": x}})) r.RegisterDisconnect("conA", sets.New[xds.EventType](typ)) Expect(r.status).To(Equal(map[string]string{"conB~": "a", "conC~": "c", "conD~": "d"})) Expect(r.reverseStatus).To(Equal(map[string]sets.String{"a": {"conB~": x}, "c": {"conC~": x}, "d": {"conD~": x}})) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 4.4K bytes - Viewed (0) -
internal/http/listener.go
} // Accept - reads from httpListener.acceptCh for one of previously accepted TCP connection and returns the same. func (listener *httpListener) Accept() (conn net.Conn, err error) { select { case result, ok := <-listener.acceptCh: if ok { return result.conn, result.err } case <-listener.ctx.Done(): } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
tools/istio-iptables/pkg/validation/vld_unix.go
func GetOriginalDestination(conn net.Conn) (daddr net.IP, dport uint16, err error) { // obtain os fd from Conn tcp, ok := conn.(*net.TCPConn) if !ok { err = errors.New("socket is not tcp") return } file, err := tcp.File() if err != nil { return } defer file.Close() fd := file.Fd() // Detect underlying ip is v4 or v6 ip := conn.RemoteAddr().(*net.TCPAddr).IP isIpv4 := false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 03:52:24 UTC 2024 - 3K bytes - Viewed (0) -
src/net/smtp/smtp.go
) // A Client represents a client connection to an SMTP server. type Client struct { // Text is the textproto.Conn used by the Client. It is exported to allow for // clients to add extensions. Text *textproto.Conn // keep a reference to the connection so it can be used to create a TLS // connection later conn net.Conn // whether the Client is using TLS tls bool serverName string // map of supported extensions
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/client_test.go
ResourceHandle: "dummy-resource", }, }, } client.NodePrepareResources(context.TODO(), req) client.(*plugin).Lock() conn := client.(*plugin).conn client.(*plugin).Unlock() m.Lock() defer m.Unlock() reusedConns[conn]++ }() } wg.Wait() // We should have only one entry otherwise it means another gRPC connection has been created if len(reusedConns) != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 8.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/net/JarURLConnectionUtil.java
* {@link JarURLConnection#getJarFile()}の例外処理をラップするメソッドです。 * * @param conn * {@link JarURLConnection}。{@literal null}であってはいけません * @return {@link JarFile} */ public static JarFile getJarFile(final JarURLConnection conn) { assertArgumentNotNull("conn", conn); try { return conn.getJarFile(); } catch (final IOException e) {
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 1.5K bytes - Viewed (0) -
pkg/xds/server.go
} func (conn *Connection) ID() string { return conn.conID } func (conn *Connection) Peer() string { return conn.peerAddr } func (conn *Connection) SetID(id string) { conn.conID = id } func (conn *Connection) ConnectedAt() time.Time { return conn.connectedAt } func (conn *Connection) Stop() { close(conn.stop) } func (conn *Connection) MarkInitialized() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
} } func (conn *Connection) Initialize(node *core.Node) error { return conn.s.initConnection(node, conn, conn.ids) } func (conn *Connection) Close() { conn.s.closeConnection(conn) } func (conn *Connection) Watcher() xds.Watcher { return conn.proxy } func (conn *Connection) Process(req *discovery.DiscoveryRequest) error { return conn.s.processRequest(req, conn) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
// The stop function closes all resources, including c1, c2, and the underlying // net.Listener (if there is one), and should not be nil. type MakePipe func() (c1, c2 net.Conn, stop func(), err error) // TestConn tests that a net.Conn implementation properly satisfies the interface. // The tests should not produce any false positives, but may experience // false negatives. Thus, some issues may only be detected when the test is
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0)