From 179b5adad46d8f27ab9c8832feff528fe3793732 Mon Sep 17 00:00:00 2001 From: Stefan Benten Date: Sun, 6 Sep 2020 01:06:06 +0200 Subject: [PATCH] storagenode/orders: add missing mon.Task parameter Change-Id: If98cf347a81f29698a6bdb0907520d60f71db433 --- storagenode/orders/service.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/storagenode/orders/service.go b/storagenode/orders/service.go index 94a35d6e7..b0d56f74e 100644 --- a/storagenode/orders/service.go +++ b/storagenode/orders/service.go @@ -179,7 +179,7 @@ func (service *Service) CleanArchive(ctx context.Context, deleteBefore time.Time // SendOrders sends the orders using now as the current time. func (service *Service) SendOrders(ctx context.Context, now time.Time) { - defer mon.Task()(&ctx) + defer mon.Task()(&ctx)(nil) service.log.Debug("sending") // If there are orders in the database, send from there. @@ -193,7 +193,7 @@ func (service *Service) SendOrders(ctx context.Context, now time.Time) { } func (service *Service) sendOrdersFromDB(ctx context.Context) (hasOrders bool) { - defer mon.Task()(&ctx) + defer mon.Task()(&ctx)(nil) const batchSize = 1000 hasOrders = true @@ -388,7 +388,7 @@ func (service *Service) settle(ctx context.Context, log *zap.Logger, satelliteID } func (service *Service) sendOrdersFromFileStore(ctx context.Context, now time.Time) { - defer mon.Task()(&ctx) + defer mon.Task()(&ctx)(nil) errorSatellites := make(map[storj.NodeID]struct{}) var errorSatellitesMu sync.Mutex