Commit f58945b5 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 4d5eb301
...@@ -127,6 +127,7 @@ ...@@ -127,6 +127,7 @@
// //
// S: <2·k> pin <bigfileX> #<blk> @<rev_max> // S: <2·k> pin <bigfileX> #<blk> @<rev_max>
// XXX @head means unpin. // XXX @head means unpin.
// XXX or use `unpin <bigfileX> #<blk>` ?
// //
// and waits until all clients confirm that changed file block can be updated // and waits until all clients confirm that changed file block can be updated
// in global OS cache. // in global OS cache.
...@@ -1354,7 +1355,9 @@ func (w *Watch) _pin(ctx context.Context, blk int64, rev zodb.Tid) (err error) { ...@@ -1354,7 +1355,9 @@ func (w *Watch) _pin(ctx context.Context, blk int64, rev zodb.Tid) (err error) {
if rev == zodb.TidMax { if rev == zodb.TidMax {
panicf("f<%s>: wlink%d: pinned[#%d] = @head", foid, w.link.id, blk) panicf("f<%s>: wlink%d: pinned[#%d] = @head", foid, w.link.id, blk)
} }
return nil // already pinned XXX for simultaneous calls? // already pinned
// (e.g. os cache for block was evicted and read called the second time)
return nil
} }
ack, err := w.link.sendReq(ctx, fmt.Sprintf("pin %s #%d @%s", foid, blk, revstr)) ack, err := w.link.sendReq(ctx, fmt.Sprintf("pin %s #%d @%s", foid, blk, revstr))
......
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