Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for setWriteDeadline (0.1 sec)

  1. internal/deadlineconn/deadlineconn.go

    			c.Conn.SetReadDeadline(now.Add(c.readDeadline + updateInterval))
    			c.readSetAt = now
    		}
    	}
    }
    
    func (c *DeadlineConn) setWriteDeadline() {
    	if c.writeDeadline > 0 {
    		now := time.Now()
    		if now.Sub(c.writeSetAt) > updateInterval {
    			c.Conn.SetWriteDeadline(now.Add(c.writeDeadline + updateInterval))
    			c.writeSetAt = now
    		}
    	}
    }
    
    // Read - reads data from the connection using wrapped buffered reader.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. 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)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    		now := time.Now()
    		// Only set write deadline once every second
    		if now.Sub(lastSetDeadline) > time.Second {
    			err := conn.SetWriteDeadline(now.Add(connWriteTimeout + time.Second))
    			if err != nil {
    				gridLogIf(ctx, fmt.Errorf("conn.SetWriteDeadline: %w", err))
    				return false
    			}
    			lastSetDeadline = now
    		}
    
    		_, err := buf.WriteTo(conn)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. 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
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  5. api/go1.10.txt

    pkg net/smtp, method (*Client) Noop() error
    pkg os, func IsTimeout(error) bool
    pkg os, method (*File) SetDeadline(time.Time) error
    pkg os, method (*File) SetReadDeadline(time.Time) error
    pkg os, method (*File) SetWriteDeadline(time.Time) error
    pkg os, method (*PathError) Timeout() bool
    pkg os, method (*SyscallError) Timeout() bool
    pkg os, var ErrNoDeadline error
    pkg strings, method (*Builder) Grow(int)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Feb 06 05:00:01 UTC 2018
    - 30.1K bytes
    - Viewed (0)
  6. api/go1.txt

    pkg crypto/tls, method (*Conn) RemoteAddr() net.Addr
    pkg crypto/tls, method (*Conn) SetDeadline(time.Time) error
    pkg crypto/tls, method (*Conn) SetReadDeadline(time.Time) error
    pkg crypto/tls, method (*Conn) SetWriteDeadline(time.Time) error
    pkg crypto/tls, method (*Conn) VerifyHostname(string) error
    pkg crypto/tls, method (*Conn) Write([]uint8) (int, error)
    pkg crypto/tls, type Certificate struct
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  7. api/go1.20.txt

    pkg net/http, method (*ResponseController) Hijack() (net.Conn, *bufio.ReadWriter, error) #54136
    pkg net/http, method (*ResponseController) SetReadDeadline(time.Time) error #54136
    pkg net/http, method (*ResponseController) SetWriteDeadline(time.Time) error #54136
    pkg net/http, type ResponseController struct #54136
    pkg net/http, type Server struct, DisableGeneralOptionsHandler bool #41773
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Feb 17 21:23:32 UTC 2023
    - 602.6K bytes
    - Viewed (0)
Back to top