Skip to content
Snippets Groups Projects
Commit 99656641 authored by Kevin Jahns's avatar Kevin Jahns
Browse files

some flush updates

parent 5d6a9872
No related branches found
No related tags found
No related merge requests found
...@@ -81,7 +81,7 @@ module.exports = function (Y) { ...@@ -81,7 +81,7 @@ module.exports = function (Y) {
} else { } else {
resolve() resolve()
} }
}, 10) }, 0)
} }
} }
globalRoom.whenTransactionsFinished().then(nextFlush) globalRoom.whenTransactionsFinished().then(nextFlush)
......
...@@ -139,8 +139,7 @@ g.applyRandomTransactionsWithGC = async(function * applyRandomTransactions (user ...@@ -139,8 +139,7 @@ g.applyRandomTransactionsWithGC = async(function * applyRandomTransactions (user
}) })
g.garbageCollectAllUsers = async(function * garbageCollectAllUsers (users) { g.garbageCollectAllUsers = async(function * garbageCollectAllUsers (users) {
// gc two times because of the two gc phases (really collect everything) yield Y.utils.globalRoom.flushAll()
yield wait(100)
for (var i in users) { for (var i in users) {
yield users[i].db.emptyGarbageCollector() yield users[i].db.emptyGarbageCollector()
} }
...@@ -254,7 +253,6 @@ g.createUsers = async(function * createUsers (self, numberOfUsers, database, ini ...@@ -254,7 +253,6 @@ g.createUsers = async(function * createUsers (self, numberOfUsers, database, ini
Y.utils.globalRoom.users[u].y.destroy() Y.utils.globalRoom.users[u].y.destroy()
} }
self.users = null self.users = null
yield wait()
var promises = [] var promises = []
for (var i = 0; i < numberOfUsers; i++) { for (var i = 0; i < numberOfUsers; i++) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment