From 1c74f34de1900722bd8e5f559752bab077faf81f Mon Sep 17 00:00:00 2001
From: Hans Moog <3293976+hmoog@users.noreply.github.com>
Date: Thu, 18 Jun 2020 16:43:30 +0200
Subject: [PATCH] Fix: make the valuetransfers single threaded (#498)
Co-authored-by: Hans Moog <hm@mkjc.net>
---
dapps/valuetransfers/packages/tangle/tangle.go | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/dapps/valuetransfers/packages/tangle/tangle.go b/dapps/valuetransfers/packages/tangle/tangle.go
index 0566e3ac..6b0fa17d 100644
--- a/dapps/valuetransfers/packages/tangle/tangle.go
+++ b/dapps/valuetransfers/packages/tangle/tangle.go
@@ -38,8 +38,7 @@ type Tangle struct {
Events Events
- workerPool async.WorkerPool
- cleanupWorkerPool async.WorkerPool
+ workerPool async.WorkerPool
}
// New is the constructor of a Tangle and creates a new Tangle object from the given details.
@@ -63,6 +62,9 @@ func New(store kvstore.KVStore) (tangle *Tangle) {
}
tangle.setupDAGSynchronization()
+ // TODO: CHANGE BACK TO MULTI THREADING ONCE WE FIXED LOGICAL RACE CONDITIONS
+ tangle.workerPool.Tune(1)
+
return
}
@@ -267,7 +269,6 @@ func (tangle *Tangle) Prune() (err error) {
// Shutdown stops the worker pools and shuts down the object storage instances.
func (tangle *Tangle) Shutdown() *Tangle {
tangle.workerPool.ShutdownGracefully()
- tangle.cleanupWorkerPool.ShutdownGracefully()
for _, storage := range []*objectstorage.ObjectStorage{
tangle.payloadStorage,
--
GitLab