funfs/cachefsrcache.h

   1 #ifndef __CACHEFSRCACHE_H
   2 #define __CACHEFSRCACHE_H
   3
   4 #include <wvstring.h>
   5 #include <wvhashtable.h>
   6 #include <uniconf.h>
   7
   8 #include "wvdiskcache.h"
   9 #include "cachefsicache.h"
  10
  11 typedef unsigned long int fino_t;
  12 class WvStream;
  13 class CacheFS;
  14 class ReadCache;
  15
  16 class WaiterHelper
  17 {
  18 public:
  19     WaiterHelper(size_t _index, WvStream *_waiter)
  20         : index(_index), waiter(_waiter) {}
  21     size_t index;
  22     WvStream *waiter;
  23 };
  24
  25 DeclareWvDict(WaiterHelper, size_t, index);
  26
  27 class RNode
  28 {
  29 public:
  30     RNode(ReadCache *_rcache, int _fd, WvStringParm _parm, size_t _fsize);
  31     ~RNode();
  32
  33     void maybe_schedule_readblock(CacheFS *cachefs, size_t index);
  34     void update_page_status(size_t index, int status);
  35     int wait_on_block(size_t index, WvStream *waiter);
  36     int do_read(char *buf, size_t size, size_t offset);
  37     void invalidate();
  38
  39     bool isok() { return m_data && m_header && fsize; }
  40
  41     int fd;
  42
  43 protected:
  44     void do_map();
  45     void do_unmap();
  46
  47     size_t fsize;
  48     char *m_data, *m_header;
  49
  50     WvString path;
  51     ReadCache *rcache;
  52     WaiterHelperDict waiters;
  53 };
  54
  55 DeclareWvDict(RNode, int, fd);
  56
  57 class ReadCache : public ICache
  58 {
  59     friend class RNode;
  60 public:
  61     ReadCache(UniConf _cfg);
  62     virtual ~ReadCache() {};
  63
  64     void rcache_do_open(WvStringParm path, int fd);
  65     void rcache_do_close(int fd);
  66     void rcache_do_invalidate(int fd);
  67     void rcache_do_invalidate(WvStringParm path);
  68
  69     int rcache_do_read(WvStream *waiter, int fd, char *buf, size_t size,
  70             size_t off);
  71     void update_page_status(int fd, size_t index, int status);
  72
  73     void diskcache_callback(WvStringParm path);
  74
  75 protected:
  76     RNodeDict fdhash;
  77     WvDiskCache diskcache;
  78 };
  79
  80 #endif