PeerPoolMgr.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_SRC_PEERPOOLMGR_H
#define SQUID_SRC_PEERPOOLMGR_H
 
#include "base/AsyncJob.h"
#include "base/forward.h"
#include "base/JobWait.h"
#include "comm/forward.h"
#include "security/forward.h"
 
class HttpRequest;
class CachePeer;
class CommConnectCbParams;
 
class PeerPoolMgr: public AsyncJob
{
    CBDATA_CHILD(PeerPoolMgr);
 
public:
    typedef CbcPointer<PeerPoolMgr> Pointer;
 
    // syncs mgr state whenever connection-related peer or pool state changes
    static void Checkpoint(const Pointer &mgr, const char *reason);
 
    explicit PeerPoolMgr(CachePeer *aPeer);
    ~PeerPoolMgr() override;
 
    PrecomputedCodeContextPointer codeContext;
 
protected:
    /* AsyncJob API */
    void start() override;
    void swanSong() override;
    bool doneAll() const override;
 
    bool validPeer() const;
 
    void checkpoint(const char *reason);
    void openNewConnection();
    void closeOldConnections(const int howMany);
 
    void handleOpenedConnection(const CommConnectCbParams &params);
 
    void handleSecuredPeer(Security::EncryptorAnswer &answer);
 
    void pushNewConnection(const Comm::ConnectionPointer &conn);
 
private:
    CachePeer *peer; 
    RefCount<HttpRequest> request; 
 
    JobWait<Comm::ConnOpener> transportWait;
 
    JobWait<Security::BlindPeerConnector> encryptionWait;
 
    unsigned int addrUsed; 
};
 
#endif /* SQUID_SRC_PEERPOOLMGR_H */