src/DiskIO/DiskThreads/DiskThreadsDiskFile.h

   1 /*
   2  * Copyright (C) 1996-2014 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 /* DEBUG: section 79    Disk IO Routines */
  10
  11 #ifndef SQUID_DISKTHREADSDISKFILE_H
  12 #define SQUID_DISKTHREADSDISKFILE_H
  13 #include "cbdata.h"
  14 #include "DiskIO/DiskFile.h"
  15 #include "DiskThreads.h"
  16
  17 class DiskThreadsDiskFile : public DiskFile
  18 {
  19
  20 public:
  21     DiskThreadsDiskFile(char const *path, DiskThreadsIOStrategy *);
  22     ~DiskThreadsDiskFile();
  23     virtual void open(int flags, mode_t mode, RefCount<IORequestor> callback);
  24     virtual void create(int flags, mode_t mode, RefCount<IORequestor> callback);
  25     virtual void read(ReadRequest *);
  26     virtual void write(WriteRequest *);
  27     virtual void close();
  28     virtual bool error() const;
  29     virtual int getFD() const { return fd;}
  30
  31     virtual bool canRead() const;
  32     virtual bool canWrite() const;
  33     virtual bool ioInProgress() const;
  34
  35 private:
  36 #if ASYNC_READ
  37
  38     static AIOCB ReadDone;
  39 #else
  40
  41     static DRCB ReadDone;
  42 #endif
  43 #if ASYNC_WRITE
  44
  45     static AIOCB WriteDone;
  46 #else
  47
  48     static DWCB WriteDone;
  49 #endif
  50
  51     int fd;
  52     bool errorOccured;
  53     char const *path_;
  54     DiskThreadsIOStrategy *IO;
  55     size_t inProgressIOs;
  56     static AIOCB OpenDone;
  57     void openDone(int fd, const char *buf, int aio_return, int aio_errno);
  58     RefCount<IORequestor> ioRequestor;
  59     void doClose();
  60
  61     void readDone(int fd, const char *buf, int len, int errflag, RefCount<ReadRequest> request);
  62     void writeDone(int fd, int errflag, size_t len, RefCount<WriteRequest> request);
  63
  64     CBDATA_CLASS2(DiskThreadsDiskFile);
  65 };
  66
  67 #include "DiskIO/ReadRequest.h"
  68
  69 template <class RT>
  70 class IoResult
  71 {
  72
  73 public:
  74     IoResult(RefCount<DiskThreadsDiskFile> aFile, RefCount<RT> aRequest) : file(aFile), request(aRequest) {}
  75
  76     RefCount<DiskThreadsDiskFile> file;
  77     RefCount<RT> request;
  78
  79 private:
  80     CBDATA_CLASS2(IoResult);
  81 };
  82
  83 template <class RT>
  84 IoResult<RT>
  85 IOResult(RefCount<RT> aRequest, RefCount<DiskThreadsDiskFile> aFile) { return IoResult<RT>(aFile, aRequest);}
  86
  87 #endif /* SQUID_DISKTHREADSDISKFILE_H */