projects / thirdparty / squid.git / blame
| Commit | Line | Data |
|---|---|---|
| 59b2d47f | 1 | /* |
| bbc27441 | 2 | * Copyright (C) 1996-2014 The Squid Software Foundation and contributors |
| 59b2d47f | 3 | * |
| bbc27441 AJ |
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. | |
| 59b2d47f | 7 | */ |
| 8 | ||
| bbc27441 AJ |
9 | /* DEBUG: section 47 Store Directory Routines */ |
| 10 | ||
| b9ae18aa | 11 | #ifndef SQUID_BLOCKINGFILE_H |
| 12 | #define SQUID_BLOCKINGFILE_H | |
| aa839030 | 13 | |
| 14 | #include "cbdata.h" | |
| b9ae18aa | 15 | #include "DiskIO/DiskFile.h" |
| 63be0a78 | 16 | #include "DiskIO/IORequestor.h" |
| 59b2d47f | 17 | |
| b9ae18aa | 18 | class BlockingFile : public DiskFile |
| 59b2d47f | 19 | { |
| 20 | ||
| 21 | public: | |
| 63be0a78 | 22 | BlockingFile(char const *path); |
| b9ae18aa | 23 | ~BlockingFile(); |
| 63be0a78 | 24 | virtual void open(int flags, mode_t mode, RefCount<IORequestor> callback); |
| 25 | virtual void create(int flags, mode_t mode, RefCount<IORequestor> callback); | |
| b9ae18aa | 26 | virtual void read(ReadRequest *); |
| 27 | virtual void write(WriteRequest *); | |
| 63be0a78 | 28 | virtual void close(); |
| b9ae18aa | 29 | virtual bool error() const; |
| 30 | virtual int getFD() const { return fd;} | |
| 59b2d47f | 31 | |
| b9ae18aa | 32 | virtual bool canRead() const; |
| 63be0a78 | 33 | virtual bool ioInProgress() const; |
| 59b2d47f | 34 | |
| b9ae18aa | 35 | private: |
| 36 | static DRCB ReadDone; | |
| 37 | static DWCB WriteDone; | |
| b9ae18aa | 38 | int fd; |
| 39 | bool closed; | |
| 40 | void error (bool const &); | |
| 41 | bool error_; | |
| 42 | char const *path_; | |
| 43 | RefCount<IORequestor> ioRequestor; | |
| 44 | RefCount<ReadRequest> readRequest; | |
| 45 | RefCount<WriteRequest> writeRequest; | |
| 46 | void doClose(); | |
| 47 | void readDone(int fd, const char *buf, int len, int errflag); | |
| 48 | void writeDone(int fd, int errflag, size_t len); | |
| c7bf588b | 49 | |
| f49c09b2 | 50 | CBDATA_CLASS2(BlockingFile); |
| b9ae18aa | 51 | }; |
| 59b2d47f | 52 | |
| b9ae18aa | 53 | #endif /* SQUID_BLOCKINGFILE_H */ |