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(); }