You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by be...@apache.org on 2015/02/11 08:34:18 UTC

mesos git commit: Additional logging in libprocess.

Repository: mesos
Updated Branches:
  refs/heads/master 1ee35b164 -> 0c2ccb64e


Additional logging in libprocess.

Log when we drop a message since we can't find the local recipient.
Include details of what was lost in a send failure.

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


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

Branch: refs/heads/master
Commit: 0c2ccb64ece54e0a72f670795ffdbe48cf30edc4
Parents: 1ee35b1
Author: Cody Maloney <co...@mesosphere.io>
Authored: Tue Feb 10 23:34:04 2015 -0800
Committer: Benjamin Hindman <be...@gmail.com>
Committed: Tue Feb 10 23:34:05 2015 -0800

----------------------------------------------------------------------
 3rdparty/libprocess/src/process.cpp | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mesos/blob/0c2ccb64/3rdparty/libprocess/src/process.cpp
----------------------------------------------------------------------
diff --git a/3rdparty/libprocess/src/process.cpp b/3rdparty/libprocess/src/process.cpp
index a1d9121..425120b 100644
--- a/3rdparty/libprocess/src/process.cpp
+++ b/3rdparty/libprocess/src/process.cpp
@@ -1543,7 +1543,8 @@ void send_connect(
 {
   if (future.isDiscarded() || future.isFailed()) {
     if (future.isFailed()) {
-      VLOG(1) << "Failed to send, connect: " << future.failure();
+      VLOG(1) << "Failed to send '" << message->name << "' to '"
+              << message->to.address << "', connect: " << future.failure();
     }
     socket_manager->close(*socket);
     delete socket;
@@ -2113,6 +2114,7 @@ bool ProcessManager::deliver(
   if (ProcessReference receiver = use(to)) {
     return deliver(receiver, event, sender);
   }
+  VLOG(1) << "Dropped / Lost event for PID: " << to;
 
   delete event;
   return false;