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 std;
  14 using namespace osl; // Sockets etc.
  15 using namespace sd;
  16
  17 Transmitter::Transmitter( IBluetoothSocket* aSocket )
  18   : pStreamSocket( aSocket ),
  19     mQueuesNotEmpty(),
  20     mFinishRequested(),
  21     mQueueMutex(),
  22     mLowPriority(),
  23     mHighPriority()
  24 {
  25 }
  26
  27 void SAL_CALL Transmitter::run()
  28 {
  29     osl_setThreadName("bluetooth Transmitter");
  30
  31     while ( true )
  32     {
  33         mQueuesNotEmpty.wait();
  34
  35         if ( mFinishRequested.check() )
  36             return;
  37
  38         ::osl::MutexGuard aQueueGuard( mQueueMutex );
  39         if ( !mHighPriority.empty() )
  40         {
  41             OString aMessage( mHighPriority.front() );
  42             mHighPriority.pop();
  43             SAL_INFO( "sdremote.bluetooth", "write high prio line '" << aMessage << "'" );
  44             pStreamSocket->write( aMessage.getStr(), aMessage.getLength() );
  45         }
  46         else if ( !mLowPriority.empty() )
  47         {
  48             OString aMessage( mLowPriority.front() );
  49             mLowPriority.pop();
  50             SAL_INFO( "sdremote.bluetooth", "write normal line '" << aMessage << "'" );
  51             pStreamSocket->write( aMessage.getStr(), aMessage.getLength() );
  52         }
  53
  54         if ( mLowPriority.empty() && mHighPriority.empty() )
  55         {
  56             mQueuesNotEmpty.reset();
  57         }
  58     }
  59 }
  60
  61 void Transmitter::notifyFinished()
  62 {
  63     mFinishRequested.set();
  64     mQueuesNotEmpty.set();
  65 }
  66
  67 Transmitter::~Transmitter()
  68 {
  69 }
  70
  71 void Transmitter::addMessage( const OString& aMessage, const Priority aPriority )
  72 {
  73     ::osl::MutexGuard aQueueGuard( mQueueMutex );
  74     switch ( aPriority )
  75     {
  76         case PRIORITY_LOW:
  77             mLowPriority.push( aMessage );
  78             break;
  79         case PRIORITY_HIGH:
  80             mHighPriority.push( aMessage );
  81             break;
  82     }
  83     if ( !mQueuesNotEmpty.check() )
  84     {
  85         mQueuesNotEmpty.set();
  86     }
  87 }
  88
  89 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */