#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 |
Definition at line 12 of file BroadcastClient.h.
|
|
Definition at line 15 of file BroadcastClient.C. References BroadcastMgr::Object(), BroadcastMgr::subscribe(), suspended, and waitForTag. 00015 {
00016 this->id = id;
00017 BroadcastMgr::Object()->subscribe(*this);
00018 waitForTag = -1;
00019 suspended = 0;
00020 }
|
|
|
Definition at line 22 of file BroadcastClient.C. References BroadcastMgr::Object(), and BroadcastMgr::unsubscribe(). 00022 {
00023 BroadcastMgr::Object()->unsubscribe(*this);
00024 }
|
|
||||||||||||
|
Definition at line 27 of file BroadcastClient.C. References DebugM, suspended, thread, and waitForTag. 00027 {
00028 DebugM(1, "awaken() client id = " << id << " tag = " << tag << "\n");
00029 if (suspended && theid == this->id && tag == waitForTag) {
00030 CthAwaken(thread);
00031 suspended = 0; waitForTag = -1;
00032 }
00033 }
|
|
|
Definition at line 36 of file BroadcastClient.C. References DebugM, suspended, thread, and waitForTag. Referenced by SimpleBroadcastObject< Tensor >::get(). 00036 {
00037 DebugM(1, "suspending() client id = " << id << " tag = " << tag << "\n");
00038 suspended = 1;
00039 waitForTag = tag;
00040 thread = CthSelf();
00041 CthSuspend();
00042 }
|
|
|
Definition at line 14 of file BroadcastClient.h. Referenced by BroadcastMgr::getbuf(), BroadcastMgr::send(), BroadcastMgr::subscribe(), and BroadcastMgr::unsubscribe(). |
|
|
Definition at line 22 of file BroadcastClient.h. Referenced by awaken(), BroadcastClient(), and suspendFor(). |
|
|
Definition at line 24 of file BroadcastClient.h. Referenced by awaken(), and suspendFor(). |
|
|
Definition at line 23 of file BroadcastClient.h. Referenced by awaken(), BroadcastClient(), and suspendFor(). |
1.3.9.1