IntervalAction.cc
Go to the documentation of this file.
1 /*
2  * Copyright (C) 1996-2017 The Squid Software Foundation and contributors
3  *
4  * Squid software is distributed under GPLv2+ license and includes
5  * contributions from numerous individuals and organizations.
6  * Please see the COPYING and CONTRIBUTORS files for details.
7  */
8 
9 /* DEBUG: section 16 Cache Manager API */
10 
11 #include "squid.h"
12 #include "base/TextException.h"
13 #include "ipc/Messages.h"
14 #include "ipc/TypedMsgHdr.h"
15 #include "mgr/IntervalAction.h"
16 #include "SquidMath.h"
17 #include "Store.h"
18 #include "tools.h"
19 
20 void GetAvgStat(Mgr::IntervalActionData& stats, int minutes, int hours);
22 
24 {
25  memset(this, 0, sizeof(*this));
26 }
27 
30 {
31  if (!timerisset(&sample_start_time) || timercmp(&sample_start_time, &stats.sample_start_time, >))
32  sample_start_time = stats.sample_start_time;
33  if (timercmp(&sample_end_time, &stats.sample_end_time, <))
34  sample_end_time = stats.sample_end_time;
35  client_http_requests += stats.client_http_requests;
36  client_http_hits += stats.client_http_hits;
37  client_http_errors += stats.client_http_errors;
38  client_http_kbytes_in += stats.client_http_kbytes_in;
39  client_http_kbytes_out += stats.client_http_kbytes_out;
40  client_http_all_median_svc_time += stats.client_http_all_median_svc_time;
41  client_http_miss_median_svc_time += stats.client_http_miss_median_svc_time;
42  client_http_nm_median_svc_time += stats.client_http_nm_median_svc_time;
43  client_http_nh_median_svc_time += stats.client_http_nh_median_svc_time;
44  client_http_hit_median_svc_time += stats.client_http_hit_median_svc_time;
45  server_all_requests += stats.server_all_requests;
46  server_all_errors += stats.server_all_errors;
47  server_all_kbytes_in += stats.server_all_kbytes_in;
48  server_all_kbytes_out += stats.server_all_kbytes_out;
49  server_http_requests += stats.server_http_requests;
50  server_http_errors += stats.server_http_errors;
51  server_http_kbytes_in += stats.server_http_kbytes_in;
52  server_http_kbytes_out += stats.server_http_kbytes_out;
53  server_ftp_requests += stats.server_ftp_requests;
54  server_ftp_errors += stats.server_ftp_errors;
55  server_ftp_kbytes_in += stats.server_ftp_kbytes_in;
56  server_ftp_kbytes_out += stats.server_ftp_kbytes_out;
57  server_other_requests += stats.server_other_requests;
58  server_other_errors += stats.server_other_errors;
59  server_other_kbytes_in += stats.server_other_kbytes_in;
60  server_other_kbytes_out += stats.server_other_kbytes_out;
61  icp_pkts_sent += stats.icp_pkts_sent;
62  icp_pkts_recv += stats.icp_pkts_recv;
63  icp_queries_sent += stats.icp_queries_sent;
64  icp_replies_sent += stats.icp_replies_sent;
65  icp_queries_recv += stats.icp_queries_recv;
66  icp_replies_recv += stats.icp_replies_recv;
67  icp_replies_queued += stats.icp_replies_queued;
68  icp_query_timeouts += stats.icp_query_timeouts;
69  icp_kbytes_sent += stats.icp_kbytes_sent;
70  icp_kbytes_recv += stats.icp_kbytes_recv;
71  icp_q_kbytes_sent += stats.icp_q_kbytes_sent;
72  icp_r_kbytes_sent += stats.icp_r_kbytes_sent;
73  icp_q_kbytes_recv += stats.icp_q_kbytes_recv;
74  icp_r_kbytes_recv += stats.icp_r_kbytes_recv;
75  icp_query_median_svc_time += stats.icp_query_median_svc_time;
76  icp_reply_median_svc_time += stats.icp_reply_median_svc_time;
77  dns_median_svc_time += stats.dns_median_svc_time;
78  unlink_requests += stats.unlink_requests;
79  page_faults += stats.page_faults;
80  select_loops += stats.select_loops;
81  select_fds += stats.select_fds;
82  average_select_fd_period += stats.average_select_fd_period;
83  median_select_fds += stats.median_select_fds;
84  swap_outs += stats.swap_outs;
85  swap_ins += stats.swap_ins;
86  swap_files_cleaned += stats.swap_files_cleaned;
87  aborted_requests += stats.aborted_requests;
88  syscalls_disk_opens += stats.syscalls_disk_opens;
89  syscalls_disk_closes += stats.syscalls_disk_closes;
90  syscalls_disk_reads += stats.syscalls_disk_reads;
91  syscalls_disk_writes += stats.syscalls_disk_writes;
92  syscalls_disk_seeks += stats.syscalls_disk_seeks;
93  syscalls_disk_unlinks += stats.syscalls_disk_unlinks;
94  syscalls_sock_accepts += stats.syscalls_sock_accepts;
95  syscalls_sock_sockets += stats.syscalls_sock_sockets;
96  syscalls_sock_connects += stats.syscalls_sock_connects;
97  syscalls_sock_binds += stats.syscalls_sock_binds;
98  syscalls_sock_closes += stats.syscalls_sock_closes;
99  syscalls_sock_reads += stats.syscalls_sock_reads;
100  syscalls_sock_writes += stats.syscalls_sock_writes;
101  syscalls_sock_recvfroms += stats.syscalls_sock_recvfroms;
102  syscalls_sock_sendtos += stats.syscalls_sock_sendtos;
103  syscalls_selects += stats.syscalls_selects;
104  cpu_time += stats.cpu_time;
105  wall_time += stats.wall_time;
106  ++count;
107 
108  return *this;
109 }
110 
113 {
114  return new IntervalAction(cmd, 5, 0);
115 }
116 
119 {
120  return new IntervalAction(cmd, 60, 0);
121 }
122 
123 Mgr::IntervalAction::IntervalAction(const CommandPointer &aCmd, int aMinutes, int aHours):
124  Action(aCmd), minutes(aMinutes), hours(aHours), data()
125 {
126  debugs(16, 5, HERE);
127 }
128 
129 void
131 {
132  debugs(16, 5, HERE);
133  data += dynamic_cast<const IntervalAction&>(action).data;
134 }
135 
136 void
138 {
139  GetAvgStat(data, minutes, hours);
140 }
141 
142 void
144 {
145  debugs(16, 5, HERE);
146  Must(entry != NULL);
147  DumpAvgStat(data, entry);
148 }
149 
150 void
152 {
154  msg.putPod(data);
155 }
156 
157 void
159 {
161  msg.getPod(data);
162 }
163 
#define timerisset(tvp)
Definition: snmp_api_util.h:85
virtual void add(const Action &action)
incrementally merge in remote information (of the same action type)
#define timercmp(tvp, uvp, cmp)
Definition: snmp_api_util.h:76
virtual void pack(Ipc::TypedMsgHdr &msg) const
pack collected action info into a message to be sent to Coordinator
void DumpAvgStat(Mgr::IntervalActionData &stats, StoreEntry *sentry)
Definition: stat.cc:1024
void getPod(Pod &pod) const
load POD
Definition: TypedMsgHdr.h:50
void putPod(const Pod &pod)
store POD
Definition: TypedMsgHdr.h:52
class Ping::pingStats_ stats
double client_http_all_median_svc_time
static Pointer Create60min(const CommandPointer &cmd)
virtual void collect()
calculate and keep local action-specific information
void const char HLPCB void * data
Definition: stub_helper.cc:16
implement aggregated interval actions
#define debugs(SECTION, LEVEL, CONTENT)
Definition: Debug.h:123
IntervalActionData & operator+=(const IntervalActionData &stats)
double client_http_miss_median_svc_time
std::ostream & HERE(std::ostream &s)
Definition: Debug.h:147
bool action(int fd, size_t metasize, const char *fn, const char *url, const SquidMetaList &meta)
Definition: purge.cc:311
#define Must(cond)
Definition: TextException.h:89
struct timeval sample_start_time
virtual void unpack(const Ipc::TypedMsgHdr &msg)
unpack action info from the message received by Coordinator
struct msghdr with a known type, fixed-size I/O and control buffers
Definition: TypedMsgHdr.h:31
void checkType(int aType) const
throws if stored type is not aType
Definition: TypedMsgHdr.cc:84
struct timeval sample_end_time
IntervalAction(const CommandPointer &cmd, int aMinutes, int aHours)
void setType(int aType)
sets message type; use MessageType enum
Definition: TypedMsgHdr.cc:90
virtual void dump(StoreEntry *entry)
void GetAvgStat(Mgr::IntervalActionData &stats, int minutes, int hours)
Definition: stat.cc:894
#define NULL
Definition: types.h:166
static Pointer Create5min(const CommandPointer &cmd)
double client_http_hit_median_svc_time

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors