diff --git a/gold/link/me.go b/gold/link/me.go index 62c4922..754f95f 100644 --- a/gold/link/me.go +++ b/gold/link/me.go @@ -92,7 +92,10 @@ func NewMe(cfg *MyConfig) (m Me) { m.srcport = cfg.SrcPort m.dstport = cfg.DstPort m.mtu = cfg.MTU & 0xfff8 - m.initrecvpool() + if m.writer == nil { + m.writer = helper.SelectWriter() + } + m.recving = ttl.NewCache[[32]byte, *head.Packet](time.Second * 128) return } diff --git a/gold/link/recv.go b/gold/link/recv.go index 1bd009b..cf5337c 100644 --- a/gold/link/recv.go +++ b/gold/link/recv.go @@ -3,13 +3,10 @@ package link import ( "encoding/binary" "encoding/hex" - "time" "unsafe" "github.com/fumiama/WireGold/gold/head" - "github.com/fumiama/WireGold/helper" "github.com/sirupsen/logrus" - "github.com/wdvxdr1123/ZeroBot/extension/ttl" ) // Read 从 peer 收包 @@ -17,13 +14,6 @@ func (l *Link) Read() *head.Packet { return <-l.pipe } -func (m *Me) initrecvpool() { - if m.writer == nil { - m.writer = helper.SelectWriter() - } - m.recving = ttl.NewCache[[32]byte, *head.Packet](time.Second * 128) -} - func (m *Me) wait(data []byte) *head.Packet { flags := binary.LittleEndian.Uint16(data[10:12]) logrus.Debugln("[recv]", len(data), "bytes data with flag", hex.EncodeToString(data[10:12]))