RanchiMall/flocore-node
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Address Service: Limit the number of simultaneous requests

Browse Source
This commit is contained in:
Braydon Fuller 2016-02-02 13:27:45 -05:00
parent ca19994326
commit 93e5dbfc34
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/services/address/constants.js
View File

@ -49,6 +49,8 @@ exports.MAX_OUTPUTS_QUERY_LENGTH = 50000;
exports.MAX_HISTORY_QUERY_LENGTH = 100; exports.MAX_HISTORY_QUERY_LENGTH = 100;
// The maximum number of addresses that can be queried at once // The maximum number of addresses that can be queried at once
exports.MAX_ADDRESSES_QUERY = 10000; exports.MAX_ADDRESSES_QUERY = 10000;
// The maximum number of simultaneous requests
exports.MAX_ADDRESSES_LIMIT = 50;
module.exports = exports; module.exports = exports;

4
lib/services/address/history.js
View File

@ -24,6 +24,7 @@ function AddressHistory(args) {
this.maxHistoryQueryLength = args.options.maxHistoryQueryLength || constants.MAX_HISTORY_QUERY_LENGTH; this.maxHistoryQueryLength = args.options.maxHistoryQueryLength || constants.MAX_HISTORY_QUERY_LENGTH;
this.maxAddressesQuery = args.options.maxAddressesQuery || constants.MAX_ADDRESSES_QUERY; this.maxAddressesQuery = args.options.maxAddressesQuery || constants.MAX_ADDRESSES_QUERY;
this.maxAddressesLimit = args.options.maxAddressesLimit || constants.MAX_ADDRESSES_LIMIT;
this.addressStrings = []; this.addressStrings = [];
for (var i = 0; i < this.addresses.length; i++) { for (var i = 0; i < this.addresses.length; i++) {
@ -89,8 +90,9 @@ AddressHistory.prototype.get = function(callback) {
} else { } else {
var opts = _.clone(this.options); var opts = _.clone(this.options);
opts.fullTxList = true; opts.fullTxList = true;
async.map( async.mapLimit(
self.addresses, self.addresses,
self.maxAddressesLimit,
function(address, next) { function(address, next) {
self.node.services.address.getAddressSummary(address, opts, next); self.node.services.address.getAddressSummary(address, opts, next);
}, },