Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 189 for Vidler (0.42 sec)

  1. transport/internet/dialer.go

    		}
    
    		protocol := streamSettings.ProtocolName
    		dialer := transportDialerCache[protocol]
    		if dialer == nil {
    			return nil, newError(protocol, " dialer not registered").AtError()
    		}
    		return dialer(ctx, dest, streamSettings)
    	}
    
    	if dest.Network == net.Network_UDP {
    		udpDialer := transportDialerCache["udp"]
    		if udpDialer == nil {
    			return nil, newError("UDP dialer not registered").AtError()
    		}
    Go
    - Registered: 2021-06-09 06:07
    - Last Modified: 2018-11-21 13:54
    - 2.2K bytes
    - Viewed (0)
  2. fs/fshttp/dialer.go

    }
    
    // Dialer structure contains default dialer and timeout, tclass support
    type Dialer struct {
    	net.Dialer
    	timeout time.Duration
    	tclass  int
    }
    
    // NewDialer creates a Dialer structure with Timeout, Keepalive,
    // LocalAddr and DSCP set from rclone flags.
    func NewDialer(ctx context.Context) *Dialer {
    	ci := fs.GetConfig(ctx)
    	dialer := &Dialer{
    		Dialer: net.Dialer{
    			Timeout:   ci.ConnectTimeout,
    Go
    - Registered: 2021-05-31 07:43
    - Last Modified: 2021-05-28 12:43
    - 3.5K bytes
    - Viewed (0)
  3. transport/internet/udp/dialer.go

    			if streamSettings != nil {
    				sockopt = streamSettings.SocketSettings
    			}
    			conn, err := internet.DialSystem(ctx, dest, sockopt)
    			if err != nil {
    				return nil, err
    			}
    			// TODO: handle dialer options
    			return internet.Connection(conn), nil
    		}))
    Go
    - Registered: 2021-06-09 06:07
    - Last Modified: 2018-11-21 13:54
    - 628 bytes
    - Viewed (0)
  4. transport/internet/system_dialer.go

    // Caller must ensure there is no race condition.
    //
    // v2ray:api:stable
    func UseAlternativeSystemDialer(dialer SystemDialer) {
    	if dialer == nil {
    		effectiveSystemDialer = &DefaultSystemDialer{}
    	}
    	effectiveSystemDialer = dialer
    }
    
    // RegisterDialerController adds a controller to the effective system dialer.
    Go
    - Registered: 2021-06-09 06:07
    - Last Modified: 2019-01-12 08:44
    - 4.7K bytes
    - Viewed (0)
  5. pkg/transport/timeout_dialer.go

    package transport
    
    import (
    	"net"
    	"time"
    )
    
    type rwTimeoutDialer struct {
    	wtimeoutd  time.Duration
    	rdtimeoutd time.Duration
    	net.Dialer
    }
    
    func (d *rwTimeoutDialer) Dial(network, address string) (net.Conn, error) {
    	conn, err := d.Dialer.Dial(network, address)
    	tconn := &timeoutConn{
    		readTimeout:  d.rdtimeoutd,
    		writeTimeout: d.wtimeoutd,
    		Conn:         conn,
    	}
    	return tconn, err
    Go
    - Registered: 2021-03-25 01:10
    - Last Modified: 2021-03-08 16:27
    - 988 bytes
    - Viewed (0)
  6. client/pkg/transport/timeout_dialer.go

    package transport
    
    import (
    	"net"
    	"time"
    )
    
    type rwTimeoutDialer struct {
    	wtimeoutd  time.Duration
    	rdtimeoutd time.Duration
    	net.Dialer
    }
    
    func (d *rwTimeoutDialer) Dial(network, address string) (net.Conn, error) {
    	conn, err := d.Dialer.Dial(network, address)
    	tconn := &timeoutConn{
    		readTimeout:  d.rdtimeoutd,
    		writeTimeout: d.wtimeoutd,
    		Conn:         conn,
    	}
    	return tconn, err
    Go
    - Registered: 2021-06-10 01:10
    - Last Modified: 2021-04-05 21:47
    - 988 bytes
    - Viewed (0)
  7. transport/internet/websocket/dialer.go

    }
    
    func dialWebsocket(ctx context.Context, dest net.Destination, streamSettings *internet.MemoryStreamConfig) (net.Conn, error) {
    	wsSettings := streamSettings.ProtocolSettings.(*Config)
    
    	dialer := &websocket.Dialer{
    		NetDial: func(network, addr string) (net.Conn, error) {
    			return internet.DialSystem(ctx, dest, streamSettings.SocketSettings)
    		},
    		ReadBufferSize:   4 * 1024,
    		WriteBufferSize:  4 * 1024,
    Go
    - Registered: 2021-06-09 06:07
    - Last Modified: 2020-06-18 03:32
    - 1.9K bytes
    - Viewed (0)
  8. transport/internet/tcp/dialer.go

    RPRX <******@****.***> 1600700203 +0000
    Go
    - Registered: 2021-06-09 06:07
    - Last Modified: 2020-09-21 14:56
    - 1.7K bytes
    - Viewed (0)
  9. transport/internet/quic/dialer.go

    Kslr <******@****.***> 1602209075 +0800
    Go
    - Registered: 2021-06-09 06:07
    - Last Modified: 2020-10-09 02:04
    - 4.5K bytes
    - Viewed (0)
  10. transport/internet/kcp/dialer.go

    RPRX <******@****.***> 1602001502 +0000
    Go
    - Registered: 2021-06-09 06:07
    - Last Modified: 2020-10-06 16:25
    - 2.5K bytes
    - Viewed (0)
Back to top