Skip to content
This repository has been archived by the owner on Jun 4, 2024. It is now read-only.

Commit

Permalink
Add eslint & fix lint errors
Browse files Browse the repository at this point in the history
  • Loading branch information
brianc committed Jul 15, 2017
1 parent 166ac10 commit 3c8697c
Show file tree
Hide file tree
Showing 25 changed files with 1,074 additions and 1,083 deletions.
10 changes: 10 additions & 0 deletions .eslintrc
Original file line number Diff line number Diff line change
@@ -0,0 +1,10 @@
{
"extends": "standard",
"env": {
"node": true,
"mocha": true
},
"rules": {
"no-new-func": "off"
}
}
56 changes: 27 additions & 29 deletions bench/index.js
Original file line number Diff line number Diff line change
@@ -1,54 +1,52 @@
var pg = require('pg').native
var Native = require('../')

var warmup = function(fn, cb) {
var count = 0;
var max = 10;
var run = function(err) {
if(err) return cb(err);
var warmup = function (fn, cb) {
var count = 0
var max = 10
var run = function (err) {
if (err) return cb(err)

if(max >= count++) {
if (max >= count++) {
return fn(run)
}

cb()
}
run();
run()
}

var native = Native();
native.connectSync();
var native = Native()
native.connectSync()

var queryText = 'SELECT generate_series(0, 1000)';
var client = new pg.Client();
client.connect(function() {
var pure = function(cb) {
client.query(queryText, function(err) {
if(err) throw err;
cb(err);
});
var queryText = 'SELECT generate_series(0, 1000)'
var client = new pg.Client()
client.connect(function () {
var pure = function (cb) {
client.query(queryText, function (err) {
if (err) throw err
cb(err)
})
}
var nativeQuery = function(cb) {
native.query(queryText, function(err) {
if(err) throw err;
cb(err);
});
var nativeQuery = function (cb) {
native.query(queryText, function (err) {
if (err) throw err
cb(err)
})
}

var run = function() {
var run = function () {
var start = Date.now()
warmup(pure, function() {
warmup(pure, function () {
console.log('pure done', Date.now() - start)
start = Date.now()
warmup(nativeQuery, function() {
warmup(nativeQuery, function () {
console.log('native done', Date.now() - start)
})
})
}

setInterval(function() {
setInterval(function () {
run()
}, 500)

});

})
104 changes: 49 additions & 55 deletions bench/leaks.js
Original file line number Diff line number Diff line change
@@ -1,45 +1,39 @@
var Client = require('../');
var async = require('async');

var loop = function() {
var client = new Client();

var connect = function(cb) {
client.connect(cb);
};

var simpleQuery = function(cb) {
client.query('SELECT NOW()', cb);
};

var paramsQuery = function(cb) {
client.query('SELECT $1::text as name', ['Brian'], cb);
};

var prepared = function(cb) {
client.prepare('test', 'SELECT $1::text as name', 1, function(err) {
if(err) return cb(err);
client.execute('test', ['Brian'], cb);
});
};

var error = function(cb) {
client.query('SELECT ASLKJDASLKJD', function() {
cb();
});
};

var sync = function(cb) {
client.querySync('SELECT NOW()');
client.querySync('SELECT $1::text as name', ['Brian']);
client.prepareSync('boom', 'SELECT $1::text as name', 1);
client.executeSync('boom', ['Brian']);
setImmediate(cb);
};

var end = function(cb) {
client.end(cb);
};
var Client = require('../')
var async = require('async')

var loop = function () {
var client = new Client()

var connect = function (cb) {
client.connect(cb)
}

var simpleQuery = function (cb) {
client.query('SELECT NOW()', cb)
}

var paramsQuery = function (cb) {
client.query('SELECT $1::text as name', ['Brian'], cb)
}

var prepared = function (cb) {
client.prepare('test', 'SELECT $1::text as name', 1, function (err) {
if (err) return cb(err)
client.execute('test', ['Brian'], cb)
})
}

var sync = function (cb) {
client.querySync('SELECT NOW()')
client.querySync('SELECT $1::text as name', ['Brian'])
client.prepareSync('boom', 'SELECT $1::text as name', 1)
client.executeSync('boom', ['Brian'])
setImmediate(cb)
}

var end = function (cb) {
client.end(cb)
}

var ops = [
connect,
Expand All @@ -48,16 +42,16 @@ var loop = function() {
prepared,
sync,
end
];

var start = Date.now();
async.series(ops, function(err) {
if(err) throw err;
console.log(Date.now() - start);
setImmediate(loop);
});
};

//on my machine this will consume memory up to about 50 megs of ram
//and then stabalize at that point
loop();
]

var start = Date.now()
async.series(ops, function (err) {
if (err) throw err
console.log(Date.now() - start)
setImmediate(loop)
})
}

// on my machine this will consume memory up to about 50 megs of ram
// and then stabalize at that point
loop()
Loading

0 comments on commit 3c8697c

Please sign in to comment.