Line data Source code
1 : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : /*
3 : * This file is part of the LibreOffice project.
4 : *
5 : * This Source Code Form is subject to the terms of the Mozilla Public
6 : * License, v. 2.0. If a copy of the MPL was not distributed with this
7 : * file, You can obtain one at http://mozilla.org/MPL/2.0/.
8 : *
9 : * This file incorporates work covered by the following license notice:
10 : *
11 : * Licensed to the Apache Software Foundation (ASF) under one or more
12 : * contributor license agreements. See the NOTICE file distributed
13 : * with this work for additional information regarding copyright
14 : * ownership. The ASF licenses this file to you under the Apache
15 : * License, Version 2.0 (the "License"); you may not use this file
16 : * except in compliance with the License. You may obtain a copy of
17 : * the License at http://www.apache.org/licenses/LICENSE-2.0 .
18 : */
19 :
20 :
21 : /**************************************************************************
22 : TODO
23 : **************************************************************************
24 :
25 : - This implementation is far away from completion. It has no interface
26 : for changes notifications etc.
27 :
28 : *************************************************************************/
29 : #include <com/sun/star/ucb/ListActionType.hpp>
30 : #include <com/sun/star/ucb/WelcomeDynamicResultSetStruct.hpp>
31 : #include <com/sun/star/ucb/CachedDynamicResultSetStubFactory.hpp>
32 : #include <com/sun/star/ucb/XSourceInitialization.hpp>
33 : #include <cppuhelper/interfacecontainer.hxx>
34 : #include <ucbhelper/resultsethelper.hxx>
35 : #include <ucbhelper/getcomponentcontext.hxx>
36 :
37 : #include "osl/diagnose.h"
38 :
39 : using namespace com::sun::star;
40 :
41 : //=========================================================================
42 : //=========================================================================
43 : //
44 : // ResultSetImplHelper Implementation.
45 : //
46 : //=========================================================================
47 : //=========================================================================
48 :
49 : namespace ucbhelper {
50 :
51 : //=========================================================================
52 0 : ResultSetImplHelper::ResultSetImplHelper(
53 : const uno::Reference< uno::XComponentContext >& rxContext,
54 : const com::sun::star::ucb::OpenCommandArgument2& rCommand )
55 : : m_pDisposeEventListeners( 0 ),
56 : m_bStatic( sal_False ),
57 : m_bInitDone( sal_False ),
58 : m_aCommand( rCommand ),
59 0 : m_xContext( rxContext )
60 : {
61 0 : }
62 :
63 : //=========================================================================
64 : // virtual
65 0 : ResultSetImplHelper::~ResultSetImplHelper()
66 : {
67 0 : delete m_pDisposeEventListeners;
68 0 : }
69 :
70 : //=========================================================================
71 : //
72 : // XInterface methods.
73 : //
74 : //=========================================================================
75 :
76 0 : XINTERFACE_IMPL_4( ResultSetImplHelper,
77 : lang::XTypeProvider,
78 : lang::XServiceInfo,
79 : lang::XComponent, /* base of XDynamicResultSet */
80 : com::sun::star::ucb::XDynamicResultSet );
81 :
82 : //=========================================================================
83 : //
84 : // XTypeProvider methods.
85 : //
86 : //=========================================================================
87 :
88 0 : XTYPEPROVIDER_IMPL_3( ResultSetImplHelper,
89 : lang::XTypeProvider,
90 : lang::XServiceInfo,
91 : com::sun::star::ucb::XDynamicResultSet );
92 :
93 : //=========================================================================
94 : //
95 : // XServiceInfo methods.
96 : //
97 : //=========================================================================
98 :
99 0 : XSERVICEINFO_NOFACTORY_IMPL_1( ResultSetImplHelper,
100 : rtl::OUString(
101 : "ResultSetImplHelper" ),
102 : rtl::OUString(
103 : DYNAMICRESULTSET_SERVICE_NAME ) );
104 :
105 : //=========================================================================
106 : //
107 : // XComponent methods.
108 : //
109 : //=========================================================================
110 :
111 : // virtual
112 0 : void SAL_CALL ResultSetImplHelper::dispose()
113 : throw( uno::RuntimeException )
114 : {
115 0 : osl::MutexGuard aGuard( m_aMutex );
116 :
117 0 : if ( m_pDisposeEventListeners && m_pDisposeEventListeners->getLength() )
118 : {
119 0 : lang::EventObject aEvt;
120 0 : aEvt.Source = static_cast< lang::XComponent * >( this );
121 0 : m_pDisposeEventListeners->disposeAndClear( aEvt );
122 0 : }
123 0 : }
124 :
125 : //=========================================================================
126 : // virtual
127 0 : void SAL_CALL ResultSetImplHelper::addEventListener(
128 : const uno::Reference< lang::XEventListener >& Listener )
129 : throw( uno::RuntimeException )
130 : {
131 0 : osl::MutexGuard aGuard( m_aMutex );
132 :
133 0 : if ( !m_pDisposeEventListeners )
134 : m_pDisposeEventListeners
135 0 : = new cppu::OInterfaceContainerHelper( m_aMutex );
136 :
137 0 : m_pDisposeEventListeners->addInterface( Listener );
138 0 : }
139 :
140 : //=========================================================================
141 : // virtual
142 0 : void SAL_CALL ResultSetImplHelper::removeEventListener(
143 : const uno::Reference< lang::XEventListener >& Listener )
144 : throw( uno::RuntimeException )
145 : {
146 0 : osl::MutexGuard aGuard( m_aMutex );
147 :
148 0 : if ( m_pDisposeEventListeners )
149 0 : m_pDisposeEventListeners->removeInterface( Listener );
150 0 : }
151 :
152 : //=========================================================================
153 : //
154 : // XDynamicResultSet methods.
155 : //
156 : //=========================================================================
157 :
158 : // virtual
159 : uno::Reference< sdbc::XResultSet > SAL_CALL
160 0 : ResultSetImplHelper::getStaticResultSet()
161 : throw( com::sun::star::ucb::ListenerAlreadySetException,
162 : uno::RuntimeException )
163 : {
164 0 : osl::MutexGuard aGuard( m_aMutex );
165 :
166 0 : if ( m_xListener.is() )
167 0 : throw com::sun::star::ucb::ListenerAlreadySetException();
168 :
169 0 : init( sal_True );
170 0 : return m_xResultSet1;
171 : }
172 :
173 : //=========================================================================
174 : // virtual
175 0 : void SAL_CALL ResultSetImplHelper::setListener(
176 : const uno::Reference< com::sun::star::ucb::XDynamicResultSetListener >&
177 : Listener )
178 : throw( com::sun::star::ucb::ListenerAlreadySetException,
179 : uno::RuntimeException )
180 : {
181 0 : osl::ClearableMutexGuard aGuard( m_aMutex );
182 :
183 0 : if ( m_bStatic || m_xListener.is() )
184 0 : throw com::sun::star::ucb::ListenerAlreadySetException();
185 :
186 0 : m_xListener = Listener;
187 :
188 : //////////////////////////////////////////////////////////////////////
189 : // Create "welcome event" and send it to listener.
190 : //////////////////////////////////////////////////////////////////////
191 :
192 : // Note: We only have the implementation for a static result set at the
193 : // moment (src590). The dynamic result sets passed to the listener
194 : // are a fake. This implementation will never call "notify" at the
195 : // listener to propagate any changes!!!
196 :
197 0 : init( sal_False );
198 :
199 0 : uno::Any aInfo;
200 : aInfo <<= com::sun::star::ucb::WelcomeDynamicResultSetStruct(
201 : m_xResultSet1 /* "old" */,
202 0 : m_xResultSet2 /* "new" */ );
203 :
204 0 : uno::Sequence< com::sun::star::ucb::ListAction > aActions( 1 );
205 : aActions.getArray()[ 0 ]
206 : = com::sun::star::ucb::ListAction(
207 : 0, // Position; not used
208 : 0, // Count; not used
209 : com::sun::star::ucb::ListActionType::WELCOME,
210 0 : aInfo );
211 0 : aGuard.clear();
212 :
213 0 : Listener->notify(
214 : com::sun::star::ucb::ListEvent(
215 0 : static_cast< cppu::OWeakObject * >( this ), aActions ) );
216 0 : }
217 :
218 : //=========================================================================
219 : // virtual
220 0 : sal_Int16 SAL_CALL ResultSetImplHelper::getCapabilities()
221 : throw( uno::RuntimeException )
222 : {
223 : // ! com::sun::star::ucb::ContentResultSetCapability::SORTED
224 0 : return 0;
225 : }
226 :
227 : //=========================================================================
228 : // virtual
229 0 : void SAL_CALL ResultSetImplHelper::connectToCache(
230 : const uno::Reference< com::sun::star::ucb::XDynamicResultSet > &
231 : xCache )
232 : throw( com::sun::star::ucb::ListenerAlreadySetException,
233 : com::sun::star::ucb::AlreadyInitializedException,
234 : com::sun::star::ucb::ServiceNotFoundException,
235 : uno::RuntimeException )
236 : {
237 0 : if ( m_xListener.is() )
238 0 : throw com::sun::star::ucb::ListenerAlreadySetException();
239 :
240 0 : if ( m_bStatic )
241 0 : throw com::sun::star::ucb::ListenerAlreadySetException();
242 :
243 : uno::Reference< com::sun::star::ucb::XSourceInitialization >
244 0 : xTarget( xCache, uno::UNO_QUERY );
245 0 : if ( xTarget.is() )
246 : {
247 : uno::Reference<
248 : com::sun::star::ucb::XCachedDynamicResultSetStubFactory >
249 0 : xStubFactory;
250 : try
251 : {
252 : xStubFactory
253 : = com::sun::star::ucb::CachedDynamicResultSetStubFactory::create(
254 0 : m_xContext );
255 : }
256 0 : catch ( uno::Exception const & )
257 : {
258 : }
259 :
260 0 : if ( xStubFactory.is() )
261 : {
262 0 : xStubFactory->connectToCache(
263 0 : this, xCache, m_aCommand.SortingInfo, 0 );
264 0 : return;
265 0 : }
266 : }
267 0 : throw com::sun::star::ucb::ServiceNotFoundException();
268 : }
269 :
270 : //=========================================================================
271 : //
272 : // Non-interface methods.
273 : //
274 : //=========================================================================
275 :
276 0 : void ResultSetImplHelper::init( sal_Bool bStatic )
277 : {
278 0 : osl::MutexGuard aGuard( m_aMutex );
279 :
280 0 : if ( !m_bInitDone )
281 : {
282 0 : if ( bStatic )
283 : {
284 : // virtual... derived class fills m_xResultSet1
285 0 : initStatic();
286 :
287 : OSL_ENSURE( m_xResultSet1.is(),
288 : "ResultSetImplHelper::init - No 1st result set!" );
289 0 : m_bStatic = sal_True;
290 : }
291 : else
292 : {
293 : // virtual... derived class fills m_xResultSet1 and m_xResultSet2
294 0 : initDynamic();
295 :
296 : OSL_ENSURE( m_xResultSet1.is(),
297 : "ResultSetImplHelper::init - No 1st result set!" );
298 : OSL_ENSURE( m_xResultSet2.is(),
299 : "ResultSetImplHelper::init - No 2nd result set!" );
300 0 : m_bStatic = sal_False;
301 : }
302 0 : m_bInitDone = sal_True;
303 0 : }
304 0 : }
305 :
306 : } // namespace ucbhelper
307 :
308 : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
