Commit ff17df41 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 6bd82a84
...@@ -46,6 +46,7 @@ import ( ...@@ -46,6 +46,7 @@ import (
"lab.nexedi.com/kirr/neo/go/xcommon/xtesting" "lab.nexedi.com/kirr/neo/go/xcommon/xtesting"
"lab.nexedi.com/kirr/go123/exc" "lab.nexedi.com/kirr/go123/exc"
"lab.nexedi.com/kirr/go123/xerr"
"fmt" "fmt"
"time" "time"
...@@ -308,19 +309,24 @@ func TestMasterStorage(t *testing.T) { ...@@ -308,19 +309,24 @@ func TestMasterStorage(t *testing.T) {
})) }))
tc.Expect(conntx("m:2", "s:2", 1, &neo.LockedTransactions{})) tc.Expect(conntx("m:2", "s:2", 1, &neo.LockedTransactions{}))
tc.Expect(conntx("s:2", "m:2", 1, &neo.AnswerLockedTransactions{ tc.Expect(conntx("s:2", "m:2", 1, &neo.AnswerLockedTransactions{
TidDict: nil, // map[zodb.Tid]zodb.Tid{}, TidDict: nil, // map[zodb.Tid]zodb.Tid{},
})) }))
lastOid, err1 := zstor.LastOid()
lastTid, err2 := zstor.LastTid()
exc.Raiseif(xerr.Merge(err1, err2))
tc.Expect(conntx("m:2", "s:2", 1, &neo.LastIDs{}))
tc.Expect(conntx("s:2", "m:2", 1, &neo.AnswerLastIDs{
LastOid: lastOid,
LastTid: lastTid,
}))
// expect: // expect:
// ? M -> S ClusterInformation(VERIFICATION) // ? M -> S ClusterInformation(VERIFICATION)
// M -> S .? LockedTransactions{}
// M <- S .? AnswerLockedTransactions{...}
// M -> S .? LastIDs{}
// M <- S .? AnswerLastIDs{...}
// + TODO there is actually txn to finish
// + TODO S leave at verify // + TODO S leave at verify
// + TODO S join at verify // + TODO S join at verify
// + TODO M.Stop() while verify // + TODO M.Stop() while verify
......
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