#include <nr.hh>
Inheritance diagram for NR:

Definition at line 365 of file nr.hh.
Public Types | |
| typedef long | handle |
Public Member Functions | |
| virtual handle | publish (NRAttrVec *publication_declarations)=0 |
| virtual int | send (handle publication_handle, NRAttrVec *)=0 |
| virtual handle | subscribe (NRAttrVec *interest_declarations, NR::Callback *cb)=0 |
| virtual int | unpublish (handle publication_handle)=0 |
| virtual int | unsubscribe (handle subscription_handle)=0 |
| virtual | ~NR () |
Static Public Member Functions | |
| static NR * | createNR (u_int16_t port=0) |
Data Structures | |
| class | Callback |
|
|
|
|
|
Definition at line 369 of file nr.hh.
|
|
|
Definition at line 149 of file dr.cc. References DEBUG_ALWAYS, DiffPrint(), and dr. Referenced by GearReceiverApp::GearReceiverApp(), GearSenderApp::GearSenderApp(), GeoRoutingFilter::GeoRoutingFilter(), GradientFilter::GradientFilter(), LogFilter::LogFilter(), OnePhasePullFilter::OnePhasePullFilter(), OPPPingReceiverApp::OPPPingReceiverApp(), OPPPingSenderApp::OPPPingSenderApp(), PushReceiverApp::PushReceiverApp(), PushSenderApp::PushSenderApp(), RmstFilter::RmstFilter(), RmstSink::RmstSink(), RmstSource::RmstSource(), SrcRtFilter::SrcRtFilter(), TagFilter::TagFilter(), TPPPingReceiverApp::TPPPingReceiverApp(), and TPPPingSenderApp::TPPPingSenderApp(). 00150 { 00151 // Create Diffusion Routing Class 00152 if (dr) 00153 return dr; 00154 00155 dr = new DiffusionRouting(port); 00156 00157 #ifdef USE_THREADS 00158 int retval; 00159 pthread_t thread; 00160 00161 // Fork a thread for receiving Messages 00162 retval = pthread_create(&thread, NULL, &ReceiveThread, (void *)dr); 00163 00164 if (retval){ 00165 DiffPrint(DEBUG_ALWAYS, "Error creating receiving thread ! Aborting...\n"); 00166 exit(-1); 00167 } 00168 #endif // USE_THREADS 00169 00170 return dr; 00171 }
Here is the call graph for this function: ![]() |
|
|
||||||||||||
|
Referenced by PushSenderApp::run(), GearSenderApp::run(), TPPPingSenderApp::run(), and OPPPingSenderApp::run(). |
|
||||||||||||
|
|
|
|
|
|
1.4.6