You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by al...@apache.org on 2017/09/01 08:37:04 UTC
[3/3] mesos git commit: Added several logs to the C++ part of the
v1-v0 adapter.
Added several logs to the C++ part of the v1-v0 adapter.
Review: https://reviews.apache.org/r/61991
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/abad63bc
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/abad63bc
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/abad63bc
Branch: refs/heads/master
Commit: abad63bcd1c69334ceee44e447d9a038ecb4d67c
Parents: 2e161d1
Author: Alexander Rukletsov <al...@apache.org>
Authored: Wed Aug 30 16:04:14 2017 +0200
Committer: Alexander Rukletsov <al...@apache.org>
Committed: Fri Sep 1 10:35:10 2017 +0200
----------------------------------------------------------------------
src/java/jni/org_apache_mesos_v1_scheduler_V0Mesos.cpp | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/abad63bc/src/java/jni/org_apache_mesos_v1_scheduler_V0Mesos.cpp
----------------------------------------------------------------------
diff --git a/src/java/jni/org_apache_mesos_v1_scheduler_V0Mesos.cpp b/src/java/jni/org_apache_mesos_v1_scheduler_V0Mesos.cpp
index 014aabd..0e7716d 100644
--- a/src/java/jni/org_apache_mesos_v1_scheduler_V0Mesos.cpp
+++ b/src/java/jni/org_apache_mesos_v1_scheduler_V0Mesos.cpp
@@ -357,6 +357,8 @@ void V0ToV1AdapterProcess::registered(
const FrameworkID& _frameworkId,
const MasterInfo& masterInfo)
{
+ LOG(INFO) << "Registered with the Mesos master; invoking connected callback";
+
connect();
// We need this copy to populate the fields in `Event::Subscribed` upon
@@ -403,6 +405,9 @@ void V0ToV1AdapterProcess::disconnected()
// - Any outstanding offers are invalidated by the master upon a scheduler
// (re-)registration.
// - Any task status updates could be reconciled by the scheduler.
+ LOG(INFO) << "Dropping " << pending.size() << " pending event(s)"
+ << " because master disconnected";
+
pending = queue<Event>();
subscribeCall = false;
@@ -411,6 +416,9 @@ void V0ToV1AdapterProcess::disconnected()
heartbeatTimer = None();
}
+ LOG(INFO) << "Disconnected with the Mesos master;"
+ << " invoking disconnected callback";
+
disconnect();
}