/* -*- 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/. */ #include #include #include #include #include #include #include #include #include #include #include "Communicator.hxx" #include "IBluetoothSocket.hxx" #include "Listener.hxx" #include "Receiver.hxx" #include "Transmitter.hxx" #include using namespace sd; using namespace com::sun::star; using namespace osl; Communicator::Communicator( std::unique_ptr pSocket ): Thread( "CommunicatorThread" ), mpSocket( std::move(pSocket) ) { } Communicator::~Communicator() { } /// Close the underlying socket from another thread to force /// an early exit / termination void Communicator::forceClose() { if( mpSocket ) mpSocket->close(); } // Run as a thread void Communicator::execute() { pTransmitter.reset( new Transmitter( mpSocket.get() ) ); pTransmitter->create(); pTransmitter->addMessage( "LO_SERVER_SERVER_PAIRED\n\n"_ostr, Transmitter::PRIORITY_HIGH ); pTransmitter->addMessage( "LO_SERVER_INFO\n" LIBO_VERSION_DOTTED "\n\n"_ostr, Transmitter::PRIORITY_HIGH ); Receiver aReceiver( pTransmitter.get() ); try { uno::Reference< frame::XDesktop2 > xFramesSupplier = frame::Desktop::create( ::comphelper::getProcessComponentContext() ); uno::Reference< frame::XFrame > xFrame = xFramesSupplier->getActiveFrame(); uno::Reference xPS; if( xFrame.is() ) xPS.set( xFrame->getController()->getModel(), uno::UNO_QUERY ); uno::Reference xPresentation; if( xPS.is() ) xPresentation.set( xPS->getPresentation(), uno::UNO_QUERY ); if ( xPresentation.is() && xPresentation->isRunning() ) { presentationStarted( xPresentation->getController() ); OString aBuffer = "slideshow_info\n" + OUStringToOString( ::comphelper::DocumentInfo::getDocumentTitle( xFrame->getController()->getModel() ), RTL_TEXTENCODING_UTF8 ) + "\n\n"; pTransmitter->addMessage( aBuffer, Transmitter::PRIORITY_LOW ); } else { pTransmitter->addMessage( "slideshow_finished\n\n"_ostr, Transmitter::PRIORITY_HIGH ); } } catch (uno::RuntimeException &) { } sal_uInt64 aRet; std::vector aCommand; while ( true ) { OString aLine; aRet = mpSocket->readLine( aLine ); if ( aRet == 0 ) { break; // I.e. transmission finished. } if ( aLine.getLength() ) { aCommand.push_back( aLine ); } else { aReceiver.pushCommand( aCommand ); aCommand.clear(); } } SAL_INFO ("sdremote", "Exiting transmission loop"); disposeListener(); pTransmitter->notifyFinished(); pTransmitter->join(); pTransmitter = nullptr; mpSocket->close(); mpSocket.reset(); RemoteServer::removeCommunicator( this ); } void Communicator::informListenerDestroyed() { // called only from the Listener::disposing() method // during disposal of this communicator if ( pTransmitter ) pTransmitter->addMessage( "slideshow_finished\n\n"_ostr, Transmitter::PRIORITY_HIGH ); } void Communicator::presentationStarted( const css::uno::Reference< css::presentation::XSlideShowController > &rController ) { if ( pTransmitter ) { mListener.set( new Listener( this, pTransmitter.get() ) ); mListener->init( rController ); } } void Communicator::disposeListener() { if ( mListener.is() ) { mListener->dispose(); mListener = nullptr; } } /* vim:set shiftwidth=4 softtabstop=4 expandtab: */ abora/dcm-6.2'>distro/collabora/dcm-6.2 LibreOffice 核心代码仓库文档基金会

path: root/connectivity/CppunitTest_connectivity_mysql_test.mk

Age	Commit message (Expand)	Author