[#9999] engine: Add non-blocking send in the shard's notification channel

Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
This commit is contained in:
Dmitrii Stepanov 2024-11-06 10:05:23 +03:00
parent 718f2bb5d6
commit b5a81deb8d
Signed by: dstepanov-yadro
GPG key ID: 237AF1A763293BC0

View file

@ -328,6 +328,7 @@ func (e *StorageEngine) HandleNewEpoch(ctx context.Context, epoch uint64) {
case <-ctx.Done():
return
case sh.NotificationChannel() <- ev:
default:
}
}
}