You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by ji...@apache.org on 2016/06/16 17:47:59 UTC

[2/5] mesos git commit: Added a metrics prefix for registrar replicated log.

Added a metrics prefix for registrar replicated log.

Review: https://reviews.apache.org/r/48802


Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/c6bf6838
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/c6bf6838
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/c6bf6838

Branch: refs/heads/metrics_replicated_log
Commit: c6bf68386e0a5e975a396f8fd450970f62ebf4d1
Parents: 14858cd
Author: Jie Yu <yu...@gmail.com>
Authored: Wed Jun 15 22:31:08 2016 -0700
Committer: Jie Yu <yu...@gmail.com>
Committed: Thu Jun 16 10:29:04 2016 -0700

----------------------------------------------------------------------
 src/local/local.cpp | 3 ++-
 src/master/main.cpp | 6 ++++--
 2 files changed, 6 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mesos/blob/c6bf6838/src/local/local.cpp
----------------------------------------------------------------------
diff --git a/src/local/local.cpp b/src/local/local.cpp
index 8f84b54..0f7d565 100644
--- a/src/local/local.cpp
+++ b/src/local/local.cpp
@@ -213,7 +213,8 @@ PID<Master> launch(const Flags& flags, Allocator* _allocator)
           1,
           path::join(flags.work_dir.get(), "replicated_log"),
           set<UPID>(),
-          flags.log_auto_initialize);
+          flags.log_auto_initialize,
+          "registrar");
       storage = new mesos::state::LogStorage(log);
     } else {
       EXIT(EXIT_FAILURE)

http://git-wip-us.apache.org/repos/asf/mesos/blob/c6bf6838/src/master/main.cpp
----------------------------------------------------------------------
diff --git a/src/master/main.cpp b/src/master/main.cpp
index 9163205..868f0b5 100644
--- a/src/master/main.cpp
+++ b/src/master/main.cpp
@@ -412,14 +412,16 @@ int main(int argc, char** argv)
           flags.zk_session_timeout,
           path::join(url.get().path, "log_replicas"),
           url.get().authentication,
-          flags.log_auto_initialize);
+          flags.log_auto_initialize,
+          "registrar");
     } else {
       // Use replicated log without ZooKeeper.
       log = new Log(
           1,
           path::join(flags.work_dir.get(), "replicated_log"),
           set<UPID>(),
-          flags.log_auto_initialize);
+          flags.log_auto_initialize,
+          "registrar");
     }
     storage = new LogStorage(log);
   } else {