diff --git a/dapps/valuetransfers/packages/tangle/tangle.go b/dapps/valuetransfers/packages/tangle/tangle.go index 0566e3ac463578d839b2b3c7047b9a8975199227..6b0fa17d077f11125bf4e75a429178b1c3b1d0fa 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,