in spec/TestingHelper.js [450:471]
static async getRequestGridIdx(message='Get') {
if (!TestingHelper._logReaders)
throw 'Logs are not enabled for the cluster';
let res = -1
for(let [id, logReader] of TestingHelper._logReaders) {
if (!logReader)
continue;
let req = null;
do {
req = await logReader.nextRequest();
TestingHelper.logDebug('Node' + id +': Got ' + req + ', looking for ' + message);
if (req === message)
res = id;
} while (req != null);
}
TestingHelper.logDebug('Request "' + message + '" node: ' + res);
return res;
}