Skip to content

Commit 25628c9

Browse files
fixup! Signer info store DB implementation
Signed-off-by: Alexandros Filios <alexandros.filios@ibm.com>
1 parent 4cac9a1 commit 25628c9

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

platform/fabric/core/generic/delivery/delivery.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,6 @@ func (d *Delivery) readBlocks(ch <-chan blockResponse, cancel func()) {
163163
}
164164
case <-d.stop:
165165
logger.Infof("Stopping delivery service")
166-
cancel()
167166
return
168167
}
169168
}
@@ -178,10 +177,13 @@ func (d *Delivery) runReceiver(ctx context.Context, ch chan<- blockResponse) err
178177
waitTime := d.channelConfig.DeliverySleepAfterFailure()
179178
for {
180179
select {
180+
case <-d.stop:
181+
logger.Infof("Stopped receiver")
182+
return nil
181183
case <-ctx.Done():
182184
logger.Infof("Context done")
183185
// Time to cancel
184-
return nil
186+
return errors.New("context done")
185187
default:
186188
deliveryCtx, span := d.tracer.Start(context.Background(), "block_delivery",
187189
tracing.WithAttributes(tracing.String(messageTypeLabel, unknown)))

0 commit comments

Comments
 (0)