#include <BroadcastClient.h>

Inheritance diagram for BroadcastClient:

Public Member Functions
	BroadcastClient (int id)

	~BroadcastClient ()

void	awaken (int id, int tag)

Public Attributes
int	id

Protected Member Functions
void	suspendFor (int tag)

Protected Attributes
int	suspended

int	waitForTag

CthThread	thread

Detailed Description

Definition at line 12 of file BroadcastClient.h.

Constructor & Destructor Documentation

BroadcastClient::BroadcastClient ( int id )

Definition at line 15 of file BroadcastClient.C.

References id, BroadcastMgr::Object(), BroadcastMgr::subscribe(), suspended, and waitForTag.

                                        {
   this->id = id;
   BroadcastMgr::Object()->subscribe(*this);
   waitForTag = -1;
   suspended = 0;
 }

BroadcastClient::~BroadcastClient ( )

Definition at line 22 of file BroadcastClient.C.

References BroadcastMgr::Object(), and BroadcastMgr::unsubscribe().

                                   {
   BroadcastMgr::Object()->unsubscribe(*this);
 }

Member Function Documentation

void BroadcastClient::awaken	(	int	id,
		int	tag
	)

Definition at line 27 of file BroadcastClient.C.

References DebugM, suspended, thread, and waitForTag.

                                           {
   DebugM(1, "awaken() client id = " << id << " tag = " << tag << "\n");
   if (suspended && theid == this->id && tag == waitForTag) {
     CthAwaken(thread);
     suspended = 0; waitForTag = -1;
   }
 }

void BroadcastClient::suspendFor ( int tag )

protected

Definition at line 36 of file BroadcastClient.C.

References DebugM, suspended, thread, and waitForTag.

Referenced by SimpleBroadcastObject< Tensor >::get().

                                    {
   DebugM(1, "suspending() client id = " << id << " tag = " << tag << "\n");
   suspended = 1;
   waitForTag = tag;
   thread = CthSelf();
   CthSuspend();
 }