BroadcastClient Class Reference

#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

Copyright (c) 1995, 1996, 1997, 1998, 1999, 2000 by The Board of Trustees of the University of Illinois. All rights reserved.

Definition at line 12 of file BroadcastClient.h.

Constructor & Destructor Documentation

BroadcastClient()

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::~BroadcastClient

(

)

Definition at line 22 of file BroadcastClient.C.

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

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

Member Function Documentation

awaken()

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

Definition at line 27 of file BroadcastClient.C.

References DebugM, suspended, thread, and waitForTag.

Referenced by BroadcastMgr::recvBroadcast().

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

suspendFor()

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();
}

Member Data Documentation

id

int BroadcastClient::id

Definition at line 14 of file BroadcastClient.h.

Referenced by BroadcastClient(), BroadcastMgr::getbuf(), BroadcastMgr::send(), BroadcastMgr::subscribe(), and BroadcastMgr::unsubscribe().

suspended

int BroadcastClient::suspended

protected

Definition at line 22 of file BroadcastClient.h.

Referenced by awaken(), BroadcastClient(), and suspendFor().

thread

CthThread BroadcastClient::thread

protected

Definition at line 24 of file BroadcastClient.h.

Referenced by awaken(), and suspendFor().

waitForTag

int BroadcastClient::waitForTag

protected

Definition at line 23 of file BroadcastClient.h.

Referenced by awaken(), BroadcastClient(), and suspendFor().

---

The documentation for this class was generated from the following files:

• BroadcastClient.h
• BroadcastClient.C