/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */ /* * This file is part of the LibreOffice project. * * This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. * * This file incorporates work covered by the following license notice: * * 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 . */ #ifndef INCLUDED_DESKTOP_SOURCE_APP_OFFICEIPCTHREAD_HXX #define INCLUDED_DESKTOP_SOURCE_APP_OFFICEIPCTHREAD_HXX #include "sal/config.h" #include #include #include #include #include #include #include #include #include #include #include #include "boost/optional.hpp" namespace desktop { oslSignalAction SAL_CALL SalMainPipeExchangeSignal_impl(void* /*pData*/, oslSignalInfo* pInfo); // A request for the current office // that was given by command line or by IPC pipe communication. struct ProcessDocumentsRequest { ProcessDocumentsRequest(boost::optional< OUString > const & cwdUrl): aCwdUrl(cwdUrl), pcProcessed( NULL ) {} boost::optional< OUString > aCwdUrl; OUString aModule; std::vector< OUString > aOpenList; // Documents that should be opened in the default way std::vector< OUString > aViewList; // Documents that should be opened in viewmode std::vector< OUString > aStartList; // Documents/Presentations that should be started std::vector< OUString > aPrintList; // Documents that should be printed on default printer std::vector< OUString > aForceOpenList; // Documents that should be forced to open for editing (even templates) std::vector< OUString > aForceNewList; // Documents that should be forced to create a new document OUString aPrinterName; // The printer name that should be used for printing std::vector< OUString > aPrintToList; // Documents that should be printed on the given printer std::vector< OUString > aConversionList; OUString aConversionParams; OUString aConversionOut; std::vector< OUString > aInFilter; ::osl::Condition *pcProcessed; // pointer condition to be set when the request has been processed }; class DispatchWatcher; class OfficeIPCThread : public salhelper::Thread { private: static rtl::Reference< OfficeIPCThread > pGlobalOfficeIPCThread; osl::Pipe maPipe; bool mbDowning; bool mbRequestsEnabled; int mnPendingRequests; DispatchWatcher* mpDispatchWatcher; /* condition to be set when the request has been processed */ ::osl::Condition cProcessed; /* condition to be set when the main event loop is ready otherwise an error dialogs event loop could eat away requests from a 2nd office */ ::osl::Condition cReady; static ::osl::Mutex& GetMutex(); static const char *sc_aTerminationSequence; static const int sc_nTSeqLength; static const char *sc_aShowSequence; static const int sc_nShSeqLength; static const char *sc_aConfirmationSequence; static const int sc_nCSeqLength; static const char *sc_aSendArgumentsSequence; static const int sc_nCSASeqLength; OfficeIPCThread(); virtual ~OfficeIPCThread(); /// Working method which should be overridden virtual void execute(); public: enum Status { IPC_STATUS_OK, IPC_STATUS_2ND_OFFICE, IPC_STATUS_PIPE_ERROR, IPC_STATUS_BOOTSTRAP_ERROR }; // controlling pipe communication during shutdown static void SetDowning(); static void EnableRequests( bool i_bEnable = true ); static sal_Bool AreRequestsPending(); static void RequestsCompleted( int n = 1 ); static sal_Bool ExecuteCmdLineRequests( ProcessDocumentsRequest& ); // return sal_False if second office static Status EnableOfficeIPCThread(); static void DisableOfficeIPCThread(bool join = true); // start dispatching events... static void SetReady( rtl::Reference< OfficeIPCThread > const & pThread = rtl::Reference< OfficeIPCThread >()); bool AreRequestsEnabled() const { return mbRequestsEnabled && ! mbDowning; } }; class OfficeIPCThreadController : public ::cppu::WeakImplHelper2< ::com::sun::star::lang::XServiceInfo, ::com::sun::star::frame::XTerminateListener > { public: OfficeIPCThreadController() {} virtual ~OfficeIPCThreadController() {} // XServiceInfo virtual OUString SAL_CALL getImplementationName() throw ( ::com::sun::star::uno::RuntimeException, std::exception ); virtual sal_Bool SAL_CALL supportsService( const OUString& ServiceName ) throw ( ::com::sun::star::uno::RuntimeException, std::exception ); virtual ::com::sun::star::uno::Sequence< OUString > SAL_CALL getSupportedServiceNames() throw ( ::com::sun::star::uno::RuntimeException, std::exception ); // XEventListener virtual void SAL_CALL disposing( const ::com::sun::star::lang::EventObject& Source ) throw( ::com::sun::star::uno::RuntimeException, std::exception ); // XTerminateListener virtual void SAL_CALL queryTermination( const ::com::sun::star::lang::EventObject& aEvent ) throw( ::com::sun::star::frame::TerminationVetoException, ::com::sun::star::uno::RuntimeException, std::exception ); virtual void SAL_CALL notifyTermination( const ::com::sun::star::lang::EventObject& aEvent ) throw( ::com::sun::star::uno::RuntimeException, std::exception ); }; } #endif // INCLUDED_DESKTOP_SOURCE_APP_OFFICEIPCTHREAD_HXX /* vim:set shiftwidth=4 softtabstop=4 expandtab: */