funfs/funfscim.cc

   1 #include "funfscim.h"
   2 #include "strutils.h"
   3
   4
   5 CacheInfo::CacheInfo(CacheInfoMgr *_cim, WvStringParm _path, bool _root)
   6     : path(_path), root(_root), uptodate(0), famid(0), child_count(0), cim(_cim)
   7 {
   8     cim->fi_by_path.add(this, root);
   9 }
  10
  11
  12 CacheInfo::~CacheInfo()
  13 {
  14     if (!root && uptodate & FILEMASK)
  15         cim->get_fileinfo(getdirname(path))->remove_child();
  16
  17     if (famid)
  18         cim->fam._unmonitor(famid);
  19
  20     cim->fi_by_path.remove(this);
  21 }
  22
  23
  24 void CacheInfo::mark_uptodate(uint8 _uptodate)
  25 {
  26     if (root || _uptodate & DIRMASK && uptodate & ~DIRMASK)
  27     {
  28         if (famid)
  29             fprintf(stderr, "monitoring listing for %s\n", path.cstr());
  30         famid = famid ? famid : cim->fam._monitordir(&path);
  31     }
  32
  33     if (_uptodate & FILEMASK && uptodate & ~FILEMASK)
  34     {
  35         fprintf(stderr, "monitoring attributes for %s\n", path.cstr());
  36         if (!root)
  37             cim->get_fileinfo(getdirname(path))->add_child();
  38         else
  39             famid = famid ? famid : cim->fam._monitordir(&path);
  40
  41     }
  42
  43     uptodate |= _uptodate;
  44 }
  45
  46
  47 bool CacheInfo::is_uptodate(uint8 _uptodate)
  48 {
  49     return uptodate & _uptodate;
  50 }
  51
  52
  53 void CacheInfo::invalidate(bool thisfile)
  54 {
  55     if (thisfile)
  56     {
  57         if (!root && uptodate & FILEMASK)
  58         {
  59             cim->get_fileinfo(getdirname(path))->remove_child();
  60             fprintf(stderr, "invalidating attributes for %s\n", path.cstr());
  61         }
  62
  63         uptodate &= ~FILEMASK;
  64     }
  65     // means something *under* us changed
  66     else
  67     {
  68         if (child_count == 0)
  69         {
  70             if (famid)
  71             {
  72                 cim->fam._unmonitor(famid);
  73                 fprintf(stderr, "invalidating listing for %s\n", path.cstr());
  74             }
  75             famid = 0;
  76         }
  77
  78         uptodate &= ~DIRMASK;
  79     }
  80
  81     if (uptodate == 0 && child_count == 0 && !root)
  82         delete this;
  83 }
  84
  85
  86 void CacheInfo::add_child()
  87 {
  88     child_count++;
  89
  90     if (!famid)
  91         famid = cim->fam._monitordir(&path);
  92 }
  93
  94
  95 void CacheInfo::remove_child()
  96 {
  97     child_count--;
  98
  99     if (child_count == 0 && uptodate == 0)
 100     {
 101         if (root)
 102         {
 103             if (famid)
 104                 cim->fam._unmonitor(famid);
 105         }
 106         else
 107             delete this;
 108     }
 109 }
 110
 111
 112 CacheInfoMgr::CacheInfoMgr()
 113     : fam(WvFamCallback(this, &CacheInfoMgr::fam_callback)), fdmap(20)
 114 {
 115     new CacheInfo(this, "/", true);
 116 }
 117
 118
 119 CacheInfo *CacheInfoMgr::get_fileinfo(WvStringParm path)
 120 {
 121     CacheInfo *fi = fi_by_path[path];
 122
 123     return fi ? fi : new CacheInfo(this, path);
 124 }
 125
 126
 127 void CacheInfoMgr::cim_do_open(WvStringParm path, int fd)
 128 {
 129     fdmap.add(fd, path);
 130 }
 131
 132
 133 void CacheInfoMgr::cim_do_close(int fd)
 134 {
 135     fdmap.remove(fd);
 136 }
 137
 138
 139 void CacheInfoMgr::cim_mark_uptodate(WvStringParm path, JobType jobtype)
 140 {
 141     CacheInfo *fi = get_fileinfo(path);
 142
 143     switch (jobtype)
 144     {
 145         case JT_GETDIR:
 146             fi->mark_uptodate(UTD_LIST);
 147             break;
 148         case JT_GETATTR:
 149             fi->mark_uptodate(UTD_ATTR);
 150             break;
 151         case JT_READLINK:
 152             fi->mark_uptodate(UTD_LINK);
 153             break;
 154         default:
 155             assert(! "cim_mark_uptodate called with unknown jobtype");
 156     }
 157
 158 }
 159
 160
 161 void CacheInfoMgr::fam_callback(WvStringParm file, WvFamEvent event, bool fromdir)
 162 {
 163     CacheInfo *fi = fi_by_path[file];
 164
 165     if (!fi)
 166         return;
 167
 168     CacheInfo *parent = fi_by_path[getdirname(file)];
 169
 170     fi->invalidate(true);
 171     if (parent)
 172         parent->invalidate(false);
 173 }