Commit 011766ea authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 987fdf4b
......@@ -411,11 +411,14 @@ error Conn::resync(Tid at) {
f.headfsize = headfsize;
_ = wconn._wlink->sendReq(context.background(), fmt::sprintf("watch %s @%s", h_(foid), h_(at)));
if (_ != "ok") {
string ack;
tie(ack, err) = wconn._wlink->sendReq(context.background(), fmt::sprintf("watch %s @%s", h_(foid), h_(at)));
if (err != nil)
return err;
if (ack != "ok") {
// XXX unregister f from _filetab
// XXX vvv -> errctx?
raise RuntimeError("resync @%s -> @%s: f<%s>: %s" % (h(wconn.at), h(at), h(foid), _))
return fmt::errorf("resync @%s -> @%s: f<%s>: %s", h_(wconn.at), h_(at), h_(foid), ack.c_str());
}
}
......
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