Function TestRecordRPCCost

rpc/pool_test.go:226–249

(t *testing.T)

}

func TestRecordRPCCost(t *testing.T) {
	Convey("Bug: bad critical section for multiple values", t, func(c C) {
		var (
			start      = time.Now()
			rounds     = 1000
			concurrent = 10
			wg         = &sync.WaitGroup{}
			body       = func(i int) {
				defer func() {
					c.So(recover(), ShouldBeNil)
					wg.Done()
				}()
				recordRPCCost(start, fmt.Sprintf("M%d", i), nil)
			}
		)
		for i := 0; i < rounds; i++ {
			for j := 0; j < concurrent; j++ {
				wg.Add(1)
				go body(i)
			}
			wg.Wait()
		}
	})
}