diff options
Diffstat (limited to 'sd/source/ui/remotecontrol/Transmitter.cxx')
-rw-r--r-- | sd/source/ui/remotecontrol/Transmitter.cxx | 99 |
1 files changed, 99 insertions, 0 deletions
diff --git a/sd/source/ui/remotecontrol/Transmitter.cxx b/sd/source/ui/remotecontrol/Transmitter.cxx new file mode 100644 index 0000000000..7992e5b94b --- /dev/null +++ b/sd/source/ui/remotecontrol/Transmitter.cxx @@ -0,0 +1,99 @@ +/* -*- 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 "Transmitter.hxx" +#include "IBluetoothSocket.hxx" +#include <sal/log.hxx> + +using namespace osl; // Sockets etc. +using namespace sd; + +Transmitter::Transmitter( IBluetoothSocket* aSocket ) + : pStreamSocket( aSocket ), + mFinishRequested( false ) +{ +} + +void SAL_CALL Transmitter::run() +{ + osl_setThreadName("bluetooth Transmitter"); + + while ( true ) + { + mProcessingRequired.wait(); + + OString aMessage; + bool isHighPrio = {}; + + { + ::osl::MutexGuard aGuard(mMutex); + + if (mFinishRequested) { + return; + } + if (!mHighPriority.empty()) + { + aMessage = mHighPriority.front(); + mHighPriority.pop(); + isHighPrio = true; + } + else if (!mLowPriority.empty()) + { + aMessage = mLowPriority.front(); + mLowPriority.pop(); + isHighPrio = false; + } + } + + SAL_INFO("sdremote.bluetooth", "write " << (isHighPrio ? "high prio" : "normal") << " line '" << aMessage << "'"); + // pStreamSocket is owned by Communicator, which joins this thread + // before destroying pStreamSocket so it can't die here. + // Sending is SLOW and blocks! + pStreamSocket->write( aMessage.getStr(), aMessage.getLength() ); + + { + ::osl::MutexGuard aGuard(mMutex); + + if (mLowPriority.empty() && mHighPriority.empty()) + { + mProcessingRequired.reset(); + } + } + } +} + +void Transmitter::notifyFinished() +{ + ::osl::MutexGuard aGuard( mMutex ); + mFinishRequested = true; + mProcessingRequired.set(); +} + +Transmitter::~Transmitter() +{ +} + +void Transmitter::addMessage( const OString& aMessage, const Priority aPriority ) +{ + ::osl::MutexGuard aGuard( mMutex ); + switch ( aPriority ) + { + case PRIORITY_LOW: + mLowPriority.push( aMessage ); + break; + case PRIORITY_HIGH: + mHighPriority.push( aMessage ); + break; + } + if ( !mProcessingRequired.check() ) + { + mProcessingRequired.set(); + } +} + +/* vim:set shiftwidth=4 softtabstop=4 expandtab: */ |