diff options
author | Erik Dubbelboer <erik@dubbelboer.com> | 2022-04-01 18:11:16 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-04-01 18:11:16 +0200 |
commit | 7a5afddf5b805a022f8e81281c772c11600da2f4 (patch) | |
tree | 76ecbf4981921328d823eb925e57f874f52c34f2 /workerpool_test.go | |
parent | support adding/removing clients from LBClient (#1243) (diff) | |
download | fasthttp-7a5afddf5b805a022f8e81281c772c11600da2f4.tar.gz fasthttp-7a5afddf5b805a022f8e81281c772c11600da2f4.tar.bz2 fasthttp-7a5afddf5b805a022f8e81281c772c11600da2f4.zip |
Mostly in tests.
Diffstat (limited to 'workerpool_test.go')
-rw-r--r-- | workerpool_test.go | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/workerpool_test.go b/workerpool_test.go index 4a09d97..b8267ab 100644 --- a/workerpool_test.go +++ b/workerpool_test.go @@ -86,14 +86,14 @@ func testWorkerPoolMaxWorkersCount(t *testing.T) { buf := make([]byte, 100) n, err := conn.Read(buf) if err != nil { - t.Errorf("unexpected error: %s", err) + t.Errorf("unexpected error: %v", err) } buf = buf[:n] if string(buf) != "foobar" { t.Errorf("unexpected data read: %q. Expecting %q", buf, "foobar") } if _, err = conn.Write([]byte("baz")); err != nil { - t.Errorf("unexpected error: %s", err) + t.Errorf("unexpected error: %v", err) } <-ready @@ -113,20 +113,20 @@ func testWorkerPoolMaxWorkersCount(t *testing.T) { go func() { conn, err := ln.Dial() if err != nil { - t.Errorf("unexpected error: %s", err) + t.Errorf("unexpected error: %v", err) } if _, err = conn.Write([]byte("foobar")); err != nil { - t.Errorf("unexpected error: %s", err) + t.Errorf("unexpected error: %v", err) } data, err := ioutil.ReadAll(conn) if err != nil { - t.Errorf("unexpected error: %s", err) + t.Errorf("unexpected error: %v", err) } if string(data) != "baz" { t.Errorf("unexpected value read: %q. Expecting %q", data, "baz") } if err = conn.Close(); err != nil { - t.Errorf("unexpected error: %s", err) + t.Errorf("unexpected error: %v", err) } clientCh <- struct{}{} }() @@ -135,7 +135,7 @@ func testWorkerPoolMaxWorkersCount(t *testing.T) { for i := 0; i < wp.MaxWorkersCount; i++ { conn, err := ln.Accept() if err != nil { - t.Fatalf("unexpected error: %s", err) + t.Fatalf("unexpected error: %v", err) } if !wp.Serve(conn) { t.Fatalf("worker pool must have enough workers to serve the conn") @@ -144,12 +144,12 @@ func testWorkerPoolMaxWorkersCount(t *testing.T) { go func() { if _, err := ln.Dial(); err != nil { - t.Errorf("unexpected error: %s", err) + t.Errorf("unexpected error: %v", err) } }() conn, err := ln.Accept() if err != nil { - t.Fatalf("unexpected error: %s", err) + t.Fatalf("unexpected error: %v", err) } for i := 0; i < 5; i++ { if wp.Serve(conn) { @@ -157,7 +157,7 @@ func testWorkerPoolMaxWorkersCount(t *testing.T) { } } if err = conn.Close(); err != nil { - t.Fatalf("unexpected error: %s", err) + t.Fatalf("unexpected error: %v", err) } close(ready) @@ -171,7 +171,7 @@ func testWorkerPoolMaxWorkersCount(t *testing.T) { } if err := ln.Close(); err != nil { - t.Fatalf("unexpected error: %s", err) + t.Fatalf("unexpected error: %v", err) } wp.Stop() } |