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

.

parent d750f5e5
...@@ -189,7 +189,7 @@ def test_wcfs_client_down_efault(): ...@@ -189,7 +189,7 @@ def test_wcfs_client_down_efault():
at2 = t.commit() at2 = t.commit()
at3 = t.commit(zf2, {1:'β3', 2:'γ3'}) at3 = t.commit(zf2, {1:'β3', 2:'γ3'})
wconn = t.wc.connect(at1) wconn = t.wc.connect(at1) # XXX -> at3
defer(wconn.close) defer(wconn.close)
fh1 = wconn.open(zf1._p_oid); defer(fh1.close) fh1 = wconn.open(zf1._p_oid); defer(fh1.close)
......
...@@ -682,6 +682,11 @@ pair<FileH, error> _Conn::open(zodb::Oid foid) { ...@@ -682,6 +682,11 @@ pair<FileH, error> _Conn::open(zodb::Oid foid) {
return make_pair(nil, E(err)); return make_pair(nil, E(err));
} }
// XXX ensure f<foid> @ wconn.at exists?
// XXX else we get pins to non-exists state from wcfs.
//
// XXX -> better teach wcfs to reject "watch <foid> @at" for @at where foid did not existed.
retry: retry:
FileH f; bool ok; FileH f; bool ok;
tie(f, ok) = wconn._filehTab.get_(foid); tie(f, ok) = wconn._filehTab.get_(foid);
......
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