Skip to content

Commit 38829b5

Browse files
committed
Handle context cancellations when sending triggers
1 parent d81c17d commit 38829b5

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

rolling-shutter/keyperimpl/shutterservice/newblock.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,15 @@ func (kpr *Keyper) sendTriggers(ctx context.Context, triggers []epochkghandler.D
248248
Uint64("eon", trigger.BlockNumber).
249249
Int("num-identities", len(trigger.IdentityPreimages)).
250250
Msg("sending decryption trigger")
251-
kpr.decryptionTriggerChannel <- event
251+
252+
select {
253+
case kpr.decryptionTriggerChannel <- event:
254+
case <-ctx.Done():
255+
log.Warn().
256+
Err(ctx.Err()).
257+
Msg("context canceled while sending decryption trigger")
258+
return
259+
}
252260
}
253261
}
254262

0 commit comments

Comments
 (0)