mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-20 21:33:19 -06:00
Code Issues Packages Projects Releases Wiki Activity

Comments

Browse source
This commit is contained in:
Neil Alexander 2020-06-09 14:32:11 +01:00
parent 566d37ec01
commit 5b0eb9cd4d
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
cmd/dendrite-demo-yggdrasil/yggconn/session.go
View file

@ -12,7 +12,7 @@ import (
func (n *Node) yamuxConfig() *yamux.Config { func (n *Node) yamuxConfig() *yamux.Config {
cfg := yamux.DefaultConfig() cfg := yamux.DefaultConfig()
cfg.EnableKeepAlive = true cfg.EnableKeepAlive = true
cfg.KeepAliveInterval = time.Second cfg.KeepAliveInterval = time.Second * 5
return cfg return cfg
} }
@ -46,22 +46,27 @@ func (n *Node) listenFromYggConn(session *yamux.Session) {
} }
} }
// Implements net.Listener
func (n *Node) Accept() (net.Conn, error) { func (n *Node) Accept() (net.Conn, error) {
return <-n.incoming, nil return <-n.incoming, nil
} }
// Implements net.Listener
func (n *Node) Close() error { func (n *Node) Close() error {
return n.listener.Close() return n.listener.Close()
} }
// Implements net.Listener
func (n *Node) Addr() net.Addr { func (n *Node) Addr() net.Addr {
return n.listener.Addr() return n.listener.Addr()
} }
// Implements http.Transport.Dial
func (n *Node) Dial(network, address string) (net.Conn, error) { func (n *Node) Dial(network, address string) (net.Conn, error) {
return n.DialContext(context.TODO(), network, address) return n.DialContext(context.TODO(), network, address)
} }
// Implements http.Transport.DialContext
func (n *Node) DialContext(ctx context.Context, network, address string) (net.Conn, error) { func (n *Node) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
s, ok1 := n.sessions.Load(address) s, ok1 := n.sessions.Load(address)
session, ok2 := s.(*yamux.Session) session, ok2 := s.(*yamux.Session)