---

CTBsignalBase.hxx

Go to the documentation of this file.

#ifndef _CTBsignalBase_HXX
#define _CTBsignalBase_HXX 1

/*----------------------------------------------------------------------------*/
/* C Tool Box: Designed and implemented by:                                   */
/*    Walter F.J. Mueller   Gesellschaft fuer Schwerionenforschung (GSI)      */
/*                          Planckstrasse 1, D-64291 Darmstadt, Germany       */
/*                  Email:  W.F.J.Mueller@gsi.de                              */
/*                  WWW:    http://www-kp3.gsi.de/www/kp3/people/mueller.html */
/*------------------------------------------+---------------------------------*/
 
#include "CTBsimpleList.hxx"
#include "CTBtreeList.hxx"

class CTBsignalLink;
class CTBsignalReceiverBase;

class CTBsignalEmitter {

  friend class CTBsignalLink;
  friend class CTBsignalReceiverBase;

  public: 

                    CTBsignalEmitter();
                    CTBsignalEmitter(const CTBsignalEmitter& rhs);

                    ~CTBsignalEmitter();

    int             NConnect() const;

    void            operator()(CTBuint32 i_mask);

    CTBsignalEmitter& operator=(const CTBsignalEmitter& rhs);

    bool            operator! () const;

                    operator bool() const;

  private:

    void            Execute(CTBuint32 i_mask) const;

  private:

    typedef CTBsimpleListHead<CTBsignalLink> ehead_t;
  
    ehead_t         m_ehead;                
};

//------------------------------------------+-----------------------------------

class CTBsignalReceiverBase {

  friend class CTBsignalLink;
  friend class CTBsignalEmitter;

  public: 

                    CTBsignalReceiverBase();
                    CTBsignalReceiverBase(const CTBsignalReceiverBase& rhs);

    virtual         ~CTBsignalReceiverBase();

    int             NConnect() const;
    void            Disconnect();
    void            Disconnect(CTBsignalEmitter& emitter);

    void            Block();
    void            Unblock();
    bool            Blocked() const;
    bool            Pending() const;

    void            Deliver();

    CTBsignalReceiverBase& operator=(const CTBsignalReceiverBase& rhs);

    bool            operator! () const;

                    operator bool() const;

  protected:

    void            Connect(CTBsignalEmitter& emitter,
                            void* p_emitter, CTBuint32 i_mask);

    virtual void    Execute(void* p_emitter, CTBuint32 i_mask) const = 0;

  protected:

    typedef CTBtreeListHead<CTBsignalReceiverBase,CTBsignalLink>  rhead_t;
    typedef CTBsimpleListHead<CTBsignalLink>                      phead_t;
  
    rhead_t          m_rhead;               
    phead_t          m_phead;               
    int              mi_nblock;             
};

//------------------------------------------+-----------------------------------

class CTBsignalLink {

  friend class CTBsignalEmitter;
  friend class CTBsignalReceiverBase;

  private:

                    CTBsignalLink(CTBsignalEmitter& emitter,
                                  CTBsignalReceiverBase& receiver,
                                  void* p_emitter, CTBuint32 i_mask);
                    CTBsignalLink(const CTBsignalLink& rhs,
                                  CTBsignalReceiverBase& receiver);
                     
                    ~CTBsignalLink();
  
    void            Mark();
    void            Unmark();

    bool            Busy() const;
    bool            Pending() const;
    bool            Zombie() const;
    bool            Deletable() const;

    void            UnlinkEmitter();
    void            UnlinkReceiver();

  private:

    typedef CTBsimpleListLink<CTBsignalLink>                      elink_t;
    typedef CTBtreeListLink<CTBsignalReceiverBase,CTBsignalLink>  rlink_t;
    typedef CTBsimpleListLink<CTBsignalLink>                      plink_t;

    elink_t         m_elink;                
    rlink_t         m_rlink;                
    plink_t         m_plink;                
    int             mi_nbusy;               
    void*           mp_emitter;             
    CTBuint32       mi_acceptmask;          
    CTBuint32       mi_pendingmask;         
};

// Notes:
//  -- proofed: 07-nov-1999(2)

#if !(defined(CTB__OutLine) || defined(CTBsignalBase__OutLine))
#include "CTBsignalBase.icc"
#endif

#endif

---