Public Member Functions | |
DiffusionCoreAgent (int argc, char **argv) | |
void | usage (char *s) |
void | run () |
void | timeToStop () |
void | neighborsTimeout () |
void | filterTimeout () |
Protected Member Functions | |
void | sendMessageToLibrary (Message *msg, u_int16_t dst_agent_id) |
void | sendPacketToLibrary (DiffPacket pkt, int len, u_int16_t dst) |
void | sendMessageToNetwork (Message *msg) |
void | sendPacketToNetwork (DiffPacket pkt, int len, int dst) |
void | recvPacket (DiffPacket pkt) |
void | recvMessage (Message *msg) |
HashEntry * | getHash (unsigned int, unsigned int) |
void | putHash (unsigned int, unsigned int) |
void | updateNeighbors (int id) |
void | processMessage (Message *msg) |
void | processControlMessage (Message *msg) |
void | logControlMessage (Message *msg, int command, int param1, int param2) |
bool | restoreOriginalHeader (Message *msg) |
FilterList * | getFilterList (NRAttrVec *attrs) |
FilterEntry * | findFilter (int16_t handle, u_int16_t agent) |
FilterEntry * | deleteFilter (int16_t handle, u_int16_t agent) |
bool | addFilter (NRAttrVec *attrs, u_int16_t agent, int16_t handle, u_int16_t priority) |
FilterList::iterator | findMatchingFilter (NRAttrVec *attrs, FilterList::iterator filter_itr) |
u_int16_t | getNextFilterPriority (int16_t handle, u_int16_t priority, u_int16_t agent) |
void | forwardMessage (Message *msg, FilterEntry *filter_entry) |
void | sendMessage (Message *msg) |
Protected Attributes | |
float | lon_ |
float | lat_ |
int32_t | my_id_ |
u_int16_t | diffusion_port_ |
int | pkt_count_ |
int | random_id_ |
char * | config_file_ |
DeviceList | in_devices_ |
DeviceList | out_devices_ |
DeviceList | local_out_devices_ |
NeighborList | neighbor_list_ |
FilterList | filter_list_ |
BlackList | black_list_ |
HashList | hash_list_ |
TimerManager * | timers_manager_ |
Tcl_HashTable | htable_ |