@@ -2,10 +2,9 @@ package srtgo
2
2
3
3
import (
4
4
"context"
5
+ "fmt"
5
6
"sync"
6
7
"testing"
7
-
8
- "github.com/pkg/errors"
9
8
)
10
9
11
10
type tester struct {
@@ -21,7 +20,7 @@ func (t *tester) send(port uint16) {
21
20
buf := make ([]byte , 1316 )
22
21
sock := NewSrtSocket ("127.0.0.1" , port , map [string ]string {"blocking" : t .blocking , "mode" : "caller" , "transtype" : "file" })
23
22
if sock == nil {
24
- t .err <- errors . New ("failed to create caller socket" )
23
+ t .err <- fmt . Errorf ("failed to create caller socket" )
25
24
return
26
25
}
27
26
defer sock .Close ()
@@ -32,7 +31,7 @@ func (t *tester) send(port uint16) {
32
31
33
32
err := sock .Connect ()
34
33
if err != nil {
35
- t .err <- errors . Wrap ( err , "connect" )
34
+ t .err <- fmt . Errorf ( "connect: %v" , err )
36
35
return
37
36
}
38
37
for {
@@ -43,7 +42,7 @@ func (t *tester) send(port uint16) {
43
42
}
44
43
_ , err := sock .Write (buf )
45
44
if err != nil {
46
- t .err <- errors . Wrap ( err , "write" )
45
+ t .err <- fmt . Errorf ( "write: %v" , err )
47
46
return
48
47
}
49
48
}
@@ -53,7 +52,7 @@ func (t *tester) send(port uint16) {
53
52
func (t * tester ) receive (port uint16 , iterations int ) {
54
53
sock := NewSrtSocket ("127.0.0.1" , port , map [string ]string {"blocking" : t .blocking , "mode" : "listener" , "rcvbuf" : "22937600" , "transtype" : "file" })
55
54
if sock == nil {
56
- t .err <- errors . New ("failed to create listener socket" )
55
+ t .err <- fmt . Errorf ("failed to create listener socket" )
57
56
return
58
57
}
59
58
buf := make ([]byte , 1316 )
@@ -66,18 +65,18 @@ func (t *tester) receive(port uint16, iterations int) {
66
65
67
66
err := sock .Listen (1 )
68
67
if err != nil {
69
- t .err <- errors . Wrap ( err , "listen" )
68
+ t .err <- fmt . Errorf ( "listen: %v" , err )
70
69
return
71
70
}
72
71
remote , _ , err := sock .Accept ()
73
72
if err != nil {
74
- t .err <- errors . Wrap ( err , "accept" )
73
+ t .err <- fmt . Errorf ( "accept: %v" , err )
75
74
return
76
75
}
77
76
for i := 0 ; i < iterations ; i ++ {
78
77
_ , err := remote .Read (buf )
79
78
if err != nil {
80
- t .err <- errors . Wrap ( err , "read" )
79
+ t .err <- fmt . Errorf ( "read: %v" , err )
81
80
return
82
81
}
83
82
}
0 commit comments