Commit 60b90468 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 2461344f
...@@ -87,12 +87,10 @@ error _WatchLink::close() { ...@@ -87,12 +87,10 @@ error _WatchLink::close() {
error err = wlink.closeWrite(); error err = wlink.closeWrite();
wlink._serveCancel(); wlink._serveCancel();
// XXX we can get stuck here if wcfs does not behave as we want. // NOTE we can get stuck here if wcfs does not behave correctly by closing
// XXX in particular if there is a silly - e.g. syntax or type error in // its side in reply to our "bye" message.
// test code - we currently get stuck here.
// //
// XXX -> better pthread_kill(SIGINT) instead of relying on wcfs proper behaviour? // TODO -> better pthread_kill(SIGINT) instead of relying on wcfs proper behaviour?
// XXX -> we now have `kill -QUIT` to wcfs.go on test timeout - remove ^^^ comments?
error err2 = wlink._serveWG->wait(); error err2 = wlink._serveWG->wait();
// canceled is expected and ok // canceled is expected and ok
if (errors::Is(err2, context::canceled)) if (errors::Is(err2, context::canceled))
...@@ -108,7 +106,7 @@ error _WatchLink::close() { ...@@ -108,7 +106,7 @@ error _WatchLink::close() {
} }
// _serveRX receives messages from ._f and dispatches them according to streamID. // _serveRX receives messages from ._f and dispatches them according to streamID.
error _WatchLink::_serveRX(context::Context ctx) { // XXX error -> where ? error _WatchLink::_serveRX(context::Context ctx) {
_WatchLink& wlink = *this; _WatchLink& wlink = *this;
xerr::Contextf E("%s: serve rx", v(wlink)); xerr::Contextf E("%s: serve rx", v(wlink));
......
...@@ -92,7 +92,7 @@ class _WatchLink : public object { ...@@ -92,7 +92,7 @@ class _WatchLink : public object {
// XXX for tests // XXX for tests
public: public:
vector<string> fatalv; // ad-hoc, racy. TODO rework to send messeges to control channel vector<string> fatalv; // ad-hoc, racy. TODO rework to send messages to control channel
chan<structZ> rx_eof; // becomes ready when wcfs closes its tx side chan<structZ> rx_eof; // becomes ready when wcfs closes its tx side
// don't new - create only via WCFS._openwatch() // don't new - create only via WCFS._openwatch()
......
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