Lines Matching refs:worker
33 mutex_init(&fWorkerLock, "imap worker lock");
99 IMAPConnectionWorker* worker = new IMAPConnectionWorker(*this,
101 if (!fWorkers.AddItem(worker)) {
102 delete worker;
106 status = worker->Run();
108 fWorkers.RemoveItem(worker);
109 delete worker;
114 IMAPConnectionWorker* worker
116 worker->Quit();
131 IMAPConnectionWorker* worker = fWorkers.ItemAt(index);
133 worker->AddMailbox(folder);
134 fWorkerMap.insert(std::make_pair(folder, worker));
145 IMAPProtocol::WorkerQuit(IMAPConnectionWorker* worker)
148 fWorkers.RemoveItem(worker);
153 if (removed->second == worker)
183 IMAPConnectionWorker* worker = found->second;
184 return worker->EnqueueUpdateFlags(folder, uid, flags);
195 // Create main (and possibly initial) connection worker
196 IMAPConnectionWorker* worker = new IMAPConnectionWorker(*this,
198 if (!fWorkers.AddItem(worker)) {
199 delete worker;
203 worker->EnqueueCheckSubscribedFolders();
204 return worker->Run();
253 IMAPConnectionWorker* worker = found->second;
254 return worker->EnqueueFetchBody(*folder, uid, replyTo);