benjamyn/any-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add peer addr to cctx

Browse Source
This commit is contained in:
Sergey Cherepanov 2023-06-13 19:06:10 +02:00
parent 69f2cb8b1d
commit 31f0014783
No known key found for this signature in database
GPG Key ID: 87F8EDE8FBDF637C
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
net/transport/yamux/conn.go
View File

@ -3,6 +3,7 @@ package yamux
import ( import (
"context" "context"
"github.com/anyproto/any-sync/net/connutil" "github.com/anyproto/any-sync/net/connutil"
"github.com/anyproto/any-sync/net/peer"
"github.com/anyproto/any-sync/net/transport" "github.com/anyproto/any-sync/net/transport"
"github.com/hashicorp/yamux" "github.com/hashicorp/yamux"
"net" "net"
@ -10,6 +11,7 @@ import (
) )
func NewMultiConn(cctx context.Context, luConn *connutil.LastUsageConn, addr string, sess *yamux.Session) transport.MultiConn { func NewMultiConn(cctx context.Context, luConn *connutil.LastUsageConn, addr string, sess *yamux.Session) transport.MultiConn {
cctx = peer.CtxWithPeerAddr(cctx, sess.RemoteAddr().String())
return &yamuxConn{ return &yamuxConn{
ctx: cctx, ctx: cctx,
luConn: luConn, luConn: luConn,