---

Activity.cc

/*
 * Copyright 2003 Michael A. Marsh, Cornell University. All rights reserved.
 * This software is released under the modified BSD license.
 * See the file LICENSE in the top-level directory for details.
 */
//
// $Id: Activity.cc,v 1.3 2004/05/19 15:56:49 mmarsh Exp $
//
// $Log: Activity.cc,v $
// Revision 1.3  2004/05/19 15:56:49  mmarsh
// *** empty log message ***
//
// Revision 1.2  2003/11/04 22:31:48  mmarsh
// *** empty log message ***
//
//

#include "Activity.h"
#include "Event.h"

#include <assert.h>

using namespace CODEX_Events;

Activity::Activity( DeadPileType& deadPile, QType& eventQueue ) :
   m_deadPile( deadPile ),
   m_queue( eventQueue ),
   m_outstanding( 0 ),
   m_canTerminate( false )
{
   //assert( 0 != m_queue );
}

Activity::~Activity()
{
}

bool
Activity::handler( EventAck& event )
{
   if ( ( 0 == --m_outstanding ) && m_canTerminate )
   {
      terminate();
   }
   return true;
}

void
Activity::sendEvent( EventBase* event, Activity* ack, bool failure )
{
   if ( 0 != event )
   {
      m_queue.push( event );
      ++m_outstanding;
   }
   if ( 0 != ack )
   {
      m_queue.push( new EventAck(ack, failure) );
   }
}

void
Activity::enableTerminate()
{
   m_canTerminate = true;
}

void
Activity::terminate()
{
   //if ( 0 != m_deadPile )
   //{
      m_deadPile.push_back(this);
   //}
}

DataHandler::DataHandler() :
   Activity( *(DeadPileType*)0, *(QType*)0 )
{
}

DataHandler::~DataHandler()
{
}

CloseHandler::CloseHandler() :
   Activity( *(DeadPileType*)0, *(QType*)0 ) // never called
{
}

CloseHandler::~CloseHandler()
{
}

---