src/DiskIO/DiskThreads/DiskThreadsDiskFile.h

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