1 /**************************************************************
2  *
3  * Licensed to the Apache Software Foundation (ASF) under one
4  * or more contributor license agreements.  See the NOTICE file
5  * distributed with this work for additional information
6  * regarding copyright ownership.  The ASF licenses this file
7  * to you under the Apache License, Version 2.0 (the
8  * "License"); you may not use this file except in compliance
9  * with the License.  You may obtain a copy of the License at
10  *
11  *   http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing,
14  * software distributed under the License is distributed on an
15  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16  * KIND, either express or implied.  See the License for the
17  * specific language governing permissions and limitations
18  * under the License.
19  *
20  *************************************************************/
21 
22 
23 #include "precompiled_sw.hxx"
24 #include <retrieveinputstreamconsumer.hxx>
25 #include <ndgrf.hxx>
26 #include <retrieveinputstream.hxx>
27 #include <swthreadmanager.hxx>
28 
29 /** class to provide creation of a thread to retrieve an input stream given by
30     an URL and to consume the retrieved input stream.
31 
32     OD 2007-01-29 #i73788#
33 
34     @author OD
35 */
SwAsyncRetrieveInputStreamThreadConsumer(SwGrfNode & rGrfNode)36 SwAsyncRetrieveInputStreamThreadConsumer::SwAsyncRetrieveInputStreamThreadConsumer(
37                                                             SwGrfNode& rGrfNode )
38     : mrGrfNode( rGrfNode ),
39       mnThreadID( 0 )
40 {
41 }
42 
~SwAsyncRetrieveInputStreamThreadConsumer()43 SwAsyncRetrieveInputStreamThreadConsumer::~SwAsyncRetrieveInputStreamThreadConsumer()
44 {
45     SwThreadManager::GetThreadManager().RemoveThread( mnThreadID );
46 }
47 
CreateThread(const String & rURL)48 void SwAsyncRetrieveInputStreamThreadConsumer::CreateThread( const String& rURL )
49 {
50     // Get new data container for input stream data
51     SwRetrievedInputStreamDataManager::tDataKey nDataKey =
52             SwRetrievedInputStreamDataManager::GetManager().ReserveData(
53                                                 mrGrfNode.GetThreadConsumer() );
54 
55     rtl::Reference< ObservableThread > pNewThread =
56         SwAsyncRetrieveInputStreamThread::createThread( nDataKey, rURL );
57 
58     // Add thread to thread manager and pass ownership of thread to thread manager.
59     mnThreadID = SwThreadManager::GetThreadManager().AddThread( pNewThread );
60 }
61 
ApplyInputStream(com::sun::star::uno::Reference<com::sun::star::io::XInputStream> xInputStream,const sal_Bool bIsStreamReadOnly)62 void SwAsyncRetrieveInputStreamThreadConsumer::ApplyInputStream(
63     com::sun::star::uno::Reference<com::sun::star::io::XInputStream> xInputStream,
64     const sal_Bool bIsStreamReadOnly )
65 {
66     mrGrfNode.ApplyInputStream( xInputStream, bIsStreamReadOnly );
67 }
68 
69