DiskThreadsDiskFile.h

Go to the documentation of this file.

/*
 * Copyright (C) 1996-2023 The Squid Software Foundation and contributors
 *
 * Squid software is distributed under GPLv2+ license and includes
 * contributions from numerous individuals and organizations.
 * Please see the COPYING and CONTRIBUTORS files for details.
 */
 
/* DEBUG: section 79    Disk IO Routines */
 
#ifndef SQUID_SRC_DISKIO_DISKTHREADS_DISKTHREADSDISKFILE_H
#define SQUID_SRC_DISKIO_DISKTHREADS_DISKTHREADSDISKFILE_H
 
#include "cbdata.h"
#include "DiskIO/DiskFile.h"
#include "DiskThreads.h"
#include "typedefs.h" //for DWCB
 
class DiskThreadsDiskFile : public DiskFile
{
    CBDATA_CLASS(DiskThreadsDiskFile);
 
public:
    DiskThreadsDiskFile(char const *path);
    ~DiskThreadsDiskFile() override;
    void open(int flags, mode_t mode, RefCount<IORequestor> callback) override;
    void create(int flags, mode_t mode, RefCount<IORequestor> callback) override;
    void read(ReadRequest *) override;
    void write(WriteRequest *) override;
    void close() override;
    bool error() const override;
    int getFD() const override { return fd;}
 
    bool canRead() const override;
    bool canWrite() const override;
    bool ioInProgress() const override;
 
private:
#if ASYNC_READ
 
    static AIOCB ReadDone;
#else
 
    static DRCB ReadDone;
#endif
#if ASYNC_WRITE
 
    static AIOCB WriteDone;
#else
 
    static DWCB WriteDone;
#endif
 
    int fd = -1;
    bool errorOccured = false;
    char const *path_ = nullptr;
    size_t inProgressIOs = 0;
    static AIOCB OpenDone;
    void openDone(int fd, const char *buf, int aio_return, int aio_errno);
    RefCount<IORequestor> ioRequestor;
    void doClose();
 
    void readDone(int fd, const char *buf, int len, int errflag, const RefCount<ReadRequest> &request);
    void writeDone(int fd, int errflag, size_t len, RefCount<WriteRequest> request);
};
 
#include "DiskIO/ReadRequest.h"
 
template <class RT>
class IoResult
{
    CBDATA_CLASS(IoResult);
 
public:
    IoResult(RefCount<DiskThreadsDiskFile> aFile, RefCount<RT> aRequest) : file(aFile), request(aRequest) {}
 
    RefCount<DiskThreadsDiskFile> file;
    RefCount<RT> request;
};
 
template <class RT>
IoResult<RT>
IOResult(RefCount<RT> aRequest, RefCount<DiskThreadsDiskFile> aFile) { return IoResult<RT>(aFile, aRequest);}
 
#endif /* SQUID_SRC_DISKIO_DISKTHREADS_DISKTHREADSDISKFILE_H */