YUKI Hiroshi
null+****@clear*****
Wed Apr 1 15:53:31 JST 2015
YUKI Hiroshi 2015-04-01 15:53:31 +0900 (Wed, 01 Apr 2015) New Revision: 37cf58f8ed42b57cdf77557b7432ae0ac5e3475c https://github.com/droonga/express-droonga/commit/37cf58f8ed42b57cdf77557b7432ae0ac5e3475c Message: Ignore engine nodes which have unprocessed write messages Modified files: lib/serf/client.js Modified: lib/serf/client.js (+6 -0) =================================================================== --- lib/serf/client.js 2015-03-26 18:35:13 +0900 (e8ffd16) +++ lib/serf/client.js 2015-04-01 15:53:31 +0900 (8c10653) @@ -82,6 +82,12 @@ Client.prototype = { member.Tags.role != 'service-provider') return false; + var name = member.Name; + if (members.some(function(member) { + return member.Tags["have-unprocessed-messages-for-" + name] == "true"; + })) + return false; + var matched = String(member.Name).match(ENGINE_NODE_NAME_PATTERN); if (matched) member.HostName = matched[1]; -------------- next part -------------- HTML����������������������������... Télécharger