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/4286d75e Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/4286d75e Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/4286d75e Branch: refs/heads/exact-filter Commit: 4286d75ec622ac6e60813c6892b131660ce3a931 Parents: a31dde4 Author: Zuyu Zhang <zu...@apache.org> Authored: Sun Nov 27 11:45:28 2016 -0800 Committer: Zuyu Zhang <zu...@apache.org> Committed: Sun Nov 27 11:45:28 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/4286d75e/query_execution/Worker.cpp ---------------------------------------------------------------------- diff --git a/query_execution/Worker.cpp b/query_execution/Worker.cpp index 31eb964..9a548fd 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 " << worker_thread_index_ +#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(
