fixed: nothing happens on osx 10.6

src/lib/base/CEventQueue.cpp

@@ -96,6 +96,8 @@ CEventQueue::~CEventQueue()
 void
 CEventQueue::loop()
 {
+	m_buffer->init();
+	
 	CEvent event;
 	getEvent(event);
 	while (event.getType() != CEvent::kQuit) {
@@ -594,9 +596,3 @@ CEventQueue::CTimer::operator<(const CTimer& t) const
 {
 	return m_time < t.m_time;
 }
-
-void
-CEventQueue::cacheCurrentEventQueueRef()
-{
-	m_buffer->cacheCurrentEventQueueRef();
-}

src/lib/base/CEventQueue.h

@@ -61,8 +61,6 @@ public:
 						getRegisteredType(const CString& name) const;
 	void*				getSystemTarget();
 
-	void				cacheCurrentEventQueueRef();
-
 private:
 	UInt32				saveEvent(const CEvent& event);
 	CEvent				removeEvent(UInt32 eventID);

src/lib/base/CSimpleEventQueueBuffer.h

@@ -33,6 +33,7 @@ public:
 	~CSimpleEventQueueBuffer();
 
 	// IEventQueueBuffer overrides
+	void				init() { }
 	virtual void		waitForEvent(double timeout);
 	virtual Type		getEvent(CEvent& event, UInt32& dataID);
 	virtual bool		addEvent(UInt32 dataID);
@@ -40,7 +41,6 @@ public:
 	virtual CEventQueueTimer*
 						newTimer(double duration, bool oneShot) const;
 	virtual void		deleteTimer(CEventQueueTimer*) const;
-	void				cacheCurrentEventQueueRef() { }
 
 private:
 	typedef std::deque<UInt32> CEventDeque;

src/lib/base/IEventQueue.h

@@ -177,8 +177,6 @@ public:
 						registerTypeOnce(CEvent::Type& type,
 							const char* name) = 0;
 
-	virtual void		cacheCurrentEventQueueRef() = 0;
-
 	//@}
 	//! @name accessors
 	//@{

src/lib/base/IEventQueueBuffer.h

@@ -40,6 +40,12 @@ public:
 	//! @name manipulators
 	//@{
 	
+	//! Initialize
+	/*!
+	Useful for platform-specific initialisation from a specific thread.
+	*/
+	virtual	void		init() = 0;
+
 	//! Block waiting for an event
 	/*!
 	Wait for an event in the event queue buffer for up to \p timeout
@@ -67,8 +73,6 @@ public:
 	*/
 	virtual bool		addEvent(UInt32 dataID) = 0;
 
-	virtual	void		cacheCurrentEventQueueRef() = 0;
-
 	//@}
 	//! @name accessors
 	//@{

src/lib/platform/CMSWindowsEventQueueBuffer.h

@@ -32,6 +32,7 @@ public:
 	virtual ~CMSWindowsEventQueueBuffer();
 
 	// IEventQueueBuffer overrides
+	virtual	void		init() { }
 	virtual void		waitForEvent(double timeout);
 	virtual Type		getEvent(CEvent& event, UInt32& dataID);
 	virtual bool		addEvent(UInt32 dataID);
@@ -40,8 +41,6 @@ public:
 						newTimer(double duration, bool oneShot) const;
 	virtual void		deleteTimer(CEventQueueTimer*) const;
 
-	virtual	void		cacheCurrentEventQueueRef() {}
-
 private:
 	DWORD				m_thread;
 	UINT				m_userEvent;

src/lib/platform/COSXEventQueueBuffer.cpp

@@ -33,7 +33,7 @@ class CEventQueueTimer { };
 COSXEventQueueBuffer::COSXEventQueueBuffer(IEventQueue* events) :
 	m_eventQueue(events),
 	m_event(NULL),
-	m_threadEventQueueRef(NULL)
+	m_carbonEventQueue(NULL)
 {
 	// do nothing
 }
@@ -46,6 +46,12 @@ COSXEventQueueBuffer::~COSXEventQueueBuffer()
 	}
 }
 
+void
+COSXEventQueueBuffer::init()
+{
+	m_carbonEventQueue = GetCurrentEventQueue();
+}
+
 void
 COSXEventQueueBuffer::waitForEvent(double timeout)
 {
@@ -100,9 +106,15 @@ COSXEventQueueBuffer::addEvent(UInt32 dataID)
 							kEventAttributeNone,
 							&event);
 
-	if (error == noErr & m_threadEventQueueRef != NULL) {
+	if (error == noErr) {
-		error = PostEventToQueue(m_threadEventQueueRef, event,
+	
+		assert(m_carbonEventQueue != NULL);
+		
+		error = PostEventToQueue(
+			m_carbonEventQueue,
+			event,
 			kEventPriorityStandard);
+		
 		ReleaseEvent(event);
 	}
 	
@@ -128,9 +140,3 @@ COSXEventQueueBuffer::deleteTimer(CEventQueueTimer* timer) const
 {
 	delete timer;
 }
-
-void
-COSXEventQueueBuffer::cacheCurrentEventQueueRef()
-{
-	m_threadEventQueueRef = GetCurrentEventQueue();
-}

src/lib/platform/COSXEventQueueBuffer.h

@@ -31,6 +31,7 @@ public:
 	virtual ~COSXEventQueueBuffer();
 
 	// IEventQueueBuffer overrides
+	virtual void		init();
 	virtual void		waitForEvent(double timeout);
 	virtual Type		getEvent(CEvent& event, UInt32& dataID);
 	virtual bool		addEvent(UInt32 dataID);
@@ -38,12 +39,11 @@ public:
 	virtual CEventQueueTimer*
 						newTimer(double duration, bool oneShot) const;
 	virtual void		deleteTimer(CEventQueueTimer*) const;
-	virtual void		cacheCurrentEventQueueRef();
 
 private:
 	EventRef			m_event;
 	IEventQueue*		m_eventQueue;
-	EventQueueRef		m_threadEventQueueRef;
+	EventQueueRef		m_carbonEventQueue;
 };
 
 #endif

src/lib/platform/CXWindowsEventQueueBuffer.h

@@ -37,6 +37,7 @@ public:
 	virtual ~CXWindowsEventQueueBuffer();
 
 	// IEventQueueBuffer overrides
+	virtual	void		init() { }
 	virtual void		waitForEvent(double timeout);
 	virtual Type		getEvent(CEvent& event, UInt32& dataID);
 	virtual bool		addEvent(UInt32 dataID);
@@ -45,8 +46,6 @@ public:
 						newTimer(double duration, bool oneShot) const;
 	virtual void		deleteTimer(CEventQueueTimer*) const;
 
-	virtual	void		cacheCurrentEventQueueRef() {}
-
 private:
 	void				flush();
 

src/lib/synergy/CApp.cpp

@@ -415,7 +415,6 @@ CApp::handleIpcMessage(const CEvent& e, void*)
 void
 CApp::runEventsLoop(void*)
 {
-	m_events->cacheCurrentEventQueueRef();
 	m_events->loop();
 	
 #if defined(MAC_OS_X_VERSION_10_7)

src/test/unittests/synergy/CMockEventQueue.h

@@ -61,7 +61,6 @@ public:
 	MOCK_METHOD0(forIKeyState, IKeyStateEvents&());
 	MOCK_METHOD0(forIPrimaryScreen, IPrimaryScreenEvents&());
 	MOCK_METHOD0(forIScreen, IScreenEvents&());
-	MOCK_METHOD0(cacheCurrentEventQueueRef, void());
 };
 
 #endif