/*
 * 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	/* MESSAGE_LOOPER_H */