Inherits Continuation.
Public Member Functions | |
CongestionDBCont () | |
int | GC (int event, Event *e) |
int | get_congest_list (int event, Event *e) |
int | get_congest_entry (int event, Event *e) |
Data Fields | |
Action | m_action |
union { | |
struct { | |
MIOBuffer * m_iobuf | |
int m_CurPartitionID | |
int m_list_format | |
} list_info | |
struct { | |
uint64_t m_key | |
char * m_hostname | |
IpEndpoint m_ip | |
CongestionControlRecord * m_rule | |
CongestionEntry ** m_ppEntry | |
} entry_info | |
} | data |
Definition at line 50 of file CongestionDB.cc.
CongestionDBCont::CongestionDBCont | ( | ) | [inline] |
Definition at line 93 of file CongestionDB.cc.
References data.
int CongestionDBCont::GC | ( | int | event, | |
Event * | e | |||
) |
Definition at line 319 of file CongestionDB.cc.
References CDBC_pid, congestionControlEnabled, MTHashTable< key_t, data_t >::cur_entry(), Debug, MTHashTable< key_t, data_t >::first_entry(), MTHashTable< key_t, data_t >::getSize(), ink_get_hrtime(), ink_hrtime_to_sec(), MTHashTable< key_t, data_t >::lock_for_key(), MUTEX_TRY_LOCK, CongestionEntry::put(), MTHashTable< key_t, data_t >::remove_entry(), CongestionDB::RunTodoList(), this_ethread(), and CongestionEntry::usefulInfo().
int CongestionDBCont::get_congest_entry | ( | int | event, | |
Event * | e | |||
) |
Definition at line 391 of file CongestionDB.cc.
References Action::cancelled, CDBC_host, CDBC_ip, CDBC_key, CDBC_ppE, CDBC_rule, CONGESTION_EVENT_CONTROL_LOOKUP_DONE, Action::continuation, Debug, Free_CongestionDBCont(), Continuation::handleEvent(), MTHashTable< key_t, data_t >::insert_entry(), MTHashTable< key_t, data_t >::lock_for_key(), MTHashTable< key_t, data_t >::lookup_entry(), m_action, MUTEX_TRY_LOCK, MTHashTable< key_t, data_t >::part_num(), CongestionDB::RunTodoList(), SCHEDULE_CONGEST_CONT_INTERVAL, Event::schedule_in(), and this_ethread().
Referenced by get_congest_entry().
int CongestionDBCont::get_congest_list | ( | int | event, | |
Event * | e | |||
) |
Definition at line 354 of file CongestionDB.cc.
References Action::cancelled, CDBC_buf, CDBC_lf, CDBC_pid, CongestionEntry::congested(), CONGESTION_EVENT_CONGESTED_LIST_DONE, Action::continuation, MTHashTable< key_t, data_t >::first_entry(), Free_CongestionDBCont(), MTHashTable< key_t, data_t >::getSize(), Continuation::handleEvent(), MTHashTable< key_t, data_t >::lock_for_key(), m_action, CongestionControlRecord::max_connection, MUTEX_TRY_LOCK, MTHashTable< key_t, data_t >::next_entry(), CongestionEntry::pRecord, CongestionDB::RunTodoList(), SCHEDULE_CONGEST_CONT_INTERVAL, Event::schedule_in(), CongestionEntry::sprint(), and this_ethread().
Referenced by get_congest_list().
union { ... } CongestionDBCont::data |
Referenced by CongestionDBCont().
struct { ... } CongestionDBCont::entry_info |
struct { ... } CongestionDBCont::list_info |
Definition at line 61 of file CongestionDB.cc.
Referenced by Free_CongestionDBCont(), get_congest_entry(), get_congest_entry(), get_congest_list(), and get_congest_list().
Definition at line 69 of file CongestionDB.cc.
Definition at line 75 of file CongestionDB.cc.
Definition at line 68 of file CongestionDB.cc.
Definition at line 76 of file CongestionDB.cc.
uint64_t CongestionDBCont::m_key |
Definition at line 74 of file CongestionDB.cc.
Definition at line 70 of file CongestionDB.cc.
Definition at line 78 of file CongestionDB.cc.
Definition at line 77 of file CongestionDB.cc.