- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for read_root (0.18 sec)
-
cni/pkg/nodeagent/ztunnelserver.go
return z.readMessage(readWriteDeadline) } func (z *ZtunnelConnection) readMessage(timeout time.Duration) (*zdsapi.WorkloadResponse, error) { m, _, err := readProto[zdsapi.WorkloadResponse](z.u, timeout, nil) return m, err } func readProto[T any, PT interface { proto.Message *T }](c *net.UnixConn, timeout time.Duration, oob []byte) (PT, int, error) { var buf [1024]byte
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
ztunServer *ztunnelServer }{ztunClient: ztunClient, ztunServer: ztun} } func readRequest(t *testing.T, c *net.UnixConn) (*zdsapi.WorkloadRequest, []int) { var oob [1024]byte m, oobn, err := readProto[zdsapi.WorkloadRequest](c, time.Second, oob[:]) if err != nil { panic(err) } receivedoob := oob[:oobn] msgs, err := unix.ParseSocketControlMessage(receivedoob) if err != nil { panic(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0)