Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for SetDeadline (0.37 sec)

  1. api/go1.10.txt

    pkg net, method (*UnixListener) SyscallConn() (syscall.RawConn, error)
    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
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Feb 06 05:00:01 UTC 2018
    - 30.1K bytes
    - Viewed (0)
  2. api/go1.txt

    pkg net, type Conn interface { Close, LocalAddr, Read, RemoteAddr, SetDeadline, SetReadDeadline, SetWriteDeadline, Write }
    pkg net, type Conn interface, Close() error
    pkg net, type Conn interface, LocalAddr() Addr
    pkg net, type Conn interface, Read([]uint8) (int, error)
    pkg net, type Conn interface, RemoteAddr() Addr
    pkg net, type Conn interface, SetDeadline(time.Time) error
    pkg net, type Conn interface, SetReadDeadline(time.Time) error
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  3. internal/grid/grid.go

    			}
    			return b, err
    		}
    		read += int64(n)
    		if want >= 0 && read == want {
    			// No need to read more...
    			return b, nil
    		}
    	}
    }
    
    // getDeadline will truncate the deadline so it is at least 1ms and at most MaxDeadline.
    func getDeadline(d time.Duration) time.Duration {
    	if d < time.Millisecond {
    		return 0
    	}
    	if d > MaxDeadline {
    		return MaxDeadline
    	}
    	return d
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    func (c *Connection) newMuxClient(ctx context.Context) (*muxClient, error) {
    	client := newMuxClient(ctx, atomic.AddUint64(&c.NextID, 1), c)
    	if dl, ok := ctx.Deadline(); ok {
    		client.deadline = getDeadline(time.Until(dl))
    		if client.deadline == 0 {
    			client.cancelFn(context.DeadlineExceeded)
    			return nil, context.DeadlineExceeded
    		}
    	}
    	for {
    		// Handle the extremely unlikely scenario that we wrapped.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top