StoreToCommWriter.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 16    Cache Manager API */
 
#ifndef SQUID_SRC_MGR_STORETOCOMMWRITER_H
#define SQUID_SRC_MGR_STORETOCOMMWRITER_H
 
#include "base/AsyncJob.h"
#include "comm/forward.h"
#include "http/forward.h"
#include "mgr/Action.h"
#include "StoreIOBuffer.h"
 
class store_client;
class CommIoCbParams;
class CommCloseCbParams;
 
namespace Mgr
{
 
class StoreToCommWriter: public AsyncJob
{
    CBDATA_INTERMEDIATE();
 
public:
    StoreToCommWriter(const Comm::ConnectionPointer &conn, StoreEntry *anEntry);
    ~StoreToCommWriter() override;
 
protected:
    /* AsyncJob API */
    void start() override;
    void swanSong() override;
    bool doneAll() const override;
 
    void scheduleStoreCopy();
    void noteStoreCopied(StoreIOBuffer ioBuf);
    static void NoteStoreCopied(void* data, StoreIOBuffer ioBuf);
    static void HandleStoreAbort(StoreToCommWriter *param);
 
    void scheduleCommWrite(const StoreIOBuffer& ioBuf);
    void noteCommWrote(const CommIoCbParams& params);
    void noteCommClosed(const CommCloseCbParams& params);
 
    void close();
 
protected:
    Comm::ConnectionPointer clientConnection; 
 
    StoreEntry* entry; 
    store_client* sc; 
    int64_t writeOffset; 
 
    AsyncCall::Pointer closer; 
    char buffer[HTTP_REQBUF_SZ]; 
};
 
} // namespace Mgr
 
#endif /* SQUID_SRC_MGR_STORETOCOMMWRITER_H */