We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent afffe1c commit cf21916Copy full SHA for cf21916
1 file changed
pkg/sshd/server_test.go
@@ -198,6 +198,22 @@ func TestManyConcurrentPushes(t *testing.T) {
198
assert.NoErr(t, waitWithTimeout(&wg, 1*time.Second))
199
}
200
201
+func TestWithCleanerLock(t *testing.T) {
202
+ srv := &server{cleanerRef: cleaner.NewRef()}
203
+ var wg sync.WaitGroup
204
+ for i := 0; i < 100; i++ {
205
+ wg.Add(1)
206
+ go func(i int) {
207
+ err := srv.withCleanerLock(func() error {
208
+ wg.Done()
209
+ return nil
210
+ })
211
+ assert.NoErr(t, err)
212
+ }(i)
213
+ }
214
+ assert.NoErr(t, waitWithTimeout(&wg, 1*time.Second))
215
+}
216
+
217
func TestDelete(t *testing.T) {
218
const testingServerAddr = "127.0.0.1:2246"
219
key, err := sshTestingHostKey()
0 commit comments