Forwarder.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_FORWARDER_H
#define SQUID_IPC_FORWARDER_H
 
#include "base/AsyncJob.h"
#include "cbdata.h"
#include "ipc/Request.h"
#include "mgr/ActionParams.h"
 
#include <map>
 
namespace Ipc
{
 
class Forwarder: public AsyncJob
{
    CBDATA_CLASS(Forwarder);
 
public:
    Forwarder(Request::Pointer aRequest, double aTimeout);
    virtual ~Forwarder();
 
    static void HandleRemoteAck(unsigned int requestId);
 
    /* has-to-be-public AsyncJob API */
    virtual void callException(const std::exception& e);
 
protected:
    /* AsyncJob API */
    virtual void start();
    virtual void swanSong();
    virtual bool doneAll() const;
 
    virtual void handleError();
    virtual void handleTimeout();
    virtual void handleException(const std::exception& e);
 
private:
    static void RequestTimedOut(void* param);
    void requestTimedOut();
    void removeTimeoutEvent();
 
    void handleRemoteAck();
 
    static AsyncCall::Pointer DequeueRequest(unsigned int requestId);
 
protected:
    Request::Pointer request;
    const double timeout; 
 
    typedef std::map<unsigned int, AsyncCall::Pointer> RequestsMap;
    static RequestsMap TheRequestsMap; 
 
    static unsigned int LastRequestId; 
};
 
} // namespace Ipc
 
#endif /* SQUID_IPC_FORWARDER_H */