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