Public Member Functions | |
GradientFilter (int argc, char **argv) | |
void | run () |
void | recv (Message *msg, handle h) |
void | messageTimeout (Message *msg) |
void | interestTimeout (Message *msg) |
void | gradientTimeout () |
void | reinforcementTimeout () |
int | subscriptionTimeout (NRAttrVec *attrs) |
Protected Member Functions | |
handle | setupFilter () |
TppRoutingEntry * | findRoutingEntry (NRAttrVec *attrs) |
void | deleteRoutingEntry (TppRoutingEntry *routing_entry) |
TppRoutingEntry * | matchRoutingEntry (NRAttrVec *attrs, RoutingTable::iterator start, RoutingTable::iterator *place) |
AttributeEntry * | findMatchingSubscription (TppRoutingEntry *routing_entry, NRAttrVec *attrs) |
void | updateGradient (TppRoutingEntry *routing_entry, int32_t last_hop, bool reinforced) |
void | updateAgent (TppRoutingEntry *routing_entry, u_int16_t source_port) |
GradientEntry * | findReinforcedGradients (GradientList *agents, GradientList::iterator start, GradientList::iterator *place) |
GradientEntry * | findReinforcedGradient (int32_t node_addr, TppRoutingEntry *routing_entry) |
void | deleteGradient (TppRoutingEntry *routing_entry, GradientEntry *gradient_entry) |
void | setReinforcementFlags (TppRoutingEntry *routing_entry, int32_t last_hop, int new_message) |
void | sendInterest (NRAttrVec *attrs, TppRoutingEntry *routing_entry) |
void | sendDisinterest (NRAttrVec *attrs, TppRoutingEntry *routing_entry) |
void | sendPositiveReinforcement (NRAttrVec *reinf_attrs, int32_t data_rdm_id, int32_t data_pkt_num, int32_t destination) |
void | forwardData (Message *msg, TppRoutingEntry *routing_entry, DataForwardingHistory *forwarding_history) |
void | forwardExploratoryData (Message *msg, TppRoutingEntry *routing_entry, DataForwardingHistory *forwarding_history) |
void | forwardPushExploratoryData (Message *msg, DataForwardingHistory *forwarding_history) |
void | processOldMessage (Message *msg) |
void | processNewMessage (Message *msg) |
HashEntry * | getHash (unsigned int pkt_num, unsigned int rdm_id) |
void | putHash (HashEntry *new_hash_entry, unsigned int pkt_num, unsigned int rdm_id) |
Protected Attributes | |
handle | filter_handle_ |
int | pkt_count_ |
int | random_id_ |
HashList | hash_list_ |
Tcl_HashTable | htable_ |
GradientFilterReceive * | filter_callback_ |
RoutingTable | routing_list_ |