void DimWriteStatistics::UpdateService ( )

private

Main loop.

Updates the service. This is the function executed by the thread.

Definition at line 154 of file DimWriteStatistics.cc.

References data, MessageImp::Debug(), fBaseSize, fDebug, fDimService, fLog, fOpenedFiles, DimWriteStatistics::Stats::freeSpace, fStats, fUpdateInterval, GetFileSizeOnDisk(), GetFreeSpace(), DimWriteStatistics::Stats::rateWritten, DimDescribedService::setData(), DimWriteStatistics::Stats::sizeWritten, str, DimWriteStatistics::Stats::timeElapsed, and DimDescribedService::Update().

Referenced by DimWriteStatistics().

{
    Time previousTime;
    uint64_t previousSize = 0;

    while (1)
    {
        if (fUpdateInterval==0)
        {
            boost::this_thread::interruption_point();
            boost::this_thread::yield();
            continue;
        }

        Stats data;

        for (set<string>::const_iterator it = fOpenedFiles.begin(); it != fOpenedFiles.end(); it++)
            data.sizeWritten += GetFileSizeOnDisk(*it);
        data.sizeWritten -= fBaseSize;

        const Time cTime = Time();

        data.freeSpace   = GetFreeSpace();
        data.rateWritten = data.sizeWritten-previousSize;
        data.timeElapsed = (cTime - previousTime).total_milliseconds();

        previousSize = data.sizeWritten;
        previousTime = cTime;

        fDimService.setData(data);
        fDimService.Update(cTime);

        fStats = data;

        if (fDebug)
        {
            ostringstream str;
            str << "Written: " << fStats.sizeWritten/1000 << " kB; writing rate: ";
            str << fStats.rateWritten/fStats.timeElapsed << " kB/s; free space: ";
            str << fStats.freeSpace/1000000 << " MB";
            fLog.Debug(str);
        }

        boost::this_thread::sleep(milliseconds(fUpdateInterval));
    }
}

Here is the call graph for this function:

Here is the caller graph for this function: