riaps.run package
Submodules
- riaps.run.actor module
- riaps.run.ansPort module
AnsPortAnsPort.ans_port_recv()AnsPort.ans_port_send()AnsPort.closeSocket()AnsPort.getInfo()AnsPort.getSocket()AnsPort.get_identity()AnsPort.inSocket()AnsPort.recv()AnsPort.recv_pyobj()AnsPort.reset()AnsPort.send()AnsPort.send_pyobj()AnsPort.set_identity()AnsPort.setup()AnsPort.setupSocket()AnsPort.update()
- riaps.run.cltPort module
- riaps.run.comp module
ComponentComponent.GROUP_PRIORITY_MAXComponent.GROUP_PRIORITY_MINComponent.getActorID()Component.getActorName()Component.getAppName()Component.getLocalID()Component.getName()Component.getTypeName()Component.getUUID()Component.handleActionVoteRequest()Component.handleActivate()Component.handleCPULimit()Component.handleDeactivate()Component.handleDeadline()Component.handleGroupMessage()Component.handleLeaderElected()Component.handleLeaderExited()Component.handleMemLimit()Component.handleMemberJoined()Component.handleMemberLeft()Component.handleMessageFromLeader()Component.handleMessageToLeader()Component.handleNICStateChange()Component.handleNetLimit()Component.handlePassivate()Component.handlePeerStateChange()Component.handleSpcLimit()Component.handleVoteRequest()Component.handleVoteResult()Component.joinGroup()Component.leaveGroup()
ComponentThreadComponentThread.addGroupSocket()ComponentThread.batchScheduler()ComponentThread.delGroupSocket()ComponentThread.executeHandlerFor()ComponentThread.getInfo()ComponentThread.logEvent()ComponentThread.priorityScheduler()ComponentThread.replaceSocket()ComponentThread.rrScheduler()ComponentThread.run()ComponentThread.runCommand()ComponentThread.sendControl()ComponentThread.setupControl()ComponentThread.setupPoller()ComponentThread.setupScheduler()ComponentThread.setupSockets()
- riaps.run.dc module
CoordinatorGroupGroup.GROUP_ACKGroup.GROUP_ANNGroup.GROUP_ERRGroup.GROUP_LELGroup.GROUP_LEXGroup.GROUP_MFLGroup.GROUP_MJDGroup.GROUP_MLTGroup.GROUP_MSGGroup.GROUP_MTLGroup.GROUP_NLDGroup.GROUP_PARAMETERSGroup.GROUP_RCMGroup.GROUP_RFVGroup.GROUP_RTCGroup.GROUP_UPDGroup.getGroupId()Group.getGroupName()Group.getLeaderId()Group.getSocket()Group.groupSize()Group.groupSocketName()Group.handleMessage()Group.hasLeader()Group.isLeader()Group.leave()Group.recv()Group.recv_msg()Group.recv_pyobj()Group.requestActionVote()Group.requestActionVote_pyobj()Group.requestVote()Group.requestVote_pyobj()Group.send()Group.sendActionVote()Group.sendToLeader()Group.sendToLeader_pyobj()Group.sendToMember()Group.sendToMember_pyobj()Group.sendVote()Group.send_port()Group.send_pyobj()Group.setup()Group.setupParams()Group.unsetup()Group.update()
GroupThreadGroupThread.AUTHORITYGroupThread.CANDIDATEGroupThread.FOLLOWERGroupThread.HEARTBEATGroupThread.LEADERGroupThread.NO_LEADERGroupThread.REQVOTEGroupThread.RSPVOTEGroupThread.announceConsensus()GroupThread.checkAllPolls()GroupThread.checkPoll()GroupThread.electionTimeout()GroupThread.getOwnId()GroupThread.handleCompMessage()GroupThread.handleMessageForLeader()GroupThread.handleMessageForMember()GroupThread.handleNetMessage()GroupThread.handleTimeout()GroupThread.heartbeat()GroupThread.isLeader()GroupThread.run()GroupThread.sendChangeMessage()GroupThread.setLeaderDeadline()GroupThread.setTimeout()GroupThread.setup()GroupThread.startPoll()GroupThread.threshold()GroupThread.updatePeers()GroupThread.updatePoll()GroupThread.updateTimeout()
Poll
- riaps.run.dcPorts module
GroupAnsPortGroupAnsPort.closeSocket()GroupAnsPort.getInfo()GroupAnsPort.getPortNumber()GroupAnsPort.getSocket()GroupAnsPort.get_identity()GroupAnsPort.inSocket()GroupAnsPort.recv()GroupAnsPort.recvFromMember()GroupAnsPort.recv_pyobj()GroupAnsPort.reset()GroupAnsPort.send()GroupAnsPort.sendToMember()GroupAnsPort.send_pyobj()GroupAnsPort.set_identity()GroupAnsPort.setup()GroupAnsPort.setupSocket()GroupAnsPort.update()GroupAnsPort.updatePoller()
GroupDuplexPortGroupPubPortGroupPubPort.closeSocket()GroupPubPort.getInfo()GroupPubPort.getSocket()GroupPubPort.inSocket()GroupPubPort.recv()GroupPubPort.recv_pyobj()GroupPubPort.reset()GroupPubPort.send()GroupPubPort.sendGroup()GroupPubPort.send_pyobj()GroupPubPort.setup()GroupPubPort.setupSocket()GroupPubPort.update()
GroupQryPortGroupQryPort.closeSocket()GroupQryPort.getInfo()GroupQryPort.getSocket()GroupQryPort.inSocket()GroupQryPort.recv()GroupQryPort.recvFromLeader()GroupQryPort.recv_pyobj()GroupQryPort.reset()GroupQryPort.send()GroupQryPort.sendToLeader()GroupQryPort.send_pyobj()GroupQryPort.setup()GroupQryPort.setupSocket()GroupQryPort.update()
GroupSimplexPortGroupSubPort
- riaps.run.deplc module
- riaps.run.device module
- riaps.run.disco module
DiscoClientDiscoClient.handleLookupReq()DiscoClient.handleRegReq()DiscoClient.handleUnlookupReq()DiscoClient.handleUnregReq()DiscoClient.reconnect()DiscoClient.recvFromDisco()DiscoClient.registerActor()DiscoClient.registerEndpoint()DiscoClient.registerGroup()DiscoClient.rpcDisco()DiscoClient.sendToDisco()DiscoClient.start()DiscoClient.terminate()DiscoClient.unregisterGroup()
- riaps.run.dmain module
- riaps.run.exc module
- riaps.run.fsm module
- riaps.run.insPort module
InsPortInsPort.activate()InsPort.deactivate()InsPort.getContext()InsPort.getInfo()InsPort.getSocket()InsPort.get_identity()InsPort.get_plug_identity()InsPort.inSocket()InsPort.ins_port_recv()InsPort.ins_port_send()InsPort.recv()InsPort.recv_pyobj()InsPort.reset()InsPort.send()InsPort.send_pyobj()InsPort.set_identity()InsPort.setup()InsPort.setupPlug()InsPort.setupSocket()InsPort.terminate()
- riaps.run.main module
- riaps.run.part module
PartPart.StatePart.activate()Part.buildAllPorts()Part.buildPorts()Part.checkpoint()Part.deactivate()Part.destroy()Part.getActorID()Part.getActorName()Part.getAppName()Part.getName()Part.getTypeName()Part.getUUID()Part.handleCPULimit()Part.handleMemLimit()Part.handleNICStateChange()Part.handleNetLimit()Part.handlePeerStateChange()Part.handlePortUpdate()Part.handleReinstate()Part.handleSpcLimit()Part.load()Part.modsPart.passivate()Part.reactivate()Part.sendControl()Part.setup()Part.setupPorts()Part.terminate()
- riaps.run.peripheral module
PeripheralPeripheral.StatePeripheral.activate()Peripheral.checkpoint()Peripheral.deactivate()Peripheral.destroy()Peripheral.getControl()Peripheral.handleCPULimit()Peripheral.handleMemLimit()Peripheral.handleNICStateChange()Peripheral.handleNetLimit()Peripheral.handlePeerStateChange()Peripheral.handlePortUpdate()Peripheral.handleReinstate()Peripheral.handleSpcLimit()Peripheral.modsPeripheral.passivate()Peripheral.reactivate()Peripheral.setup()Peripheral.terminate()
- riaps.run.port module
BindPortConnPortDuplexBindPortDuplexConnPortDuplexPortPortPort.activate()Port.closeSocket()Port.deactivate()Port.getDeadline()Port.getGlobalIface()Port.getIndex()Port.getInfo()Port.getLocalIface()Port.getSocket()Port.get_hwm()Port.get_recvTime()Port.get_recv_timeout()Port.get_sendTime()Port.get_send_timeout()Port.inSocket()Port.port_recv()Port.port_send()Port.recv()Port.recv_capnp()Port.recv_pyobj()Port.reset()Port.send()Port.send_capnp()Port.send_pyobj()Port.setOwner()Port.set_recv_timeout()Port.set_send_timeout()Port.set_sockoptions()Port.setup()Port.setupCurve()Port.setupSocket()Port.terminate()Port.update()
PortInfoPortScopeSimplexBindPortSimplexConnPortSimplexPort
- riaps.run.pubPort module
- riaps.run.qryPort module
- riaps.run.repPort module
- riaps.run.reqPort module
- riaps.run.srvPort module
- riaps.run.subPort module
- riaps.run.timPort module
TimPortTimPort.activate()TimPort.cancel()TimPort.deactivate()TimPort.getDelay()TimPort.getInfo()TimPort.getPeriod()TimPort.getSocket()TimPort.halt()TimPort.inSocket()TimPort.launch()TimPort.recv()TimPort.recv_pyobj()TimPort.reset()TimPort.running()TimPort.send()TimPort.send_pyobj()TimPort.setDelay()TimPort.setPeriod()TimPort.setup()TimPort.setupSocket()TimPort.terminate()
TimerThread