|
void | fwRPC_broker_initialize () |
|
private void | _fwRPC_broker_beginTick () |
|
private void | _fwRPC_broker_dbg_report () |
|
public synchronized void | fwRPC_broker_newMbxCB (string project, string name) |
|
public synchronized void | fwRPC_broker_sys_drop (string project) |
|
public synchronized void | _fwRPC_broker_dropCore (string project, string name="") |
|
public synchronized void | _fwRPC_broker_dropClient (string project, string name="") |
|
public void | _fwRPC_broker_hdlDisconnect (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlRequest (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlStatus (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlGetResult (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlSetResult (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlRegister (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlAcknowledge (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlCancel (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlRecover (string senderProject, string senderName, anytype buffer) |
|
public void | _fwRPC_broker_hdlListServices (string senderProject, string senderName, string buffer) |
|
public 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