Skip to content

Commit

Permalink
Expose DialFirst
Browse files Browse the repository at this point in the history
  • Loading branch information
anacrolix committed Jun 21, 2021
1 parent 9f5ce7e commit 765edfa
Show file tree
Hide file tree
Showing 3 changed files with 33 additions and 35 deletions.
53 changes: 23 additions & 30 deletions client.go
Original file line number Diff line number Diff line change
Expand Up @@ -553,9 +553,9 @@ func (cl *Client) torrent(ih metainfo.Hash) *Torrent {
return cl.torrents[ih]
}

type dialResult struct {
Conn net.Conn
Network string
type DialResult struct {
Conn net.Conn
Dialer Dialer
}

func countDialResult(err error) {
Expand All @@ -581,39 +581,37 @@ func (cl *Client) dopplegangerAddr(addr string) bool {
}

// Returns a connection over UTP or TCP, whichever is first to connect.
func (cl *Client) dialFirst(ctx context.Context, addr string) (res dialResult) {
func (cl *Client) dialFirst(ctx context.Context, addr string) (res DialResult) {
return DialFirst(ctx, addr, cl.dialers)
}

// Returns a connection over UTP or TCP, whichever is first to connect.
func DialFirst(ctx context.Context, addr string, dialers []Dialer) (res DialResult) {
{
t := perf.NewTimer(perf.CallerName(0))
defer func() {
if res.Conn == nil {
t.Mark(fmt.Sprintf("returned no conn (context: %v)", ctx.Err()))
} else {
t.Mark("returned conn over " + res.Network)
t.Mark("returned conn over " + res.Dialer.DialerNetwork())
}
}()
}
ctx, cancel := context.WithCancel(ctx)
// As soon as we return one connection, cancel the others.
defer cancel()
left := 0
resCh := make(chan dialResult, left)
func() {
cl.lock()
defer cl.unlock()
cl.eachDialer(func(s Dialer) bool {
func() {
left++
//cl.logger.Printf("dialing %s on %s/%s", addr, s.Addr().Network(), s.Addr())
go func() {
resCh <- dialResult{
cl.dialFromSocket(ctx, s, addr),
s.LocalAddr().Network(),
}
}()
}()
return true
})
}()
resCh := make(chan DialResult, left)
for _, _s := range dialers {
left++
s := _s
go func() {
resCh <- DialResult{
dialFromSocket(ctx, s, addr),
s,
}
}()
}
// Wait for a successful connection.
func() {
defer perf.ScopeTimer()()
Expand All @@ -633,15 +631,10 @@ func (cl *Client) dialFirst(ctx context.Context, addr string) (res dialResult) {
if res.Conn != nil {
go torrent.Add(fmt.Sprintf("network dialed first: %s", res.Conn.RemoteAddr().Network()), 1)
}
//if res.Conn != nil {
// cl.logger.Printf("first connection for %s from %s/%s", addr, res.Conn.LocalAddr().Network(), res.Conn.LocalAddr().String())
//} else {
// cl.logger.Printf("failed to dial %s", addr)
//}
return res
}

func (cl *Client) dialFromSocket(ctx context.Context, s Dialer, addr string) net.Conn {
func dialFromSocket(ctx context.Context, s Dialer, addr string) net.Conn {
c, err := s.Dial(ctx, addr)
// This is a bit optimistic, but it looks non-trivial to thread this through the proxy code. Set
// it now in case we close the connection forthwith.
Expand Down Expand Up @@ -711,7 +704,7 @@ func (cl *Client) establishOutgoingConnEx(t *Torrent, addr PeerRemoteAddr, obfus
}
return nil, errors.New("dial failed")
}
c, err := cl.initiateProtocolHandshakes(context.Background(), nc, t, true, obfuscatedHeader, addr, dr.Network, regularNetConnPeerConnConnString(nc))
c, err := cl.initiateProtocolHandshakes(context.Background(), nc, t, true, obfuscatedHeader, addr, dr.Dialer.DialerNetwork(), regularNetConnPeerConnConnString(nc))
if err != nil {
nc.Close()
}
Expand Down
10 changes: 5 additions & 5 deletions dialer.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,19 +8,19 @@ import (
)

type Dialer interface {
// The network is implied by the instance.
Dial(_ context.Context, addr string) (net.Conn, error)
// This is required for registering with the connection tracker (router connection table
// emulating rate-limiter) before dialing. TODO: What about connections that wouldn't infringe
// on routers, like localhost or unix sockets.
LocalAddr() net.Addr
DialerNetwork() string
}

type NetDialer struct {
Network string
Dialer net.Dialer
}

func (me NetDialer) DialerNetwork() string {
return me.Network
}

func (me NetDialer) Dial(ctx context.Context, addr string) (_ net.Conn, err error) {
defer perf.ScopeTimerErr(&err)()
return me.Dialer.DialContext(ctx, me.Network, addr)
Expand Down
5 changes: 5 additions & 0 deletions socket.go
Original file line number Diff line number Diff line change
Expand Up @@ -106,11 +106,16 @@ func listenUtp(network, addr string, fc firewallCallback) (socket, error) {
return utpSocketSocket{us, network}, err
}

// utpSocket wrapper, additionally wrapped for the torrent package's socket interface.
type utpSocketSocket struct {
utpSocket
network string
}

func (me utpSocketSocket) DialerNetwork() string {
return me.network
}

func (me utpSocketSocket) Dial(ctx context.Context, addr string) (conn net.Conn, err error) {
defer perf.ScopeTimerErr(&err)()
return me.utpSocket.DialContext(ctx, me.network, addr)
Expand Down

0 comments on commit 765edfa

Please sign in to comment.