src/mgr/StoreIoAction.cc

   1 /*
   2  * Copyright (C) 1996-2018 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/StoreIoAction.h"
  16 #include "Store.h"
  17 #include "tools.h"
  18
  19 Mgr::StoreIoActionData::StoreIoActionData()
  20 {
  21     memset(this, 0, sizeof(*this));
  22 }
  23
  24 Mgr::StoreIoActionData&
  25 Mgr::StoreIoActionData::operator += (const StoreIoActionData& stats)
  26 {
  27     create_calls += stats.create_calls;
  28     create_select_fail += stats.create_select_fail;
  29     create_create_fail += stats.create_create_fail;
  30     create_success += stats.create_success;
  31
  32     return *this;
  33 }
  34
  35 Mgr::StoreIoAction::Pointer
  36 Mgr::StoreIoAction::Create(const CommandPointer &cmd)
  37 {
  38     return new StoreIoAction(cmd);
  39 }
  40
  41 Mgr::StoreIoAction::StoreIoAction(const CommandPointer &aCmd):
  42     Action(aCmd), data()
  43 {
  44     debugs(16, 5, HERE);
  45 }
  46
  47 void
  48 Mgr::StoreIoAction::add(const Action& action)
  49 {
  50     debugs(16, 5, HERE);
  51     data += dynamic_cast<const StoreIoAction&>(action).data;
  52 }
  53
  54 void
  55 Mgr::StoreIoAction::collect()
  56 {
  57     data.create_calls = store_io_stats.create.calls;
  58     data.create_select_fail = store_io_stats.create.select_fail;
  59     data.create_create_fail = store_io_stats.create.create_fail;
  60     data.create_success = store_io_stats.create.success;
  61 }
  62
  63 void
  64 Mgr::StoreIoAction::dump(StoreEntry* entry)
  65 {
  66     debugs(16, 5, HERE);
  67     Must(entry != NULL);
  68     storeAppendPrintf(entry, "Store IO Interface Stats\n");
  69     storeAppendPrintf(entry, "create.calls %.0f\n", data.create_calls);
  70     storeAppendPrintf(entry, "create.select_fail %.0f\n", data.create_select_fail);
  71     storeAppendPrintf(entry, "create.create_fail %.0f\n", data.create_create_fail);
  72     storeAppendPrintf(entry, "create.success %.0f\n", data.create_success);
  73 }
  74
  75 void
  76 Mgr::StoreIoAction::pack(Ipc::TypedMsgHdr& msg) const
  77 {
  78     msg.setType(Ipc::mtCacheMgrResponse);
  79     msg.putPod(data);
  80 }
  81
  82 void
  83 Mgr::StoreIoAction::unpack(const Ipc::TypedMsgHdr& msg)
  84 {
  85     msg.checkType(Ipc::mtCacheMgrResponse);
  86     msg.getPod(data);
  87 }
  88