OPENTECH / yoho-node-ci · Commits

Go to a project

Authored by 郝肖肖
Commit 295844dbbf708581ca8bc23b871b85561c2937f1 1 parent 8e09dfe0

'flx'

Inline Side-by-side
Showing 2 changed files with 6 additions and 6 deletions
... ... @@ -11,7 +11,7 @@ class ZookeeperModel extends model {
return await DegradeServer.findAll();
}
async setPath(path, val) {
let degradeServer = await DegradeServer.findAll();
let degradeServer = await this.getConfigAll();
let results = await Promise.all(_.map(degradeServer, item => {
return zookeeperHelpers.creator(`${item.ip}:${item.port}`, path, val, true);
}));
... ... @@ -19,7 +19,7 @@ class ZookeeperModel extends model {
return results && results[0] || false; // return Boolean
}
async getPath(path) {
let degradeServer = await DegradeServer.findAll();
let degradeServer = await this.getConfigAll();
if (degradeServer[0]) {
return await zookeeperHelpers.getter(`${degradeServer[0].ip}:${degradeServer[0].port}`, path);
... ...
... ... @@ -33,12 +33,12 @@ const creator = (server, path, value, iscover) => new Promise((resolve, reject)
client.once('connected', function () {
_exists(client, path).then(stat => {
if (stat && iscover) {
client.setData(path, new Buffer(val.toString()), function(err, data, stat) {
client.setData(path, new Buffer(value.toString()), function(err, data, stat) {
if (err) {
console.log('update path %s data error');
resolve(false);
} else {
console.log('path %s data change to', path, val);
console.log('path %s data change to', path, value);
resolve(true);
}
});
... ... @@ -92,7 +92,7 @@ const getter = (server, path) => new Promise((resolve, reject) => {
client.connect();
});
const setter = (server, path, val) => new Promise((resolve, reject) => {
const setter = (server, path, value) => new Promise((resolve, reject) => {
const client = zookeeper.createClient(server);
client.once('connected', function () {
... ... @@ -103,7 +103,7 @@ const setter = (server, path, val) => new Promise((resolve, reject) => {
console.log('update path %s data error');
resolve(false);
} else {
console.log('path %s data change to', path, val);
console.log('path %s data change to', path, value);
resolve(true);
}
... ...