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