src/mgr/ServiceTimesAction.cc

   1 /*
   2  * Copyright (C) 1996-2015 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/ServiceTimesAction.h"
  16 #include "Store.h"
  17 #include "tools.h"
  18
  19 void GetServiceTimesStats(Mgr::ServiceTimesActionData& stats);
  20 void DumpServiceTimesStats(Mgr::ServiceTimesActionData& stats, StoreEntry* sentry);
  21
  22 Mgr::ServiceTimesActionData::ServiceTimesActionData()
  23 {
  24     memset(this, 0, sizeof(*this));
  25 }
  26
  27 Mgr::ServiceTimesActionData&
  28 Mgr::ServiceTimesActionData::operator += (const ServiceTimesActionData& stats)
  29 {
  30     for (int i = 0; i < seriesSize; ++i) {
  31         http_requests5[i] += stats.http_requests5[i];
  32         http_requests60[i] += stats.http_requests60[i];
  33
  34         cache_misses5[i] += stats.cache_misses5[i];
  35         cache_misses60[i] += stats.cache_misses60[i];
  36
  37         cache_hits5[i] += stats.cache_hits5[i];
  38         cache_hits60[i] += stats.cache_hits60[i];
  39
  40         near_hits5[i] += stats.near_hits5[i];
  41         near_hits60[i] += stats.near_hits60[i];
  42
  43         not_modified_replies5[i] += stats.not_modified_replies5[i];
  44         not_modified_replies60[i] += stats.not_modified_replies60[i];
  45
  46         dns_lookups5[i] += stats.dns_lookups5[i];
  47         dns_lookups60[i] += stats.dns_lookups60[i];
  48
  49         icp_queries5[i] += stats.icp_queries5[i];
  50         icp_queries60[i] += stats.icp_queries60[i];
  51     }
  52     ++count;
  53
  54     return *this;
  55 }
  56
  57 Mgr::ServiceTimesAction::Pointer
  58 Mgr::ServiceTimesAction::Create(const CommandPointer &cmd)
  59 {
  60     return new ServiceTimesAction(cmd);
  61 }
  62
  63 Mgr::ServiceTimesAction::ServiceTimesAction(const CommandPointer &aCmd):
  64     Action(aCmd), data()
  65 {
  66     debugs(16, 5, HERE);
  67 }
  68
  69 void
  70 Mgr::ServiceTimesAction::add(const Action& action)
  71 {
  72     debugs(16, 5, HERE);
  73     data += dynamic_cast<const ServiceTimesAction&>(action).data;
  74 }
  75
  76 void
  77 Mgr::ServiceTimesAction::collect()
  78 {
  79     debugs(16, 5, HERE);
  80     GetServiceTimesStats(data);
  81 }
  82
  83 void
  84 Mgr::ServiceTimesAction::dump(StoreEntry* entry)
  85 {
  86     debugs(16, 5, HERE);
  87     Must(entry != NULL);
  88     DumpServiceTimesStats(data, entry);
  89 }
  90
  91 void
  92 Mgr::ServiceTimesAction::pack(Ipc::TypedMsgHdr& msg) const
  93 {
  94     msg.setType(Ipc::mtCacheMgrResponse);
  95     msg.putPod(data);
  96 }
  97
  98 void
  99 Mgr::ServiceTimesAction::unpack(const Ipc::TypedMsgHdr& msg)
 100 {
 101     msg.checkType(Ipc::mtCacheMgrResponse);
 102     msg.getPod(data);
 103 }
 104