, including all inherited members.
addFilter(NRAttrVec *filter_attrs, u_int16_t priority, FilterCallback *cb) (defined in DiffusionRouting) | DiffusionRouting | |
addTimer(int timeout, TimerCallback *callback) (defined in DiffusionRouting) | DiffusionRouting | |
addTimer(int timeout, void *param, TimerCallbacks *cb) (defined in DiffusionRouting) | DiffusionRouting | |
addToBlacklist(int32_t node) (defined in DiffusionRouting) | DiffusionRouting | |
agent_id_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
checkPublication(NRAttrVec *attrs) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
checkSend(NRAttrVec *attrs) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
checkSubscription(NRAttrVec *attrs) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
clearBlacklist() (defined in DiffusionRouting) | DiffusionRouting | |
createNR(u_int16_t port=0) (defined in NR) | NR | [static] |
deleteFilter(handle my_handle) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
diffusion_port_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
DiffusionRouting(u_int16_t port) (defined in DiffusionRouting) | DiffusionRouting | |
doIt() (defined in DiffusionRouting) | DiffusionRouting | |
doOne(long timeout=WAIT_FOREVER) (defined in DiffusionRouting) | DiffusionRouting | |
dr_mtx_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
filter_list_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
filterKeepaliveTimeout(FilterEntry *filter_entry) (defined in DiffusionRouting) | DiffusionRouting | |
findFilter(handle my_handle) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
findHandle(handle my_handle, HandleList *hl) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
handle typedef (defined in NR) | NR | |
hasScope(NRAttrVec *attrs) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
in_devices_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
interestTimeout(HandleEntry *handle_entry) (defined in DiffusionRouting) | DiffusionRouting | |
isPushData(NRAttrVec *attrs) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
local_out_devices_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
next_handle_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
pkt_count_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
processControlMessage(Message *msg) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
processMessage(Message *msg) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
processRmst(Message *msg) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
pub_list_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
publish(NRAttrVec *publish_attrs) (defined in DiffusionRouting) | DiffusionRouting | [virtual] |
random_id_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
rec_rmst_map_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
recvMessage(Message *msg) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
recvPacket(DiffPacket pkt) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
removeFilter(handle filter_handle) (defined in DiffusionRouting) | DiffusionRouting | |
removeHandle(handle my_handle, HandleList *hl) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
removeTimer(handle hdl) (defined in DiffusionRouting) | DiffusionRouting | |
run(bool wait_condition, long max_timeout) (defined in DiffusionRouting) | DiffusionRouting | |
send(handle publication_handle, NRAttrVec *send_attrs) (defined in DiffusionRouting) | DiffusionRouting | [virtual] |
sendMessage(Message *msg, handle h, u_int16_t priority=FILTER_KEEP_PRIORITY) (defined in DiffusionRouting) | DiffusionRouting | |
sendMessageToDiffusion(Message *msg) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
sendPacketToDiffusion(DiffPacket pkt, int len, int dst) (defined in DiffusionRouting) | DiffusionRouting | [protected] |
sendRmst(handle publication_handle, NRAttrVec *send_attrs, int fragment_size) (defined in DiffusionRouting) | DiffusionRouting | |
sub_list_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
subscribe(NRAttrVec *subscribe_attrs, NR::Callback *cb) (defined in DiffusionRouting) | DiffusionRouting | [virtual] |
timers_manager_ (defined in DiffusionRouting) | DiffusionRouting | [protected] |
unpublish(handle publication_handle) (defined in DiffusionRouting) | DiffusionRouting | [virtual] |
unsubscribe(handle subscription_handle) (defined in DiffusionRouting) | DiffusionRouting | [virtual] |
~DiffusionRouting() (defined in DiffusionRouting) | DiffusionRouting | [virtual] |
~NR() (defined in NR) | NR | [inline, virtual] |