196de5490SAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
396de5490SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
496de5490SAndrew Rist * or more contributor license agreements. See the NOTICE file
596de5490SAndrew Rist * distributed with this work for additional information
696de5490SAndrew Rist * regarding copyright ownership. The ASF licenses this file
796de5490SAndrew Rist * to you under the Apache License, Version 2.0 (the
896de5490SAndrew Rist * "License"); you may not use this file except in compliance
996de5490SAndrew Rist * with the License. You may obtain a copy of the License at
1096de5490SAndrew Rist *
1196de5490SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
1296de5490SAndrew Rist *
1396de5490SAndrew Rist * Unless required by applicable law or agreed to in writing,
1496de5490SAndrew Rist * software distributed under the License is distributed on an
1596de5490SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
1696de5490SAndrew Rist * KIND, either express or implied. See the License for the
1796de5490SAndrew Rist * specific language governing permissions and limitations
1896de5490SAndrew Rist * under the License.
1996de5490SAndrew Rist *
2096de5490SAndrew Rist *************************************************************/
2196de5490SAndrew Rist
2296de5490SAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25*b63233d8Sdamjan #include "precompiled_dbui.hxx"
26cdf0e10cSrcweir #ifndef DBAUI_ASYNCRONOUSLINK_HXX
27cdf0e10cSrcweir #include "AsyncronousLink.hxx"
28cdf0e10cSrcweir #endif
29cdf0e10cSrcweir #ifndef _SV_SVAPP_HXX
30cdf0e10cSrcweir #include <vcl/svapp.hxx>
31cdf0e10cSrcweir #endif
32cdf0e10cSrcweir #ifndef _TOOLS_DEBUG_HXX
33cdf0e10cSrcweir #include <tools/debug.hxx>
34cdf0e10cSrcweir #endif
35cdf0e10cSrcweir
36cdf0e10cSrcweir //==================================================================
37cdf0e10cSrcweir //= OAsyncronousLink
38cdf0e10cSrcweir //==================================================================
39cdf0e10cSrcweir using namespace dbaui;
DBG_NAME(OAsyncronousLink)40cdf0e10cSrcweir DBG_NAME(OAsyncronousLink)
41cdf0e10cSrcweir //------------------------------------------------------------------
42cdf0e10cSrcweir OAsyncronousLink::OAsyncronousLink( const Link& _rHandler )
43cdf0e10cSrcweir :m_aHandler(_rHandler)
44cdf0e10cSrcweir ,m_aEventSafety()
45cdf0e10cSrcweir ,m_aDestructionSafety()
46cdf0e10cSrcweir ,m_nEventId(0)
47cdf0e10cSrcweir {
48cdf0e10cSrcweir DBG_CTOR(OAsyncronousLink,NULL);
49cdf0e10cSrcweir }
50cdf0e10cSrcweir
51cdf0e10cSrcweir //------------------------------------------------------------------
~OAsyncronousLink()52cdf0e10cSrcweir OAsyncronousLink::~OAsyncronousLink()
53cdf0e10cSrcweir {
54cdf0e10cSrcweir {
55cdf0e10cSrcweir ::osl::MutexGuard aEventGuard( m_aEventSafety );
56cdf0e10cSrcweir if ( m_nEventId )
57cdf0e10cSrcweir Application::RemoveUserEvent(m_nEventId);
58cdf0e10cSrcweir m_nEventId = 0;
59cdf0e10cSrcweir }
60cdf0e10cSrcweir
61cdf0e10cSrcweir {
62cdf0e10cSrcweir ::osl::MutexGuard aDestructionGuard( m_aDestructionSafety );
63cdf0e10cSrcweir // this is just for the case we're deleted while another thread just handled the event :
64cdf0e10cSrcweir // if this other thread called our link while we were deleting the event here, the
65cdf0e10cSrcweir // link handler blocked. With leaving the above block it continued, but now we are prevented
66cdf0e10cSrcweir // to leave this destructor 'til the link handler recognizes that nEvent == 0 and leaves.
67cdf0e10cSrcweir }
68cdf0e10cSrcweir DBG_DTOR(OAsyncronousLink,NULL);
69cdf0e10cSrcweir }
70cdf0e10cSrcweir
71cdf0e10cSrcweir
72cdf0e10cSrcweir //------------------------------------------------------------------
Call(void * _pArgument)73cdf0e10cSrcweir void OAsyncronousLink::Call( void* _pArgument )
74cdf0e10cSrcweir {
75cdf0e10cSrcweir ::osl::MutexGuard aEventGuard( m_aEventSafety );
76cdf0e10cSrcweir if (m_nEventId)
77cdf0e10cSrcweir Application::RemoveUserEvent(m_nEventId);
78cdf0e10cSrcweir m_nEventId = Application::PostUserEvent( LINK( this, OAsyncronousLink, OnAsyncCall ), _pArgument );
79cdf0e10cSrcweir }
80cdf0e10cSrcweir
81cdf0e10cSrcweir //------------------------------------------------------------------
CancelCall()82cdf0e10cSrcweir void OAsyncronousLink::CancelCall()
83cdf0e10cSrcweir {
84cdf0e10cSrcweir ::osl::MutexGuard aEventGuard( m_aEventSafety );
85cdf0e10cSrcweir if ( m_nEventId )
86cdf0e10cSrcweir Application::RemoveUserEvent( m_nEventId );
87cdf0e10cSrcweir m_nEventId = 0;
88cdf0e10cSrcweir }
89cdf0e10cSrcweir
90cdf0e10cSrcweir //------------------------------------------------------------------
IMPL_LINK(OAsyncronousLink,OnAsyncCall,void *,_pArg)91cdf0e10cSrcweir IMPL_LINK(OAsyncronousLink, OnAsyncCall, void*, _pArg)
92cdf0e10cSrcweir {
93cdf0e10cSrcweir {
94cdf0e10cSrcweir ::osl::MutexGuard aDestructionGuard( m_aDestructionSafety );
95cdf0e10cSrcweir {
96cdf0e10cSrcweir ::osl::MutexGuard aEventGuard( m_aEventSafety );
97cdf0e10cSrcweir if (!m_nEventId)
98cdf0e10cSrcweir // our destructor deleted the event just while we we're waiting for m_aEventSafety
99cdf0e10cSrcweir // -> get outta here
100cdf0e10cSrcweir return 0;
101cdf0e10cSrcweir m_nEventId = 0;
102cdf0e10cSrcweir }
103cdf0e10cSrcweir }
104cdf0e10cSrcweir if (m_aHandler.IsSet())
105cdf0e10cSrcweir return m_aHandler.Call(_pArg);
106cdf0e10cSrcweir
107cdf0e10cSrcweir return 0L;
108cdf0e10cSrcweir }
109