#include <P_ClusterLoadMonitor.h>
Inherits Continuation.

Data Structures | |
| struct | cluster_load_ping_msg |
Public Member Functions | |
| ClusterLoadMonitor (ClusterHandler *ch) | |
| void | init () |
| ~ClusterLoadMonitor () | |
| void | cancel_monitor () |
| bool | is_cluster_overloaded () |
Static Public Member Functions | |
| static void | cluster_load_ping_rethandler (ClusterHandler *, void *, int) |
Static Public Attributes | |
| static int | cf_monitor_enabled |
| static int | cf_ping_message_send_msec_interval |
| static int | cf_num_ping_response_buckets |
| static int | cf_msecs_per_ping_response_bucket |
| static int | cf_ping_latency_threshold_msecs |
| static int | cf_cluster_load_compute_msec_interval |
| static int | cf_cluster_periodic_msec_interval |
| static int | cf_ping_history_buf_length |
| static int | cf_cluster_load_clear_duration |
| static int | cf_cluster_load_exceed_duration |
Definition at line 38 of file P_ClusterLoadMonitor.h.
| ClusterLoadMonitor::ClusterLoadMonitor | ( | ClusterHandler * | ch | ) |
Definition at line 52 of file ClusterLoadMonitor.cc.
References ats_malloc(), cf_cluster_load_clear_duration, cf_cluster_load_compute_msec_interval, cf_cluster_load_exceed_duration, cf_cluster_periodic_msec_interval, cf_msecs_per_ping_response_bucket, cf_num_ping_response_buckets, cf_ping_history_buf_length, cf_ping_latency_threshold_msecs, cf_ping_message_send_msec_interval, Debug, HRTIME_SECONDS, Continuation::mutex, and SET_HANDLER.
| ClusterLoadMonitor::~ClusterLoadMonitor | ( | ) |
Definition at line 106 of file ClusterLoadMonitor.cc.
References ats_free(), and ink_release_assert.
| void ClusterLoadMonitor::cancel_monitor | ( | ) |
Definition at line 128 of file ClusterLoadMonitor.cc.
Referenced by ClusterHandler::zombify().
| void ClusterLoadMonitor::cluster_load_ping_rethandler | ( | ClusterHandler * | ch, | |
| void * | data, | |||
| int | len | |||
| ) | [static] |
Definition at line 258 of file ClusterLoadMonitor.cc.
References ClusterLoadMonitor::cluster_load_ping_msg::CL_MSG_MAGICNO, ClusterLoadMonitor::cluster_load_ping_msg::CL_MSG_VERSION, and memcpy.
| void ClusterLoadMonitor::init | ( | ) |
Definition at line 101 of file ClusterLoadMonitor.cc.
References ET_CALL, eventProcessor, HRTIME_MSECONDS, and EventProcessor::schedule_every().
Referenced by ClusterHandler::startClusterEvent().
| bool ClusterLoadMonitor::is_cluster_overloaded | ( | ) |
Definition at line 134 of file ClusterLoadMonitor.cc.
Referenced by ClusterHandler::mainClusterEvent().
int ClusterLoadMonitor::cf_cluster_load_clear_duration [static] |
Definition at line 52 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
Definition at line 49 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
int ClusterLoadMonitor::cf_cluster_load_exceed_duration [static] |
Definition at line 53 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
Definition at line 50 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
int ClusterLoadMonitor::cf_monitor_enabled [static] |
Definition at line 44 of file P_ClusterLoadMonitor.h.
Referenced by ClusterProcessor::init(), and ClusterHandler::mainClusterEvent().
Definition at line 47 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
int ClusterLoadMonitor::cf_num_ping_response_buckets [static] |
Definition at line 46 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
int ClusterLoadMonitor::cf_ping_history_buf_length [static] |
Definition at line 51 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
int ClusterLoadMonitor::cf_ping_latency_threshold_msecs [static] |
Definition at line 48 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
Definition at line 45 of file P_ClusterLoadMonitor.h.
Referenced by ClusterLoadMonitor(), and ClusterProcessor::init().
1.7.1