Coordinator.h

Go to the documentation of this file.

/*
 * Copyright (C) 1996-2020 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 54    Interprocess Communication */
 
#ifndef SQUID_IPC_COORDINATOR_H
#define SQUID_IPC_COORDINATOR_H
 
#include "ipc/Messages.h"
#include "ipc/Port.h"
#include "ipc/SharedListen.h"
#include "ipc/StrandCoords.h"
#include "ipc/StrandSearch.h"
#include "mgr/forward.h"
#if SQUID_SNMP
#include "snmp/forward.h"
#endif
#include <list>
#include <map>
 
namespace Ipc
{
 
class Coordinator: public Port
{
    CBDATA_CLASS(Coordinator);
 
public:
    static Coordinator* Instance();
 
public:
    Coordinator();
 
    void broadcastSignal(int sig) const; 
 
    const StrandCoords &strands() const; 
 
protected:
    virtual void start(); // Port (AsyncJob) API
    virtual void receive(const TypedMsgHdr& message); // Port API
 
    StrandCoord* findStrand(int kidId); 
    void registerStrand(const StrandCoord &); 
    void handleRegistrationRequest(const HereIamMessage &); 
 
    void notifySearcher(const StrandSearchRequest &request, const StrandCoord&);
    void handleSearchRequest(const StrandSearchRequest &request);
 
    void handleSharedListenRequest(const SharedListenRequest& request);
    void handleCacheMgrRequest(const Mgr::Request& request);
    void handleCacheMgrResponse(const Mgr::Response& response);
#if SQUID_SNMP
    void handleSnmpRequest(const Snmp::Request& request);
    void handleSnmpResponse(const Snmp::Response& response);
#endif
    Comm::ConnectionPointer openListenSocket(const SharedListenRequest& request, int &errNo);
 
private:
    StrandCoords strands_; 
 
    typedef std::list<StrandSearchRequest> Searchers; 
    Searchers searchers; 
 
    typedef std::map<OpenListenerParams, Comm::ConnectionPointer> Listeners; 
    Listeners listeners; 
 
    static Coordinator* TheInstance; 
 
private:
    Coordinator(const Coordinator&); // not implemented
    Coordinator& operator =(const Coordinator&); // not implemented
};
 
} // namespace Ipc
 
#endif /* SQUID_IPC_COORDINATOR_H */