Skip to content
Snippets Groups Projects
Unverified Commit 1c74f34d authored by Hans Moog's avatar Hans Moog Committed by GitHub
Browse files

Fix: make the valuetransfers single threaded (#498)


Co-authored-by: default avatarHans Moog <hm@mkjc.net>
parent 4cca0efd
No related branches found
No related tags found
No related merge requests found
......@@ -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,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment