/*******************************************************************************
/
/	File:			TimedEventQueue.h
/
/	Description:	A priority queue for holding media_timed_events.
/					Sorts by increasing time, so events near the front
/					of the queue are to occur earlier.
/
/	Copyright 1999, Be Incorporated, All Rights Reserved
/
*******************************************************************************/

#ifndef _TIMED_EVENT_QUEUE_H
#define _TIMED_EVENT_QUEUE_H

#include <MediaDefs.h>

struct _event_queue_imp;


struct media_timed_event {
					media_timed_event();
					media_timed_event(bigtime_t inTime, int32 inType);
					media_timed_event(bigtime_t inTime, int32 inType,
						void *inPointer, uint32 inCleanup);
					media_timed_event(
						bigtime_t inTime, int32 inType,
						void *inPointer, uint32 inCleanup,
						int32 inData, int64 inBigdata,
						char *inUserData, size_t dataSize = 0);
					
					media_timed_event(const media_timed_event & clone);
					void operator=(const media_timed_event & clone);
					
					~media_timed_event();
					
	bigtime_t		event_time;
	int32			type;
	void *			pointer;
	uint32			cleanup;
	int32			data;
	int64			bigdata;
	char			user_data[64];
	uint32			_reserved_media_timed_event_[8];
};

_IMPEXP_MEDIA bool operator==(const media_timed_event & a, const media_timed_event & b);
_IMPEXP_MEDIA bool operator!=(const media_timed_event & a, const media_timed_event & b);
_IMPEXP_MEDIA bool operator<(const media_timed_event & a, const media_timed_event & b);
_IMPEXP_MEDIA bool operator>(const media_timed_event & a, const media_timed_event &b);


class BTimedEventQueue {
	public:

		enum event_type {
			B_NO_EVENT = -1,		// never push this type! it will fail
			B_ANY_EVENT = 0,		// never push this type! it will fail
			B_START,
			B_STOP,
			B_SEEK,
			B_WARP,
			B_TIMER,
			B_HANDLE_BUFFER,
			B_DATA_STATUS,
			B_HARDWARE,
			B_PARAMETER,
			/* user defined events above this value */
			B_USER_EVENT = 0x4000
		};

		enum cleanup_flag {
			B_NO_CLEANUP = 0,
			B_RECYCLE_BUFFER,		// recycle buffers handled by BTimedEventQueue
			B_EXPIRE_TIMER,			// call TimerExpired() on the event->data
			B_USER_CLEANUP = 0x4000	// others go to the cleanup func
		};

		enum time_direction {
			B_ALWAYS = -1,
			B_BEFORE_TIME = 0,
			B_AT_TIME,
			B_AFTER_TIME
		};


		void * operator new(size_t s);
		void operator delete(void * p, size_t s);
		
							BTimedEventQueue();
		virtual				~BTimedEventQueue();
		
		status_t			AddEvent(const media_timed_event &event);
		status_t			RemoveEvent(const media_timed_event *event);
		status_t  			RemoveFirstEvent(media_timed_event * outEvent = NULL);
		
		bool				HasEvents() const;
		int32				EventCount() const;

		/* Accessors */
		const media_timed_event *	FirstEvent() const;
		bigtime_t					FirstEventTime() const;
		const media_timed_event *	LastEvent() const;
		bigtime_t					LastEventTime() const;

		const media_timed_event *	FindFirstMatch(
										bigtime_t eventTime,
										time_direction direction,
										bool inclusive = true,
										int32 eventType = B_ANY_EVENT);

		
		/* queue manipulation */
		/* call DoForEach to perform a function on each event in the */
		/* queue.  Return an appropriate status defining an action to take */
		/* for that event.  DoForEach is an atomic operation ensuring the */
		/* consistency of the queue during the call. */
		enum queue_action {
			B_DONE = -1,
			B_NO_ACTION = 0,
			B_REMOVE_EVENT,
			B_RESORT_QUEUE
		};
		typedef queue_action (*for_each_hook)(media_timed_event *event, void *context);
		
		status_t			DoForEach(
								for_each_hook hook,
								void *context,
								bigtime_t eventTime = 0,
								time_direction direction = B_ALWAYS,
								bool inclusive = true,
								int32 eventType = B_ANY_EVENT);
		
		
		/* flushing events */
		/* the cleanup hook is called when events are flushed from the queue */
		/* and the cleanup is not B_NO_CLEANUP or B_RECYCLE_BUFFER */
		typedef void (*cleanup_hook)(const media_timed_event *event, void * context);	
		void				SetCleanupHook(cleanup_hook hook, void *context);
		status_t			FlushEvents(
								bigtime_t eventTime,
								time_direction direction,
								bool inclusive = true,
								int32 eventType = B_ANY_EVENT);
				
		
	private:
							BTimedEventQueue(					//unimplemented
								const BTimedEventQueue & other);
							BTimedEventQueue &operator =(		//unimplemented
								const BTimedEventQueue & other);


		/* hide actual queue implementation */
		_event_queue_imp *	fImp;

		/* Mmmh, stuffing! */
		virtual	status_t 	_Reserved_BTimedEventQueue_0(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_1(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_2(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_3(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_4(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_5(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_6(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_7(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_8(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_9(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_10(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_11(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_12(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_13(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_14(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_15(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_16(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_17(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_18(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_19(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_20(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_21(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_22(void *, ...);
		virtual	status_t 	_Reserved_BTimedEventQueue_23(void *, ...);

		uint32 				_reserved_timed_event_queue_[6];
};

#endif