Skip to content

Commit

Permalink
Remove hack for not running tests in parallel in Travis
Browse files Browse the repository at this point in the history
  • Loading branch information
fsouza committed Sep 16, 2021
1 parent eca9aab commit 93e805e
Show file tree
Hide file tree
Showing 6 changed files with 8 additions and 25 deletions.
6 changes: 3 additions & 3 deletions net_sink_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -642,7 +642,7 @@ func testNetSinkReconnect(t *testing.T, protocol string) {
if testing.Short() {
t.Skip("Skipping: short test")
}
Parallel(t)
t.Parallel()

const expected = "counter:1|c\n"

Expand Down Expand Up @@ -692,7 +692,7 @@ func testNetSinkReconnectFailure(t *testing.T, protocol string) {
if testing.Short() {
t.Skip("Skipping: short test")
}
Parallel(t)
t.Parallel()

ts, sink := setupTestNetSink(t, protocol, true)
defer ts.Close()
Expand Down Expand Up @@ -794,7 +794,7 @@ func buildBinary(t testing.TB, path string) (string, func()) {
}

func testNetSinkIntegration(t *testing.T, protocol string) {
Parallel(t)
t.Parallel()

ctx, cancel := context.WithCancel(context.Background())
defer cancel()
Expand Down
4 changes: 2 additions & 2 deletions net_util_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -359,7 +359,7 @@ func reconnectRetry(t testing.TB, fn func() error) {
}

func TestReconnectRetryTCP(t *testing.T) {
Parallel(t)
t.Parallel()

l1, err := net.ListenTCP("tcp", &net.TCPAddr{
IP: net.IPv4(127, 0, 0, 1),
Expand Down Expand Up @@ -397,7 +397,7 @@ func TestReconnectRetryTCP(t *testing.T) {
}

func TestReconnectRetryUDP(t *testing.T) {
Parallel(t)
t.Parallel()

l1, err := net.ListenUDP("udp", &net.UDPAddr{
IP: net.IPv4(127, 0, 0, 1),
Expand Down
9 changes: 0 additions & 9 deletions parallel_ci_test.go

This file was deleted.

8 changes: 0 additions & 8 deletions parallel_test.go

This file was deleted.

2 changes: 1 addition & 1 deletion stat_handler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import (
)

func TestHttpHandler_ServeHTTP(t *testing.T) {
Parallel(t)
t.Parallel()

sink := mock.NewSink()
store := NewStore(sink, false)
Expand Down
4 changes: 2 additions & 2 deletions stat_handler_wrapper_1.7_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import (
)

func TestHTTPHandler_WrapResponse(t *testing.T) {
Parallel(t)
t.Parallel()

tests := []http.ResponseWriter{
struct {
Expand Down Expand Up @@ -58,7 +58,7 @@ func TestHTTPHandler_WrapResponse(t *testing.T) {
for i, test := range tests {
tc := test
t.Run(fmt.Sprint("test:", i), func(t *testing.T) {
Parallel(t)
t.Parallel()

_, canFlush := tc.(http.Flusher)
_, canHijack := tc.(http.Hijacker)
Expand Down

0 comments on commit 93e805e

Please sign in to comment.