Coordinator.h
void handleSearchRequest(const StrandSearchRequest &request)
answers or queues the request if the answer is not yet known
Definition: Coordinator.cc:199
Coordinator & operator=(const Coordinator &)
void handleSnmpResponse(const Snmp::Response &response)
Definition: Coordinator.cc:246
void handleCacheMgrRequest(const Mgr::Request &request)
Definition: Coordinator.cc:167
Waits for and receives incoming IPC messages; kids handle the messages.
Definition: Port.h:22
void notifySearcher(const StrandSearchRequest &request, const StrandCoord &)
answer the waiting search request
Definition: Coordinator.cc:220
Definition: Response.h:24
Coordinates shared activities of Strands (Squid processes or threads)
Definition: Coordinator.h:31
void handleCacheMgrResponse(const Mgr::Response &response)
Definition: Coordinator.cc:193
virtual void receive(const TypedMsgHdr &message)
Definition: Coordinator.cc:79
Definition: Response.h:24
std::vector< StrandCoord > StrandCoords
a collection of strand coordinates; the order, if any, is owner-dependent
Definition: StrandCoords.h:19
struct msghdr with a known type, fixed-size I/O and control buffers
Definition: TypedMsgHdr.h:33
CBDATA_CLASS(Coordinator)
Comm::ConnectionPointer openListenSocket(const SharedListenRequest &request, int &errNo)
calls comm_open_listener()
Definition: Coordinator.cc:254
Coordinator(const Coordinator &)
void handleSnmpRequest(const Snmp::Request &request)
Definition: Coordinator.cc:233
void handleSharedListenRequest(const SharedListenRequest &request)
returns cached socket or calls openListenSocket()
Definition: Coordinator.cc:147
std::map< OpenListenerParams, Comm::ConnectionPointer > Listeners
params:connection map
Definition: Coordinator.h:74
Definition: IpcIoFile.h:24