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

Public Types | |
| typedef long | handle |
Public Member Functions | |
| virtual handle | subscribe (NRAttrVec *interest_declarations, NR::Callback *cb)=0 |
| virtual int | unsubscribe (handle subscription_handle)=0 |
| virtual handle | publish (NRAttrVec *publication_declarations)=0 |
| virtual int | unpublish (handle publication_handle)=0 |
| virtual int | send (handle publication_handle, NRAttrVec *)=0 |
Static Public Member Functions | |
| NR * | createNR (u_int16_t port=0) |
|
|
Definition at line 302 of file nr.hh. Referenced by DiffusionRouting::processControlMessage(). |
|
|
Definition at line 123 of file dr.cc. References DEBUG_ALWAYS, DiffPrint(), and dr. Referenced by GeoRoutingFilter::GeoRoutingFilter(), GradientFilter::GradientFilter(), LogFilter::LogFilter(), PingReceiverApp::PingReceiverApp(), PingSenderApp::PingSenderApp(), PushReceiverApp::PushReceiverApp(), PushSenderApp::PushSenderApp(), SrcRtFilter::SrcRtFilter(), and TagFilter::TagFilter().
00124 {
00125 // Create Diffusion Routing Class
00126 if (dr)
00127 return dr;
00128
00129 dr = new DiffusionRouting(port);
00130
00131 #ifdef USE_THREADS
00132 int retval;
00133 pthread_t thread;
00134
00135 // Fork a thread for receiving Messages
00136 retval = pthread_create(&thread, NULL, &ReceiveThread, (void *)dr);
00137
00138 if (retval){
00139 DiffPrint(DEBUG_ALWAYS, "Error creating receiving thread ! Aborting...\n");
00140 exit(-1);
00141 }
00142 #endif // USE_THREADS
00143
00144 return dr;
00145 }
|
Here is the call graph for this function:

|
|
Implemented in DiffusionRouting. Referenced by PushSenderApp::setupPublication(), and PingSenderApp::setupPublication(). |
|
||||||||||||
|
Implemented in DiffusionRouting. Referenced by PushSenderApp::run(), and PingSenderApp::run(). |
|
||||||||||||
|
Implemented in DiffusionRouting. Referenced by PushReceiverApp::setupSubscription(), PingSenderApp::setupSubscription(), and PingReceiverApp::setupSubscription(). |
|
|
Implemented in DiffusionRouting. |
|
|
Implemented in DiffusionRouting. |
1.3.3