diff --git a/src/ProtocolManager.cpp b/src/ProtocolManager.cpp index 76c8d20daa73ba4aea930b72b3b109d3c6c1091a..c67f34504d729fdd4cf3c44cc9985c44a6850328 100644 --- a/src/ProtocolManager.cpp +++ b/src/ProtocolManager.cpp @@ -224,31 +224,39 @@ ResponseSP ProtocolManager::prepareMetadata(RequestSP request_sp) response_sp->set_type(Response::METADATA); - Response::Metadata* metadata = response_sp->mutable_metadata(); + Response::Metadata* metadataRes = response_sp->mutable_metadata(); + metadataRes->set_partial(0); + metadataRes->set_total(0); if(m_isAuthorised) { if(m_isValidated) { - metadata->set_state(Response::Metadata::ACCEPTED); - metadata->set_status("Metadata ready"); - metadata->set_partial(0); - metadata->set_total(0); + const Request::Metadata& metadataReq = request_sp->metadata(); + + std::string schema = metadataReq.schema(); + std::string table = metadataReq.table(); + int64_t rawTimestamp = metadataReq.timestamp(); + + std::tm timestamp = *localtime(&rawTimestamp); + + DEBUG_STREAM << "ProtocolManager::prepareMetadata() " + << "schema " << schema << " table " << table << " timestamp " + << asctime(×tamp) << " from " << m_remoteEndpoint << endl; + + metadataRes->set_state(Response::Metadata::ACCEPTED); + metadataRes->set_status("Metadata ready"); } else { - metadata->set_state(Response::Metadata::REJECTED); - metadata->set_status("Not validated"); - metadata->set_partial(0); - metadata->set_total(0); + metadataRes->set_state(Response::Metadata::REJECTED); + metadataRes->set_status("Not validated"); } } else { - metadata->set_state(Response::Metadata::REJECTED); - metadata->set_status("Not authorised"); - metadata->set_partial(0); - metadata->set_total(0); + metadataRes->set_state(Response::Metadata::REJECTED); + metadataRes->set_status("Not authorised"); } return response_sp; diff --git a/src/WorkerThread.cpp b/src/WorkerThread.cpp index 5a696ca7e4dd416387e66de60aa60f87fc8dd461..e3a757bb8140fe4ee3e340d898036bb19d15ca73 100644 --- a/src/WorkerThread.cpp +++ b/src/WorkerThread.cpp @@ -27,7 +27,7 @@ WorkerThread::~WorkerThread() //============================================================================== void WorkerThread::run() { - INFO_STREAM << "WorkerThread::run() STARTING" << endl; + DEBUG_STREAM << "WorkerThread::run() Starting" << endl; while(true) { @@ -51,9 +51,9 @@ void WorkerThread::run() DEBUG_STREAM << "WorkerThread::run() interrupt" << endl; break; } - } //while + } - INFO_STREAM << "WorkerThread::run() STOPPING" << endl; + DEBUG_STREAM << "WorkerThread::run() Stopping" << endl; } } \ No newline at end of file