Forwarder.h
Definition: AsyncJob.h:32
static void RequestTimedOut(void *param)
Ipc::Forwarder::requestTimedOut wrapper.
Definition: Forwarder.cc:100
static void HandleRemoteAck(RequestId)
finds and calls the right Forwarder upon Coordinator's response
Definition: Forwarder.cc:176
void handleRemoteAck()
called when Coordinator starts processing the request
Definition: Forwarder.cc:88
virtual void handleException(const std::exception &e)
terminate with an error
Definition: Forwarder.cc:134
std::map< RequestId::Index, AsyncCall::Pointer > RequestsMap
maps request->id to Forwarder::handleRemoteAck callback
Definition: Forwarder.h:69
void requestTimedOut()
called when Coordinator fails to start processing the request [in time]
Definition: Forwarder.cc:114
CBDATA_CLASS(Forwarder)
static AsyncCall::Pointer DequeueRequest(RequestId::Index)
returns and forgets the right Forwarder callback for the request
Definition: Forwarder.cc:153
Definition: Forwarder.h:30
virtual void callException(const std::exception &e)
called when the job throws during an async call
Definition: Forwarder.cc:141
Definition: RequestId.h:23
Forwarder(Request::Pointer aRequest, double aTimeout)
Definition: Forwarder.cc:27
void removeTimeoutEvent()
called when we are no longer waiting for Coordinator to respond
Definition: Forwarder.cc:169
Definition: IpcIoFile.h:24