Repository: incubator-quickstep Updated Branches: refs/heads/multi-shiftboss-test 845e8eeca -> 6bd5f582c
A better debug log for worker. Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/6bd5f582 Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/6bd5f582 Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/6bd5f582 Branch: refs/heads/multi-shiftboss-test Commit: 6bd5f582c4d3be78221dd2a42a434de162f95699 Parents: 845e8ee Author: Zuyu Zhang <zu...@apache.org> Authored: Thu Nov 17 15:10:03 2016 -0800 Committer: Zuyu Zhang <zu...@apache.org> Committed: Thu Nov 17 15:10:03 2016 -0800 ---------------------------------------------------------------------- query_execution/Worker.cpp | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/6bd5f582/query_execution/Worker.cpp ---------------------------------------------------------------------- diff --git a/query_execution/Worker.cpp b/query_execution/Worker.cpp index 31eb964..ec6c503 100644 --- a/query_execution/Worker.cpp +++ b/query_execution/Worker.cpp @@ -107,7 +107,14 @@ void Worker::sendWorkOrderCompleteMessage(const tmb::client_id receiver, static_cast<const void *>(proto_bytes), proto_length, message_type); std::free(proto_bytes); - DLOG(INFO) << "Worker sent WorkOrderCompleteMessage (typed '" << message_type + DLOG(INFO) << "Worker" +#ifdef QUICKSTEP_DISTRIBUTED + << " in Shiftboss " << shiftboss_index_ +#endif // QUICKSTEP_DISTRIBUTED + << " sent " + << (message_type == kWorkOrderCompleteMessage ? "WorkOrderCompleteMessage" + : "RebuildWorkOrderCompleteMessage") + << " (typed '" << message_type << "') to Scheduler with TMB client ID " << receiver; const tmb::MessageBus::SendStatus send_status = QueryExecutionUtil::SendTMBMessage(
