|
void | fwRPC_broker_initialize () |
|
private void | _fwRPC_broker_beginTick () |
|
private void | _fwRPC_broker_dbg_report () |
|
private synchronized void | fwRPC_broker_newMbxCB (string project, string name) |
|
private synchronized void | fwRPC_broker_sys_drop (string project) |
|
private synchronized void | _fwRPC_broker_dropCore (string project, string name="") |
|
private synchronized void | _fwRPC_broker_dropClient (string project, string name="") |
|
private void | _fwRPC_broker_hdlDisconnect (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlRequest (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlStatus (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlGetResult (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlSetResult (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlRegister (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlAcknowledge (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlCancel (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlRecover (string senderProject, string senderName, anytype buffer) |
|
private void | _fwRPC_broker_hdlListServices (string senderProject, string senderName, string buffer) |
|
private int | _getNextServiceProvider (string service, dyn_string &node) |
|
This library contains functionality for the broker in a distributed RPC system.
- Author
- Victor Rodrigues (CERN, BE-ICS-SDS)
private global mapping _g_fwRPC_broker_pendingCalls |
Mapping of pending calls. New client requests are appended to this collection, signifying that they have not yet received indication that the core has processed it. The broker will wait for _fwRPC_BROKER_CORE_EXPIRE_TIME_S seconds before attempting to reassign the call to a new core.
Once the broker receives a status update for the given call, the call will be removed from this mapping.
key: call hdl value: call packet (fwRPC_DISTMSG_REQUEST_*) with expire timestamp at index 4