[mesos] branch master updated: Added more logging to `DynamicReservationFramework`.

[bm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

bmahler pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/mesos.git


The following commit(s) were added to refs/heads/master by this push:
     new edec94a  Added more logging to `DynamicReservationFramework`.
edec94a is described below

commit edec94a60d7816c4e0da0e142e682ad75ced39e4
Author: Meng Zhu <mz...@mesosphere.io>
AuthorDate: Thu Sep 20 13:12:32 2018 -0700

    Added more logging to `DynamicReservationFramework`.
    
    This would help to investigate MESOS-5804.
    
    Review: https://reviews.apache.org/r/68773/
---
 src/examples/dynamic_reservation_framework.cpp | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/examples/dynamic_reservation_framework.cpp b/src/examples/dynamic_reservation_framework.cpp
index 9c21725..f9c7dfe 100644
--- a/src/examples/dynamic_reservation_framework.cpp
+++ b/src/examples/dynamic_reservation_framework.cpp
@@ -96,8 +96,8 @@ public:
                               const vector<Offer>& offers) override
   {
     foreach (const Offer& offer, offers) {
-      LOG(INFO) << "Received offer " << offer.id() << " with "
-                << offer.resources();
+      LOG(INFO) << "Received offer " << offer.id() << " from agent "
+                << offer.slave_id() << " with " << offer.resources();
 
       // If the framework got this offer for the first time, the state is
       // `State::INIT`; framework will reserve it (sending RESERVE operation
@@ -150,7 +150,9 @@ public:
           Resources resources = offer.resources();
           Resources reserved = resources.reserved(role);
 
-          CHECK(reserved.contains(taskResources));
+          CHECK(reserved.contains(taskResources))
+            << "Reserved " << reserved << " does not contain taskResources "
+            << taskResources << " states " << stringify(states);
 
           // If all tasks were launched, unreserve those resources.
           if (tasksLaunched == totalTasks) {