LOG only in the debug mode for BlockLocator.
Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/e50a2b7a Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/e50a2b7a Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/e50a2b7a Branch: refs/heads/mark_single_node_query Commit: e50a2b7aaed97f3282c338be0b36071a5cffd523 Parents: 5ff89dd Author: Zuyu Zhang <zu...@apache.org> Authored: Sat Dec 3 21:24:25 2016 -0800 Committer: Zuyu Zhang <zu...@apache.org> Committed: Sat Dec 3 21:24:25 2016 -0800 ---------------------------------------------------------------------- query_execution/BlockLocator.cpp | 48 ++++++++++++------------ query_execution/QueryManagerDistributed.cpp | 4 +- 2 files changed, 26 insertions(+), 26 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/e50a2b7a/query_execution/BlockLocator.cpp ---------------------------------------------------------------------- diff --git a/query_execution/BlockLocator.cpp b/query_execution/BlockLocator.cpp index 81684ba..5de6a54 100644 --- a/query_execution/BlockLocator.cpp +++ b/query_execution/BlockLocator.cpp @@ -55,8 +55,8 @@ void BlockLocator::run() { const tmb::AnnotatedMessage annotated_message = bus_->Receive(locator_client_id_, 0, true); const TaggedMessage &tagged_message = annotated_message.tagged_message; const client_id sender = annotated_message.sender; - LOG(INFO) << "BlockLocator received the typed '" << tagged_message.message_type() - << "' message from TMB Client " << sender; + DLOG(INFO) << "BlockLocator received the typed '" << tagged_message.message_type() + << "' message from TMB Client " << sender; switch (tagged_message.message_type()) { case kBlockDomainRegistrationMessage: { serialization::BlockDomainRegistrationMessage proto; @@ -77,9 +77,9 @@ void BlockLocator::run() { DCHECK_EQ(result_block_locations.second, result_domain_blocks.second); if (result_domain_blocks.second) { - LOG(INFO) << "Block " << BlockIdUtil::ToString(block) << " loaded in Domain " << domain; + DLOG(INFO) << "Block " << BlockIdUtil::ToString(block) << " loaded in Domain " << domain; } else { - LOG(INFO) << "Block " << BlockIdUtil::ToString(block) << " existed in Domain " << domain; + DLOG(INFO) << "Block " << BlockIdUtil::ToString(block) << " existed in Domain " << domain; } break; } @@ -95,9 +95,9 @@ void BlockLocator::run() { block_locations_[block].erase(domain); domain_blocks_[domain].erase(block); - LOG(INFO) << "Block " << BlockIdUtil::ToString(block) << " evicted in Domain " << domain; + DLOG(INFO) << "Block " << BlockIdUtil::ToString(block) << " evicted in Domain " << domain; } else { - LOG(INFO) << "Block " << BlockIdUtil::ToString(block) << " not found in Domain " << domain; + DLOG(INFO) << "Block " << BlockIdUtil::ToString(block) << " not found in Domain " << domain; } break; } @@ -128,7 +128,7 @@ void BlockLocator::run() { } domain_blocks_.erase(domain); - LOG(INFO) << "Unregistered Domain " << domain; + DLOG(INFO) << "Unregistered Domain " << domain; break; } case kPoisonMessage: { @@ -153,14 +153,14 @@ void BlockLocator::processBlockDomainRegistrationMessage(const client_id receive CHECK(proto.SerializeToArray(proto_bytes, proto_length)); TaggedMessage message(static_cast<const void*>(proto_bytes), - proto_length, - kBlockDomainRegistrationResponseMessage); + proto_length, + kBlockDomainRegistrationResponseMessage); free(proto_bytes); - LOG(INFO) << "BlockLocator (id '" << locator_client_id_ - << "') sent BlockDomainRegistrationResponseMessage (typed '" - << kBlockDomainRegistrationResponseMessage - << "') to Worker (id '" << receiver << "')"; + DLOG(INFO) << "BlockLocator (id '" << locator_client_id_ + << "') sent BlockDomainRegistrationResponseMessage (typed '" + << kBlockDomainRegistrationResponseMessage + << "') to TMB Client (id '" << receiver << "')"; CHECK(tmb::MessageBus::SendStatus::kOK == QueryExecutionUtil::SendTMBMessage(bus_, locator_client_id_, @@ -181,13 +181,13 @@ void BlockLocator::processLocateBlockMessage(const client_id receiver, CHECK(proto.SerializeToArray(proto_bytes, proto_length)); TaggedMessage message(static_cast<const void*>(proto_bytes), - proto_length, - kLocateBlockResponseMessage); + proto_length, + kLocateBlockResponseMessage); free(proto_bytes); - LOG(INFO) << "BlockLocator (id '" << locator_client_id_ - << "') sent LocateBlockResponseMessage (typed '" << kLocateBlockResponseMessage - << "') to StorageManager (id '" << receiver << "')"; + DLOG(INFO) << "BlockLocator (id '" << locator_client_id_ + << "') sent LocateBlockResponseMessage (typed '" << kLocateBlockResponseMessage + << "') to StorageManager (id '" << receiver << "')"; CHECK(tmb::MessageBus::SendStatus::kOK == QueryExecutionUtil::SendTMBMessage(bus_, locator_client_id_, @@ -208,14 +208,14 @@ void BlockLocator::processGetPeerDomainNetworkAddressesMessage(const client_id r CHECK(proto.SerializeToArray(proto_bytes, proto_length)); TaggedMessage message(static_cast<const void*>(proto_bytes), - proto_length, - kGetPeerDomainNetworkAddressesResponseMessage); + proto_length, + kGetPeerDomainNetworkAddressesResponseMessage); free(proto_bytes); - LOG(INFO) << "BlockLocator (id '" << locator_client_id_ - << "') sent GetPeerDomainNetworkAddressesResponseMessage (typed '" - << kGetPeerDomainNetworkAddressesResponseMessage - << "') to StorageManager (id '" << receiver << "')"; + DLOG(INFO) << "BlockLocator (id '" << locator_client_id_ + << "') sent GetPeerDomainNetworkAddressesResponseMessage (typed '" + << kGetPeerDomainNetworkAddressesResponseMessage + << "') to StorageManager (id '" << receiver << "')"; CHECK(tmb::MessageBus::SendStatus::kOK == QueryExecutionUtil::SendTMBMessage(bus_, locator_client_id_, http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/e50a2b7a/query_execution/QueryManagerDistributed.cpp ---------------------------------------------------------------------- diff --git a/query_execution/QueryManagerDistributed.cpp b/query_execution/QueryManagerDistributed.cpp index 20650d0..5c7e0d8 100644 --- a/query_execution/QueryManagerDistributed.cpp +++ b/query_execution/QueryManagerDistributed.cpp @@ -176,8 +176,8 @@ bool QueryManagerDistributed::initiateRebuild(const dag_node_index index) { shiftboss_addresses.AddRecipient(shiftboss_directory_->getClientId(i)); } - LOG(INFO) << "ForemanDistributed sent InitiateRebuildMessage (typed '" << kInitiateRebuildMessage - << "') to all Shiftbosses"; + DLOG(INFO) << "ForemanDistributed sent InitiateRebuildMessage (typed '" << kInitiateRebuildMessage + << "') to all Shiftbosses"; QueryExecutionUtil::BroadcastMessage(foreman_client_id_, shiftboss_addresses, move(tagged_msg),
