1*10ce8018SAndrew Rist /**************************************************************
2cdf0e10cSrcweir  *
3*10ce8018SAndrew Rist  * Licensed to the Apache Software Foundation (ASF) under one
4*10ce8018SAndrew Rist  * or more contributor license agreements.  See the NOTICE file
5*10ce8018SAndrew Rist  * distributed with this work for additional information
6*10ce8018SAndrew Rist  * regarding copyright ownership.  The ASF licenses this file
7*10ce8018SAndrew Rist  * to you under the Apache License, Version 2.0 (the
8*10ce8018SAndrew Rist  * "License"); you may not use this file except in compliance
9*10ce8018SAndrew Rist  * with the License.  You may obtain a copy of the License at
10*10ce8018SAndrew Rist  *
11*10ce8018SAndrew Rist  *   http://www.apache.org/licenses/LICENSE-2.0
12*10ce8018SAndrew Rist  *
13*10ce8018SAndrew Rist  * Unless required by applicable law or agreed to in writing,
14*10ce8018SAndrew Rist  * software distributed under the License is distributed on an
15*10ce8018SAndrew Rist  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*10ce8018SAndrew Rist  * KIND, either express or implied.  See the License for the
17*10ce8018SAndrew Rist  * specific language governing permissions and limitations
18*10ce8018SAndrew Rist  * under the License.
19*10ce8018SAndrew Rist  *
20*10ce8018SAndrew Rist  *************************************************************/
21*10ce8018SAndrew Rist 
22*10ce8018SAndrew Rist 
23cdf0e10cSrcweir 
24cdf0e10cSrcweir #ifndef _ASYNCEVENTNOTIFIER_HXX_
25cdf0e10cSrcweir #define _ASYNCEVENTNOTIFIER_HXX_
26cdf0e10cSrcweir 
27cdf0e10cSrcweir //------------------------------------------------------------------------
28cdf0e10cSrcweir // includes
29cdf0e10cSrcweir //------------------------------------------------------------------------
30cdf0e10cSrcweir 
31cdf0e10cSrcweir #include <osl/mutex.hxx>
32cdf0e10cSrcweir #include <osl/conditn.hxx>
33cdf0e10cSrcweir #include <cppuhelper/interfacecontainer.h>
34cdf0e10cSrcweir 
35cdf0e10cSrcweir #if defined _MSC_VER
36cdf0e10cSrcweir #pragma warning(push, 1)
37cdf0e10cSrcweir #endif
38cdf0e10cSrcweir #include <windows.h>
39cdf0e10cSrcweir #if defined _MSC_VER
40cdf0e10cSrcweir #pragma warning(pop)
41cdf0e10cSrcweir #endif
42cdf0e10cSrcweir 
43cdf0e10cSrcweir #include <list>
44cdf0e10cSrcweir #include <utility>
45cdf0e10cSrcweir #include "eventnotification.hxx"
46cdf0e10cSrcweir 
47cdf0e10cSrcweir //---------------------------------------------
48cdf0e10cSrcweir //
49cdf0e10cSrcweir //---------------------------------------------
50cdf0e10cSrcweir 
51cdf0e10cSrcweir class CAsyncEventNotifier
52cdf0e10cSrcweir {
53cdf0e10cSrcweir public:
54cdf0e10cSrcweir     CAsyncEventNotifier(cppu::OBroadcastHelper& rBroadcastHelper);
55cdf0e10cSrcweir     ~CAsyncEventNotifier();
56cdf0e10cSrcweir 
57cdf0e10cSrcweir 	bool SAL_CALL startup(bool bCreateSuspended = true);
58cdf0e10cSrcweir 	void SAL_CALL shutdown();
59cdf0e10cSrcweir 
60cdf0e10cSrcweir     // notifications may be added the
61cdf0e10cSrcweir     // the event queue but will only
62cdf0e10cSrcweir     // be notified to the clients after
63cdf0e10cSrcweir     // resume was called
64cdf0e10cSrcweir     void suspend();
65cdf0e10cSrcweir 
66cdf0e10cSrcweir     // resume notifying events
67cdf0e10cSrcweir     void resume();
68cdf0e10cSrcweir 
69cdf0e10cSrcweir 	// this class is responsible for the memory management of
70cdf0e10cSrcweir 	// the CEventNotification instance
71cdf0e10cSrcweir     void SAL_CALL notifyEvent(CEventNotification* EventNotification);
72cdf0e10cSrcweir 
73cdf0e10cSrcweir     void SAL_CALL addListener   (const ::com::sun::star::uno::Type&                                           aType    ,
74cdf0e10cSrcweir                                  const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& xListener);
75cdf0e10cSrcweir     void SAL_CALL removeListener(const ::com::sun::star::uno::Type&                                           aType    ,
76cdf0e10cSrcweir                                  const ::com::sun::star::uno::Reference< ::com::sun::star::uno::XInterface >& xListener);
77cdf0e10cSrcweir 
78cdf0e10cSrcweir private:
79cdf0e10cSrcweir 	size_t              SAL_CALL getEventListSize();
80cdf0e10cSrcweir 	void                SAL_CALL resetNotifyEvent();
81cdf0e10cSrcweir 	CEventNotification* SAL_CALL getNextEventRecord();
82cdf0e10cSrcweir 	void                SAL_CALL removeNextEventRecord();
83cdf0e10cSrcweir 
84cdf0e10cSrcweir     void SAL_CALL run( );
85cdf0e10cSrcweir 
86cdf0e10cSrcweir 	static unsigned int WINAPI ThreadProc(LPVOID pParam);
87cdf0e10cSrcweir 
88cdf0e10cSrcweir private:
89cdf0e10cSrcweir     std::list<CEventNotification*>  m_EventList;
90cdf0e10cSrcweir     HANDLE							m_hThread;
91cdf0e10cSrcweir 	bool							m_bRun;
92cdf0e10cSrcweir 	unsigned						m_ThreadId;
93cdf0e10cSrcweir     ::cppu::OBroadcastHelper&		m_rBroadcastHelper;
94cdf0e10cSrcweir     HANDLE                          m_hEvents[2];
95cdf0e10cSrcweir     HANDLE&                         m_NotifyEvent;
96cdf0e10cSrcweir     HANDLE&                         m_ResumeNotifying;
97cdf0e10cSrcweir     osl::Mutex						m_Mutex;
98cdf0e10cSrcweir 
99cdf0e10cSrcweir // prevent copy and assignment
100cdf0e10cSrcweir private:
101cdf0e10cSrcweir     CAsyncEventNotifier( const CAsyncEventNotifier& );
102cdf0e10cSrcweir     CAsyncEventNotifier& operator=( const CAsyncEventNotifier& );
103cdf0e10cSrcweir };
104cdf0e10cSrcweir 
105cdf0e10cSrcweir #endif
106