[Groonga-commit] droonga/express-droonga at 37cf58f [master] Ignore engine nodes which have unprocessed write messages

Back to archive index

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 



More information about the Groonga-commit mailing list
Back to archive index