Commit 6d0aae55 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 74905116
...@@ -106,7 +106,7 @@ func TestTracetestExample(t *testing.T) { ...@@ -106,7 +106,7 @@ func TestTracetestExample(t *testing.T) {
}() }()
// assert that events come as expected // assert that events come as expected
t.Expect("t2", eventHello("T2·C")) t.Expect("t3", eventHi("T2·C"))
t.Expect("t1", eventHi("T1·A")) t.Expect("t1", eventHi("T1·A"))
t.Expect("t1", eventHello("T1·B")) t.Expect("t1", eventHello("T1·B"))
......
...@@ -493,7 +493,7 @@ type T struct { ...@@ -493,7 +493,7 @@ type T struct {
testing.TB testing.TB
streamTabMu sync.Mutex streamTabMu sync.Mutex
streamTab map[/*stream*/string]Chan streamTab map[/*stream*/string]Chan // set to nil on test shutdown
routeEvent func(event interface{}) (stream string) routeEvent func(event interface{}) (stream string)
nakq []nak // naks queued to be sent after Fatal nakq []nak // naks queued to be sent after Fatal
...@@ -651,7 +651,7 @@ func (t *T) xget1(stream string, eventp interface{}) *Msg { ...@@ -651,7 +651,7 @@ func (t *T) xget1(stream string, eventp interface{}) *Msg {
case <-time.After(*deadTime): case <-time.After(*deadTime):
//t.deadlock(stream, eventp) //t.deadlock(stream, eventp)
t.Fatalf("%s: deadlock waiting for %T\n", stream, eventp) t.Fatalf("%s: recv: deadlock waiting for %T\n", stream, eventp)
} }
reventp := reflect.ValueOf(eventp) reventp := reflect.ValueOf(eventp)
......
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