funfs/cachefsasync.cc

   1 #include "cachefsasync.h"
   2
   3 #include <wvstreamlist.h>
   4 #include <wvistreamlist.h>
   5
   6
   7 unsigned char AsyncRequest::counter = 0;
   8 WvStreamList *AsyncRequest::delayed = NULL;
   9
  10 AsyncRequest::AsyncRequest(CacheFS *_cachefs) : cachefs(_cachefs)
  11 {
  12     ok = true;
  13     uses_continue_select = true;
  14
  15     if (!delayed)
  16         delayed = new WvStreamList();
  17
  18     if (counter++ > 20)
  19     {
  20         delayed->append(this, false);
  21     }
  22     else
  23     {
  24         alarm(0);
  25     }
  26
  27
  28     personal_stack_size = 2048;
  29     WvIStreamList::globallist.append(this, true);
  30 }
  31
  32 AsyncRequest::~AsyncRequest()
  33 {
  34     counter--;
  35     terminate_continue_select();
  36
  37     if (!delayed->isempty())
  38     {
  39         delayed->first()->alarm(0);
  40         delayed->unlink_first();
  41     }
  42 }
  43
  44 void AsyncReadblock::execute()
  45 {
  46     WvStream::execute();
  47
  48     //fprintf(stderr, "Starting Async read fd = %d index = %d\n", fd, index);
  49     int r = cachefs->fs->fs_read(this, fd, buf, FUSE_BLOCK_SIZE,
  50             index * FUSE_BLOCK_SIZE);
  51
  52     cachefs->update_page_status(fd, index, r);
  53
  54     ok = false;
  55 }