Commit eab13d28 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 334aaf4d
...@@ -18,7 +18,7 @@ ...@@ -18,7 +18,7 @@
// See https://www.nexedi.com/licensing for rationale and options. // See https://www.nexedi.com/licensing for rationale and options.
// wcfs_watchlink provides WatchLink class that implements message exchange // wcfs_watchlink provides WatchLink class that implements message exchange
// over /head/watch. // over /head/watch on wcfs.
#ifndef _NXD_WCFS_WATCHLINK_H_ #ifndef _NXD_WCFS_WATCHLINK_H_
#define _NXD_WCFS_WATCHLINK_H_ #define _NXD_WCFS_WATCHLINK_H_
...@@ -80,7 +80,7 @@ class _WatchLink : public object { ...@@ -80,7 +80,7 @@ class _WatchLink : public object {
sync::Mutex _rxmu; sync::Mutex _rxmu;
bool _rxdown; bool _rxdown;
dict<StreamID, chan<rxPkt>> dict<StreamID, chan<rxPkt>>
_rxtab; // {} stream -> rxq server replies go via here _rxtab; // {} stream -> rxq server replies go via here
set<StreamID> _accepted; // streams we accepted but did not replied yet set<StreamID> _accepted; // streams we accepted but did not replied yet
StreamID _req_next; // stream ID for next client-originated request XXX -> atomic StreamID _req_next; // stream ID for next client-originated request XXX -> atomic
......
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