Commit 21315313 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 1059b27f
......@@ -84,7 +84,14 @@ func _TestMasterStorage(t0 *tEnv) {
// trace
tM.Expect(δnode("m", "s:1", proto.STORAGE, 1, proto.RUNNING, 0.01))
t.Expect("m", δnode("m", "s:1", proto.STORAGE, 1, proto.RUNNING, 0.01))
t.Expect("m-s", conntx("m:2", "s:2", 6, &proto.NotifyNodeInformation{
IdTime: proto.IdTimeNone, // XXX ?
NodeList: []proto.NodeInfo{
nodei("s:1", proto.STORAGE, 1, proto.RUNNING, 0.01),
},
}))
t.Expect("s", δnode("s", "s:1", proto.STORAGE, 1, proto.RUNNING, 0.01))
xwait(wg)
// XXX M.partTab <- S1
......@@ -92,7 +99,7 @@ func _TestMasterStorage(t0 *tEnv) {
// M starts verification
tM.Expect(clusterState("m", proto.ClusterVerifying))
tMS.Expect(conntx("m:2", "s:2", 4, &proto.SendPartitionTable{
tMS.Expect(conntx("m:2", "s:2", 8, &proto.SendPartitionTable{
PTid: 1,
NumReplicas: 0,
RowList: []proto.RowInfo{
......
......@@ -1195,7 +1195,7 @@ func (c *Conn) sendPktDirect(pkt *pktBuf) error {
// ---- raw IO ----
const dumpio = true
const dumpio = false
// sendPkt sends raw packet to peer.
//
......
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