Commit 370ac7a9 authored by David COME's avatar David COME
Browse files

Removed the logging closingTime for reading and add the actuel measure for writing

parent ad954fc0
......@@ -150,7 +150,6 @@ void DiskReadTask::circulateAllBlocks(size_t fromBlockId){
void DiskReadTask::logWithStat(int level,const std::string& msg,log::LogContext& lc){
log::ScopedParamContainer params(lc);
params.add("transferTime", m_stats.transferTime)
.add("closingTime", m_stats.closingTime)
.add("checksumingTime",m_stats.checksumingTime)
.add("waitDataTime",m_stats.waitDataTime)
.add("waitReportingTime",m_stats.waitReportingTime)
......
......@@ -162,7 +162,6 @@ logWithStat(int level, const std::string& message){
.add("threadWaitReportingTime",m_threadStat.waitReportingTime)
.add("threadCheckingErrorTime",m_threadStat.checkingErrorTime)
.add("threadOpeningTime",m_threadStat.openingTime)
.add("threadClosingTime", m_threadStat.closingTime)
.add("threaDataVolumeInMB", 1.0*m_threadStat.dataVolume/1024/1024)
.add("threadPayloadTransferSpeedMB/s",
1.0*m_threadStat.dataVolume/1024/1024/m_threadStat.transferTime);
......
......@@ -83,11 +83,12 @@ bool DiskWriteTask::execute(RecallReportPacker& reporter,log::LogContext& lc) {
//A close is done in WriteFile's destructor, but it may lead to some
//silent data loss
ourFile.close();
m_stats.closingTime +=localTime.secs(utils::Timer::resetCounter);
break;
}
} //end of while(1)
reporter.reportCompletedJob(*m_recallingFile,checksum);
m_stats.waitReportingTime+=localTime.secs(utils::Timer::resetCounter);;
m_stats.waitReportingTime+=localTime.secs(utils::Timer::resetCounter);
logWithStat(LOG_DEBUG, "File successfully transfered to disk",lc);
return true;
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment