inbound_protocols/imap/IMAPConnectionWorker.cpp

28 	WorkerPrivate(IMAPConnectionWorker& worker)
30 		fWorker(worker)
108 	virtual	status_t Process(IMAPConnectionWorker& worker) = 0;
131 	worker's fSyncPending member, and will thus prevent syncing more than once
144 	virtual status_t Process(IMAPConnectionWorker& worker)
146 		WorkerPrivate(worker).Quit();
154 	virtual status_t Process(IMAPConnectionWorker& worker)
156 		IMAP::Protocol& protocol = WorkerPrivate(worker).Protocol();
158 		// The main worker checks the subscribed folders, and creates
160 		return worker.Owner().CheckSubscribedFolders(protocol,
161 			worker.UsesIdle());
178 	virtual status_t Process(IMAPConnectionWorker& worker)
180 		IMAP::Protocol& protocol = WorkerPrivate(worker).Protocol();
188 		status_t status = WorkerPrivate(worker).SelectMailbox(fFolder);
248 	virtual status_t Process(IMAPConnectionWorker& worker)
250 		IMAP::Protocol& protocol = WorkerPrivate(worker).Protocol();
252 		status_t status = WorkerPrivate(worker).SelectMailbox(fFolder);
268 			WorkerPrivate(worker).EnqueueCommand(new FetchBodiesCommand(fFolder,
312 	CheckMailboxesCommand(IMAPConnectionWorker& worker)
314 		fWorker(worker),
322 	virtual status_t Process(IMAPConnectionWorker& worker)
324 		IMAP::Protocol& protocol = WorkerPrivate(worker).Protocol();
328 			status_t status = WorkerPrivate(worker).AddFolders(fFolders);
342 					WorkerPrivate(worker).EnqueueCommand(
350 			fMailbox = WorkerPrivate(worker).MailboxFor(*fFolder);
352 			status_t status = WorkerPrivate(worker).SelectMailbox(*fFolder);
356 			fLastIndex = WorkerPrivate(worker).MessagesExist();
363 			status_t status = WorkerPrivate(worker).SelectMailbox(*fFolder);
409 						WorkerPrivate(worker).BodyFetchLimit());
461 	virtual status_t Process(IMAPConnectionWorker& worker)
469 		status_t status = WorkerPrivate(worker).SelectMailbox(fFolder);
471 			IMAP::Protocol& protocol = WorkerPrivate(worker).Protocol();
507 	CommandDeleter(IMAPConnectionWorker& worker, WorkerCommand* command)
510 		fWorker(worker)
548 	puts("worker quit");
607 	fThread = spawn_thread(&_Worker, "imap connection worker",
620 	printf("IMAP: worker %p: enqueue quit\n", this);
631 	printf("IMAP: worker %p: enqueue check subscribed folders\n", this);
644 	printf("IMAP: worker %p: enqueue check mailboxes\n", this);
765 /*!	Enqueues the given command to the worker queue. This method will take
874 	// remove this worker, and reduce the number of concurrent connections