Open-Harbor/osrm-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

Small fixes for osrm-runner

Browse Source
This commit is contained in:
Patrick Niklaus 2017-05-31 00:03:06 +00:00 committed by Patrick Niklaus
parent 0266c9d969
commit 51bf9c4ff2
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
scripts/osrm-runner.js
View File

@ -1,5 +1,7 @@
#!/usr/bin/env node #!/usr/bin/env node
'use strict';
const fs = require('fs'); const fs = require('fs');
const http = require('http'); const http = require('http');
const process = require('process'); const process = require('process');
@ -7,12 +9,11 @@ const cla = require('command-line-args');
const clu = require('command-line-usage'); const clu = require('command-line-usage');
const ansi = require('ansi-escape-sequences'); const ansi = require('ansi-escape-sequences');
const turf = require('turf'); const turf = require('turf');
const util = require('util');
const jp = require('jsonpath'); const jp = require('jsonpath');
const run_query = (query_options, filters, callback) => { const run_query = (query_options, filters, callback) => {
let tic = () => 0.; let tic = () => 0.;
let req = http.request(query_options, function (res) { http.request(query_options, function (res) {
let body = '', ttfb = tic(); let body = '', ttfb = tic();
if (res.statusCode != 200) if (res.statusCode != 200)
return callback(query_options.path, res.statusCode, ttfb); return callback(query_options.path, res.statusCode, ttfb);
@ -27,12 +28,12 @@ const run_query = (query_options, filters, callback) => {
Promise.all(filters.map(filter => jp.query(json, filter))) Promise.all(filters.map(filter => jp.query(json, filter)))
.then(values => callback(query_options.path, res.statusCode, ttfb, elapsed, values)); .then(values => callback(query_options.path, res.statusCode, ttfb, elapsed, values));
}); });
}).on('socket', function (res) { }).on('socket', function (/*res*/) {
tic = ((toc) => { return () => process.hrtime(toc)[1] / 1000000; })(process.hrtime()); tic = ((toc) => { return () => process.hrtime(toc)[1] / 1000000; })(process.hrtime());
}).on('error', function (res) { }).on('error', function (res) {
callback(query_options.path, res.code); callback(query_options.path, res.code);
}).end(); }).end();
} };
function generate_points(polygon, number) { function generate_points(polygon, number) {
let query_points = []; let query_points = [];