StartListening.cc
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 #include "squid.h"
12 #include "base/TextException.h"
13 #include "comm.h"
14 #include "comm/Connection.h"
15 #include "ipc/SharedListen.h"
16 #include "ipc/StartListening.h"
17 #include "tools.h"
18 
19 #include <cerrno>
20 
22 {
23 }
24 
26 {
27 }
28 
29 std::ostream &Ipc::StartListeningCb::startPrint(std::ostream &os) const
30 {
31  return os << "(" << conn << ", err=" << errNo;
32 }
33 
34 void
35 Ipc::StartListening(int sock_type, int proto, const Comm::ConnectionPointer &listenConn,
37 {
38  StartListeningCb *cbd = dynamic_cast<StartListeningCb*>(callback->getDialer());
39  Must(cbd);
40  cbd->conn = listenConn;
41 
42  if (UsingSmp()) { // if SMP is on, share
44  p.sock_type = sock_type;
45  p.proto = proto;
46  p.addr = listenConn->local;
47  p.flags = listenConn->flags;
48  p.fdNote = fdNote;
49  Ipc::JoinSharedListen(p, callback);
50  return; // wait for the call back
51  }
52 
53  enter_suid();
54  comm_open_listener(sock_type, proto, cbd->conn, FdNote(fdNote));
55  cbd->errNo = Comm::IsConnOpen(cbd->conn) ? 0 : errno;
56  leave_suid();
57 
58  debugs(54, 3, HERE << "opened listen " << cbd->conn);
59  ScheduleCallHere(callback);
60 }
61 
const char * FdNote(int fdNodeId)
converts FdNoteId into a string
Definition: FdNotes.cc:16
void StartListening(int sock_type, int proto, const Comm::ConnectionPointer &listenConn, FdNoteId fdNote, AsyncCall::Pointer &callback)
void const char HLPCB * callback
Definition: stub_helper.cc:16
std::ostream & startPrint(std::ostream &os) const
starts printing arguments, return os
void comm_open_listener(int sock_type, int proto, Comm::ConnectionPointer &conn, const char *note)
Definition: comm.cc:232
char * p
Definition: membanger.c:43
int conn
the current server connection FD
Definition: Transport.cc:26
Ip::Address addr
will be memset and memcopied
Definition: SharedListen.h:37
FdNoteId
We cannot send char* FD notes to other processes. Pass int IDs and convert.
Definition: FdNotes.h:20
bool IsConnOpen(const Comm::ConnectionPointer &conn)
Definition: Connection.cc:24
common API for all StartListening() callbacks
virtual CallDialer * getDialer()=0
#define debugs(SECTION, LEVEL, CONTENT)
Definition: Debug.h:123
Comm::ConnectionPointer conn
opened listening socket
void leave_suid(void)
Definition: tools.cc:504
bool UsingSmp()
Whether there should be more than one worker process running.
Definition: tools.cc:658
std::ostream & HERE(std::ostream &s)
Definition: Debug.h:147
#define Must(cond)
Definition: TextException.h:89
Ip::Address local
Definition: Connection.h:135
int errNo
errno value from the comm_open_listener() call
int fdNote
index into fd_note() comment strings
Definition: SharedListen.h:34
void JoinSharedListen(const OpenListenerParams &, AsyncCall::Pointer &)
prepare and send SharedListenRequest to Coordinator
void enter_suid(void)
Definition: tools.cc:575
#define ScheduleCallHere(call)
Definition: AsyncCall.h:166
"shared listen" is when concurrent processes are listening on the same fd
Definition: SharedListen.h:24
#define NULL
Definition: types.h:166

 

Introduction

Documentation

Support

Miscellaneous

Web Site Translations

Mirrors