File tree Expand file tree Collapse file tree 1 file changed +29
-0
lines changed Expand file tree Collapse file tree 1 file changed +29
-0
lines changed Original file line number Diff line number Diff line change 5
5
"bytes"
6
6
"context"
7
7
"net/http"
8
+ "sync"
8
9
"testing"
9
10
10
11
"github.com/google/uuid"
@@ -69,6 +70,34 @@ func TestPostFiles(t *testing.T) {
69
70
_ , err = client .Upload (ctx , codersdk .ContentTypeTar , bytes .NewReader (data ))
70
71
require .NoError (t , err )
71
72
})
73
+ t .Run ("InsertConcurrent" , func (t * testing.T ) {
74
+ t .Parallel ()
75
+ client := coderdtest .New (t , nil )
76
+ _ = coderdtest .CreateFirstUser (t , client )
77
+
78
+ ctx , cancel := context .WithTimeout (context .Background (), testutil .WaitLong )
79
+ defer cancel ()
80
+
81
+ var wg sync.WaitGroup
82
+ var end sync.WaitGroup
83
+ wg .Add (1 )
84
+ end .Add (3 )
85
+ for range 3 {
86
+ go func () {
87
+ wg .Wait ()
88
+ data := make ([]byte , 1024 )
89
+ _ , err := client .Upload (ctx , codersdk .ContentTypeTar , bytes .NewReader (data ))
90
+ end .Done ()
91
+ require .NoError (t , err )
92
+ }()
93
+
94
+ }
95
+ wg .Done ()
96
+ end .Wait ()
97
+
98
+ // _, err = client.Upload(ctx, codersdk.ContentTypeTar, bytes.NewReader(data))
99
+ // require.NoError(t, err)
100
+ })
72
101
}
73
102
74
103
func TestDownload (t * testing.T ) {
You can’t perform that action at this time.
0 commit comments