S3FC project page

S3FC home page

---

               

---

s3_fifo_base.cc

Go to the documentation of this file.

/*
 * Stone Three Foundation Class (s3fc) provides a number of utility classes.
 * Copyright (C) 2001 by Stone Three Signal Processing (Pty) Ltd.
 *
 * Authored by Stone Three Signal Processing (Pty) Ltd.
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 * 
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * 
 * Please see the file 'COPYING' in the source root directory.
 */

#include <s3fc/s3_fifo_base.h>
#include <s3fc/s3_macros.h>
#include <s3fc/s3_exception.h>
#include <sstream>
#include <algorithm>

//
void s3_subscribable_fifo::subscribe_producer(const s3_semaphore& sem)
{
   notification_lock.lock();
   // test precondition
   if ( std::find(producers.begin(), producers.end(), &sem) != producers.end() )
   {
      // semaphore already subscribed
      notification_lock.unlock();
      std::stringstream str;
      str << "Semaphore at  [" << &sem << "] already subscribed to "
     << "producer notification list";
      throw s3_generic_exception("s3_subscribable_fifo::"
             "subscribe_producer", str.str());
   }
   // add to list
   producers.push_back(const_cast<s3_semaphore*>(&sem));
   notification_lock.unlock();
}

//
void s3_subscribable_fifo::unsubscribe_producer(const s3_semaphore& sem)
{

   notification_lock.lock();
   // test precondition
   if ( std::find(producers.begin(), producers.end(), &sem) == producers.end() )
   {
      // semaphore not subscribed
      notification_lock.unlock();
      std::stringstream str;
      str << "Semaphore at  [" << &sem << "] not subscribed to "
     << "producer notification list";
      throw s3_generic_exception("s3_subscribable_fifo::"
             "unsubscribe_producer", str.str());
   }
   // remove from list
   producers.erase(std::find(producers.begin(), producers.end(), &sem));
   notification_lock.unlock();
}

//
bool s3_subscribable_fifo::is_subscribed_producer(const s3_semaphore& sem)
{
   bool retval;
   notification_lock.lock();
   retval = std::find(producers.begin(),
            producers.end(), &sem) != producers.end();
   notification_lock.unlock();
   return retval;
}

//
void s3_subscribable_fifo::subscribe_consumer(const s3_semaphore& sem)
{
   notification_lock.lock();
   // test precondition
   if ( std::find(consumers.begin(), consumers.end(), &sem) != consumers.end() )
   {
      // semaphore already subscribed
      notification_lock.unlock();
      std::stringstream str;
      str << "Semaphore at  [" << &sem << "] already subscribed to "
     << "consumer notification list";
      throw s3_generic_exception("s3_subscribable_fifo::"
             "subscribe_consumer", str.str());
   }
   // add to list
   consumers.push_back(const_cast<s3_semaphore*>(&sem));
   notification_lock.unlock();
}

//
void s3_subscribable_fifo::unsubscribe_consumer(const s3_semaphore& sem)
{
   notification_lock.lock();
   // test precondition
   if ( std::find(consumers.begin(), consumers.end(), &sem) == consumers.end() )
   {
      // semaphore not subscribed
      notification_lock.unlock();
      std::stringstream str;
      str << "Semaphore at  [" << &sem << "] not subscribed to "
     << "consumer notification list";
      throw s3_generic_exception("s3_subscribable_fifo::"
             "unsubscribe_consumer", str.str());
   }
   // remove from list
   consumers.erase(std::find(consumers.begin(), consumers.end(), &sem));
   notification_lock.unlock();
}

//
bool s3_subscribable_fifo::is_subscribed_consumer(const s3_semaphore& sem)
{
   bool retval;
   notification_lock.lock();
   retval = std::find(consumers.begin(), consumers.end(), &sem) !=
       consumers.end();
   notification_lock.unlock();
   return retval;
}


//
void s3_subscribable_fifo::notify_producers() const
{
   notification_lock.lock();   
   for (T_ConstIterator ptr = producers.begin(); 
   ptr != producers.end();
   ptr++)
   {
      (*ptr)->post();
   }
   notification_lock.unlock();      
}

//
void s3_subscribable_fifo::notify_consumers() const
{
   notification_lock.lock();   
   for (T_ConstIterator ptr = consumers.begin(); 
   ptr != consumers.end();
   ptr++)
   {
      (*ptr)->post();
   }
   notification_lock.unlock();      
}

---

Send comments to: s3fc@stonethree.com