SharedListen.h

Go to the documentation of this file.

/*
 * Copyright (C) 1996-2018 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_SHARED_LISTEN_H
#define SQUID_IPC_SHARED_LISTEN_H

#include "base/AsyncCall.h"
#include "base/Subscription.h"

namespace Ipc
{


class OpenListenerParams
{
public:
    OpenListenerParams();

    bool operator <(const OpenListenerParams &p) const; 

    // bits to re-create the fde entry
    int sock_type;
    int proto;
    int fdNote; 

    // bits to re-create the listener Comm::Connection descriptor
    Ip::Address addr; 
    int flags;

    Subscription::Pointer handlerSubscription;
};

class TypedMsgHdr;

class SharedListenRequest
{
public:
    SharedListenRequest(); 
    explicit SharedListenRequest(const TypedMsgHdr &hdrMsg); 
    void pack(TypedMsgHdr &hdrMsg) const; 

public:
    int requestorId; 

    OpenListenerParams params; 

    int mapId; 
};

class SharedListenResponse
{
public:
    SharedListenResponse(int fd, int errNo, int mapId);
    explicit SharedListenResponse(const TypedMsgHdr &hdrMsg); 
    void pack(TypedMsgHdr &hdrMsg) const; 

public:
    int fd; 
    int errNo; 
    int mapId; 
};

void JoinSharedListen(const OpenListenerParams &, AsyncCall::Pointer &);

void SharedListenJoined(const SharedListenResponse &response);

} // namespace Ipc;

#endif /* SQUID_IPC_SHARED_LISTEN_H */