gbn: run unit tests in parallel

Author: ellemouton

gbn/gbn_conn_test.go

@@ -12,6 +12,8 @@ import (
 )
 
 func TestNormal(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -86,6 +88,8 @@ func TestNormal(t *testing.T) {
 // so will call Recv or Send which will hang indefinitely unless we set a
 // timeout.
 func TestServerHandshakeTimeout(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -188,6 +192,8 @@ func TestServerHandshakeTimeout(t *testing.T) {
 }
 
 func TestDroppedMessage(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -268,6 +274,8 @@ func TestDroppedMessage(t *testing.T) {
 }
 
 func TestDroppedACKs(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -357,6 +365,8 @@ func TestDroppedACKs(t *testing.T) {
 }
 
 func TestReceiveDuplicateMessages(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -438,6 +448,8 @@ func TestReceiveDuplicateMessages(t *testing.T) {
 }
 
 func TestReceiveDuplicateDataAndACKs(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -536,6 +548,8 @@ func TestReceiveDuplicateDataAndACKs(t *testing.T) {
 }
 
 func TestBidirectional(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -619,6 +633,8 @@ func TestBidirectional(t *testing.T) {
 }
 
 func TestSendNBeforeNeedingAck(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -682,6 +698,8 @@ func TestSendNBeforeNeedingAck(t *testing.T) {
 }
 
 func TestDropFirstNPackets(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -769,6 +787,8 @@ func TestDropFirstNPackets(t *testing.T) {
 }
 
 func TestBidirectional2(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -898,6 +918,8 @@ func TestBidirectional2(t *testing.T) {
 }
 
 func TestSendingIsNonBlockingUpToN(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -994,6 +1016,8 @@ func TestSendingIsNonBlockingUpToN(t *testing.T) {
 }
 
 func TestSendingLargeNumberOfMessages(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -1066,6 +1090,8 @@ func TestSendingLargeNumberOfMessages(t *testing.T) {
 }
 
 func TestResendAfterTimeout(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -1121,6 +1147,8 @@ func TestResendAfterTimeout(t *testing.T) {
 }
 
 func TestPayloadSplitting(t *testing.T) {
+	t.Parallel()
+
 	s1Chan := make(chan []byte, 10)
 	s2Chan := make(chan []byte, 10)
 
@@ -1185,6 +1213,8 @@ func setUpClientServerConns(t *testing.T, n uint8,
 	cWrite, sWrite func(ctx context.Context, b []byte) error,
 	opts ...Option) (*GoBackNConn, *GoBackNConn, func()) {
 
+	t.Helper()
+
 	var (
 		server *GoBackNConn
 		err    error

gbn/queue_test.go

@@ -7,6 +7,8 @@ import (
 )
 
 func TestQueueSize(t *testing.T) {
+	t.Parallel()
+
 	q := newQueue(&queueCfg{s: 4})
 
 	require.Equal(t, uint8(0), q.size())

gbn/ticker_test.go

@@ -28,9 +28,13 @@ var tickers = []struct {
 // same principle behaviors when accessed via the ticker.Ticker interface
 // methods.
 func TestInterfaceTickers(t *testing.T) {
+	t.Parallel()
+
 	for _, test := range tickers {
 		test := test
 		t.Run(test.name, func(t *testing.T) {
+			t.Parallel()
+
 			testTicker(t, test.ticker)
 		})
 	}