bb121c864c
I had to drop XEventBroadcaster from the merged interface because it introduced method name conflicts (addEventListener). Shouldn't be an issue since it was scheduled to be dropped anyhow, and the service implementation still implements it, so existing clients will be fine. I dropped the interface XPropertySet from the combined IDL because nobody seems to be using it, and it's primary purpose appears to be to set weird flags. I dropped the optional interfaces XStatusIndicatorFactory XDispatchInformationProvider from the combined IDL because the service does not implement them, and nobody seems to be using them. I suspect they were mistakenly copied from XFrame. I also did not convert the Title, UserDefinedAttributes and LayoutManager properties to attributes, again because no-one is using them. Change-Id: I678a00006ed2cca2d6c37c4e39465811442c33af
125 lines
3.3 KiB
C++
125 lines
3.3 KiB
C++
/* -*- 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 <algorithm>
|
|
#include <vector>
|
|
|
|
#include <com/sun/star/frame/Desktop.hpp>
|
|
#include <comphelper/processfactory.hxx>
|
|
|
|
#include "Communicator.hxx"
|
|
#include "Listener.hxx"
|
|
#include "Receiver.hxx"
|
|
#include "RemoteServer.hxx"
|
|
|
|
using namespace sd;
|
|
using namespace std;
|
|
using namespace com::sun::star;
|
|
using namespace osl;
|
|
|
|
Communicator::Communicator( BufferedStreamSocket *pSocket ):
|
|
Thread( "CommunicatorThread" ),
|
|
mpSocket( pSocket ),
|
|
pTransmitter( 0 ),
|
|
mListener( 0 )
|
|
{
|
|
}
|
|
|
|
Communicator::~Communicator()
|
|
{
|
|
}
|
|
|
|
// Run as a thread
|
|
void Communicator::execute()
|
|
{
|
|
pTransmitter = new Transmitter( mpSocket );
|
|
pTransmitter->create();
|
|
|
|
pTransmitter->addMessage( "LO_SERVER_SERVER_PAIRED\n\n",
|
|
Transmitter::PRIORITY_HIGH );
|
|
Receiver aReceiver( pTransmitter );
|
|
try {
|
|
uno::Reference< frame::XDesktop2 > xFramesSupplier = frame::Desktop::create( ::comphelper::getProcessComponentContext() );
|
|
uno::Reference< frame::XFrame > xFrame ( xFramesSupplier->getActiveFrame(), uno::UNO_QUERY_THROW );
|
|
uno::Reference<presentation::XPresentationSupplier> xPS ( xFrame->getController()->getModel(), uno::UNO_QUERY_THROW);
|
|
uno::Reference<presentation::XPresentation2> xPresentation(
|
|
xPS->getPresentation(), uno::UNO_QUERY_THROW);
|
|
if ( xPresentation->isRunning() )
|
|
{
|
|
presentationStarted( xPresentation->getController() );
|
|
}
|
|
else
|
|
{
|
|
pTransmitter->addMessage( "slideshow_finished\n\n",
|
|
Transmitter::PRIORITY_HIGH );
|
|
}
|
|
}
|
|
catch (uno::RuntimeException &)
|
|
{
|
|
}
|
|
|
|
sal_uInt64 aRet;
|
|
vector<OString> 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.parseCommand( aCommand );
|
|
aCommand.clear();
|
|
}
|
|
}
|
|
disposeListener();
|
|
|
|
pTransmitter->notifyFinished();
|
|
pTransmitter->join();
|
|
pTransmitter = NULL;
|
|
|
|
delete mpSocket;
|
|
|
|
RemoteServer::removeCommunicator( this );
|
|
}
|
|
|
|
void Communicator::informListenerDestroyed()
|
|
{
|
|
if ( pTransmitter )
|
|
pTransmitter->addMessage( "slideshow_finished\n\n",
|
|
Transmitter::PRIORITY_HIGH );
|
|
mListener.clear();
|
|
}
|
|
|
|
void Communicator::presentationStarted( const css::uno::Reference<
|
|
css::presentation::XSlideShowController > &rController )
|
|
{
|
|
if ( pTransmitter )
|
|
{
|
|
mListener = rtl::Reference<Listener>( new Listener( this, pTransmitter ) );
|
|
mListener->init( rController );
|
|
}
|
|
}
|
|
|
|
void Communicator::disposeListener()
|
|
{
|
|
if ( mListener.is() )
|
|
{
|
|
mListener->disposing();
|
|
mListener = NULL;
|
|
}
|
|
}
|
|
|
|
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|