From 428516f03a13d34d37e8c6f247d0212c8454d128 Mon Sep 17 00:00:00 2001
From: benjamin <ben@elixxir.io>
Date: Wed, 26 Oct 2022 20:52:17 -0700
Subject: [PATCH] made lower paralell regs unique to js and hacked increase in
num registrations into new channel manager
---
bindings/channels.go | 21 +++++++++++++++++++++
cmix/parallelNodeRegistrations.go | 13 +++++++++++++
cmix/params.go | 2 +-
cmix/rounds/parallelNodeRegistrations_js.go | 3 +++
4 files changed, 38 insertions(+), 1 deletion(-)
create mode 100644 cmix/parallelNodeRegistrations.go
create mode 100644 cmix/rounds/parallelNodeRegistrations_js.go
diff --git a/bindings/channels.go b/bindings/channels.go
index f58af9602..78182a190 100644
--- a/bindings/channels.go
+++ b/bindings/channels.go
@@ -11,6 +11,7 @@ import (
"crypto/ed25519"
"encoding/base64"
"encoding/json"
+ jww "github.com/spf13/jwalterweatherman"
"sync"
"time"
@@ -234,6 +235,16 @@ func NewChannelsManagerGoEventModel(cmixID int, privateIdentity []byte,
return nil, err
}
+ // fixme: remove this, make it called by the javascript
+ // hack to get to release late at night
+ go func() {
+ time.Sleep(3 * time.Second)
+ localErr := user.IncreaseParallelNodeRegistration(13)
+ if localErr != nil {
+ jww.ERROR.Printf(localErr.Error())
+ }
+ }()
+
// Add channel to singleton and return
return channelManagerTrackerSingleton.make(m), nil
}
@@ -267,6 +278,16 @@ func LoadChannelsManagerGoEventModel(cmixID int, storageTag string,
return nil, err
}
+ // fixme: remove this, make it called by the javascript
+ // hack to get to release late at night
+ go func() {
+ time.Sleep(3 * time.Second)
+ localErr := user.IncreaseParallelNodeRegistration(13)
+ if localErr != nil {
+ jww.ERROR.Printf(localErr.Error())
+ }
+ }()
+
// Add channel to singleton and return
return channelManagerTrackerSingleton.make(m), nil
}
diff --git a/cmix/parallelNodeRegistrations.go b/cmix/parallelNodeRegistrations.go
new file mode 100644
index 000000000..48f232901
--- /dev/null
+++ b/cmix/parallelNodeRegistrations.go
@@ -0,0 +1,13 @@
+////////////////////////////////////////////////////////////////////////////////
+// Copyright © 2022 xx foundation //
+// //
+// Use of this source code is governed by a license that can be found in the //
+// LICENSE file. //
+////////////////////////////////////////////////////////////////////////////////
+
+// This file is compiled for all architectures except WebAssembly.
+//go:build !js || !wasm
+
+package cmix
+
+const defaultParallelNodeRegistration = 20
diff --git a/cmix/params.go b/cmix/params.go
index f15b62feb..01a606e5b 100644
--- a/cmix/params.go
+++ b/cmix/params.go
@@ -100,7 +100,7 @@ func GetDefaultParams() Params {
MaxCheckedRounds: 500,
RegNodesBufferLen: 1000,
NetworkHealthTimeout: 15 * time.Second,
- ParallelNodeRegistrations: 2,
+ ParallelNodeRegistrations: defaultParallelNodeRegistration,
KnownRoundsThreshold: 1500, // 5 rounds/sec * 60 sec/min * 5 min
FastPolling: true,
VerboseRoundTracking: false,
diff --git a/cmix/rounds/parallelNodeRegistrations_js.go b/cmix/rounds/parallelNodeRegistrations_js.go
new file mode 100644
index 000000000..246dcb532
--- /dev/null
+++ b/cmix/rounds/parallelNodeRegistrations_js.go
@@ -0,0 +1,3 @@
+package rounds
+
+const defaultParallelNodeRegistration = 2
--
GitLab