Commit e0f03507 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 60b90468
...@@ -112,7 +112,7 @@ error _WatchLink::_serveRX(context::Context ctx) { ...@@ -112,7 +112,7 @@ error _WatchLink::_serveRX(context::Context ctx) {
// when finishing - wakeup everyone waiting for rx // when finishing - wakeup everyone waiting for rx
defer([&]() { defer([&]() {
//printf("serveRX: close all chans\n"); //trace("serveRX: close all chans\n");
wlink._acceptq.close(); wlink._acceptq.close();
wlink._rxmu.lock(); wlink._rxmu.lock();
wlink._rxdown = true; // don't allow new rxtab registers wlink._rxdown = true; // don't allow new rxtab registers
...@@ -153,8 +153,7 @@ error _WatchLink::_serveRX(context::Context ctx) { ...@@ -153,8 +153,7 @@ error _WatchLink::_serveRX(context::Context ctx) {
//printf("pkt.datalen: %u\n", pkt.datalen); //printf("pkt.datalen: %u\n", pkt.datalen);
if (pkt.stream == 0) { // control/fatal message from wcfs if (pkt.stream == 0) { // control/fatal message from wcfs
// XXX print -> receive somewhere? XXX -> recvCtl ? log::Warnf("C: watch : rx fatal: %s\n", v(l));
printf("C: watch : rx fatal: %s\n", v(l));
wlink.fatalv.push_back(pkt.to_string()); wlink.fatalv.push_back(pkt.to_string());
continue; continue;
} }
......
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