Repository: mesos Updated Branches: refs/heads/master 999aaf0f5 -> 2c2796a81
Added a few master log lines. - On the agent (re)-registration code paths. - Could be helpful for triaging performance issues. Review: https://reviews.apache.org/r/59434 Project: http://git-wip-us.apache.org/repos/asf/mesos/repo Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/2c2796a8 Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/2c2796a8 Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/2c2796a8 Branch: refs/heads/master Commit: 2c2796a81fca3b5ad3a68ffda6a960ff6397587e Parents: 999aaf0 Author: Jiang Yan Xu <xuj...@apple.com> Authored: Sun May 21 22:23:35 2017 -0700 Committer: Jiang Yan Xu <xuj...@apple.com> Committed: Tue May 23 17:26:14 2017 -0700 ---------------------------------------------------------------------- src/master/master.cpp | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mesos/blob/2c2796a8/src/master/master.cpp ---------------------------------------------------------------------- diff --git a/src/master/master.cpp b/src/master/master.cpp index 1c89a11..f02d388 100644 --- a/src/master/master.cpp +++ b/src/master/master.cpp @@ -5486,6 +5486,9 @@ void Master::_registerSlave( return; } + VLOG(1) << "Authorized registration of agent at " << pid + << " (" << slaveInfo.hostname() << ")"; + MachineID machineId; machineId.set_hostname(slaveInfo.hostname()); machineId.set_ip(stringify(pid.address.ip)); @@ -5609,6 +5612,9 @@ void Master::__registerSlave( return; } + VLOG(1) << "Admitted agent " << slaveInfo.id() << " at " << pid + << " (" << slaveInfo.hostname() << ")"; + MachineID machineId; machineId.set_hostname(slaveInfo.hostname()); machineId.set_ip(stringify(pid.address.ip)); @@ -5775,6 +5781,9 @@ void Master::_reregisterSlave( return; } + VLOG(1) << "Authorized re-registration of agent " << slaveInfo.id() + << " at " << pid << " (" << slaveInfo.hostname() << ")"; + MachineID machineId; machineId.set_hostname(slaveInfo.hostname()); machineId.set_ip(stringify(pid.address.ip)); @@ -5943,7 +5952,8 @@ void Master::__reregisterSlave( // `MarkSlaveReachable` registry operation should never fail. CHECK(readmit.get()); - // Re-admission succeeded. + VLOG(1) << "Re-admitted agent " << slaveInfo.id() << " at " << pid + << " (" << slaveInfo.hostname() << ")"; // Ensure we don't remove the slave for not re-registering after // we've recovered it from the registry.
