Worker
Worker* fWorker;
Worker* fWorker;
class Worker;
ThreadHandler(::Thread* thread, Worker* worker,
friend class Worker;
void SetWorker(Worker* worker);
Worker* fWorker;
class Worker {
Worker();
~Worker();
class Worker;
Worker* GetWorker() const { return fWorker; }
Worker::Worker(RTF::Header &start)
Worker::~Worker()
Worker::Dispatch(Element *element)
Worker::Work()
Worker::Group(RTF::Group *group)
Worker::GroupEnd(RTF::Group *group)
Worker::Command(RTF::Command *command)
Worker::Text(RTF::Text *text)
Worker::Start()
Worker::Skip()
Worker::Abort(status_t status)
class Worker {
Worker(RTF::Header &start);
virtual ~Worker();
: RTF::Worker(start),
class TextOutput : public RTF::Worker {
AutoLocker<Worker> workerLocker(fWorker);
fWorker = new(std::nothrow) Worker;
ThreadHandler::ThreadHandler(::Thread* thread, Worker* worker,
AutoLocker<Worker> workerLocker(GetWorker());
static status_t ScheduleIfNecessary(Worker* worker,
LoadImageDebugInfoJob::ScheduleIfNecessary(Worker* worker, Image* image,
AutoLocker<Worker> workerLocker(GetWorker());
Job::SetWorker(Worker* worker)
Worker::Worker()
Worker::~Worker()
Worker::Init()
Worker::ShutDown()
AutoLocker<Worker> locker(this);
Worker::ScheduleJob(Job* job, JobListener* listener)
AutoLocker<Worker> locker(this);
Worker::AbortJob(const JobKey& key)
AutoLocker<Worker> locker(this);
Worker::GetJob(const JobKey& key)
AutoLocker<Worker> locker(this);
Worker::ResumeJob(Job* job)
AutoLocker<Worker> locker(this);
Worker::HasPendingJobs()
AutoLocker<Worker> locker(this);
Worker::AddListener(const JobKey& key, JobListener* listener)
AutoLocker<Worker> locker(this);
Worker::RemoveListener(const JobKey& key, JobListener* listener)
AutoLocker<Worker> locker(this);
Worker::WaitForJob(Job* waitingJob, const JobKey& key)
AutoLocker<Worker> locker(this);
Worker::WaitForUserInput(Job* waitingJob)
AutoLocker<Worker> locker(this);
Worker::_WorkerLoopEntry(void* data)
return ((Worker*)data)->_WorkerLoop();
Worker::_WorkerLoop()
AutoLocker<Worker> locker(this);
Worker::_ProcessJobs()
AutoLocker<Worker> locker(this);
Worker::_AbortJob(Job* job, bool removeFromTable)
Worker::_FinishJob(Job* job)
Worker(queue),
Worker* worker = new Worker(fJobQueue);
return Worker::Run(job);
Worker::Worker(JobQueue& queue)
Worker::~Worker()
Worker::Init()
fThread = spawn_thread(&Worker::_Process, Name(), B_NORMAL_PRIORITY,
Worker::Process()
Worker::Timeout() const
Worker::Name() const
Worker::Run(BJob* job)
Worker::_Process(void* _self)
Worker* self = (Worker*)_self;
class Worker {
Worker(JobQueue& queue);
virtual ~Worker();
class MainWorker : public Worker {