Fixes: double callbacks and untested headers
This commit is contained in:
committed by
Patrick Niklaus
parent
1bcdc0fa75
commit
bf8e4e8270
@@ -44,8 +44,8 @@ class DB {
|
||||
uid: n.OSM_UID,
|
||||
user: n.OSM_USER,
|
||||
timestamp: n.OSM_TIMESTAMP,
|
||||
lon: n.lon,
|
||||
lat: n.lat
|
||||
lon: ensureDecimal(n.lon),
|
||||
lat: ensureDecimal(n.lat)
|
||||
});
|
||||
|
||||
for (var k in n.tags) {
|
||||
@@ -109,8 +109,8 @@ class Node {
|
||||
this.OSM_USER = OSM_USER;
|
||||
this.OSM_TIMESTAMP = OSM_TIMESTAMP;
|
||||
this.OSM_UID = OSM_UID;
|
||||
this.lon = ensureDecimal(lon);
|
||||
this.lat = ensureDecimal(lat);
|
||||
this.lon = lon;
|
||||
this.lat = lat;
|
||||
this.tags = tags;
|
||||
}
|
||||
|
||||
|
||||
@@ -151,7 +151,6 @@ module.exports = function () {
|
||||
};
|
||||
|
||||
this.writeOSM = (callback) => {
|
||||
|
||||
fs.exists(this.DATA_FOLDER, (exists) => {
|
||||
var mkDirFn = exists ? (cb) => { cb(); } : fs.mkdir.bind(fs.mkdir, this.DATA_FOLDER);
|
||||
mkDirFn((err) => {
|
||||
@@ -329,7 +328,7 @@ module.exports = function () {
|
||||
this.processRowsAndDiff = (table, fn, callback) => {
|
||||
var q = d3.queue(1);
|
||||
|
||||
table.hashes().forEach((row, i) => q.defer(fn, row, i));
|
||||
table.hashes().forEach((row, i) => { q.defer(fn, row, i); });
|
||||
|
||||
q.awaitAll((err, actual) => {
|
||||
if (err) return callback(err);
|
||||
|
||||
@@ -20,7 +20,7 @@ var OSRMBaseLoader = class {
|
||||
});
|
||||
};
|
||||
|
||||
runLaunch(limit((e) => { if (e) callback(e); callback(); }));
|
||||
runLaunch(limit((e) => { if (e) callback(e); else callback(); }));
|
||||
}
|
||||
|
||||
shutdown (callback) {
|
||||
@@ -30,7 +30,7 @@ var OSRMBaseLoader = class {
|
||||
this.osrmDown(cb);
|
||||
};
|
||||
|
||||
runShutdown(limit((e) => { if (e) callback(e); callback(); }));
|
||||
runShutdown(limit((e) => { if (e) callback(e); else callback(); }));
|
||||
}
|
||||
|
||||
osrmIsRunning () {
|
||||
@@ -62,7 +62,7 @@ var OSRMBaseLoader = class {
|
||||
|
||||
waitForShutdown (callback) {
|
||||
var check = () => {
|
||||
if (!this.osrmIsRunning()) callback();
|
||||
if (!this.osrmIsRunning()) return callback();
|
||||
};
|
||||
setTimeout(check, 100);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user