| /************************************************************** |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| *************************************************************/ |
| |
| |
| |
| // MARKER(update_precomp.py): autogen include statement, do not remove |
| #include "precompiled_desktop.hxx" |
| |
| #include "dp_misc.h" |
| #include "rtl/strbuf.hxx" |
| #include "osl/time.h" |
| #include "osl/thread.h" |
| #include "cppuhelper/compbase1.hxx" |
| #include "comphelper/anytostring.hxx" |
| #include "comphelper/servicedecl.hxx" |
| #include "comphelper/unwrapargs.hxx" |
| #include "com/sun/star/deployment/DeploymentException.hpp" |
| #include "com/sun/star/ucb/XProgressHandler.hpp" |
| #include "com/sun/star/ucb/XSimpleFileAccess.hpp" |
| #include "com/sun/star/io/XSeekable.hpp" |
| #include <stdio.h> |
| |
| |
| using namespace ::rtl; |
| using namespace ::com::sun::star; |
| using namespace ::com::sun::star::uno; |
| |
| namespace dp_log { |
| |
| typedef ::cppu::WeakComponentImplHelper1<ucb::XProgressHandler> t_log_helper; |
| |
| //============================================================================== |
| class ProgressLogImpl : public ::dp_misc::MutexHolder, public t_log_helper |
| { |
| Reference<io::XOutputStream> m_xLogFile; |
| sal_Int32 m_log_level; |
| void log_write( OString const & text ); |
| |
| protected: |
| virtual void SAL_CALL disposing(); |
| virtual ~ProgressLogImpl(); |
| |
| public: |
| ProgressLogImpl( Sequence<Any> const & args, |
| Reference<XComponentContext> const & xContext ); |
| |
| // XProgressHandler |
| virtual void SAL_CALL push( Any const & Status ) throw (RuntimeException); |
| virtual void SAL_CALL update( Any const & Status ) throw (RuntimeException); |
| virtual void SAL_CALL pop() throw (RuntimeException); |
| }; |
| |
| //______________________________________________________________________________ |
| ProgressLogImpl::~ProgressLogImpl() |
| { |
| } |
| |
| //______________________________________________________________________________ |
| void ProgressLogImpl::disposing() |
| { |
| try { |
| if (m_xLogFile.is()) { |
| m_xLogFile->closeOutput(); |
| m_xLogFile.clear(); |
| } |
| } |
| catch (Exception & exc) { |
| (void) exc; |
| OSL_ENSURE( 0, OUStringToOString( |
| exc.Message, RTL_TEXTENCODING_UTF8 ).getStr() ); |
| } |
| } |
| |
| //______________________________________________________________________________ |
| ProgressLogImpl::ProgressLogImpl( |
| Sequence<Any> const & args, |
| Reference<XComponentContext> const & xContext ) |
| : t_log_helper( getMutex() ), |
| m_log_level( 0 ) |
| { |
| OUString log_file; |
| boost::optional< Reference<task::XInteractionHandler> > interactionHandler; |
| comphelper::unwrapArgs( args, log_file, interactionHandler ); |
| |
| Reference<ucb::XSimpleFileAccess> xSimpleFileAccess( |
| xContext->getServiceManager()->createInstanceWithContext( |
| OUSTR("com.sun.star.ucb.SimpleFileAccess"), |
| xContext ), UNO_QUERY_THROW ); |
| // optional ia handler: |
| if (interactionHandler) |
| xSimpleFileAccess->setInteractionHandler( *interactionHandler ); |
| |
| m_xLogFile.set( |
| xSimpleFileAccess->openFileWrite( log_file ), UNO_QUERY_THROW ); |
| Reference<io::XSeekable> xSeekable( m_xLogFile, UNO_QUERY_THROW ); |
| xSeekable->seek( xSeekable->getLength() ); |
| |
| // write log stamp |
| OStringBuffer buf; |
| buf.append( |
| RTL_CONSTASCII_STRINGPARAM("###### Progress log entry ") ); |
| TimeValue m_start_time, tLocal; |
| oslDateTime date_time; |
| if (osl_getSystemTime( &m_start_time ) && |
| osl_getLocalTimeFromSystemTime( &m_start_time, &tLocal ) && |
| osl_getDateTimeFromTimeValue( &tLocal, &date_time )) |
| { |
| char ar[ 128 ]; |
| snprintf( |
| ar, sizeof (ar), |
| "%04d-%02d-%02d %02d:%02d:%02d ", |
| date_time.Year, date_time.Month, date_time.Day, |
| date_time.Hours, date_time.Minutes, date_time.Seconds ); |
| buf.append( ar ); |
| } |
| buf.append( RTL_CONSTASCII_STRINGPARAM("######\n") ); |
| log_write( buf.makeStringAndClear() ); |
| } |
| |
| //______________________________________________________________________________ |
| void ProgressLogImpl::log_write( OString const & text ) |
| { |
| try { |
| if (m_xLogFile.is()) { |
| m_xLogFile->writeBytes( |
| Sequence< sal_Int8 >( |
| reinterpret_cast< sal_Int8 const * >(text.getStr()), |
| text.getLength() ) ); |
| } |
| } |
| catch (io::IOException & exc) { |
| (void) exc; |
| OSL_ENSURE( 0, OUStringToOString( |
| exc.Message, RTL_TEXTENCODING_UTF8 ).getStr() ); |
| } |
| } |
| |
| // XProgressHandler |
| //______________________________________________________________________________ |
| void ProgressLogImpl::push( Any const & Status ) |
| throw (RuntimeException) |
| { |
| update( Status ); |
| OSL_ASSERT( m_log_level >= 0 ); |
| ++m_log_level; |
| } |
| |
| //______________________________________________________________________________ |
| void ProgressLogImpl::update( Any const & Status ) |
| throw (RuntimeException) |
| { |
| if (! Status.hasValue()) |
| return; |
| |
| OUStringBuffer buf; |
| OSL_ASSERT( m_log_level >= 0 ); |
| for ( sal_Int32 n = 0; n < m_log_level; ++n ) |
| buf.append( static_cast<sal_Unicode>(' ') ); |
| |
| OUString msg; |
| if (Status >>= msg) { |
| buf.append( msg ); |
| } |
| else { |
| buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("ERROR: ") ); |
| buf.append( ::comphelper::anyToString(Status) ); |
| } |
| buf.appendAscii( RTL_CONSTASCII_STRINGPARAM("\n") ); |
| log_write( OUStringToOString( |
| buf.makeStringAndClear(), osl_getThreadTextEncoding() ) ); |
| } |
| |
| //______________________________________________________________________________ |
| void ProgressLogImpl::pop() throw (RuntimeException) |
| { |
| OSL_ASSERT( m_log_level > 0 ); |
| --m_log_level; |
| } |
| |
| namespace sdecl = comphelper::service_decl; |
| sdecl::class_<ProgressLogImpl, sdecl::with_args<true> > servicePLI; |
| extern sdecl::ServiceDecl const serviceDecl( |
| servicePLI, |
| // a private one: |
| "com.sun.star.comp.deployment.ProgressLog", |
| "com.sun.star.comp.deployment.ProgressLog" ); |
| |
| } // namespace dp_log |
| |