1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_desktop.hxx"
26*b1cdbd2cSJim Jagielski
27*b1cdbd2cSJim Jagielski #include "dp_misc.h"
28*b1cdbd2cSJim Jagielski #include "rtl/strbuf.hxx"
29*b1cdbd2cSJim Jagielski #include "osl/time.h"
30*b1cdbd2cSJim Jagielski #include "osl/thread.h"
31*b1cdbd2cSJim Jagielski #include "cppuhelper/compbase1.hxx"
32*b1cdbd2cSJim Jagielski #include "comphelper/anytostring.hxx"
33*b1cdbd2cSJim Jagielski #include "comphelper/servicedecl.hxx"
34*b1cdbd2cSJim Jagielski #include "comphelper/unwrapargs.hxx"
35*b1cdbd2cSJim Jagielski #include "com/sun/star/deployment/DeploymentException.hpp"
36*b1cdbd2cSJim Jagielski #include "com/sun/star/ucb/XProgressHandler.hpp"
37*b1cdbd2cSJim Jagielski #include "com/sun/star/ucb/XSimpleFileAccess.hpp"
38*b1cdbd2cSJim Jagielski #include "com/sun/star/io/XSeekable.hpp"
39*b1cdbd2cSJim Jagielski #include <stdio.h>
40*b1cdbd2cSJim Jagielski
41*b1cdbd2cSJim Jagielski
42*b1cdbd2cSJim Jagielski using namespace ::rtl;
43*b1cdbd2cSJim Jagielski using namespace ::com::sun::star;
44*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::uno;
45*b1cdbd2cSJim Jagielski
46*b1cdbd2cSJim Jagielski namespace dp_log {
47*b1cdbd2cSJim Jagielski
48*b1cdbd2cSJim Jagielski typedef ::cppu::WeakComponentImplHelper1<ucb::XProgressHandler> t_log_helper;
49*b1cdbd2cSJim Jagielski
50*b1cdbd2cSJim Jagielski //==============================================================================
51*b1cdbd2cSJim Jagielski class ProgressLogImpl : public ::dp_misc::MutexHolder, public t_log_helper
52*b1cdbd2cSJim Jagielski {
53*b1cdbd2cSJim Jagielski Reference<io::XOutputStream> m_xLogFile;
54*b1cdbd2cSJim Jagielski sal_Int32 m_log_level;
55*b1cdbd2cSJim Jagielski void log_write( OString const & text );
56*b1cdbd2cSJim Jagielski
57*b1cdbd2cSJim Jagielski protected:
58*b1cdbd2cSJim Jagielski virtual void SAL_CALL disposing();
59*b1cdbd2cSJim Jagielski virtual ~ProgressLogImpl();
60*b1cdbd2cSJim Jagielski
61*b1cdbd2cSJim Jagielski public:
62*b1cdbd2cSJim Jagielski ProgressLogImpl( Sequence<Any> const & args,
63*b1cdbd2cSJim Jagielski Reference<XComponentContext> const & xContext );
64*b1cdbd2cSJim Jagielski
65*b1cdbd2cSJim Jagielski // XProgressHandler
66*b1cdbd2cSJim Jagielski virtual void SAL_CALL push( Any const & Status ) throw (RuntimeException);
67*b1cdbd2cSJim Jagielski virtual void SAL_CALL update( Any const & Status ) throw (RuntimeException);
68*b1cdbd2cSJim Jagielski virtual void SAL_CALL pop() throw (RuntimeException);
69*b1cdbd2cSJim Jagielski };
70*b1cdbd2cSJim Jagielski
71*b1cdbd2cSJim Jagielski //______________________________________________________________________________
~ProgressLogImpl()72*b1cdbd2cSJim Jagielski ProgressLogImpl::~ProgressLogImpl()
73*b1cdbd2cSJim Jagielski {
74*b1cdbd2cSJim Jagielski }
75*b1cdbd2cSJim Jagielski
76*b1cdbd2cSJim Jagielski //______________________________________________________________________________
disposing()77*b1cdbd2cSJim Jagielski void ProgressLogImpl::disposing()
78*b1cdbd2cSJim Jagielski {
79*b1cdbd2cSJim Jagielski try {
80*b1cdbd2cSJim Jagielski if (m_xLogFile.is()) {
81*b1cdbd2cSJim Jagielski m_xLogFile->closeOutput();
82*b1cdbd2cSJim Jagielski m_xLogFile.clear();
83*b1cdbd2cSJim Jagielski }
84*b1cdbd2cSJim Jagielski }
85*b1cdbd2cSJim Jagielski catch (Exception & exc) {
86*b1cdbd2cSJim Jagielski (void) exc;
87*b1cdbd2cSJim Jagielski OSL_ENSURE( 0, OUStringToOString(
88*b1cdbd2cSJim Jagielski exc.Message, RTL_TEXTENCODING_UTF8 ).getStr() );
89*b1cdbd2cSJim Jagielski }
90*b1cdbd2cSJim Jagielski }
91*b1cdbd2cSJim Jagielski
92*b1cdbd2cSJim Jagielski //______________________________________________________________________________
ProgressLogImpl(Sequence<Any> const & args,Reference<XComponentContext> const & xContext)93*b1cdbd2cSJim Jagielski ProgressLogImpl::ProgressLogImpl(
94*b1cdbd2cSJim Jagielski Sequence<Any> const & args,
95*b1cdbd2cSJim Jagielski Reference<XComponentContext> const & xContext )
96*b1cdbd2cSJim Jagielski : t_log_helper( getMutex() ),
97*b1cdbd2cSJim Jagielski m_log_level( 0 )
98*b1cdbd2cSJim Jagielski {
99*b1cdbd2cSJim Jagielski OUString log_file;
100*b1cdbd2cSJim Jagielski boost::optional< Reference<task::XInteractionHandler> > interactionHandler;
101*b1cdbd2cSJim Jagielski comphelper::unwrapArgs( args, log_file, interactionHandler );
102*b1cdbd2cSJim Jagielski
103*b1cdbd2cSJim Jagielski Reference<ucb::XSimpleFileAccess> xSimpleFileAccess(
104*b1cdbd2cSJim Jagielski xContext->getServiceManager()->createInstanceWithContext(
105*b1cdbd2cSJim Jagielski OUSTR("com.sun.star.ucb.SimpleFileAccess"),
106*b1cdbd2cSJim Jagielski xContext ), UNO_QUERY_THROW );
107*b1cdbd2cSJim Jagielski // optional ia handler:
108*b1cdbd2cSJim Jagielski if (interactionHandler)
109*b1cdbd2cSJim Jagielski xSimpleFileAccess->setInteractionHandler( *interactionHandler );
110*b1cdbd2cSJim Jagielski
111*b1cdbd2cSJim Jagielski m_xLogFile.set(
112*b1cdbd2cSJim Jagielski xSimpleFileAccess->openFileWrite( log_file ), UNO_QUERY_THROW );
113*b1cdbd2cSJim Jagielski Reference<io::XSeekable> xSeekable( m_xLogFile, UNO_QUERY_THROW );
114*b1cdbd2cSJim Jagielski xSeekable->seek( xSeekable->getLength() );
115*b1cdbd2cSJim Jagielski
116*b1cdbd2cSJim Jagielski // write log stamp
117*b1cdbd2cSJim Jagielski OStringBuffer buf;
118*b1cdbd2cSJim Jagielski buf.append(
119*b1cdbd2cSJim Jagielski RTL_CONSTASCII_STRINGPARAM("###### Progress log entry ") );
120*b1cdbd2cSJim Jagielski TimeValue m_start_time, tLocal;
121*b1cdbd2cSJim Jagielski oslDateTime date_time;
122*b1cdbd2cSJim Jagielski if (osl_getSystemTime( &m_start_time ) &&
123*b1cdbd2cSJim Jagielski osl_getLocalTimeFromSystemTime( &m_start_time, &tLocal ) &&
124*b1cdbd2cSJim Jagielski osl_getDateTimeFromTimeValue( &tLocal, &date_time ))
125*b1cdbd2cSJim Jagielski {
126*b1cdbd2cSJim Jagielski char ar[ 128 ];
127*b1cdbd2cSJim Jagielski snprintf(
128*b1cdbd2cSJim Jagielski ar, sizeof (ar),
129*b1cdbd2cSJim Jagielski "%04d-%02d-%02d %02d:%02d:%02d ",
130*b1cdbd2cSJim Jagielski date_time.Year, date_time.Month, date_time.Day,
131*b1cdbd2cSJim Jagielski date_time.Hours, date_time.Minutes, date_time.Seconds );
132*b1cdbd2cSJim Jagielski buf.append( ar );
133*b1cdbd2cSJim Jagielski }
134*b1cdbd2cSJim Jagielski buf.append( RTL_CONSTASCII_STRINGPARAM("######\n") );
135*b1cdbd2cSJim Jagielski log_write( buf.makeStringAndClear() );
136*b1cdbd2cSJim Jagielski }
137*b1cdbd2cSJim Jagielski
138*b1cdbd2cSJim Jagielski //______________________________________________________________________________
log_write(OString const & text)139*b1cdbd2cSJim Jagielski void ProgressLogImpl::log_write( OString const & text )
140*b1cdbd2cSJim Jagielski {
141*b1cdbd2cSJim Jagielski try {
142*b1cdbd2cSJim Jagielski if (m_xLogFile.is()) {
143*b1cdbd2cSJim Jagielski m_xLogFile->writeBytes(
144*b1cdbd2cSJim Jagielski Sequence< sal_Int8 >(
145*b1cdbd2cSJim Jagielski reinterpret_cast< sal_Int8 const * >(text.getStr()),
146*b1cdbd2cSJim Jagielski text.getLength() ) );
147*b1cdbd2cSJim Jagielski }
148*b1cdbd2cSJim Jagielski }
149*b1cdbd2cSJim Jagielski catch (io::IOException & exc) {
150*b1cdbd2cSJim Jagielski (void) exc;
151*b1cdbd2cSJim Jagielski OSL_ENSURE( 0, OUStringToOString(
152*b1cdbd2cSJim Jagielski exc.Message, RTL_TEXTENCODING_UTF8 ).getStr() );
153*b1cdbd2cSJim Jagielski }
154*b1cdbd2cSJim Jagielski }
155*b1cdbd2cSJim Jagielski
156*b1cdbd2cSJim Jagielski // XProgressHandler
157*b1cdbd2cSJim Jagielski //______________________________________________________________________________
push(Any const & Status)158*b1cdbd2cSJim Jagielski void ProgressLogImpl::push( Any const & Status )
159*b1cdbd2cSJim Jagielski throw (RuntimeException)
160*b1cdbd2cSJim Jagielski {
161*b1cdbd2cSJim Jagielski update( Status );
162*b1cdbd2cSJim Jagielski OSL_ASSERT( m_log_level >= 0 );
163*b1cdbd2cSJim Jagielski ++m_log_level;
164*b1cdbd2cSJim Jagielski }
165*b1cdbd2cSJim Jagielski
166*b1cdbd2cSJim Jagielski //______________________________________________________________________________
update(Any const & Status)167*b1cdbd2cSJim Jagielski void ProgressLogImpl::update( Any const & Status )
168*b1cdbd2cSJim Jagielski throw (RuntimeException)
169*b1cdbd2cSJim Jagielski {
170*b1cdbd2cSJim Jagielski if (! Status.hasValue())
171*b1cdbd2cSJim Jagielski return;
172*b1cdbd2cSJim Jagielski
173*b1cdbd2cSJim Jagielski OUStringBuffer buf;
174*b1cdbd2cSJim Jagielski OSL_ASSERT( m_log_level >= 0 );
175*b1cdbd2cSJim Jagielski for ( sal_Int32 n = 0; n < m_log_level; ++n )
176*b1cdbd2cSJim Jagielski buf.append( static_cast<sal_Unicode>(' ') );
177*b1cdbd2cSJim Jagielski
178*b1cdbd2cSJim Jagielski OUString msg;
179*b1cdbd2cSJim Jagielski if (Status >>= msg) {
180*b1cdbd2cSJim Jagielski buf.append( msg );
181*b1cdbd2cSJim Jagielski }
182*b1cdbd2cSJim Jagielski else {
183*b1cdbd2cSJim Jagielski buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("ERROR: ") );
184*b1cdbd2cSJim Jagielski buf.append( ::comphelper::anyToString(Status) );
185*b1cdbd2cSJim Jagielski }
186*b1cdbd2cSJim Jagielski buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\n") );
187*b1cdbd2cSJim Jagielski log_write( OUStringToOString(
188*b1cdbd2cSJim Jagielski buf.makeStringAndClear(), osl_getThreadTextEncoding() ) );
189*b1cdbd2cSJim Jagielski }
190*b1cdbd2cSJim Jagielski
191*b1cdbd2cSJim Jagielski //______________________________________________________________________________
pop()192*b1cdbd2cSJim Jagielski void ProgressLogImpl::pop() throw (RuntimeException)
193*b1cdbd2cSJim Jagielski {
194*b1cdbd2cSJim Jagielski OSL_ASSERT( m_log_level > 0 );
195*b1cdbd2cSJim Jagielski --m_log_level;
196*b1cdbd2cSJim Jagielski }
197*b1cdbd2cSJim Jagielski
198*b1cdbd2cSJim Jagielski namespace sdecl = comphelper::service_decl;
199*b1cdbd2cSJim Jagielski sdecl::class_<ProgressLogImpl, sdecl::with_args<true> > servicePLI;
200*b1cdbd2cSJim Jagielski extern sdecl::ServiceDecl const serviceDecl(
201*b1cdbd2cSJim Jagielski servicePLI,
202*b1cdbd2cSJim Jagielski // a private one:
203*b1cdbd2cSJim Jagielski "com.sun.star.comp.deployment.ProgressLog",
204*b1cdbd2cSJim Jagielski "com.sun.star.comp.deployment.ProgressLog" );
205*b1cdbd2cSJim Jagielski
206*b1cdbd2cSJim Jagielski } // namespace dp_log
207*b1cdbd2cSJim Jagielski
208