Skip to content

Commit 5e28aa9

Browse files
global: remove socket limit - fixes #522
1 parent 98a2153 commit 5e28aa9

3 files changed

Lines changed: 15 additions & 3 deletions

File tree

lib/common/util.js

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,11 @@
2323

2424
var extend = require('extend');
2525
var GoogleAuth = require('google-auth-library');
26-
var request = require('request');
26+
var request = require('request').defaults({
27+
pool: {
28+
maxSockets: Infinity
29+
}
30+
});
2731
var nodeutil = require('util');
2832
var uuid = require('node-uuid');
2933

lib/datastore/request.js

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,11 @@
2121
'use strict';
2222

2323
var streamEvents = require('stream-events');
24-
var request = require('request');
24+
var request = require('request').defaults({
25+
pool: {
26+
maxSockets: Infinity
27+
}
28+
});
2529
var through = require('through2');
2630

2731
/**

lib/storage/file.js

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,11 @@ var crypto = require('crypto');
2727
var duplexify = require('duplexify');
2828
var fs = require('fs');
2929
var once = require('once');
30-
var request = require('request');
30+
var request = require('request').defaults({
31+
pool: {
32+
maxSockets: Infinity
33+
}
34+
});
3135
var streamEvents = require('stream-events');
3236
var through = require('through2');
3337

0 commit comments

Comments
 (0)