diff --git a/go/neo/connection.go b/go/neo/connection.go index eca0baadd577c54913b6d894a10031df0722850d..1d9b59f222e783b7f67f48ac8ba1ddecf2a39523 100644 --- a/go/neo/connection.go +++ b/go/neo/connection.go @@ -112,7 +112,6 @@ type Conn struct { // XXX ^^^ split to different cache lines? rxerrOnce sync.Once // rx error is reported only once - then it is link down or closed XXX !light? -// errMsg *Error // error message for peer if rx is down XXX try to do without it // there are two modes a Conn could be used: // - full mode - where full Conn functionality is working, and @@ -202,7 +201,7 @@ func newNodeLink(conn net.Conn, role LinkRole) *NodeLink { peerLink: conn, connTab: map[uint32]*Conn{}, nextConnId: nextConnId, - acceptq: make(chan *Conn), // XXX +buf + acceptq: make(chan *Conn), // XXX +buf ? txq: make(chan txReq), rxghandoff: make(chan struct{}), // axdown: make(chan struct{}), @@ -220,7 +219,7 @@ func newNodeLink(conn net.Conn, role LinkRole) *NodeLink { // XXX make it per-link? var connPool = sync.Pool{New: func() interface{} { 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 txdown: make(chan struct{}), // rxdown: make(chan struct{}), @@ -1690,7 +1689,7 @@ func (link *NodeLink) Send1(msg Msg) error { return err } - conn.downRX(errConnClosed) // XXX just new conn this way + conn.downRX(errConnClosed) // XXX just initially create conn this way err = conn.sendMsgDirect(msg) conn.lightClose() diff --git a/go/neo/t/neotest b/go/neo/t/neotest index 07732dc4de843ab0c59a352cb085a26afa4dcc9b..9e108a0315d3680b545baa9e44b1f787f8652384 100755 --- a/go/neo/t/neotest +++ b/go/neo/t/neotest @@ -966,6 +966,7 @@ esac # neo/py, wendelin.core, ... - must be pip install'ed - `neotest deploy` cares about that go install -v lab.nexedi.com/kirr/neo/go/... go build -o zhash_go zhash.go +#go build -race -o zhash_go zhash.go go build -o tsha1_go tsha1.go # setup network & fs environment