---

Activity.h

/*
 * 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.h,v 1.3 2004/05/19 15:56:49 mmarsh Exp $
//
// $Log: Activity.h,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 ***
//
//

#ifndef __CODEX_EVENTS_ACTIVITY_H__
#define __CODEX_EVENTS_ACTIVITY_H__

#include <queue>
#include <vector>

#include "Event.h"

using namespace std;

namespace CODEX_Events
{
   typedef std::queue< EventBase* > QType; // namespace needed on Solaris

   typedef vector< Activity* > DeadPileType;

   class Activity
   {
      public:
         Activity( DeadPileType& deadPile, QType& eventQueue );

         virtual ~Activity();

         virtual bool handler( EventAck& event );

      protected:
         void sendEvent( EventBase* event,
                         Activity* source,
                         bool failure=false );

         void enableTerminate();

      private :
         void terminate();

      protected :
         DeadPileType& m_deadPile;
         QType&        m_queue;

      private :
         int           m_outstanding;
         bool          m_canTerminate;
   };

   class DataEvent;

   class DataHandler : public virtual Activity
   {
      public:
         DataHandler();

         virtual ~DataHandler();

         virtual bool handler( DataEvent& event ) = 0;
   };

   class CloseEvent;

   class CloseHandler : public virtual Activity
   {
      public:
         CloseHandler();

         virtual ~CloseHandler();

         virtual bool handler( CloseEvent& event ) = 0;
   };

}

#endif /* __CODEX_EVENTS_ACTIVITY_H__ */

---