From 09348110eb5d2b8e631f9b5b09be9f18bfa92017 Mon Sep 17 00:00:00 2001 From: xtaci Date: Tue, 4 Jun 2019 09:29:07 +0800 Subject: [PATCH] add NewConn3 --- sess.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/sess.go b/sess.go index 589d5cd..ba049b1 100644 --- a/sess.go +++ b/sess.go @@ -969,11 +969,16 @@ func DialWithOptions(raddr string, block BlockCrypt, dataShards, parityShards in return NewConn(raddr, block, dataShards, parityShards, conn) } -// NewConn establishes a session and talks KCP protocol over a packet connection. +// NewConn3 establishes a session and talks KCP protocol over a packet connection. +func NewConn3(convid uint32, raddr net.Addr, block BlockCrypt, dataShards, parityShards int, conn net.PacketConn) (*UDPSession, error) { + return newUDPSession(convid, dataShards, parityShards, nil, conn, raddr, block), nil +} + +// NewConn2 establishes a session and talks KCP protocol over a packet connection. func NewConn2(raddr net.Addr, block BlockCrypt, dataShards, parityShards int, conn net.PacketConn) (*UDPSession, error) { var convid uint32 binary.Read(rand.Reader, binary.LittleEndian, &convid) - return newUDPSession(convid, dataShards, parityShards, nil, conn, raddr, block), nil + return NewConn3(convid, raddr, block, dataShards, parityShards, conn) } // NewConn establishes a session and talks KCP protocol over a packet connection.