166 lines
2.3 KiB
C++
166 lines
2.3 KiB
C++
|
/*
|
||
|
* This file is a part of Winix
|
||
|
* and is not publicly distributed
|
||
|
*
|
||
|
* Copyright (c) 2012, Tomasz Sowa
|
||
|
* All rights reserved.
|
||
|
*
|
||
|
*/
|
||
|
|
||
|
#include "job.h"
|
||
|
#include "plugin.h"
|
||
|
#include "log.h"
|
||
|
|
||
|
|
||
|
|
||
|
Job::Job()
|
||
|
{
|
||
|
jobs_queue_tab.resize(WINIX_JOBS_HOW_MANY_PRIORITIES);
|
||
|
}
|
||
|
|
||
|
|
||
|
void Job::CheckPriority(int & priority) const
|
||
|
{
|
||
|
if( priority < 0 )
|
||
|
priority = 0;
|
||
|
|
||
|
if( priority >= WINIX_JOBS_HOW_MANY_PRIORITIES )
|
||
|
priority = WINIX_JOBS_HOW_MANY_PRIORITIES - 1;
|
||
|
}
|
||
|
|
||
|
|
||
|
// first thread (objects locked)
|
||
|
void Job::Add(PT::Space & job, int priority)
|
||
|
{
|
||
|
CheckPriority(priority);
|
||
|
jobs_queue_tab[priority].push(job);
|
||
|
WakeUpThread();
|
||
|
}
|
||
|
|
||
|
|
||
|
|
||
|
size_t Job::Size(int priority) const
|
||
|
{
|
||
|
CheckPriority(priority);
|
||
|
return jobs_queue_tab[priority].size();
|
||
|
}
|
||
|
|
||
|
|
||
|
|
||
|
size_t Job::Size() const
|
||
|
{
|
||
|
size_t sum = 0;
|
||
|
|
||
|
for(size_t i=0 ; i<WINIX_JOBS_HOW_MANY_PRIORITIES ; ++i)
|
||
|
sum += Size(i);
|
||
|
|
||
|
return sum;
|
||
|
}
|
||
|
|
||
|
|
||
|
bool Job::Empty(int priority) const
|
||
|
{
|
||
|
CheckPriority(priority);
|
||
|
return jobs_queue_tab[priority].empty();
|
||
|
}
|
||
|
|
||
|
|
||
|
bool Job::Empty() const
|
||
|
{
|
||
|
for(size_t i=0 ; i<WINIX_JOBS_HOW_MANY_PRIORITIES ; ++i)
|
||
|
if( !Empty(i) )
|
||
|
return false;
|
||
|
|
||
|
return true;
|
||
|
}
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
/*
|
||
|
second thread
|
||
|
*/
|
||
|
|
||
|
// second thread (objects locked)
|
||
|
bool Job::SignalReceived()
|
||
|
{
|
||
|
return !Empty();
|
||
|
}
|
||
|
|
||
|
|
||
|
// second thread (objects not locked)
|
||
|
void Job::Do()
|
||
|
{
|
||
|
size_t i = WINIX_JOBS_HOW_MANY_PRIORITIES;
|
||
|
bool is_empty;
|
||
|
|
||
|
while( i-- > 0 && !IsExitSignal() )
|
||
|
{
|
||
|
do
|
||
|
{
|
||
|
Lock();
|
||
|
is_empty = Empty(i);
|
||
|
Unlock();
|
||
|
|
||
|
if( !is_empty )
|
||
|
DoQueue(jobs_queue_tab[i]);
|
||
|
}
|
||
|
while( !is_empty && !IsExitSignal() );
|
||
|
}
|
||
|
}
|
||
|
|
||
|
|
||
|
// second thread (objects not locked, jobs_queue is not empty)
|
||
|
void Job::DoQueue(JobsQueue & jobs_queue)
|
||
|
{
|
||
|
bool is_empty;
|
||
|
|
||
|
do
|
||
|
{
|
||
|
Lock();
|
||
|
// references will not be invalidated after insertion to jobs_queue
|
||
|
// (jobs_queue is std::queue and it uses std::deque by default)
|
||
|
PT::Space & job = jobs_queue.front();
|
||
|
Unlock();
|
||
|
|
||
|
DoJob(job);
|
||
|
|
||
|
Lock();
|
||
|
jobs_queue.pop();
|
||
|
is_empty = jobs_queue.empty();
|
||
|
Unlock();
|
||
|
}
|
||
|
while( !is_empty && !IsExitSignal() );
|
||
|
}
|
||
|
|
||
|
|
||
|
// second thread (objects not locked)
|
||
|
void Job::DoJob(PT::Space & job)
|
||
|
{
|
||
|
try
|
||
|
{
|
||
|
PluginRes res = plugin.Call((Session*)0, WINIX_JOB, &job);
|
||
|
|
||
|
if( res.res_true == 0 )
|
||
|
DoWinixJob(job);
|
||
|
}
|
||
|
catch(...)
|
||
|
{
|
||
|
}
|
||
|
}
|
||
|
|
||
|
|
||
|
// second thread (objects not locked)
|
||
|
void Job::DoWinixJob(PT::Space & job)
|
||
|
{
|
||
|
Lock();
|
||
|
//log << log1 << "standard winix job: " << job.Text(L"type") << logend;
|
||
|
Unlock();
|
||
|
}
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|