* Copyright 2005, Haiku, Inc. All Rights Reserved.
* Distributed under the terms of the MIT License.
*
* Authors:
* Axel Dörfler, axeld@pinc-software.de
*/
#ifndef EVENT_STREAM_H
#define EVENT_STREAM_H
#include <LinkReceiver.h>
#include <MessageQueue.h>
#include <Messenger.h>
struct shared_cursor;
class EventStream {
public:
EventStream();
virtual ~EventStream();
virtual bool IsValid() = 0;
virtual void SendQuit() = 0;
virtual bool SupportsCursorThread() const;
virtual void UpdateScreenBounds(BRect bounds) = 0;
virtual bool GetNextEvent(BMessage** _event) = 0;
virtual status_t GetNextCursorPosition(BPoint& where,
bigtime_t timeout = B_INFINITE_TIMEOUT);
virtual status_t InsertEvent(BMessage* event) = 0;
virtual BMessage* PeekLatestMouseMoved() = 0;
};
class InputServerStream : public EventStream {
public:
InputServerStream(BMessenger& inputServerMessenger);
#if TEST_MODE
InputServerStream();
#endif
virtual ~InputServerStream();
virtual bool IsValid();
virtual void SendQuit();
virtual bool SupportsCursorThread() const { return fCursorSemaphore >= B_OK; }
virtual void UpdateScreenBounds(BRect bounds);
virtual bool GetNextEvent(BMessage** _event);
virtual status_t GetNextCursorPosition(BPoint& where,
bigtime_t timeout = B_INFINITE_TIMEOUT);
virtual status_t InsertEvent(BMessage* event);
virtual BMessage* PeekLatestMouseMoved();
private:
status_t _MessageFromPort(BMessage** _message,
bigtime_t timeout = B_INFINITE_TIMEOUT);
BMessenger fInputServer;
BMessageQueue fEvents;
port_id fPort;
bool fQuitting;
sem_id fCursorSemaphore;
area_id fCursorArea;
shared_cursor* fCursorBuffer;
BMessage* fLatestMouseMoved;
};
#endif
