dragon.infrastructure.messages

Dragon infrastructure messages are the internal API used for service communication.

Functions

`camel_case_msg_name`(msg_id)
`mk_all_message_classes_set`()
`parse`(serialized[, restrict])
`type_filter`(the_msg_types)

Classes

`AbnormalTermination`	Refer to definition and Common Fields for a description of the message structure.
`BEHaltOverlay`	Refer to definition and Common Fields for a description of the message structure.
`BEHalted`	Refer to definition and Common Fields for a description of the message structure.
`BEIsUp`	Refer to definition and Common Fields for a description of the message structure.
`BENodeIdxSH`	Refer to definition and Common Fields for a description of the message structure.
`BEPingSH`	Refer to definition and Common Fields for a description of the message structure.
`Breakpoint`
`CapNProtoMsg`	Common base for all capnproto messages.
`CapNProtoResponseMsg`	Common base for all capnproto response messages.
`DDClear`
`DDClearResponse`
`DDConnectToManager`
`DDConnectToManagerResponse`
`DDContains`
`DDContainsResponse`
`DDCreate`
`DDCreateResponse`
`DDDeregisterClient`
`DDDeregisterClientResponse`
`DDDestroy`
`DDDestroyManager`
`DDDestroyManagerResponse`
`DDDestroyResponse`
`DDGet`
`DDGetIterator`
`DDGetIteratorResponse`
`DDGetLength`
`DDGetLengthResponse`
`DDGetRandomManager`
`DDGetRandomManagerResponse`
`DDGetResponse`
`DDIteratorNext`
`DDIteratorNextResponse`
`DDKeys`
`DDKeysResponse`
`DDPop`
`DDPopResponse`
`DDPut`
`DDPutResponse`
`DDRegisterClient`
`DDRegisterClientID`
`DDRegisterClientIDResponse`
`DDRegisterClientResponse`
`DDRegisterManager`
`DDRegisterManagerResponse`
`ExceptionlessAbort`	Refer to definition and Common Fields for a description of the message structure.
`FENodeIdxBE`	Refer to definition and Common Fields for a description of the message structure.
`FileDescriptor`	An enumeration.
`GSChannelCreate`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelCreateResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelDestroy`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelDestroyResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelDetach`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelDetachResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelGetRecvH`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelGetRecvHResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelGetSendH`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelGetSendHResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelJoin`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelJoinResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelList`	Refer to definition and to Common Fields for a description of the message structure.
`GSChannelListResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelQuery`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelQueryResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSChannelRelease`	Refer to definition and Common Fields for a description of the message structure.
`GSDumpState`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupAddTo`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupAddToResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupCreate`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupCreateAddTo`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupCreateAddToResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupCreateResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupDestroy`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupDestroyRemoveFrom`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupDestroyRemoveFromResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupDestroyResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupKill`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupKillResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupList`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupListResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupQuery`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupQueryResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupRemoveFrom`	Refer to definition and Common Fields for a description of the message structure.
`GSGroupRemoveFromResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSHalted`	Refer to definition and Common Fields for a description of the message structure.
`GSHeadExit`	Refer to definition and Common Fields for a description of the message structure.
`GSIsUp`	Refer to definition and Common Fields for a description of the message structure.
`GSNodeList`	type enum
`GSNodeListResponse`	type enum
`GSNodeQuery`	Refer to definition and Common Fields for a description of the message structure.
`GSNodeQueryResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSNodeQueryTotalCPUCount`	type enum
`GSNodeQueryTotalCPUCountResponse`	type enum
`GSPingProc`	Refer to definition and Common Fields for a description of the message structure.
`GSPingSH`	Refer to definition and Common Fields for a description of the message structure.
`GSPoolCreate`	Refer to definition and Common Fields for a description of the message structure.
`GSPoolCreateResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSPoolDestroy`	Refer to definition and Common Fields for a description of the message structure.
`GSPoolDestroyResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSPoolList`	Refer to definition and Common Fields for a description of the message structure.
`GSPoolListResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSPoolQuery`	Refer to definition and Common Fields for a description of the message structure.
`GSPoolQueryResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessCreate`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessCreateResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessJoin`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessJoinList`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessJoinListResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessJoinResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessKill`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessKillResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessList`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessListResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessQuery`	Refer to definition and Common Fields for a description of the message structure.
`GSProcessQueryResponse`	Refer to definition and Common Fields for a description of the message structure.
`GSStarted`	Refer to definition and Common Fields for a description of the message structure.
`GSTeardown`	Refer to definition and Common Fields for a description of the message structure.
`GSUnexpected`	Refer to definition and Common Fields for a description of the message structure.
`HaltLoggingInfra`	Refer to definition and Common Fields for a description of the message structure.
`HaltOverlay`	Refer to definition and Common Fields for a description of the message structure.
`InfraMsg`	Common base for all messages.
`LABroadcast`	Refer to definition and Common Fields for a description of the message structure.
`LAChannelsInfo`	Refer to definition and Common Fields for a description of the message structure.
`LADumpState`	Refer to definition and Common Fields for a description of the message structure.
`LAExit`	Refer to definition and Common Fields for a description of the message structure.
`LAHaltOverlay`	Refer to definition and Common Fields for a description of the message structure.
`LAPassThruBF`	Refer to definition and Common Fields for a description of the message structure.
`LAPassThruFB`	Refer to definition and Common Fields for a description of the message structure.
`LAProcessDict`	Refer to definition and Common Fields for a description of the message structure.
`LAProcessDictResponse`	Refer to definition and Common Fields for a description of the message structure.
`LAServerMode`	Refer to definition and Common Fields for a description of the message structure.
`LAServerModeExit`	Refer to definition and Common Fields for a description of the message structure.
`LogFlushed`	Refer to definition and Common Fields for a description of the message structure.
`LoggingMsg`	Refer to definition and Common Fields for a description of the message structure.
`LoggingMsgList`	Refer to definition and Common Fields for a description of the message structure.
`MessageTypes`	These are the enumerated values of message type identifiers within the Dragon infrastructure messages.
`OverlayHalted`	Refer to definition and Common Fields for a description of the message structure.
`OverlayPingBE`	Refer to definition and Common Fields for a description of the message structure.
`OverlayPingLA`	Refer to definition and Common Fields for a description of the message structure.
`PMIGroupInfo`	Required information to enable the launching of pmi based applications.
`PMIProcessInfo`	Required information to enable the launching of pmi based applications.
`RuntimeDesc`	Refer to definition and Common Fields for a description of the message structure.
`SHAllocBlock`	Refer to definition and Common Fields for a description of the message structure.
`SHAllocBlockResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHAllocMsg`	Refer to definition and Common Fields for a description of the message structure.
`SHAllocMsgResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHChannelCreate`	Refer to definition and Common Fields for a description of the message structure.
`SHChannelCreateResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHChannelDestroy`	Refer to definition and Common Fields for a description of the message structure.
`SHChannelDestroyResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHChannelsUp`	Refer to definition and Common Fields for a description of the message structure.
`SHCreateProcessLocalChannel`
`SHCreateProcessLocalChannelResponse`
`SHDumpState`	Refer to definition and Common Fields for a description of the message structure.
`SHExecMemRequest`	Refer to definition and Common Fields for a description of the message structure.
`SHExecMemResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHFwdInput`	Refer to definition and Common Fields for a description of the message structure.
`SHFwdInputErr`	Refer to definition and Common Fields for a description of the message structure.
`SHFwdOutput`	Refer to definition and Common Fields for a description of the message structure.
`SHGetKV`
`SHGetKVL`
`SHGetKVLResponse`
`SHGetKVResponse`
`SHHaltBE`	Refer to definition and Common Fields for a description of the message structure.
`SHHaltTA`	Refer to definition and Common Fields for a description of the message structure.
`SHHalted`	Refer to definition and Common Fields for a description of the message structure.
`SHLockChannel`	Refer to definition and Common Fields for a description of the message structure.
`SHLockChannelResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHMultiProcessCreate`
`SHMultiProcessCreateResponse`
`SHPingBE`	Refer to definition and Common Fields for a description of the message structure.
`SHPingGS`	Refer to definition and Common Fields for a description of the message structure.
`SHPoolCreate`	Refer to definition and Common Fields for a description of the message structure.
`SHPoolCreateResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHPoolDestroy`	Refer to definition and to the Common Fields for a description of the message structure.
`SHPoolDestroyResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHPopKVL`
`SHPopKVLResponse`
`SHProcessCreate`	Refer to definition and Common Fields for a description of the message structure.
`SHProcessCreateResponse`	Refer to definition and Common Fields for a description of the message structure.
`SHProcessExit`	Refer to definition and to Common Fields for a description of the message structure.
`SHProcessKill`	Refer to definition and Common Fields for a description of the message structure.
`SHProcessKillResponse`
`SHPushKVL`
`SHPushKVLResponse`
`SHSetKV`
`SHSetKVResponse`
`SHTeardown`	Refer to definition and Common Fields for a description of the message structure.
`TAHalted`	Refer to definition and Common Fields for a description of the message structure.
`TAPingSH`	Refer to definition and Common Fields for a description of the message structure.
`TAUp`	Refer to definition and Common Fields for a description of the message structure.
`TAUpdateNodes`	Refer to definition and Common Fields for a description of the message structure.
`UserHaltOOB`	Refer to definition and Common Fields for a description of the message structure.

Exceptions

AbnormalTerminationError

class MessageTypes

These are the enumerated values of message type identifiers within the Dragon infrastructure messages.

DRAGON_MSG = 0: Deliberately invalid

GS_PROCESS_CREATE = 1

GS_PROCESS_CREATE_RESPONSE = 2

GS_PROCESS_LIST = 3

GS_PROCESS_LIST_RESPONSE = 4

GS_PROCESS_QUERY = 5

GS_PROCESS_QUERY_RESPONSE = 6

GS_PROCESS_KILL = 7

GS_PROCESS_KILL_RESPONSE = 8

GS_PROCESS_JOIN = 9

GS_PROCESS_JOIN_RESPONSE = 10

GS_CHANNEL_CREATE = 11

GS_CHANNEL_CREATE_RESPONSE = 12

GS_CHANNEL_LIST = 13

GS_CHANNEL_LIST_RESPONSE = 14

GS_CHANNEL_QUERY = 15

GS_CHANNEL_QUERY_RESPONSE = 16

GS_CHANNEL_DESTROY = 17

GS_CHANNEL_DESTROY_RESPONSE = 18

GS_CHANNEL_JOIN = 19

GS_CHANNEL_JOIN_RESPONSE = 20

GS_CHANNEL_DETACH = 21

GS_CHANNEL_DETACH_RESPONSE = 22

GS_CHANNEL_GET_SENDH = 23

GS_CHANNEL_GET_SENDH_RESPONSE = 24

GS_CHANNEL_GET_RECVH = 25

GS_CHANNEL_GET_RECVH_RESPONSE = 26

ABNORMAL_TERMINATION = 27

GS_STARTED = 28

GS_PING_SH = 29

GS_IS_UP = 30

GS_HEAD_EXIT = 31

GS_CHANNEL_RELEASE = 32

GS_HALTED = 33

SH_PROCESS_CREATE = 34

SH_PROCESS_CREATE_RESPONSE = 35

SH_MULTI_PROCESS_CREATE = 36

SH_MULTI_PROCESS_CREATE_RESPONSE = 37

SH_PROCESS_KILL = 38

SH_PROCESS_EXIT = 39

SH_CHANNEL_CREATE = 40

SH_CHANNEL_CREATE_RESPONSE = 41

SH_CHANNEL_DESTROY = 42

SH_CHANNEL_DESTROY_RESPONSE = 43

SH_LOCK_CHANNEL = 44

SH_LOCK_CHANNEL_RESPONSE = 45

SH_ALLOC_MSG = 46

SH_ALLOC_MSG_RESPONSE = 47

SH_ALLOC_BLOCK = 48

SH_ALLOC_BLOCK_RESPONSE = 49

SH_CHANNELS_UP = 50

SH_PING_GS = 51

SH_HALTED = 52

SH_FWD_INPUT = 53

SH_FWD_INPUT_ERR = 54

SH_FWD_OUTPUT = 55

GS_TEARDOWN = 56

SH_TEARDOWN = 57

SH_PING_BE = 58

BE_PING_SH = 59

TA_PING_SH = 60

SH_HALT_TA = 61

TA_HALTED = 62

SH_HALT_BE = 63

BE_HALTED = 64

TA_UP = 65

GS_PING_PROC = 66

GS_DUMP_STATE = 67

SH_DUMP_STATE = 68

LA_BROADCAST = 69

LA_PASS_THRU_FB = 70

LA_PASS_THRU_BF = 71

GS_POOL_CREATE = 72

GS_POOL_CREATE_RESPONSE = 73

GS_POOL_DESTROY = 74

GS_POOL_DESTROY_RESPONSE = 75

GS_POOL_LIST = 76

GS_POOL_LIST_RESPONSE = 77

GS_POOL_QUERY = 78

GS_POOL_QUERY_RESPONSE = 79

SH_POOL_CREATE = 80

SH_POOL_CREATE_RESPONSE = 81

SH_POOL_DESTROY = 82

SH_POOL_DESTROY_RESPONSE = 83

SH_CREATE_PROCESS_LOCAL_CHANNEL = 84

SH_CREATE_PROCESS_LOCAL_CHANNEL_RESPONSE = 85

SH_PUSH_KVL = 86

SH_PUSH_KVL_RESPONSE = 87

SH_POP_KVL = 88

SH_POP_KVL_RESPONSE = 89

SH_GET_KVL = 90

SH_GET_KVL_RESPONSE = 91

SH_SET_KV = 92

SH_EXEC_MEM_REQUEST = 96

SH_EXEC_MEM_RESPONSE = 97

GS_UNEXPECTED = 98

LA_SERVER_MODE = 99

LA_SERVER_MODE_EXIT = 100

LA_PROCESS_DICT = 101

LA_PROCESS_DICT_RESPONSE = 102

LA_DUMP_STATE = 103

BE_NODE_IDX_SH = 104

LA_CHANNELS_INFO = 105

SH_PROCESS_KILL_RESPONSE = 106

BREAKPOINT = 107

GS_PROCESS_JOIN_LIST = 108

GS_PROCESS_JOIN_LIST_RESPONSE = 109

GS_NODE_QUERY = 110

GS_NODE_QUERY_RESPONSE = 111

LOGGING_MSG = 112

LOGGING_MSG_LIST = 113

LOG_FLUSHED = 114

GS_NODE_LIST = 115

GS_NODE_LIST_RESPONSE = 116

GS_NODE_QUERY_TOTAL_CPU_COUNT = 117

GS_NODE_QUERY_TOTAL_CPU_COUNT_RESPONSE = 118

BE_IS_UP = 119

FE_NODE_IDX_BE = 120

HALT_OVERLAY = 121

HALT_LOGGING_INFRA = 122

OVERLAY_PING_BE = 123

OVERLAY_PING_LA = 124

LA_HALT_OVERLAY = 125

BE_HALT_OVERLAY = 126

OVERLAY_HALTED = 127

EXCEPTIONLESS_ABORT = 128: Communicate abnormal termination without raising exception

LA_EXIT = 129

GS_GROUP_LIST = 130

GS_GROUP_LIST_RESPONSE = 131

GS_GROUP_QUERY = 132

GS_GROUP_QUERY_RESPONSE = 133

GS_GROUP_DESTROY = 134

GS_GROUP_DESTROY_RESPONSE = 135

GS_GROUP_ADD_TO = 136

GS_GROUP_ADD_TO_RESPONSE = 137

GS_GROUP_REMOVE_FROM = 138

GS_GROUP_REMOVE_FROM_RESPONSE = 139

GS_GROUP_CREATE = 140

GS_GROUP_CREATE_RESPONSE = 141

GS_GROUP_KILL = 142

GS_GROUP_KILL_RESPONSE = 143

GS_GROUP_CREATE_ADD_TO = 144

GS_GROUP_CREATE_ADD_TO_RESPONSE = 145

GS_GROUP_DESTROY_REMOVE_FROM = 146

GS_GROUP_DESTROY_REMOVE_FROM_RESPONSE = 147

TA_UPDATE_NODES = 148

RUNTIME_DESC = 149

USER_HALT_OOB = 150

DD_REGISTER_CLIENT = 151

DD_REGISTER_CLIENT_RESPONSE = 152

DD_DESTROY = 153

DD_DESTROY_RESPONSE = 154

DD_REGISTER_MANAGER = 155

DD_REGISTER_MANAGER_RESPONSE = 156

DD_REGISTER_CLIENT_ID = 157

DD_REGISTER_CLIENT_ID_RESPONSE = 158

DD_DESTROY_MANAGER = 159

DD_DESTROY_MANAGER_RESPONSE = 160

DD_PUT = 161

DD_PUT_RESPONSE = 162

DD_GET = 163

DD_GET_RESPONSE = 164

DD_POP = 165

DD_POP_RESPONSE = 166

DD_CONTAINS = 167

DD_CONTAINS_RESPONSE = 168

DD_GET_LENGTH = 169

DD_GET_LENGTH_RESPONSE = 170

DD_CLEAR = 171

DD_CLEAR_RESPONSE = 172

DD_GET_ITERATOR = 173

DD_GET_ITERATOR_RESPONSE = 174

DD_ITERATOR_NEXT = 175

DD_ITERATOR_NEXT_RESPONSE = 176

DD_KEYS = 177

DD_KEYS_RESPONSE = 178

DD_DEREGISTER_CLIENT = 179

DD_DEREGISTER_CLIENT_RESPONSE = 180

DD_CREATE = 181

DD_CREATE_RESPONSE = 182

DD_CONNECT_TO_MANAGER = 183

DD_CONNECT_TO_MANAGER_RESPONSE = 184

DD_GET_RANDOM_MANAGER = 185

DD_GET_RANDOM_MANAGER_RESPONSE = 186

class FileDescriptor: An enumeration.

exception AbnormalTerminationError

__init__(msg='')

class PMIGroupInfo

Required information to enable the launching of pmi based applications.

__init__(job_id: int, nnodes: int, nranks: int, nidlist: list[int], hostlist: list[str], control_port: int) → None

class PMIProcessInfo

Required information to enable the launching of pmi based applications.

__init__(lrank: int, ppn: int, nid: int, pid_base: int) → None

class InfraMsg

Common base for all messages.

This common base type for all messages sets up the default fields and the serialization strategy for now.

class Errors: An enumeration.

__init__(tag, ref=None, err=None)

class CapNProtoMsg

Common base for all capnproto messages.

This common base type for all messages sets up the default fields and the serialization strategy for messages to be exchanged between C and Python.

Errors: alias of DragonError

__init__(tag)

class CapNProtoResponseMsg

Common base for all capnproto response messages.

This provides some support for code common to all response messages.

__init__(tag, ref, err, errInfo)

class SHCreateProcessLocalChannel

__init__(tag, puid, respFLI)

class SHCreateProcessLocalChannelResponse

__init__(tag, ref, err, errInfo='', serChannel='')

class SHPushKVL

__init__(tag, key, value, respFLI)

class SHPushKVLResponse

__init__(tag, ref, err, errInfo='')

class SHPopKVL

__init__(tag, key, value, respFLI)

class SHPopKVLResponse

__init__(tag, ref, err, errInfo='')

class SHGetKVL

__init__(tag, key, respFLI)

class SHGetKVLResponse

__init__(tag, ref, err, errInfo='', values=[])

class SHSetKV

__init__(tag, key, value, respFLI)

class SHSetKVResponse

__init__(tag, ref, err, errInfo='')

class SHGetKV

__init__(tag, key, respFLI)

class SHGetKVResponse

__init__(tag, ref, err, errInfo='', value=None)

class DDCreate

__init__(tag, respFLI, args)

class DDCreateResponse

__init__(tag, ref, err, errInfo='')

class DDGetRandomManager

__init__(tag, respFLI)

class DDGetRandomManagerResponse

__init__(tag, ref, err, manager, errInfo='')

class DDRegisterClient

__init__(tag, respFLI, bufferedRespFLI)

class DDRegisterClientResponse

__init__(tag, ref, err, clientID, numManagers, errInfo='')

class DDConnectToManager

__init__(tag, clientID, managerID)

class DDConnectToManagerResponse

__init__(tag, ref, err, manager, errInfo='')

class DDDestroy

__init__(tag, clientID, respFLI)

class DDDestroyResponse

__init__(tag, ref, err, errInfo='')

class DDRegisterManager

__init__(tag, mainFLI, respFLI)

class DDRegisterManagerResponse

__init__(tag, ref, err, managerID, errInfo='', managers=[])

class DDRegisterClientID

__init__(tag, clientID, respFLI, bufferedRespFLI)

class DDRegisterClientIDResponse

__init__(tag, ref, err, errInfo='')

class DDDestroyManager

__init__(tag, respFLI)

class DDDestroyManagerResponse

__init__(tag, ref, err, errInfo='')

class DDPut

__init__(tag, clientID)

class DDPutResponse

__init__(tag, ref, err, errInfo='')

class DDGet

__init__(tag, clientID)

class DDGetResponse

__init__(tag, ref, err, errInfo='')

class DDPop

__init__(tag, clientID)

class DDPopResponse

__init__(tag, ref, err, errInfo='')

class DDContains

__init__(tag, clientID)

class DDContainsResponse

__init__(tag, ref, err, errInfo='')

class DDGetLength

__init__(tag, clientID)

class DDGetLengthResponse

__init__(tag, ref, err, errInfo='', length=0)

class DDClear

__init__(tag, clientID)

class DDClearResponse

__init__(tag, ref, err, errInfo='')

class DDGetIterator

__init__(tag, clientID)

class DDGetIteratorResponse

__init__(tag, ref, err, errInfo='', iterID=0)

class DDIteratorNext

__init__(tag, clientID, iterID)

class DDIteratorNextResponse

__init__(tag, ref, err, errInfo='')

class DDKeys

__init__(tag, clientID)

class DDKeysResponse

__init__(tag, ref, err, errInfo='')

class DDDeregisterClient

__init__(tag, clientID, respFLI)

class DDDeregisterClientResponse

__init__(tag, ref, err, errInfo='')

class GSProcessCreate

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, exe, args, env=None, rundir='', user_name='', options=None, stdin=None, stdout=None, stderr=None, group=None, user=None, umask=-1, pipesize=None, pmi_required=False, _pmi_info=None, layout=None, policy=None, _tc=None)

class GSProcessCreateResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0: Process was created

FAIL = 1: Process was not created

ALREADY = 2: Process exists already

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class GSProcessList

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, _tc=None)

class GSProcessListResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0: Always succeeds

__init__(tag, ref, err, plist=None, _tc=None)

class GSProcessQuery

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, t_p_uid=None, user_name='', _tc=None)

class GSProcessQueryResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class GSProcessKill

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, sig, t_p_uid=None, user_name='', _tc=None)

class GSProcessKillResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

FAIL_KILL = 2

DEAD = 3

PENDING = 4

__init__(tag, ref, err, exit_code=0, err_info='', _tc=None)

class GSProcessJoin

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, timeout=-1, t_p_uid=None, user_name='', _tc=None)

class GSProcessJoinResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

TIMEOUT = 2

SELF = 3

__init__(tag, ref, err, exit_code=0, err_info='', _tc=None)

class GSProcessJoinList

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, timeout=-1, t_p_uid_list=None, user_name_list=None, join_all=False, return_on_bad_exit=False, _tc=None)

class GSProcessJoinListResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

TIMEOUT = 2

SELF = 3

PENDING = 4

__init__(tag, ref, puid_status, _tc=None)

class GSPoolCreate

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, size, user_name='', options=None, _tc=None)

class GSPoolCreateResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0: Pool was created

FAIL = 1: Pool was not created

ALREADY = 2: Pool exists already

__init__(tag, ref, err, err_code=0, desc=None, err_info='', _tc=None)

class GSPoolList

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, _tc=None)

class GSPoolListResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0: Always succeeds

__init__(tag, ref, err, mlist=None, _tc=None)

class GSPoolQuery

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, m_uid=None, user_name='', _tc=None)

class GSPoolQueryResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class GSPoolDestroy

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, m_uid=0, user_name='', _tc=None)

class GSPoolDestroyResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

FAIL = 2

GONE = 3

PENDING = 4

__init__(tag, ref, err, err_code=0, err_info='', _tc=None)

class GSGroupCreate

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, items=None, policy=None, user_name='', _tc=None)

class GSGroupCreateResponse

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, ref, desc=None, _tc=None)

class GSGroupList

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, _tc=None)

class GSGroupListResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0: Always succeeds

__init__(tag, ref, err, glist=None, _tc=None)

class GSGroupQuery

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, g_uid=None, user_name='', _tc=None)

class GSGroupQueryResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class GSGroupKill

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, sig, g_uid=None, user_name='', _tc=None)

class GSGroupKillResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

DEAD = 2

PENDING = 3

ALREADY = 4

__init__(tag, ref, err, err_info='', desc=None, _tc=None)

class GSGroupDestroy

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, g_uid=None, user_name='', _tc=None)

class GSGroupDestroyResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

DEAD = 3

PENDING = 4

__init__(tag, ref, err, err_info='', desc=None, _tc=None)

class GSGroupAddTo

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, g_uid=None, user_name='', items=None, _tc=None)

class GSGroupAddToResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

FAIL = 2

DEAD = 3

PENDING = 4

__init__(tag, ref, err, err_info='', desc=None, _tc=None)

class GSGroupCreateAddTo

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, g_uid=None, user_name='', items=None, policy=None, _tc=None)

class GSGroupCreateAddToResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

DEAD = 2

PENDING = 3

__init__(tag, ref, err, err_info='', desc=None, _tc=None)

class GSGroupRemoveFrom

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, g_uid=None, user_name='', items=None, _tc=None)

class GSGroupRemoveFromResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

FAIL = 2

DEAD = 3

PENDING = 4

__init__(tag, ref, err, err_info='', desc=None, _tc=None)

class GSGroupDestroyRemoveFrom

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, g_uid=None, user_name='', items=None, _tc=None)

class GSGroupDestroyRemoveFromResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

FAIL = 2

DEAD = 3

PENDING = 4

__init__(tag, ref, err, err_info='', desc=None, _tc=None)

class GSChannelCreate

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, m_uid, options=None, user_name='', _tc=None)

class GSChannelCreateResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

FAIL = 1

ALREADY = 2

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class GSChannelList

Refer to definition and to Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, _tc=None)

class GSChannelListResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0: Always succeeds

__init__(tag, ref, err, clist=None, _tc=None)

class GSChannelQuery

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, c_uid=None, user_name='', inc_refcnt=False, _tc=None)

class GSChannelQueryResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class GSChannelDestroy

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, c_uid=None, user_name='', reply_req=True, dec_ref=False, _tc=None)

class GSChannelDestroyResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

UNKNOWN_CHANNEL = 2

BUSY = 3

__init__(tag, ref, err, err_info='', _tc=None)

class GSChannelJoin

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, name, timeout=-1, _tc=None)

class GSChannelJoinResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

TIMEOUT = 1

DEAD = 2

__init__(tag, ref, err, desc=None, _tc=None)

class GSChannelDetach

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, c_uid, _tc=None)

class GSChannelDetachResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

UNKNOWN_CHANNEL = 2

NOT_ATTACHED = 3

__init__(tag, ref, err, _tc=None)

class GSChannelGetSendH

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, c_uid, _tc=None)

class GSChannelGetSendHResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

UNKNOWN_CHANNEL = 2

NOT_ATTACHED = 3

CANT = 4

__init__(tag, ref, err, sendh=None, err_info='', _tc=None)

class GSChannelGetRecvH

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, c_uid, _tc=None)

class GSChannelGetRecvHResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

UNKNOWN_CHANNEL = 2

NOT_ATTACHED = 3

CANT = 4

__init__(tag, ref, err, recvh=None, err_info='', _tc=None)

class GSNodeList

type enum: GS_NODE_LIST (= 102)
purpose: Return a list of tuples of h_uid for all nodes currently registered.
fields: None additional
response: GSNodeListResponse
see also: GSNodeQuery
see also: refer to the Common Fields section for additional request message fields

__init__(tag, p_uid, r_c_uid, _tc=None)

class GSNodeListResponse

type enum

GS_NODE_LIST_RESPONSE (= 103)

purpose

Responds with a list of h_uid for all the nodes currently registered.

fields

hlist

list of nonnegative integers

request

GSNodeList

see also

GSNodeQuery

class Errors

An enumeration.

SUCCESS = 0: Always succeeds

__init__(tag, ref, err, hlist=None, _tc=None)

class GSNodeQuery

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid: int, r_c_uid: int, name: str = '', h_uid=None, _tc=None)

class GSNodeQueryResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class GSNodeQueryTotalCPUCount

type enum: GS_NODE_QUERY_TOTAL_CPU_COUNT (= 104)
purpose: Asks GS to return the total number of CPUS beloging to all of the registered nodes.
see also: refer to the Common Fields section for additional request message fields
response: GSNodeQueryTotalCPUCountResponse

__init__(tag, p_uid: int, r_c_uid: int, _tc=None)

class GSNodeQueryTotalCPUCountResponse

type enum

GS_NODE_QUERY_TOTAL_CPU_COUNT_RESPONSE (= 105)

purpose

Return the total number of CPUS beloging to all of the registered nodes.

fields

Alternatives on err:

SUCCESS (= 0)

The machine descriptor was successfully constructed

total_cpus

total number of CPUS beloging to all of the registered nodes.

UNKNOWN ( = 1): An unknown error has occured.

request

GSNodeQueryTotalCPUCount

see also

GSNodeQuery

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

__init__(tag, ref, err, total_cpus=0, err_info='', _tc=None)

class AbnormalTermination

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, err_info='', host_id=0, _tc=None)

class ExceptionlessAbort

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class GSStarted

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class GSPingSH

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class GSIsUp

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class GSPingProc

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, mode=None, argdata=None, _tc=None)

class GSDumpState

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, filename, _tc=None)

class GSHeadExit

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, exit_code=0, _tc=None)

class GSTeardown

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class GSUnexpected

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, ref, _tc=None)

class GSChannelRelease

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class GSHalted

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class SHProcessCreate

Refer to definition and Common Fields for a description of the message structure.

The initial_stdin is a string which if non-empty is written along with a terminating newline character to the stdin of the newly created process.

The stdin, stdout, and stderr are all either None or an instance of SHChannelCreate to be processed by the local services component.

__init__(tag, p_uid, r_c_uid, t_p_uid, exe, args, env=None, rundir='', options=None, initial_stdin='', stdin=None, stdout=None, stderr=None, group=None, user=None, umask=-1, pipesize=None, stdin_msg=None, stdout_msg=None, stderr_msg=None, pmi_info=None, layout=None, gs_ret_chan_msg=None, _tc=None)

class SHProcessCreateResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

FAIL = 1

__init__(tag, ref, err, err_info='', stdin_resp=None, stdout_resp=None, stderr_resp=None, gs_ret_chan_resp=None, _tc=None)

class SHProcessKill

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, t_p_uid, sig, _tc=None)

class SHProcessKillResponse

class Errors: An enumeration.

__init__(tag, ref, err, err_info='', _tc=None)

class SHProcessExit

Refer to definition and to Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

__init__(tag, p_uid, exit_code=0, _tc=None)

class SHMultiProcessCreate

__init__(tag, r_c_uid, procs: List[Union[Dict, SHProcessCreate]], pmi_group_info: Optional[PMIGroupInfo] = None, _tc=None)

class SHMultiProcessCreateResponse

class Errors: An enumeration.

__init__(tag, ref, err, err_info='', exit_code=0, responses: Optional[List[Union[Dict, SHProcessCreateResponse]]] = None, failed: bool = False, _tc=None)

class SHPoolCreate

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, size, m_uid, name, attr='', _tc=None)

class SHPoolCreateResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0: Pool was created

FAIL = 1: Pool was not created

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class SHPoolDestroy

Refer to definition and to the Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, m_uid, _tc=None)

class SHPoolDestroyResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

FAIL = 1

__init__(tag, ref, err, err_info='', _tc=None)

class SHExecMemRequest

Refer to definition and Common Fields for a description of the message structure.

class KINDS: An enumeration.

__init__(tag, p_uid, r_c_uid, kind, request, _tc=None)

class SHExecMemResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

FAIL = 1

__init__(tag, ref, err, err_code=0, err_info='', response=None, _tc=None)

class SHChannelCreate

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, m_uid, c_uid, options=None, _tc=None)

class SHChannelCreateResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

FAIL = 1

__init__(tag, ref, err, desc=None, err_info='', _tc=None)

class SHChannelDestroy

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, c_uid, _tc=None)

class SHChannelDestroyResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

FAIL = 1

__init__(tag, ref, err, err_info='', _tc=None)

class SHLockChannel

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, _tc=None)

class SHLockChannelResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

ALREADY = 1

__init__(tag, ref, err, _tc=None)

class SHAllocMsg

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, _tc=None)

class SHAllocMsgResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

__init__(tag, ref, err, _tc=None)

class SHAllocBlock

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, _tc=None)

class SHAllocBlockResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

UNKNOWN = 1

FAIL = 2

__init__(tag, ref, err, seg_name='', offset=0, err_info='', _tc=None)

class SHChannelsUp

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, node_desc, gs_cd, idx=0, _tc=None)

class SHPingGS

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, idx=0, node_sdesc=None, _tc=None)

class SHTeardown

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class SHPingBE

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, shep_cd='', be_cd='', gs_cd='', default_pd='', inf_pd='', _tc=None)

class SHHaltTA

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class SHHaltBE

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class SHHalted

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, idx=0, _tc=None)

class SHFwdInput

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, p_uid, r_c_uid, t_p_uid=None, input='', confirm=False, _tc=None)

class SHFwdInputErr

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

FAIL = 1

__init__(tag, ref, err, idx=0, err_info='', _tc=None)

class SHFwdOutput

Refer to definition and Common Fields for a description of the message structure.

class FDNum: An enumeration.

__init__(tag, p_uid, idx, fd_num, data, _tc=None, pid=-1, hostname='NONE')

class SHDumpState

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, filename=None, _tc=None)

class BENodeIdxSH

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, node_idx, host_name=None, ip_addrs=None, primary=None, logger_sdesc=None, _tc=None)

class BEPingSH

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class BEHalted

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class LABroadcast

Refer to definition and Common Fields for a description of the message structure. The _tc value of this message must be set to 68. The Launcher Network Front End has this as an external dependency.

__init__(tag, data, _tc=None)

class LAPassThruFB

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, c_uid, data, _tc=None)

class LAPassThruBF

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, data, _tc=None)

class LAServerMode

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, frontend, backend, frontend_args=None, backend_args=None, backend_env=None, backend_run_dir='', backend_user_name='', backend_options=None, _tc=None)

class LAServerModeExit

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0

FAIL = 1

__init__(tag, ref, err, _tc=None)

class LAProcessDict

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class LAProcessDictResponse

Refer to definition and Common Fields for a description of the message structure.

class Errors

An enumeration.

SUCCESS = 0: Always succeeds

__init__(tag, ref, err, pdict=None, _tc=None)

class LADumpState

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, filename=None, _tc=None)

class LAChannelsInfo

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, nodes_desc, gs_cd, num_gw_channels, port=7575, transport='tcp', _tc=None)

class LoggingMsg

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, name, msg, time, func, hostname, ip_address, port, service, level, _tc=None)

class LoggingMsgList

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, records, _tc=None)

class LogFlushed

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class TAPingSH

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class TAHalted

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class TAUp

Refer to definition and Common Fields for a description of the message structure.

The test_channels are empty unless the DRAGON_TRANSPORT_TEST environment variable is set to some value. When set in the environment, local services will create two channels and provide the base64 encoded serialized channel descriptors in this test_channels field to the launcher front end which then disseminates them to the test program which is started on each node.

__init__(tag, idx=0, test_channels=[], _tc=None)

class Breakpoint

__init__(tag, p_uid, index, out_desc, in_desc, _tc=None)

class BEIsUp

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, be_ch_desc, host_id, _tc=None)

class FENodeIdxBE

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, node_index, forward: Optional[dict['str', Union[dragon.infrastructure.node_desc.NodeDescriptor, dict]]] = None, send_desc: Optional[Union[B64, str]] = None, _tc=None)

class HaltLoggingInfra

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class HaltOverlay

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class OverlayHalted

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class BEHaltOverlay

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class LAHaltOverlay

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class OverlayPingBE

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class OverlayPingLA

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class LAExit

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, sigint=False, _tc=None)

class RuntimeDesc

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, gs_cd, gs_ret_cd, ls_cd, ls_ret_cd, fe_ext_ip_addr, head_node_ip_addr, oob_port, env, _tc=None)

class UserHaltOOB

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, _tc=None)

class TAUpdateNodes

Refer to definition and Common Fields for a description of the message structure.

__init__(tag, nodes: list[Union[dragon.infrastructure.node_desc.NodeDescriptor, dict]], _tc=None)