sd/source/ui/remotecontrol/Transmitter.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  */
   9 #include "Transmitter.hxx"
  10 #include "IBluetoothSocket.hxx"
  11 #include <sal/log.hxx>
  12
  13 using namespace osl; // Sockets etc.
  14 using namespace sd;
  15
  16 Transmitter::Transmitter( IBluetoothSocket* aSocket )
  17   : pStreamSocket( aSocket ),
  18     mFinishRequested( false )
  19 {
  20 }
  21
  22 void SAL_CALL Transmitter::run()
  23 {
  24     osl_setThreadName("bluetooth Transmitter");
  25
  26     while ( true )
  27     {
  28         mProcessingRequired.wait();
  29
  30         OString aMessage;
  31         bool isHighPrio = {};
  32
  33         {
  34             ::osl::MutexGuard aGuard(mMutex);
  35
  36             if (mFinishRequested) {
  37                 return;
  38             }
  39             if (!mHighPriority.empty())
  40             {
  41                 aMessage = mHighPriority.front();
  42                 mHighPriority.pop();
  43                 isHighPrio = true;
  44             }
  45             else if (!mLowPriority.empty())
  46             {
  47                 aMessage = mLowPriority.front();
  48                 mLowPriority.pop();
  49                 isHighPrio = false;
  50             }
  51         }
  52
  53         SAL_INFO("sdremote.bluetooth", "write " << (isHighPrio ? "high prio" : "normal") << " line '" << aMessage << "'");
  54         // pStreamSocket is owned by Communicator, which joins this thread
  55         // before destroying pStreamSocket so it can't die here.
  56         // Sending is SLOW and blocks!
  57         pStreamSocket->write( aMessage.getStr(), aMessage.getLength() );
  58
  59         {
  60             ::osl::MutexGuard aGuard(mMutex);
  61
  62             if (mLowPriority.empty() && mHighPriority.empty())
  63             {
  64                 mProcessingRequired.reset();
  65             }
  66         }
  67     }
  68 }
  69
  70 void Transmitter::notifyFinished()
  71 {
  72     ::osl::MutexGuard aGuard( mMutex );
  73     mFinishRequested = true;
  74     mProcessingRequired.set();
  75 }
  76
  77 Transmitter::~Transmitter()
  78 {
  79 }
  80
  81 void Transmitter::addMessage( const OString& aMessage, const Priority aPriority )
  82 {
  83     ::osl::MutexGuard aGuard( mMutex );
  84     switch ( aPriority )
  85     {
  86         case PRIORITY_LOW:
  87             mLowPriority.push( aMessage );
  88             break;
  89         case PRIORITY_HIGH:
  90             mHighPriority.push( aMessage );
  91             break;
  92     }
  93     if ( !mProcessingRequired.check() )
  94     {
  95         mProcessingRequired.set();
  96     }
  97 }
  98
  99 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */