3eac6effbb
https://nodejs.org/api/child_process.html#child_process_event_exit Note that when the 'exit' event is triggered, child process stdio streams might still be open.
53 lines
1.9 KiB
JavaScript
53 lines
1.9 KiB
JavaScript
'use strict';
|
|
|
|
const fs = require('fs');
|
|
const util = require('util');
|
|
const child_process = require('child_process');
|
|
|
|
module.exports = function () {
|
|
// replaces placeholders for in user supplied commands
|
|
this.expandOptions = (options) => {
|
|
let opts = options.slice();
|
|
let table = {
|
|
'{osm_file}': this.inputCacheFile,
|
|
'{processed_file}': this.processedCacheFile,
|
|
'{profile_file}': this.profileFile,
|
|
'{rastersource_file}': this.rasterCacheFile,
|
|
'{speeds_file}': this.speedsCacheFile,
|
|
'{penalties_file}': this.penaltiesCacheFile
|
|
};
|
|
|
|
for (let k in table) {
|
|
opts = opts.replace(k, table[k]);
|
|
}
|
|
|
|
return opts;
|
|
};
|
|
|
|
this.setupOutputLog = (process, log) => {
|
|
if (process.logFunc) {
|
|
process.stdout.removeListener('data', process.logFunc);
|
|
process.stderr.removeListener('data', process.logFunc);
|
|
}
|
|
|
|
process.logFunc = (message) => { log.write(message); };
|
|
process.stdout.on('data', process.logFunc);
|
|
process.stderr.on('data', process.logFunc);
|
|
};
|
|
|
|
this.runBin = (bin, options, env, callback) => {
|
|
let cmd = util.format('%s%s/%s%s%s', this.QQ, this.BIN_PATH, bin, this.EXE, this.QQ);
|
|
let opts = options.split(' ').filter((x) => { return x && x.length > 0; });
|
|
let log = fs.createWriteStream(this.scenarioLogFile, {'flags': 'a'});
|
|
log.write(util.format('*** running %s %s\n', cmd, options));
|
|
// we need to set a large maxbuffer here because we have long running processes like osrm-routed
|
|
// with lots of log output
|
|
let child = child_process.execFile(cmd, opts, {maxBuffer: 1024 * 1024 * 1000, env: env}, callback);
|
|
child.on('exit', function(code) {
|
|
log.write(util.format('*** %s exited with code %d\n', bin, code));
|
|
}.bind(this));
|
|
this.setupOutputLog(child, log);
|
|
return child;
|
|
};
|
|
};
|