...
|
...
|
@@ -5,11 +5,11 @@ import zookeeper from 'node-zookeeper-client'; |
|
|
|
|
|
import creator from './creator';
|
|
|
|
|
|
const getter = (client, path, resolve, reject) => {
|
|
|
const getter = (server, client, path, resolve, reject) => {
|
|
|
client.exists(path, (err, stat) => {
|
|
|
if (err) {
|
|
|
console.log('path %s exits error', path, err.stack);
|
|
|
resolve(true);
|
|
|
resolve(false);
|
|
|
return;
|
|
|
}
|
|
|
|
...
|
...
|
@@ -22,18 +22,18 @@ const getter = (client, path, resolve, reject) => { |
|
|
}
|
|
|
client.close();
|
|
|
|
|
|
resolve((data && data.toString('utf8') === 'false') ? false : true);
|
|
|
resolve((data && data.toString('utf8') === 'true') ? true : false);
|
|
|
}
|
|
|
)
|
|
|
} else {
|
|
|
// 不存在的路径
|
|
|
console.log('no path %s, we will create it with value "true" automatic', path);
|
|
|
console.log('no path %s, we will create it with value "false" automatic', path);
|
|
|
client.close();
|
|
|
|
|
|
// create path
|
|
|
creator(path);
|
|
|
creator(server, path);
|
|
|
|
|
|
resolve(true);
|
|
|
resolve(false);
|
|
|
}
|
|
|
});
|
|
|
|
...
|
...
|
@@ -43,7 +43,7 @@ module.exports = (server, path) => new Promise((resolve, reject) => { |
|
|
const client = zookeeper.createClient(server);
|
|
|
|
|
|
client.once('connected', () => {
|
|
|
getter(client, path, resolve, reject);
|
|
|
getter(server, client, path, resolve, reject);
|
|
|
});
|
|
|
|
|
|
client.connect();
|
...
|
...
|
|