src/fs/coss/StoreFScoss.cc

   1 /*
   2  * $Id$
   3  *
   4  * DEBUG: section 47    Store Directory Routines
   5  * AUTHOR: Robert Collins
   6  *
   7  * SQUID Web Proxy Cache          http://www.squid-cache.org/
   8  * ----------------------------------------------------------
   9  *
  10  *  Squid is the result of efforts by numerous individuals from
  11  *  the Internet community; see the CONTRIBUTORS file for full
  12  *  details.   Many organizations have provided support for Squid's
  13  *  development; see the SPONSORS file for full details.  Squid is
  14  *  Copyrighted (C) 2001 by the Regents of the University of
  15  *  California; see the COPYRIGHT file for full details.  Squid
  16  *  incorporates software developed and/or copyrighted by other
  17  *  sources; see the CREDITS file for full details.
  18  *
  19  *  This program is free software; you can redistribute it and/or modify
  20  *  it under the terms of the GNU General Public License as published by
  21  *  the Free Software Foundation; either version 2 of the License, or
  22  *  (at your option) any later version.
  23  *
  24  *  This program is distributed in the hope that it will be useful,
  25  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  26  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  27  *  GNU General Public License for more details.
  28  *
  29  *  You should have received a copy of the GNU General Public License
  30  *  along with this program; if not, write to the Free Software
  31  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
  32  *
  33  * Copyright (c) 2003, Robert Collins <robertc@squid-cache.org>
  34  */
  35
  36 #include "squid.h"
  37 #include "StoreFileSystem.h"
  38 #include "StoreFScoss.h"
  39 #include "mgr/Registration.h"
  40 #include "Store.h"
  41 #include "CossSwapDir.h"
  42 #include "store_coss.h"
  43
  44 StoreFScoss StoreFScoss::_instance;
  45
  46 StoreFScoss &
  47 StoreFScoss::GetInstance()
  48 {
  49     return _instance;
  50 }
  51
  52 StoreFScoss::StoreFScoss()
  53 {
  54     FsAdd(*this);
  55     registerWithCacheManager();
  56 }
  57
  58 char const *
  59 StoreFScoss::type() const
  60 {
  61     return "coss";
  62 }
  63
  64 void
  65 StoreFScoss::done()
  66 {
  67     /*  delete coss_index_pool;coss_index_pool = NULL;  XXX Should be here? */
  68     initialised = false;
  69 }
  70
  71 SwapDir *
  72 StoreFScoss::createSwapDir()
  73 {
  74     SwapDir *result = new CossSwapDir;
  75     return result;
  76 }
  77
  78 void
  79 StoreFScoss::setup()
  80 {
  81     assert(!initialised);
  82
  83     coss_index_pool = memPoolCreate("COSS index data", sizeof(CossIndexNode));
  84     initialised = true;
  85 }
  86
  87 void
  88 StoreFScoss::registerWithCacheManager()
  89 {
  90     Mgr::RegisterAction("coss", "COSS Stats", Stats, 0, 1);
  91 }
  92
  93 void
  94 StoreFScoss::Stats(StoreEntry * sentry)
  95 {
  96     GetInstance().stat(sentry);
  97 }
  98
  99 void
 100 StoreFScoss::stat(StoreEntry *sentry)
 101 {
 102     stats.stat(sentry);
 103 }
 104
 105 void
 106 CossStats::stat(StoreEntry *sentry)
 107 {
 108     const char *tbl_fmt = "%10s %10d %10d %10d\n";
 109     storeAppendPrintf(sentry, "\n                   OPS     SUCCESS        FAIL\n");
 110     storeAppendPrintf(sentry, tbl_fmt,
 111                       "open", open.ops, open.success, open.fail);
 112     storeAppendPrintf(sentry, tbl_fmt,
 113                       "create", create.ops, create.success, create.fail);
 114     storeAppendPrintf(sentry, tbl_fmt,
 115                       "close", close.ops, close.success, close.fail);
 116     storeAppendPrintf(sentry, tbl_fmt,
 117                       "unlink", unlink.ops, unlink.success, unlink.fail);
 118     storeAppendPrintf(sentry, tbl_fmt,
 119                       "read", read.ops, read.success, read.fail);
 120     storeAppendPrintf(sentry, tbl_fmt,
 121                       "write", write.ops, write.success, write.fail);
 122     storeAppendPrintf(sentry, tbl_fmt,
 123                       "s_write", stripe_write.ops, stripe_write.success, stripe_write.fail);
 124
 125     storeAppendPrintf(sentry, "\n");
 126     storeAppendPrintf(sentry, "stripes:          %d\n", stripes);
 127     storeAppendPrintf(sentry, "alloc.alloc:      %d\n", alloc.alloc);
 128     storeAppendPrintf(sentry, "alloc.realloc:    %d\n", alloc.realloc);
 129     storeAppendPrintf(sentry, "alloc.collisions: %d\n", alloc.collisions);
 130     storeAppendPrintf(sentry, "disk_overflows:   %d\n", disk_overflows);
 131     storeAppendPrintf(sentry, "stripe_overflows: %d\n", stripe_overflows);
 132     storeAppendPrintf(sentry, "open_mem_hits:    %d\n", open_mem_hits);
 133     storeAppendPrintf(sentry, "open_mem_misses:  %d\n", open_mem_misses);
 134 }