RockHeaderUpdater.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.
 */
 
#ifndef SQUID_FS_ROCK_HEADER_UPDATER_H
#define SQUID_FS_ROCK_HEADER_UPDATER_H
 
#include "base/AsyncJob.h"
#include "cbdata.h"
#include "fs/rock/forward.h"
#include "fs/rock/RockSwapDir.h"
#include "ipc/StoreMap.h"
 
namespace Rock
{
 
class HeaderUpdater: public AsyncJob
{
    CBDATA_CHILD(HeaderUpdater);
 
public:
    class IoCbParams {
    public:
        IoCbParams(const char *aBuf, ssize_t aSize) : buf(aBuf), size(aSize) {}
        const char *buf;
        ssize_t size;
    };
    HeaderUpdater(const Rock::SwapDir::Pointer &aStore, const Ipc::StoreMapUpdate &update);
    ~HeaderUpdater() override = default;
 
protected:
    /* AsyncJob API */
    void start() override;
    bool doneAll() const override;
    void swanSong() override;
 
private:
    static StoreIOState::STRCB NoteRead;
    static StoreIOState::STIOCB NoteDoneReading;
    static StoreIOState::STIOCB NoteDoneWriting;
 
    void startReading();
    void stopReading(const char *why);
    void readMore(const char *why);
    void noteRead(const IoCbParams result);
    void noteDoneReading(int errflag);
    void parseReadBytes();
 
    void startWriting();
    void noteDoneWriting(int errflag);
 
    Rock::SwapDir::Pointer store; 
    Ipc::StoreMapUpdate update; 
 
    StoreIOState::Pointer reader; 
    StoreIOState::Pointer writer; 
 
    SBuf readerBuffer; 
    SBuf exchangeBuffer; 
    uint64_t bytesRead; 
 
    size_t staleSwapHeaderSize; 
 
    SlotId staleSplicingPointNext; 
};
 
inline
std::ostream &operator <<(std::ostream &os, const HeaderUpdater::IoCbParams &params)
{
    os << static_cast<const void *>(params.buf) << "," << params.size;
    return os;
}
 
} // namespace Rock
 
#endif /* SQUID_FS_ROCK_HEADER_UPDATER_H */