CollapsedForwarding.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 17    Request Forwarding */
 
#ifndef SQUID_SRC_COLLAPSEDFORWARDING_H
#define SQUID_SRC_COLLAPSEDFORWARDING_H
 
#include "ipc/forward.h"
#include "ipc/Queue.h"
#include "store/forward.h"
 
#include <memory>
 
class StoreEntry;
 
class CollapsedForwarding
{
public:
    static void Init();
 
    static void Broadcast(const StoreEntry &e, const bool includingThisWorker = false);
 
    static void Broadcast(const sfileno index, const bool includingThisWorker);
 
    static void Notify(const int workerId);
 
    static void HandleNewData(const char *const when);
 
    static void HandleNotification(const Ipc::TypedMsgHdr &msg);
 
    static void StatQueue(std::ostream &);
 
private:
    static void HandleNewDataAtStart();
 
    typedef Ipc::MultiQueue Queue;
    static std::unique_ptr<Queue> queue; 
};
 
#endif /* SQUID_SRC_COLLAPSEDFORWARDING_H */