SharedListen.h
Go to the documentation of this file.
1/*
2 * Copyright (C) 1996-2022 The Squid Software Foundation and contributors
3 *
4 * Squid software is distributed under GPLv2+ license and includes
5 * contributions from numerous individuals and organizations.
6 * Please see the COPYING and CONTRIBUTORS files for details.
7 */
8
9/* DEBUG: section 54 Interprocess Communication */
10
11#ifndef SQUID_IPC_SHARED_LISTEN_H
12#define SQUID_IPC_SHARED_LISTEN_H
13
14#include "base/AsyncCall.h"
15#include "base/Subscription.h"
16#include "ipc/QuestionerId.h"
17#include "ipc/RequestId.h"
18
19namespace Ipc
20{
21
23
27{
28public:
29 bool operator <(const OpenListenerParams &p) const;
30
31 // bits to re-create the fde entry
32 int sock_type = 0;
33 int proto = 0;
34 int fdNote = 0;
35
36 // bits to re-create the listener Comm::Connection descriptor
38 int flags = 0;
39};
40
41class TypedMsgHdr;
42
45{
46public:
48 explicit SharedListenRequest(const TypedMsgHdr &hdrMsg);
49 void pack(TypedMsgHdr &hdrMsg) const;
50
51public:
53
55
57};
58
61{
62public:
63 SharedListenResponse(int fd, int errNo, RequestId aMapId);
64 explicit SharedListenResponse(const TypedMsgHdr &hdrMsg);
65 void pack(TypedMsgHdr &hdrMsg) const;
66
69
70public:
71 int fd;
72 int errNo;
74};
75
78
80void SharedListenJoined(const SharedListenResponse &response);
81
82} // namespace Ipc;
83
84#endif /* SQUID_IPC_SHARED_LISTEN_H */
85
"shared listen" is when concurrent processes are listening on the same fd
Definition: SharedListen.h:27
int fdNote
index into fd_note() comment strings
Definition: SharedListen.h:34
bool operator<(const OpenListenerParams &p) const
useful for map<>
Definition: SharedListen.cc:59
Ip::Address addr
will be memset and memcopied
Definition: SharedListen.h:37
QuestionerId questioner() const
Definition: RequestId.h:44
a request for a listen socket with given parameters
Definition: SharedListen.h:45
OpenListenerParams params
actual comm_open_sharedListen() parameters
Definition: SharedListen.h:54
SharedListenRequest(const OpenListenerParams &, RequestId aMapId)
sender's constructor
Definition: SharedListen.cc:72
int requestorId
kidId of the requestor
Definition: SharedListen.h:52
RequestId mapId
to map future response to the requestor's callback
Definition: SharedListen.h:56
void pack(TypedMsgHdr &hdrMsg) const
prepare for sendmsg()
Definition: SharedListen.cc:86
a response to SharedListenRequest
Definition: SharedListen.h:61
void pack(TypedMsgHdr &hdrMsg) const
prepare for sendmsg()
SharedListenResponse(int fd, int errNo, RequestId aMapId)
sender's constructor
Definition: SharedListen.cc:92
int fd
opened listening socket or -1
Definition: SharedListen.h:71
QuestionerId intendedRecepient() const
for Mine() tests
Definition: SharedListen.h:68
RequestId mapId
to map future response to the requestor's callback
Definition: SharedListen.h:73
int errNo
errno value from comm_open_sharedListen() call
Definition: SharedListen.h:72
struct msghdr with a known type, fixed-size I/O and control buffers
Definition: TypedMsgHdr.h:35
Definition: IpcIoFile.h:24
void SharedListenJoined(const SharedListenResponse &response)
process Coordinator response to SharedListenRequest
void JoinSharedListen(const OpenListenerParams &, AsyncCall::Pointer &)
prepare and send SharedListenRequest to Coordinator

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors