Commit 10db70e4 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent b09b8abf
...@@ -478,7 +478,7 @@ tuple</*rxq*/chan<rxPkt>, error> WatchLink::_sendReq(IContext *ctx, const string ...@@ -478,7 +478,7 @@ tuple</*rxq*/chan<rxPkt>, error> WatchLink::_sendReq(IContext *ctx, const string
wlink->_txmu.lock(); // XXX -> atomic (currently uses arbitrary lock) wlink->_txmu.lock(); // XXX -> atomic (currently uses arbitrary lock)
StreamID stream = wlink->_req_next; StreamID stream = wlink->_req_next;
wlink->_req_next = (wlink->_req_next + 2) & ((1ULL<<64)-1); wlink->_req_next = (wlink->_req_next + 2); // wrapped around at uint64 max
wlink->_txmu.unlock(); wlink->_txmu.unlock();
auto rxq = makechan<rxPkt>(1); auto rxq = makechan<rxPkt>(1);
......
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