1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99
|
/******************************************************************************
*
* Copyright (C) 2002 Hugo PEREIRA <mailto: hugo.pereira@free.fr>
*
* This is free software; you can redistribute it and/or modify it under the
* terms of the GNU General Public License as published by the Free Software
* Foundation; either version 2 of the License, or (at your option) any later
* version.
*
* This software is distributed in the hope that it will be useful, but WITHOUT
* Any WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* for more details.
*
* You should have received a copy of the GNU General Public License along with
* this program. If not, see <http://www.gnu.org/licenses/>.
*
*******************************************************************************/
#include "JobRecord.h"
#include "Debug.h"
//_____________________________________________________
bool JobRecord::updateJob( const Job& job )
{
Debug::Throw( "JobRecord::updateJob.\n" );
if( job.id() != job_.id() ) return false;
// update job
job_.updateFrom( job );
// update current record
current_ = Record( job_ );
// update max record
max_.cpu_ = qMax( max_.cpu_, current_.cpu_ );
max_.memory_ = qMax( max_.memory_, current_.memory_ );
// update samples
records_.add( current_ );
return true;
}
//_____________________________________________________
JobRecord::Record::Record( const Job& job ):
Counter( "Record" ),
virtualMemory_( job.virtualMemory() ),
residentMemory_( job.residentMemory() ),
sharedMemory_( job.sharedMemory() ),
cpu_( job.cpu() ),
memory_( job.memory() )
{ Debug::Throw( "JobRecord::Record::Record.\n" ); }
//___________________________________________
void JobRecord::Samples::setSampleSize( const int& size )
{
Debug::Throw() << "JobRecord::Samples::setSampleSize - " << size << endl;
sampleSize_ = size;
while( sampleList_.size() > sampleSize_ )
{ sampleList_.removeFirst(); }
}
//________________________________________________
void JobRecord::Samples::setMaxLength( int length )
{
Debug::Throw() << "JobRecord::Samples::setMaxLength: " << length << endl;
maxLength_ = length;
while( recordList_.size() > maxLength_ )
{ recordList_.removeFirst(); }
}
//________________________________________________
void JobRecord::Samples::add( const JobRecord::Record& record )
{
// add data to samples
sampleList_ << record;
// check size
if( sampleList_.size() > sampleSize_ )
{
sampleList_.removeFirst();
Record sum;
foreach( const Record& record, sampleList_ )
{ sum += record; }
sum = sum.divide( sampleSize_ );
recordList_ << sum;
if( recordList_.size() > maxLength_ ) recordList_.removeFirst();
}
return;
}
|