Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SetWriteDeadline (0.17 sec)

  1. cni/pkg/nodeagent/ztunnelserver_test.go

    	if err != nil {
    		panic(err)
    	}
    	err = c.SetWriteDeadline(time.Now().Add(time.Second))
    	if err != nil {
    		panic(err)
    	}
    	c.Write(data)
    }
    
    func sendHello(c *net.UnixConn) {
    	ack := &zdsapi.ZdsHello{
    		Version: zdsapi.Version_V1,
    	}
    	data, err := proto.Marshal(ack)
    	if err != nil {
    		panic(err)
    	}
    	err = c.SetWriteDeadline(time.Now().Add(time.Second))
    	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)
  2. internal/grid/connection.go

    			if err != nil {
    				gridLogIf(ctx, fmt.Errorf("ws writeMessage: %w", err))
    				return
    			}
    			PutByteBuffer(toSend)
    			err = conn.SetWriteDeadline(time.Now().Add(connWriteTimeout))
    			if err != nil {
    				gridLogIf(ctx, fmt.Errorf("conn.SetWriteDeadline: %w", err))
    				return
    			}
    			_, err = buf.WriteTo(conn)
    			if err != nil {
    				gridLogIf(ctx, fmt.Errorf("ws write: %w", err))
    				return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/ztunnelserver.go

    }
    
    func (z *ZtunnelConnection) sendDataAndWaitForAck(data []byte, fd *int) (*zdsapi.WorkloadResponse, error) {
    	var rights []byte
    	if fd != nil {
    		rights = unix.UnixRights(*fd)
    	}
    	err := z.u.SetWriteDeadline(time.Now().Add(readWriteDeadline))
    	if err != nil {
    		return nil, err
    	}
    
    	_, _, err = z.u.WriteMsgUnix(data, rights, nil)
    	if err != nil {
    		return nil, err
    	}
    
    	// wait for ack
    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)
Back to top