From 340a290ceb632e52b321266fb1e18f947e75ffc0 Mon Sep 17 00:00:00 2001 From: ansuz Date: Fri, 6 Sep 2019 14:58:00 +0200 Subject: [PATCH] add names for batched reads for debugging --- historyKeeper.js | 2 +- rpc.js | 12 ++++++------ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/historyKeeper.js b/historyKeeper.js index b84bb8bc3..d90b8c113 100644 --- a/historyKeeper.js +++ b/historyKeeper.js @@ -232,7 +232,7 @@ module.exports.create = function (cfg) { as an added bonus: if the channel exists but its index does not then it caches the index */ - const batchIndexReads = BatchRead(); + const batchIndexReads = BatchRead("HK_GET_INDEX"); const getIndex = (ctx, channelName, cb) => { const chan = ctx.channels[channelName]; // if there is a channel in memory and it has an index cached, return it diff --git a/rpc.js b/rpc.js index 5655061a7..71e267dfd 100644 --- a/rpc.js +++ b/rpc.js @@ -232,7 +232,7 @@ var checkSignature = function (signedMsg, signature, publicKey) { return Nacl.sign.detached.verify(signedBuffer, signatureBuffer, pubBuffer); }; -const batchUserPins = BatchRead(); +const batchUserPins = BatchRead("LOAD_USER_PINS"); var loadUserPins = function (Env, publicKey, cb) { var session = getSession(Env.Sessions, publicKey); @@ -294,7 +294,7 @@ var getUploadSize = function (Env, channel, cb) { // FIXME FILES }); }; -const batchFileSize = BatchRead(); +const batchFileSize = BatchRead("GET_FILE_SIZE"); var getFileSize = function (Env, channel, cb) { if (!isValidId(channel)) { return void cb('INVALID_CHAN'); } batchFileSize(channel, cb, function (done) { @@ -320,7 +320,7 @@ var getFileSize = function (Env, channel, cb) { }); }; -const batchMetadata = BatchRead(); +const batchMetadata = BatchRead("GET_METADATA"); var getMetadata = function (Env, channel, cb) { if (!isValidId(channel)) { return void cb('INVALID_CHAN'); } @@ -478,7 +478,7 @@ var getDeletedPads = function (Env, channels, cb) { }); }; -const batchTotalSize = BatchRead(); +const batchTotalSize = BatchRead("GET_TOTAL_SIZE"); var getTotalSize = function (Env, publicKey, cb) { batchTotalSize(publicKey, cb, function (done) { var bytes = 0; @@ -1614,7 +1614,7 @@ var writePrivateMessage = function (Env, args, nfwssCtx, cb) { }); }; -const batchDiskUsage = BatchRead(); +const batchDiskUsage = BatchRead("GET_DISK_USAGE"); var getDiskUsage = function (Env, cb) { batchDiskUsage('', cb, function (done) { var data = {}; @@ -1643,7 +1643,7 @@ var getDiskUsage = function (Env, cb) { }); }; -const batchRegisteredUsers = BatchRead(); +const batchRegisteredUsers = BatchRead("GET_REGISTERED_USERS"); var getRegisteredUsers = function (Env, cb) { batchRegisteredUsers('', cb, function (done) { var dir = Env.paths.pin;