From 7bdcb4be2b4ee5e81e01b6a60479d5cc88ef01ee Mon Sep 17 00:00:00 2001 From: Jim McDonald Date: Tue, 27 Jul 2021 16:56:58 +0100 Subject: [PATCH] Update tests. --- services/accountmanager/dirk/parameters.go | 7 ++----- services/accountmanager/dirk/service_test.go | 2 +- services/synccommitteemessenger/standard/parameters.go | 2 +- 3 files changed, 4 insertions(+), 7 deletions(-) diff --git a/services/accountmanager/dirk/parameters.go b/services/accountmanager/dirk/parameters.go index 4efac14..a8b0e91 100644 --- a/services/accountmanager/dirk/parameters.go +++ b/services/accountmanager/dirk/parameters.go @@ -156,17 +156,14 @@ func parseAndCheckParameters(params ...Parameter) (*parameters, error) { } } - if parameters.processConcurrency == 0 { - return nil, errors.New("no process concurrency specified") - } if parameters.monitor == nil { return nil, errors.New("no monitor specified") } if parameters.clientMonitor == nil { return nil, errors.New("no client monitor specified") } - if parameters.processConcurrency <= 0 { - return nil, errors.New("process concurrency must be > 0") + if parameters.processConcurrency < 1 { + return nil, errors.New("no process concurrency specified") } if len(parameters.endpoints) == 0 { return nil, errors.New("no endpoints specified") diff --git a/services/accountmanager/dirk/service_test.go b/services/accountmanager/dirk/service_test.go index f5b1273..ab1d0a4 100644 --- a/services/accountmanager/dirk/service_test.go +++ b/services/accountmanager/dirk/service_test.go @@ -108,7 +108,7 @@ func TestService(t *testing.T) { dirk.WithFarFutureEpochProvider(farFutureEpochProvider), dirk.WithCurrentEpochProvider(chainTime), }, - err: "problem with parameters: process concurrency must be > 0", + err: "problem with parameters: no process concurrency specified", }, { name: "EndpointsNil", diff --git a/services/synccommitteemessenger/standard/parameters.go b/services/synccommitteemessenger/standard/parameters.go index 95da047..df3e7a0 100644 --- a/services/synccommitteemessenger/standard/parameters.go +++ b/services/synccommitteemessenger/standard/parameters.go @@ -150,7 +150,7 @@ func parseAndCheckParameters(params ...Parameter) (*parameters, error) { } } - if parameters.processConcurrency == 0 { + if parameters.processConcurrency < 1 { return nil, errors.New("no process concurrency specified") } if parameters.monitor == nil {