src/PeerDigest.h

   1 /*
   2  * Copyright (C) 1996-2016 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 #ifndef   SQUID_PEERDIGEST_H
  10 #define   SQUID_PEERDIGEST_H
  11
  12 #if USE_CACHE_DIGESTS
  13
  14 #include "cbdata.h"
  15 #include "StatCounters.h"
  16
  17 class Version
  18 {
  19 public:
  20     short int current;      /* current version */
  21     short int required;     /* minimal version that can safely handle current version */
  22 };
  23
  24 /* digest control block; used for transmission and storage */
  25
  26 class StoreDigestCBlock
  27 {
  28 public:
  29     Version ver;
  30     int capacity;
  31     int count;
  32     int del_count;
  33     int mask_size;
  34     unsigned char bits_per_entry;
  35     unsigned char hash_func_count;
  36     short int reserved_short;
  37     int reserved[32 - 6];
  38 };
  39
  40 class HttpRequest;
  41 class PeerDigest;
  42 class store_client;
  43
  44 class DigestFetchState
  45 {
  46     CBDATA_CLASS(DigestFetchState);
  47
  48 public:
  49     DigestFetchState(PeerDigest *,HttpRequest *);
  50     ~DigestFetchState();
  51
  52     PeerDigest *pd;
  53     StoreEntry *entry;
  54     StoreEntry *old_entry;
  55     store_client *sc;
  56     store_client *old_sc;
  57     HttpRequest *request;
  58     int offset;
  59     int mask_offset;
  60     time_t start_time;
  61     time_t resp_time;
  62     time_t expires;
  63
  64     struct {
  65         int msg;
  66         int bytes;
  67     } sent, recv;
  68
  69     char buf[SM_PAGE_SIZE];
  70     ssize_t bufofs;
  71     digest_read_state_t state;
  72 };
  73
  74 class PeerDigest
  75 {
  76     CBDATA_CLASS(PeerDigest);
  77
  78 public:
  79     CachePeer *peer;          /**< pointer back to peer structure, argh */
  80     CacheDigest *cd;            /**< actual digest structure */
  81     String host;                /**< copy of peer->host */
  82     const char *req_result;     /**< text status of the last request */
  83
  84     struct {
  85         bool needed;          /**< there were requests for this digest */
  86         bool usable;          /**< can be used for lookups */
  87         bool requested;       /**< in process of receiving [fresh] digest */
  88     } flags;
  89
  90     struct {
  91         /* all times are absolute unless augmented with _delay */
  92         time_t initialized; /* creation */
  93         time_t needed;      /* first lookup/use by a peer */
  94         time_t next_check;  /* next scheduled check/refresh event */
  95         time_t retry_delay; /* delay before re-checking _invalid_ digest */
  96         time_t requested;   /* requested a fresh copy of a digest */
  97         time_t req_delay;   /* last request response time */
  98         time_t received;    /* received the current copy of a digest */
  99         time_t disabled;    /* disabled for good */
 100     } times;
 101
 102     struct {
 103         CacheDigestGuessStats guess;
 104         int used_count;
 105
 106         struct {
 107             int msgs;
 108             ByteCounter kbytes;
 109         } sent, recv;
 110     } stats;
 111 };
 112
 113 extern const Version CacheDigestVer;
 114
 115 PeerDigest *peerDigestCreate(CachePeer * p);
 116 void peerDigestNeeded(PeerDigest * pd);
 117 void peerDigestNotePeerGone(PeerDigest * pd);
 118 void peerDigestStatsReport(const PeerDigest * pd, StoreEntry * e);
 119
 120 #endif /* USE_CACHE_DIGESTS */
 121
 122 #endif /* SQUID_PEERDIGEST_H */
 123