From e1725846a434d393b81df5d5f5d914f711ca86f3 Mon Sep 17 00:00:00 2001
From: benjamin <ben@elixxir.io>
Date: Wed, 26 Oct 2022 20:43:43 -0700
Subject: [PATCH] glued interfaces together
---
cmix/nodes/interfaces.go | 4 ++++
cmix/nodes/registrar.go | 4 ++--
2 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/cmix/nodes/interfaces.go b/cmix/nodes/interfaces.go
index 5d08e6db9..ddce4b8f2 100644
--- a/cmix/nodes/interfaces.go
+++ b/cmix/nodes/interfaces.go
@@ -27,6 +27,10 @@ type Registrar interface {
// to register with nodes.
StartProcesses(numParallel uint) stoppable.Stoppable
+ // IncreaseParallelNodeRegistration increases the number of parallel node
+ // registrations by num
+ IncreaseParallelNodeRegistration(num int) func() (stoppable.Stoppable, error)
+
// GetNodeKeys returns a MixCypher for the topology and a list of nodes it did
// not have a key for. If there are missing keys, then returns nil.
GetNodeKeys(topology *connect.Circuit) (MixCypher, error)
diff --git a/cmix/nodes/registrar.go b/cmix/nodes/registrar.go
index fedd7ddd3..0c942b8de 100644
--- a/cmix/nodes/registrar.go
+++ b/cmix/nodes/registrar.go
@@ -108,11 +108,11 @@ func (r *registrar) StartProcesses(numParallel uint) stoppable.Stoppable {
// IncreaseParallelNodeRegistration increases the number of parallel node
// registrations by num
-func (r *registrar) IncreaseParallelNodeRegistration(numParallel uint) func() (stoppable.Stoppable, error) {
+func (r *registrar) IncreaseParallelNodeRegistration(numParallel int) func() (stoppable.Stoppable, error) {
return func() (stoppable.Stoppable, error) {
multi := stoppable.NewMulti("NodeRegistrationsIncrease")
- for i := uint(0); i < numParallel; i++ {
+ for i := uint(0); i < uint(numParallel); i++ {
stop := stoppable.NewSingle("NodeRegistration Increase" + strconv.Itoa(int(i)))
go registerNodes(r, r.session, stop, &r.inProgress, &r.attempts)
--
GitLab