eventdispatcher_epoll_p.h

#ifndef EVENTDISPATCHER_EPOLL_P_H
#define EVENTDISPATCHER_EPOLL_P_H

#include <qplatformdefs.h>
#include <QtCore/QAbstractEventDispatcher>
#include <QtCore/QHash>

#if QT_VERSION >= 0x040400
#	include <QtCore/QAtomicInt>
#endif

#include "qt4compat.h"

enum HandleType {
	htTimer,
	htSocketNotifier
};

struct SocketNotifierInfo {
	QSocketNotifier* r;
	QSocketNotifier* w;
	QSocketNotifier* x;
	int events;
};

struct TimerInfo {
	QObject* object;
	struct timeval when;
	int timerId;
	int interval;
	int fd;
	Qt::TimerType type;
};

struct ZeroTimer {
	QObject* object;
	bool active;
};

struct HandleData {
	HandleType type;
	union {
		SocketNotifierInfo sni;
		TimerInfo ti;
	};
};

Q_DECLARE_TYPEINFO(SocketNotifierInfo, Q_PRIMITIVE_TYPE);
Q_DECLARE_TYPEINFO(TimerInfo, Q_PRIMITIVE_TYPE);
Q_DECLARE_TYPEINFO(HandleData, Q_PRIMITIVE_TYPE);

class EventDispatcherEPoll;

class Q_DECL_HIDDEN EventDispatcherEPollPrivate {
public:
	EventDispatcherEPollPrivate(EventDispatcherEPoll* const q);
	~EventDispatcherEPollPrivate(void);
	bool processEvents(QEventLoop::ProcessEventsFlags flags);
	void registerSocketNotifier(QSocketNotifier* notifier);
	void unregisterSocketNotifier(QSocketNotifier* notifier);
	void registerTimer(int timerId, int interval, Qt::TimerType type, QObject* object);
	void registerZeroTimer(int timerId, QObject* object);
	bool unregisterTimer(int timerId);
	bool unregisterTimers(QObject* object);
	QList<QAbstractEventDispatcher::TimerInfo> registeredTimers(QObject* object) const;
	int remainingTime(int timerId) const;
	void wakeup(void);

	typedef QHash<int, HandleData*> HandleHash;
	typedef QHash<int, HandleData*> TimerHash;
	typedef QHash<QSocketNotifier*, HandleData*> SocketNotifierHash;
	typedef QHash<int, ZeroTimer> ZeroTimerHash;

private:
	Q_DISABLE_COPY(EventDispatcherEPollPrivate)
	Q_DECLARE_PUBLIC(EventDispatcherEPoll)
	EventDispatcherEPoll* const q_ptr;

	int m_epoll_fd;
	int m_event_fd;
	bool m_interrupt;
#if QT_VERSION >= 0x040400
	QAtomicInt m_wakeups;
#endif
	HandleHash m_handles;
	SocketNotifierHash m_notifiers;
	TimerHash m_timers;
	ZeroTimerHash m_zero_timers;

	static void socket_notifier_callback(const SocketNotifierInfo& n, int events);
	void timer_callback(const TimerInfo& info);
	void wake_up_handler(void);

	bool disableSocketNotifiers(bool disable);
	bool disableTimers(bool disable);
};

#endif // EVENTDISPATCHER_EPOLL_P_H