SharedListen.h
Go to the documentation of this file.
1 /*
2  * Copyright (C) 1996-2017 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 
17 namespace Ipc
18 {
19 
21 
25 {
26 public:
28 
29  bool operator <(const OpenListenerParams &p) const;
30 
31  // bits to re-create the fde entry
32  int sock_type;
33  int proto;
34  int fdNote;
35 
36  // bits to re-create the listener Comm::Connection descriptor
38  int flags;
39 
42 };
43 
44 class TypedMsgHdr;
45 
48 {
49 public:
51  explicit SharedListenRequest(const TypedMsgHdr &hdrMsg);
52  void pack(TypedMsgHdr &hdrMsg) const;
53 
54 public:
56 
58 
59  int mapId;
60 };
61 
64 {
65 public:
66  SharedListenResponse(int fd, int errNo, int mapId);
67  explicit SharedListenResponse(const TypedMsgHdr &hdrMsg);
68  void pack(TypedMsgHdr &hdrMsg) const;
69 
70 public:
71  int fd;
72  int errNo;
73  int mapId;
74 };
75 
78 
80 void SharedListenJoined(const SharedListenResponse &response);
81 
82 } // namespace Ipc;
83 
84 #endif /* SQUID_IPC_SHARED_LISTEN_H */
85 
void pack(TypedMsgHdr &hdrMsg) const
prepare for sendmsg()
Definition: SharedListen.cc:87
int mapId
to map future response to the requestor's callback
Definition: SharedListen.h:73
SharedListenRequest()
from OpenSharedListen() which then sets public data
Definition: SharedListen.cc:76
int requestorId
kidId of the requestor
Definition: SharedListen.h:55
char * p
Definition: membanger.c:43
Ip::Address addr
will be memset and memcopied
Definition: SharedListen.h:37
void SharedListenJoined(const SharedListenResponse &response)
process Coordinator response to SharedListenRequest
OpenListenerParams params
actual comm_open_sharedListen() parameters
Definition: SharedListen.h:57
a response to SharedListenRequest
Definition: SharedListen.h:63
a request for a listen socket with given parameters
Definition: SharedListen.h:47
int fdNote
index into fd_note() comment strings
Definition: SharedListen.h:34
void JoinSharedListen(const OpenListenerParams &, AsyncCall::Pointer &)
prepare and send SharedListenRequest to Coordinator
Subscription::Pointer handlerSubscription
handler to subscribe to Comm::ConnAcceptor when we get the response
Definition: SharedListen.h:41
SharedListenResponse(int fd, int errNo, int mapId)
Definition: SharedListen.cc:93
struct msghdr with a known type, fixed-size I/O and control buffers
Definition: TypedMsgHdr.h:31
int errNo
errno value from comm_open_sharedListen() call
Definition: SharedListen.h:72
void pack(TypedMsgHdr &hdrMsg) const
prepare for sendmsg()
int fd
opened listening socket or -1
Definition: SharedListen.h:71
"shared listen" is when concurrent processes are listening on the same fd
Definition: SharedListen.h:24
bool operator<(const OpenListenerParams &p) const
useful for map<>
Definition: SharedListen.cc:63
int mapId
to map future response to the requestor's callback
Definition: SharedListen.h:59

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors