We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a6ea995 commit 78ac4dfCopy full SHA for 78ac4df
provisionerd/provisionerd_test.go
@@ -310,12 +310,15 @@ func TestProvisionerd(t *testing.T) {
310
didLog atomic.Bool
311
didAcquireJob atomic.Bool
312
)
313
+ var complete sync.Once
314
completeChan := make(chan struct{})
315
closer := createProvisionerd(t, func(ctx context.Context) (proto.DRPCProvisionerDaemonClient, error) {
316
return createProvisionerDaemonClient(t, provisionerDaemonTestServer{
317
acquireJob: func(ctx context.Context, _ *proto.Empty) (*proto.AcquiredJob, error) {
318
if didAcquireJob.Load() {
- close(completeChan)
319
+ complete.Do(func() {
320
+ close(completeChan)
321
+ })
322
return &proto.AcquiredJob{}, nil
323
}
324
didAcquireJob.Store(true)
0 commit comments