Commit 3db68ece authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent f7d0d2da
...@@ -152,8 +152,8 @@ typedef uint64_t StreamID; ...@@ -152,8 +152,8 @@ typedef uint64_t StreamID;
// It is safe to use WatchLink from multiple threads simultaneously. // It is safe to use WatchLink from multiple threads simultaneously.
class WatchLink { class WatchLink {
WCFS *_wc; WCFS *_wc;
os::File _f; // head/watch file handle os::File _f; // head/watch file handle
chan<structZ> _rxeof; // becomes ready when wcfs closes its tx side chan<structZ> _rx_eof; // becomes ready when wcfs closes its tx side
// inv.protocol message IO // inv.protocol message IO
chan<(StreamID,msg)> _acceptq; // server originated messages go here chan<(StreamID,msg)> _acceptq; // server originated messages go here
...@@ -171,6 +171,7 @@ class WatchLink { ...@@ -171,6 +171,7 @@ class WatchLink {
#endif #endif
public: public:
friend tuple<WatchLink*, error> WCFS::_openwatch();
SrvReq *recvReq(IContext *ctx); SrvReq *recvReq(IContext *ctx);
}; };
......
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