Commit e665df91 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 508a7e3f
......@@ -867,7 +867,12 @@ func Verify(t *testing.T, f func(t *T)) {
}
}
// retest f with 10·δtMax delay injected at i'th event XXX 10x is too much?
// retest f with 10·δtMax delay injected at i'th event
delayT := 10*δtMax // TODO make sure it < deadTime
delayTmin := 10*time.Millisecond // make sure delayT ≥ 10ms
if delayT < delayTmin {
delayT = delayTmin
}
for i := 0; i < len(trace0); i++ {
// stream and on-stream sequence number for i'th global event
stream := trace0[i].stream
......@@ -882,7 +887,7 @@ func Verify(t *testing.T, f func(t *T)) {
tT := testf(t, map[string]*delayInjectState{
stream: &delayInjectState{
delayAt: istream,
delayT: 10*δtMax, // TODO make sure it < deadTime
delayT: delayT,
},
})
......
......@@ -38,7 +38,9 @@ import (
// tCluster is a test NEO cluster NEO.
//
// Create it with tNewCluster.
// Create nodes with .NewMaster, .NewStorage and .NewClient.
type tCluster struct {
*tracetest.T // original testing env this cluster was created at
......@@ -80,6 +82,7 @@ type ITestClient interface {
// tNewCluster creates new NEO test cluster.
//
// At the end of the test the cluster has to be stopped via t.Stop().
// TODO add options describeing whether node type X should be created via Go or via Py.
func tNewCluster(ttest *tracetest.T, name string) *tCluster {
t := &tCluster{
T: ttest,
......
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