Commit e042b296 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 0900035c
...@@ -286,8 +286,8 @@ func newNodeLink(conn net.Conn, role _LinkRole) *NodeLink { ...@@ -286,8 +286,8 @@ func newNodeLink(conn net.Conn, role _LinkRole) *NodeLink {
// XXX make it per-link? // XXX make it per-link?
var connPool = sync.Pool{New: func() interface{} { var connPool = sync.Pool{New: func() interface{} {
return &Conn{ return &Conn{
rxq: make(chan *pktBuf, 1), // NOTE non-blocking - see serveRecv XXX +buf ? rxq: make(chan *pktBuf, 1), // NOTE non-blocking - see serveRecv XXX +buf ?
txerr: make(chan error, 1), // NOTE non-blocking - see Conn.Send txerr: make(chan error, 1), // NOTE non-blocking - see Conn.Send
txdown: make(chan struct{}), txdown: make(chan struct{}),
// rxdown: make(chan struct{}), // rxdown: make(chan struct{}),
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment