* Copyright 2005-2016, Haiku.
* Distributed under the terms of the MIT License.
*
* Authors:
* Axel Dörfler, axeld@pinc-software.de
*/
#ifndef MESSAGE_LOOPER_H
#define MESSAGE_LOOPER_H
#include <PortLink.h>
#include <Locker.h>
#include <OS.h>
class MessageLooper : public BLocker {
public:
MessageLooper(const char* name);
virtual ~MessageLooper();
virtual status_t Run();
virtual void Quit();
status_t PostMessage(int32 code,
bigtime_t timeout = B_INFINITE_TIMEOUT);
thread_id Thread() const { return fThread; }
bool IsQuitting() const { return fQuitting; }
sem_id DeathSemaphore() const
{ return fDeathSemaphore; }
virtual port_id MessagePort() const = 0;
static status_t WaitForQuit(sem_id semaphore,
bigtime_t timeout = B_INFINITE_TIMEOUT);
private:
virtual void _PrepareQuit();
virtual void _GetLooperName(char* name, size_t length);
virtual void _DispatchMessage(int32 code,
BPrivate::LinkReceiver& link);
virtual void _MessageLooper();
protected:
static int32 _message_thread(void*_looper);
protected:
const char* fName;
thread_id fThread;
BPrivate::PortLink fLink;
bool fQuitting;
sem_id fDeathSemaphore;
};
static const int32 kMsgQuitLooper = 'quit';
#endif
