Coordinator.cc
Go to the documentation of this file.
strand registration with Coordinator (also used as an ACK)
Definition: StrandCoord.h:36
Definition: SquidString.h:25
Coordinates shared activities of Strands (Squid processes or threads)
Definition: Coordinator.h:30
void handleSnmpRequest(const Snmp::Request &request)
Definition: Coordinator.cc:233
void comm_open_listener(int sock_type, int proto, Comm::ConnectionPointer &conn, const char *note)
Definition: comm.cc:232
Definition: IpcIoFile.h:23
Definition: Messages.h:20
static void HandleRemoteAck(const Response &response)
finds and calls the right Inquirer upon strand's response
Definition: Inquirer.cc:156
Definition: Inquirer.h:26
static Pointer Start(AsyncJob *job)
starts a freshly created job (i.e., makes the job asynchronous)
Definition: AsyncJob.cc:23
CBDATA_NAMESPACED_CLASS_INIT(Ipc, Coordinator)
void notifySearcher(const StrandSearchRequest &request, const StrandCoord &)
answer the waiting search request
Definition: Coordinator.cc:220
void handleCacheMgrRequest(const Mgr::Request &request)
Definition: Coordinator.cc:167
static String MakeAddr(const char *proccessLabel, int id)
calculates IPC message address for strand id of processLabel type
Definition: Port.cc:51
Definition: Messages.h:25
Definition: Messages.h:28
Definition: Messages.h:21
Mgr::Action::Pointer createRequestedAction(const Mgr::ActionParams &)
Definition: cache_manager.cc:140
Definition: Messages.h:25
std::vector< StrandCoord > StrandCoords
a collection of strand coordinates; the order, if any, is owner-dependent
Definition: StrandCoords.h:19
void handleCacheMgrResponse(const Mgr::Response &response)
Definition: Coordinator.cc:193
void handleSnmpResponse(const Snmp::Response &response)
Definition: Coordinator.cc:246
virtual void receive(const TypedMsgHdr &message)
handle IPC message just read
Definition: Coordinator.cc:79
void SendMessage(const String &toAddress, const TypedMsgHdr &message)
Definition: UdsOp.cc:188
bool action(int fd, size_t metasize, const char *fn, const char *url, const SquidMetaList &meta)
Definition: purge.cc:311
Waits for and receives incoming IPC messages; kids handle the messages.
Definition: Port.h:21
struct msghdr with a known type, fixed-size I/O and control buffers
Definition: TypedMsgHdr.h:31
Definition: Inquirer.h:26
Definition: Response.h:23
Comm::ConnectionPointer openListenSocket(const SharedListenRequest &request, int &errNo)
calls comm_open_listener()
Definition: Coordinator.cc:254
Definition: Messages.h:28
"shared listen" is when concurrent processes are listening on the same fd
Definition: SharedListen.h:24
void handleSharedListenRequest(const SharedListenRequest &request)
returns cached socket or calls openListenSocket()
Definition: Coordinator.cc:147
Definition: Messages.h:22
void handleSearchRequest(const StrandSearchRequest &request)
answers or queues the request if the answer is not yet known
Definition: Coordinator.cc:199
Definition: Response.h:23
Definition: Connection.h:65