Commit f53573a2 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 7b144106
......@@ -123,6 +123,7 @@
// changes:
//
// S: <2·k> pin <bigfileX> #<blk> @<rev_max>
// XXX @head means unpin.
//
// and waits until all clients confirm that changed file block can be updated
// in global OS cache.
......
......@@ -720,7 +720,8 @@ def watch(w, zf, at): # XXX -> ?
def _expectPin(w, ctx, zf, expect):
expected = set() # of expected pin messages
for blk, at in expect.items():
msg = b"pin %s #%d @%s" % (h(zf._p_oid), blk, h(at))
hat = h(at) if at is not None else 'head'
msg = b"pin %s #%d @%s" % (h(zf._p_oid), blk, hat)
assert msg not in expected
expected.add(msg)
......
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