Commit 5bb2accb authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 323ba50c
...@@ -148,16 +148,12 @@ error _WatchLink::_serveRX(context::Context ctx) { ...@@ -148,16 +148,12 @@ error _WatchLink::_serveRX(context::Context ctx) {
err = nil; err = nil;
return E(err); return E(err);
} }
printf("C: watch : rx: \"%s\"", v(l)); //trace("C: watch : rx: \"%s\"", v(l));
err = pkt.from_string(l); err = pkt.from_string(l);
//printf("line -> pkt: err='%s'\n", v(err));
if (err != nil) if (err != nil)
return E(err); return E(err);
//printf("pkt.stream: %lu\n", pkt.stream);
//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
log::Errorf("C: watch : rx fatal: %s\n", v(l)); log::Errorf("C: watch : rx fatal: %s\n", v(l));
wlink.fatalv.push_back(pkt.to_string()); wlink.fatalv.push_back(pkt.to_string());
...@@ -239,7 +235,6 @@ error _WatchLink::replyReq(context::Context ctx, const PinReq *req, const string ...@@ -239,7 +235,6 @@ error _WatchLink::replyReq(context::Context ctx, const PinReq *req, const string
_WatchLink& wlink = *this; _WatchLink& wlink = *this;
xerr::Contextf E("%s: replyReq .%d", v(wlink), req->stream); xerr::Contextf E("%s: replyReq .%d", v(wlink), req->stream);
//print('C: reply %s <- %r ...' % (req, answer))
wlink._rxmu.lock(); wlink._rxmu.lock();
bool ok = wlink._accepted.has(req->stream); bool ok = wlink._accepted.has(req->stream);
wlink._rxmu.unlock(); wlink._rxmu.unlock();
...@@ -293,7 +288,7 @@ error _WatchLink::_write(const string &pkt) { ...@@ -293,7 +288,7 @@ error _WatchLink::_write(const string &pkt) {
wlink._txmu.unlock(); wlink._txmu.unlock();
}); });
//trace('C: watch : tx: %r' % pkt) //trace('C: watch : tx: \"%s\"', v(pkt));
int n; int n;
error err; error err;
tie(n, err) = wlink._f->write(pkt.c_str(), pkt.size()); tie(n, err) = wlink._f->write(pkt.c_str(), pkt.size());
......
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