src/DiskIO/DiskThreads/DiskThreadsDiskFile.h

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