Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-10-07 22:57:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix benchmark so that adds happen only after log history has been fetched

Browse Source
This commit is contained in:
haad 2016-05-09 12:55:54 +02:00
parent e5f12057ea
commit f9abd5f819
1 changed files with 22 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
examples/benchmark.js
View File

@ -37,6 +37,14 @@ let run = (() => {
let lastTenSeconds = 0; let lastTenSeconds = 0;
const queryLoop = (db) => { const queryLoop = (db) => {
// const queryLoop = (ipfs) => {
// const data = new Buffer(JSON.stringify({ Data: JSON.stringify({ hello: "world" }) }));
// ipfs.object.put(data).then(() => {
// totalQueries ++;
// lastTenSeconds ++;
// queriesPerSecond ++;
// process.nextTick(() => queryLoop(ipfs));
// })
db.add(username + totalQueries).then(() => { db.add(username + totalQueries).then(() => {
totalQueries ++; totalQueries ++;
lastTenSeconds ++; lastTenSeconds ++;
@ -48,20 +56,30 @@ let run = (() => {
// Connect // Connect
console.log(`Connecting...`) console.log(`Connecting...`)
startIpfs() startIpfs()
// .then((ipfs) => queryLoop(ipfs))
.then((ipfs) => OrbitDB.connect(network, username, password, ipfs)) .then((ipfs) => OrbitDB.connect(network, username, password, ipfs))
.then((orbit) => orbit.eventlog(channelName)) .then((orbit) => orbit.eventlog(channelName))
.then(queryLoop) .then((db) => {
return new Promise((resolve, reject) => {
db.events.on('load', () => console.log("loading log from history"))
db.events.on('readable', () => {
console.log("log fetched from history");
queryLoop(db);
resolve();
});
});
})
.then(() => { .then(() => {
// Metrics output // Metrics output
setInterval(() => { setInterval(() => {
seconds ++; seconds ++;
if(seconds % 10 === 0) { if(seconds % 10 === 0) {
console.log(`--> Average of ${lastTenSeconds/10} q/s in the last 10 seconds`) console.log(`--> Average of ${lastTenSeconds/10} q/s in the last 10 seconds`);
if(lastTenSeconds === 0) if(lastTenSeconds === 0)
throw new Error("Problems!"); throw new Error("Problems!");
lastTenSeconds = 0 lastTenSeconds = 0;
} }
console.log(`${queriesPerSecond} queries per second, ${totalQueries} queries in ${seconds} seconds`) console.log(`${queriesPerSecond} queries per second, ${totalQueries} queries in ${seconds} seconds`);
queriesPerSecond = 0; queriesPerSecond = 0;
}, 1000); }, 1000);
}) })