(t *testing.T)
| 239 | } |
| 240 | |
| 241 | func Test_MultiStream(t *testing.T) { |
| 242 | tutils.CheckSkip(t, tutils.SkipTestArgs{Long: true}) |
| 243 | |
| 244 | tlog.Logf("Duration %v\n", duration) |
| 245 | ts := httptest.NewServer(objmux) |
| 246 | defer ts.Close() |
| 247 | |
| 248 | wg := &sync.WaitGroup{} |
| 249 | netstats := make(map[string]transport.EndpointStats) |
| 250 | lock := &sync.Mutex{} |
| 251 | for i := 0; i < 16; i++ { |
| 252 | wg.Add(1) |
| 253 | go streamWriteUntil(t, i, wg, ts, netstats, lock, false /*compress*/, false /*PDU*/) |
| 254 | } |
| 255 | wg.Wait() |
| 256 | compareNetworkStats(t, netstats) |
| 257 | } |
| 258 | |
| 259 | func printNetworkStats(t *testing.T) { |
| 260 | netstats, err := transport.GetStats() |
nothing calls this directly
no test coverage detected