(t *testing.T)
| 411 | } |
| 412 | |
| 413 | func TestIncQueued(t *testing.T) { |
| 414 | u := testGetUser() |
| 415 | cu := testGetClusterUser() |
| 416 | c := testGetCluster() |
| 417 | expectedSessionHostMap := map[string]string{ |
| 418 | "0": "127.0.0.22", |
| 419 | "1": "127.0.0.33", |
| 420 | "2": "127.0.0.44", |
| 421 | "3": "127.0.0.55", |
| 422 | } |
| 423 | if err := testConcurrentQuery(c, u, cu, 10000, expectedSessionHostMap); err != nil { |
| 424 | t.Fatalf("incQueue test err: %s", err) |
| 425 | } |
| 426 | } |
| 427 | |
| 428 | func testConcurrentQuery(c *cluster, u *user, cu *clusterUser, concurrency int, expectedSessionHostMap map[string]string) error { |
| 429 | ch := make(chan map[string]string, 10000) |
nothing calls this directly
no test coverage detected