dragon.infrastructure.messages

Components in the Dragon runtime interact with each other using messages transported with a variety of different means (e.g., stdout or Channels). Although typically there will be a Python API to construct and send these messages, the messages themselves constitute the true internal interface. To that end, they are a convention.

Here we document this internal message API.

Generalities about Messages

Many messages are part of a request/response pair. At the level discussed here, successful and error responses are carried by the same response type but the fields present or valid may change according to whether the response is successful or an error.

All messages are serialized using JSON; the reason for this is to allow non-Python actors to interact with the Dragon infrastructure as well as allowing the possibility for the different components of the Dragon runtime to be implemented in something other than Python.

The serialization method may change in the future as an optimization; JSON is chosen here as a reasonable cross language starting point. In particular, the fields discussed here for basic message parsing (type and instance tagging, and errors) are defined in terms of integer valued enumerations suitable for a fixed field location and width binary determination.

The top level of the JSON structure will be a dictionary (map) where the ‘_tc’ key’s value is an integer corresponding to an element of the dragon.messages.MsgTypes enumeration class. The other fields of this map will be defined on a message by message basis.

The canonical form of the message will be taken on the JSON level, not the string level. This means that messages should not be compared or sorted as strings. Internally the Python interface will construct inbound messages into class objects of distinct type according to the ‘_tc’ field in the initializer by using a factory function. The reason to have a lot of different message types instead of just one type differentiated by the value of the ‘_tc’ field is that this allows IDEs and documentation tools to work better by having explicit knowledge of what fields and methods are expected in any particular message.

Common Fields

These fields are common to every message described below depending on their category of classification.

The _tc TypeCode Field

The _tc typecode field is used during parsing to determine the type of a received message. The message format is JSON. The _tc field can be used to determine of all expected fields of a message are indeed in the message to verify its format.

Beyond the _tc typecode field, there are other fields expected to belong to every message.

The tag Field

Every message has a 64 bit positive unsigned integer tag field. Together with the identity of the sender is implicit or explicitly identified in some other field, this serves to uniquely identify the message.

Ideally, this would be throughout the life of the runtime, but it’s enough to say that no two messages should be simultaneously relevant with the same (sender, tag).

Message Categories

There are three general categories of messages:

request messages, where one entity asks another one to do something
response messages, returning the result to the requester
- the name of these messages normally ends “Response”
other messages, mostly to do with infrastructure sequencing

Every request message will contain p_uid and r_c_uid fields. These fields denote the unique process ID of the entity that created the request and the unique channel ID to send the response to. See ConventionalIDs for more details on process identification.

The ref Field

Every response message generated in reply to a request message will contain a ref field that echos the tag field of the request message that caused it to be generated. If a response message is generated asynchronously - for instance, as part of a startup notification or some event such as a process exiting unexpectedly - then the ref field will be 0, which is an illegal value for the tag field.

The err Field

Every response message will also have an err field, holding an integer enumeration particular to the response. This enumeration will be the class attribute Errors in the response message class. The enumeration element with value 0 will always indicate success. Which fields are present in the response message may depend on the enumeration value.

Format of Messages List

Class Name

type enum
member of dragon.messages.MsgTypes enum class

purpose
succinct description of purpose, sender and receiver, where and when typically seen. Starts with ‘Request’ if it is a request message and ‘Response’ if it is a response message.

fields
Fields in the message, together with description of how they are to get parsed out. Some fields may themselves be dictionary structures used to initialize member objects.

Fields in common to every message (such as tag, ref, and err) are not mentioned here.

An expected type will be mentioned on each field where it is an obvious primitive (such as a string or an integer). Where a type isn’t mentioned, it is assumed to be another key-value map to be interpreted as the initializer for some more complex type.

response
If a request kind of message, gives the class name of the corresponding response message, if applicable

request
If a request kind of message, gives the class name of the corresponding response message.

see also
Other related messages

Functions

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

Classes

`AbnormalTermination`	Refer to Common Fields for a description of the message structure.
`BEHaltOverlay`	Refer to Common Fields for a description of the message structure.
`BEHalted`	Refer to Common Fields for a description of the message structure.
`BEIsUp`	Refer to Common Fields for a description of the message structure.
`BENodeIdxSH`	Refer to Common Fields for a description of the message structure.
`BEPingSH`	Refer to 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.
`DDBPut`
`DDBPutResponse`
`DDBatchPut`
`DDBatchPutResponse`
`DDClear`
`DDClearResponse`
`DDConnectToManager`
`DDConnectToManagerResponse`
`DDContains`
`DDContainsResponse`
`DDCreate`
`DDCreateResponse`
`DDDeregisterClient`
`DDDeregisterClientResponse`
`DDDestroy`
`DDDestroyManager`
`DDDestroyManagerResponse`
`DDDestroyResponse`
`DDEmptyManagers`
`DDEmptyManagersResponse`
`DDGet`
`DDGetManagers`
`DDGetManagersResponse`
`DDGetMetaData`
`DDGetMetaDataResponse`
`DDGetResponse`
`DDItems`
`DDItemsResponse`
`DDIterator`
`DDIteratorNext`
`DDIteratorNextResponse`
`DDIteratorResponse`
`DDKeys`
`DDKeysResponse`
`DDLength`
`DDLengthResponse`
`DDManagerNewestChkptID`
`DDManagerNewestChkptIDResponse`
`DDManagerNodes`
`DDManagerNodesResponse`
`DDManagerSetState`
`DDManagerSetStateResponse`
`DDManagerStats`
`DDManagerStatsResponse`
`DDManagerSync`
`DDManagerSyncResponse`
`DDMarkDrainedManagers`
`DDMarkDrainedManagersResponse`
`DDPop`
`DDPopResponse`
`DDPut`
`DDPutResponse`
`DDRandomManager`
`DDRandomManagerResponse`
`DDRegisterClient`
`DDRegisterClientID`
`DDRegisterClientIDResponse`
`DDRegisterClientResponse`
`DDRegisterManager`
`DDRegisterManagerResponse`
`DDUnmarkDrainedManagers`
`DDUnmarkDrainedManagersResponse`
`DDValues`
`DDValuesResponse`
`ExceptionlessAbort`	Refer to Common Fields for a description of the message structure.
`FENodeIdxBE`	Refer to Common Fields for a description of the message structure.
`FileDescriptor`
`GSChannelCreate`	Refer to Common Fields for a description of the message structure.
`GSChannelCreateResponse`	Refer to Common Fields for a description of the message structure.
`GSChannelDestroy`	Refer to Common Fields for a description of the message structure.
`GSChannelDestroyResponse`	Refer to Common Fields for a description of the message structure.
`GSChannelDetach`	Refer to Common Fields for a description of the message structure.
`GSChannelDetachResponse`	Refer to Common Fields for a description of the message structure.
`GSChannelGetRecvH`	Refer to Common Fields for a description of the message structure.
`GSChannelGetRecvHResponse`	Refer to Common Fields for a description of the message structure.
`GSChannelGetSendH`	Refer to Common Fields for a description of the message structure.
`GSChannelGetSendHResponse`	Refer to Common Fields for a description of the message structure.
`GSChannelJoin`	Refer to Common Fields for a description of the message structure.
`GSChannelJoinResponse`	Refer to Common Fields for a description of the message structure.
`GSChannelList`	Refer to to Common Fields for a description of the message structure.
`GSChannelListResponse`	Refer to Common Fields for a description of the message structure.
`GSChannelQuery`	Refer to Common Fields for a description of the message structure.
`GSChannelQueryResponse`	Refer to Common Fields for a description of the message structure.
`GSChannelRelease`	Refer to Common Fields for a description of the message structure.
`GSDumpState`	Refer to Common Fields for a description of the message structure.
`GSGroupAddTo`	Refer to Common Fields for a description of the message structure.
`GSGroupAddToResponse`	Refer to Common Fields for a description of the message structure.
`GSGroupCreate`	Refer to Common Fields for a description of the message structure.
`GSGroupCreateAddTo`	Refer to Common Fields for a description of the message structure.
`GSGroupCreateAddToResponse`	Refer to Common Fields for a description of the message structure.
`GSGroupCreateResponse`	Refer to Common Fields for a description of the message structure.
`GSGroupDestroy`	Refer to Common Fields for a description of the message structure.
`GSGroupDestroyRemoveFrom`	Refer to Common Fields for a description of the message structure.
`GSGroupDestroyRemoveFromResponse`	Refer to Common Fields for a description of the message structure.
`GSGroupDestroyResponse`	Refer to Common Fields for a description of the message structure.
`GSGroupKill`	Refer to Common Fields for a description of the message structure.
`GSGroupKillResponse`	Refer to Common Fields for a description of the message structure.
`GSGroupList`	Refer to Common Fields for a description of the message structure.
`GSGroupListResponse`	Refer to Common Fields for a description of the message structure.
`GSGroupQuery`	Refer to Common Fields for a description of the message structure.
`GSGroupQueryResponse`	Refer to Common Fields for a description of the message structure.
`GSGroupRemoveFrom`	Refer to Common Fields for a description of the message structure.
`GSGroupRemoveFromResponse`	Refer to Common Fields for a description of the message structure.
`GSHalted`	Refer to Common Fields for a description of the message structure.
`GSHeadExit`	Refer to Common Fields for a description of the message structure.
`GSIsUp`	Refer to Common Fields for a description of the message structure.
`GSNodeList`	type enum
`GSNodeListResponse`	type enum
`GSNodeQuery`	Refer to Common Fields for a description of the message structure.
`GSNodeQueryAll`	Refer to Common Fields for a description of the message structure.
`GSNodeQueryAllResponse`	Refer to Common Fields for a description of the message structure.
`GSNodeQueryResponse`	Refer to Common Fields for a description of the message structure.
`GSNodeQueryTotalCPUCount`	type enum
`GSNodeQueryTotalCPUCountResponse`	type enum
`GSPingProc`	Refer to Common Fields for a description of the message structure.
`GSPingSH`	Refer to Common Fields for a description of the message structure.
`GSPoolCreate`	Refer to Common Fields for a description of the message structure.
`GSPoolCreateResponse`	Refer to Common Fields for a description of the message structure.
`GSPoolDestroy`	Refer to Common Fields for a description of the message structure.
`GSPoolDestroyResponse`	Refer to Common Fields for a description of the message structure.
`GSPoolList`	Refer to Common Fields for a description of the message structure.
`GSPoolListResponse`	Refer to Common Fields for a description of the message structure.
`GSPoolQuery`	Refer to Common Fields for a description of the message structure.
`GSPoolQueryResponse`	Refer to Common Fields for a description of the message structure.
`GSProcessCreate`	Refer to Common Fields for a description of the message structure.
`GSProcessCreateResponse`	Refer to Common Fields for a description of the message structure.
`GSProcessJoin`	Refer to Common Fields for a description of the message structure.
`GSProcessJoinList`	Refer to Common Fields for a description of the message structure.
`GSProcessJoinListResponse`	Refer to Common Fields for a description of the message structure.
`GSProcessJoinResponse`	Refer to Common Fields for a description of the message structure.
`GSProcessKill`	Refer to Common Fields for a description of the message structure.
`GSProcessKillResponse`	Refer to Common Fields for a description of the message structure.
`GSProcessList`	Refer to Common Fields for a description of the message structure.
`GSProcessListResponse`	Refer to Common Fields for a description of the message structure.
`GSProcessQuery`	Refer to Common Fields for a description of the message structure.
`GSProcessQueryResponse`	Refer to Common Fields for a description of the message structure.
`GSRebootRuntime`	Refer to Common Fields for a description of the message structure.
`GSRebootRuntimeResponse`	Refer to Common Fields for a description of the message structure.
`GSStarted`	Refer to Common Fields for a description of the message structure.
`GSTeardown`	Refer to Common Fields for a description of the message structure.
`GSUnexpected`	Refer to Common Fields for a description of the message structure.
`HaltLoggingInfra`	Refer to Common Fields for a description of the message structure.
`HaltOverlay`	Refer to Common Fields for a description of the message structure.
`InfraMsg`	Common base for all messages.
`LABroadcast`	Refer to Common Fields for a description of the message structure.
`LAChannelsInfo`	Refer to Common Fields for a description of the message structure.
`LADumpState`	Refer to Common Fields for a description of the message structure.
`LAExit`	Refer to Common Fields for a description of the message structure.
`LAHaltOverlay`	Refer to Common Fields for a description of the message structure.
`LAPassThruBF`	Refer to Common Fields for a description of the message structure.
`LAPassThruFB`	Refer to Common Fields for a description of the message structure.
`LAProcessDict`	Refer to Common Fields for a description of the message structure.
`LAProcessDictResponse`	Refer to Common Fields for a description of the message structure.
`LAServerMode`	Refer to Common Fields for a description of the message structure.
`LAServerModeExit`	Refer to Common Fields for a description of the message structure.
`LogFlushed`	Refer to Common Fields for a description of the message structure.
`LoggingMsg`	Refer to Common Fields for a description of the message structure.
`LoggingMsgList`	Refer to 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 Common Fields for a description of the message structure.
`OverlayPingBE`	Refer to Common Fields for a description of the message structure.
`OverlayPingLA`	Refer to Common Fields for a description of the message structure.
`PGAddProcessTemplates`
`PGClientResponse`	Refer to Common Fields for a description of the message structure.
`PGClose`
`PGJoin`
`PGPuids`
`PGRegisterClient`	Refer to Common Fields for a description of the message structure.
`PGSetProperties`
`PGSignal`
`PGStart`
`PGState`
`PGStop`
`PGStopRestart`
`PGUnregisterClient`	Refer to 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.
`RebootRuntime`	Refer to definition and Common Fields for a description of the message structure.
`RuntimeDesc`	Refer to Common Fields for a description of the message structure.
`SHAllocBlock`	Refer to Common Fields for a description of the message structure.
`SHAllocBlockResponse`	Refer to Common Fields for a description of the message structure.
`SHAllocMsg`	Refer to Common Fields for a description of the message structure.
`SHAllocMsgResponse`	Refer to Common Fields for a description of the message structure.
`SHChannelCreate`	Refer to Common Fields for a description of the message structure.
`SHChannelCreateResponse`	Refer to Common Fields for a description of the message structure.
`SHChannelDestroy`	Refer to Common Fields for a description of the message structure.
`SHChannelDestroyResponse`	Refer to Common Fields for a description of the message structure.
`SHChannelsUp`	Refer to Common Fields for a description of the message structure.
`SHCreateProcessLocalChannel`
`SHCreateProcessLocalChannelResponse`
`SHCreateProcessLocalPool`
`SHCreateProcessLocalPoolResponse`
`SHDeregisterProcessLocalPool`
`SHDeregisterProcessLocalPoolResponse`
`SHDestroyProcessLocalChannel`
`SHDestroyProcessLocalChannelResponse`
`SHDumpState`	Refer to Common Fields for a description of the message structure.
`SHExecMemRequest`	Refer to Common Fields for a description of the message structure.
`SHExecMemResponse`	Refer to Common Fields for a description of the message structure.
`SHFwdInput`	Refer to Common Fields for a description of the message structure.
`SHFwdInputErr`	Refer to Common Fields for a description of the message structure.
`SHFwdOutput`	Refer to Common Fields for a description of the message structure.
`SHGetKV`
`SHGetKVL`
`SHGetKVLResponse`
`SHGetKVResponse`
`SHHaltBE`	Refer to Common Fields for a description of the message structure.
`SHHaltTA`	Refer to Common Fields for a description of the message structure.
`SHHalted`	Refer to Common Fields for a description of the message structure.
`SHLockChannel`	Refer to Common Fields for a description of the message structure.
`SHLockChannelResponse`	Refer to Common Fields for a description of the message structure.
`SHMultiProcessCreate`
`SHMultiProcessCreateResponse`
`SHMultiProcessKill`
`SHMultiProcessKillResponse`
`SHPingBE`	Refer to Common Fields for a description of the message structure.
`SHPingGS`	Refer to Common Fields for a description of the message structure.
`SHPoolCreate`	Refer to Common Fields for a description of the message structure.
`SHPoolCreateResponse`	Refer to Common Fields for a description of the message structure.
`SHPoolDestroy`	Refer to to the Common Fields for a description of the message structure.
`SHPoolDestroyResponse`	Refer to Common Fields for a description of the message structure.
`SHPopKVL`
`SHPopKVLResponse`
`SHProcessCreate`	Refer to Common Fields for a description of the message structure.
`SHProcessCreateResponse`	Refer to Common Fields for a description of the message structure.
`SHProcessExit`	Refer to to Common Fields for a description of the message structure.
`SHProcessKill`	Refer to Common Fields for a description of the message structure.
`SHProcessKillResponse`
`SHPushKVL`
`SHPushKVLResponse`
`SHRegisterProcessLocalPool`
`SHRegisterProcessLocalPoolResponse`
`SHSetKV`
`SHSetKVResponse`
`SHTeardown`	Refer to Common Fields for a description of the message structure.
`TAHalted`	Refer to Common Fields for a description of the message structure.
`TAPingSH`	Refer to Common Fields for a description of the message structure.
`TAUp`	Refer to Common Fields for a description of the message structure.
`TAUpdateNodes`	Refer to Common Fields for a description of the message structure.
`UserHaltOOB`	Refer to Common Fields for a description of the message structure.

Exceptions

AbnormalTerminationError

class MessageTypes

Bases: Enum

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_MULTI_PROCESS_KILL = 38

SH_PROCESS_KILL = 39

SH_PROCESS_EXIT = 40

SH_CHANNEL_CREATE = 41

SH_CHANNEL_CREATE_RESPONSE = 42

SH_CHANNEL_DESTROY = 43

SH_CHANNEL_DESTROY_RESPONSE = 44

SH_LOCK_CHANNEL = 45

SH_LOCK_CHANNEL_RESPONSE = 46

SH_ALLOC_MSG = 47

SH_ALLOC_MSG_RESPONSE = 48

SH_ALLOC_BLOCK = 49

SH_ALLOC_BLOCK_RESPONSE = 50

SH_CHANNELS_UP = 51

SH_PING_GS = 52

SH_HALTED = 53

SH_FWD_INPUT = 54

SH_FWD_INPUT_ERR = 55

SH_FWD_OUTPUT = 56

GS_TEARDOWN = 57

SH_TEARDOWN = 58

SH_PING_BE = 59

BE_PING_SH = 60

TA_PING_SH = 61

SH_HALT_TA = 62

TA_HALTED = 63

SH_HALT_BE = 64

BE_HALTED = 65

TA_UP = 66

GS_PING_PROC = 67

GS_DUMP_STATE = 68

SH_DUMP_STATE = 69

LA_BROADCAST = 70

LA_PASS_THRU_FB = 71

LA_PASS_THRU_BF = 72

GS_POOL_CREATE = 73

GS_POOL_CREATE_RESPONSE = 74

GS_POOL_DESTROY = 75

GS_POOL_DESTROY_RESPONSE = 76

GS_POOL_LIST = 77

GS_POOL_LIST_RESPONSE = 78

GS_POOL_QUERY = 79

GS_POOL_QUERY_RESPONSE = 80

SH_POOL_CREATE = 81

SH_POOL_CREATE_RESPONSE = 82

SH_POOL_DESTROY = 83

SH_POOL_DESTROY_RESPONSE = 84

SH_CREATE_PROCESS_LOCAL_CHANNEL = 85

SH_CREATE_PROCESS_LOCAL_CHANNEL_RESPONSE = 86

SH_DESTROY_PROCESS_LOCAL_CHANNEL = 87

SH_DESTROY_PROCESS_LOCAL_CHANNEL_RESPONSE = 88

SH_CREATE_PROCESS_LOCAL_POOL = 89

SH_CREATE_PROCESS_LOCAL_POOL_RESPONSE = 90

SH_REGISTER_PROCESS_LOCAL_POOL = 91

SH_REGISTER_PROCESS_LOCAL_POOL_RESPONSE = 92

SH_DEREGISTER_PROCESS_LOCAL_POOL = 93

SH_DEREGISTER_PROCESS_LOCAL_POOL_RESPONSE = 94

SH_PUSH_KVL = 95

SH_PUSH_KVL_RESPONSE = 96

SH_POP_KVL = 97

SH_POP_KVL_RESPONSE = 98

SH_GET_KVL = 99

SH_GET_KVL_RESPONSE = 100

SH_SET_KV = 101

SH_SET_KV_RESPONSE = 102

SH_GET_KV = 103

SH_GET_KV_RESPONSE = 104

SH_EXEC_MEM_REQUEST = 105

SH_EXEC_MEM_RESPONSE = 106

GS_UNEXPECTED = 107

LA_SERVER_MODE = 108

LA_SERVER_MODE_EXIT = 109

LA_PROCESS_DICT = 110

LA_PROCESS_DICT_RESPONSE = 111

LA_DUMP_STATE = 112

BE_NODE_IDX_SH = 113

LA_CHANNELS_INFO = 114

SH_MULTI_PROCESS_KILL_RESPONSE = 115

SH_PROCESS_KILL_RESPONSE = 116

BREAKPOINT = 117

GS_PROCESS_JOIN_LIST = 118

GS_PROCESS_JOIN_LIST_RESPONSE = 119

GS_NODE_QUERY = 120

GS_NODE_QUERY_RESPONSE = 121

GS_NODE_QUERY_ALL = 122

GS_NODE_QUERY_ALL_RESPONSE = 123

LOGGING_MSG = 124

LOGGING_MSG_LIST = 125

LOG_FLUSHED = 126

GS_NODE_LIST = 127

GS_NODE_LIST_RESPONSE = 128

GS_NODE_QUERY_TOTAL_CPU_COUNT = 129

GS_NODE_QUERY_TOTAL_CPU_COUNT_RESPONSE = 130

BE_IS_UP = 131

FE_NODE_IDX_BE = 132

HALT_OVERLAY = 133

HALT_LOGGING_INFRA = 134

OVERLAY_PING_BE = 135

OVERLAY_PING_LA = 136

LA_HALT_OVERLAY = 137

BE_HALT_OVERLAY = 138

OVERLAY_HALTED = 139

EXCEPTIONLESS_ABORT = 140: Communicate abnormal termination without raising exception

LA_EXIT = 141

GS_GROUP_LIST = 142

GS_GROUP_LIST_RESPONSE = 143

GS_GROUP_QUERY = 144

GS_GROUP_QUERY_RESPONSE = 145

GS_GROUP_DESTROY = 146

GS_GROUP_DESTROY_RESPONSE = 147

GS_GROUP_ADD_TO = 148

GS_GROUP_ADD_TO_RESPONSE = 149

GS_GROUP_REMOVE_FROM = 150

GS_GROUP_REMOVE_FROM_RESPONSE = 151

GS_GROUP_CREATE = 152

GS_GROUP_CREATE_RESPONSE = 153

GS_GROUP_KILL = 154

GS_GROUP_KILL_RESPONSE = 155

GS_GROUP_CREATE_ADD_TO = 156

GS_GROUP_CREATE_ADD_TO_RESPONSE = 157

GS_GROUP_DESTROY_REMOVE_FROM = 158

GS_GROUP_DESTROY_REMOVE_FROM_RESPONSE = 159

GS_REBOOT_RUNTIME = 160

GS_REBOOT_RUNTIME_RESPONSE = 161

REBOOT_RUNTIME = 162

TA_UPDATE_NODES = 163

RUNTIME_DESC = 164

USER_HALT_OOB = 165

DD_REGISTER_CLIENT = 166

DD_REGISTER_CLIENT_RESPONSE = 167

DD_DESTROY = 168

DD_DESTROY_RESPONSE = 169

DD_REGISTER_MANAGER = 170

DD_REGISTER_MANAGER_RESPONSE = 171

DD_REGISTER_CLIENT_ID = 172

DD_REGISTER_CLIENT_ID_RESPONSE = 173

DD_DESTROY_MANAGER = 174

DD_DESTROY_MANAGER_RESPONSE = 175

DD_PUT = 176

DD_PUT_RESPONSE = 177

DD_GET = 178

DD_GET_RESPONSE = 179

DD_POP = 180

DD_POP_RESPONSE = 181

DD_CONTAINS = 182

DD_CONTAINS_RESPONSE = 183

DD_LENGTH = 184

DD_LENGTH_RESPONSE = 185

DD_CLEAR = 186

DD_CLEAR_RESPONSE = 187

DD_ITERATOR = 188

DD_ITERATOR_RESPONSE = 189

DD_ITERATOR_NEXT = 190

DD_ITERATOR_NEXT_RESPONSE = 191

DD_KEYS = 192

DD_KEYS_RESPONSE = 193

DD_VALUES = 194

DD_VALUES_RESPONSE = 195

DD_ITEMS = 196

DD_ITEMS_RESPONSE = 197

DD_DEREGISTER_CLIENT = 198

DD_DEREGISTER_CLIENT_RESPONSE = 199

DD_CREATE = 200

DD_CREATE_RESPONSE = 201

DD_CONNECT_TO_MANAGER = 202

DD_CONNECT_TO_MANAGER_RESPONSE = 203

DD_RANDOM_MANAGER = 204

DD_RANDOM_MANAGER_RESPONSE = 205

DD_MANAGER_STATS = 206

DD_MANAGER_STATS_RESPONSE = 207

DD_MANAGER_NEWEST_CHKPT_ID = 208

DD_MANAGER_NEWEST_CHKPT_ID_RESPONSE = 209

DD_EMPTY_MANAGERS = 210

DD_EMPTY_MANAGERS_RESPONSE = 211

DD_BATCH_PUT = 212

DD_BATCH_PUT_RESPONSE = 213

DD_GET_MANAGERS = 214

DD_GET_MANAGERS_RESPONSE = 215

DD_MANAGER_SYNC = 216

DD_MANAGER_SYNC_RESPONSE = 217

DD_MANAGER_SET_STATE = 218

DD_MANAGER_SET_STATE_RESPONSE = 219

DD_MARK_DRAINED_MANAGERS = 220

DD_MARK_DRAINED_MANAGERS_RESPONSE = 221

DD_UNMARK_DRAINED_MANAGERS = 222

DD_UNMARK_DRAINED_MANAGERS_RESPONSE = 223

DD_GET_META_DATA = 224

DD_GET_META_DATA_RESPONSE = 225

DD_MANAGER_NODES = 226

DD_MANAGER_NODES_RESPONSE = 227

DD_B_PUT = 228

DD_B_PUT_RESPONSE = 229

PG_REGISTER_CLIENT = 230

PG_UNREGISTER_CLIENT = 231

PG_CLIENT_RESPONSE = 232

PG_SET_PROPERTIES = 233

PG_STOP_RESTART = 234

PG_ADD_PROCESS_TEMPLATES = 235

PG_START = 236

PG_JOIN = 237

PG_SIGNAL = 238

PG_STATE = 239

PG_PUIDS = 240

PG_STOP = 241

PG_CLOSE = 242

class FileDescriptor

Bases: Enum

stdin = 0

stdout = 1

stderr = 2

exception AbnormalTerminationError

Bases: Exception

__init__(msg='')

class PMIGroupInfo

Bases: object

Required information to enable the launching of pmi based applications.

job_id: int 

nnodes: int 

nranks: int 

nidlist: list [int ]

hostlist: list [str ]

control_port: int 

classmethod fromdict(d)

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

class PMIProcessInfo

Bases: object

Required information to enable the launching of pmi based applications.

lrank: int 

ppn: int 

nid: int 

pid_base: int 

classmethod fromdict(d)

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

class InfraMsg

Bases: object

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

Bases: Enum

INVALID = -1

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

get_sdict()

property tc

classmethod tcv()

property tag

property ref

property err

classmethod from_sdict(sdict)

classmethod deserialize(msg)

uncompressed_serialize()

serialize()

class CapNProtoMsg

Bases: object

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)

classmethod from_sdict(sdict)

classmethod deserialize(msg_str)

serialize()

get_sdict()

builder()

property capnp_name

property tc

property tag

class CapNProtoResponseMsg

Bases: CapNProtoMsg

Common base for all capnproto response messages.

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

__init__(tag, ref, err, errInfo)

get_sdict()

builder()

property ref

property err

property errInfo

class SHCreateProcessLocalChannel

Bases: CapNProtoMsg

__init__(tag, puid, blockSize, capacity, respFLI)

get_sdict()

builder()

property respFLI

property puid

property blockSize

property capacity

class SHCreateProcessLocalChannelResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property serialized_channel

class SHDestroyProcessLocalChannel

Bases: CapNProtoMsg

__init__(tag, puid, cuid, respFLI)

get_sdict()

builder()

property respFLI

property puid

property cuid

class SHDestroyProcessLocalChannelResponse

Bases: CapNProtoResponseMsg

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

class SHCreateProcessLocalPool

Bases: CapNProtoMsg

__init__(tag, puid, size, minBlockSize, preAllocs, name, respFLI)

get_sdict()

builder()

property respFLI

property puid

property size

property minBlockSize

property preAllocs

property name

class SHCreateProcessLocalPoolResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property serialized_pool

class SHRegisterProcessLocalPool

Bases: CapNProtoMsg

__init__(tag, puid, serPool, respFLI)

get_sdict()

builder()

property serPool

property puid

property respFLI

class SHRegisterProcessLocalPoolResponse

Bases: CapNProtoResponseMsg

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

class SHDeregisterProcessLocalPool

Bases: CapNProtoMsg

__init__(tag, puid, serPool, respFLI)

get_sdict()

builder()

property serPool

property puid

property respFLI

class SHDeregisterProcessLocalPoolResponse

Bases: CapNProtoResponseMsg

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

class SHPushKVL

Bases: CapNProtoMsg

__init__(tag, key, value, respFLI)

get_sdict()

builder()

property key

property value

property respFLI

class SHPushKVLResponse

Bases: CapNProtoResponseMsg

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

class SHPopKVL

Bases: CapNProtoMsg

__init__(tag, key, value, respFLI)

get_sdict()

builder()

property key

property value

property respFLI

class SHPopKVLResponse

Bases: CapNProtoResponseMsg

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

class SHGetKVL

Bases: CapNProtoMsg

__init__(tag, key, respFLI)

get_sdict()

builder()

property key

property respFLI

class SHGetKVLResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property values

class SHSetKV

Bases: CapNProtoMsg

__init__(tag, key, value, respFLI)

get_sdict()

builder()

property key

property value

property respFLI

class SHSetKVResponse

Bases: CapNProtoResponseMsg

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

class SHGetKV

Bases: CapNProtoMsg

__init__(tag, key, respFLI)

get_sdict()

builder()

property key

property respFLI

class SHGetKVResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property value

class DDCreate

Bases: CapNProtoMsg

__init__(tag, respFLI, args)

get_sdict()

builder()

property respFLI

property args

class DDCreateResponse

Bases: CapNProtoResponseMsg

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

class DDRandomManager

Bases: CapNProtoMsg

__init__(tag, respFLI)

get_sdict()

builder()

property respFLI

class DDRandomManagerResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property manager

class DDRegisterClient

Bases: CapNProtoMsg

__init__(tag, respFLI, bufferedRespFLI)

get_sdict()

builder()

property respFLI

property bufferedRespFLI

class DDRegisterClientResponse

Bases: CapNProtoResponseMsg

__init__(tag, ref, err, clientID, numManagers, managerID, managerNodes, name, timeout, errInfo='')

get_sdict()

builder()

property clientID

property numManagers

property managerID

property managerNodes

property name

property timeout

class DDConnectToManager

Bases: CapNProtoMsg

__init__(tag, clientID, managerID)

get_sdict()

builder()

property clientID

property managerID

class DDConnectToManagerResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property manager

class DDDestroy

Bases: CapNProtoMsg

__init__(tag, clientID, respFLI, allowRestart)

get_sdict()

builder()

property respFLI

property clientID

property allowRestart

class DDDestroyResponse

Bases: CapNProtoResponseMsg

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

class DDRegisterManager

Bases: CapNProtoMsg

__init__(tag, managerID, mainFLI, respFLI, hostID, poolSdesc, err, errInfo)

get_sdict()

builder()

property managerID

property mainFLI

property respFLI

property hostID

property poolSdesc

property err

property errInfo

class DDRegisterManagerResponse

Bases: CapNProtoResponseMsg

__init__(tag, ref, err, errInfo, managers, managerNodes)

get_sdict()

builder()

property managers

property managerNodes

class DDRegisterClientID

Bases: CapNProtoMsg

__init__(tag, clientID, respFLI, bufferedRespFLI)

get_sdict()

builder()

property clientID

property respFLI

property bufferedRespFLI

class DDRegisterClientIDResponse

Bases: CapNProtoResponseMsg

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

class DDDestroyManager

Bases: CapNProtoMsg

__init__(tag, respFLI, allowRestart)

get_sdict()

builder()

property respFLI

property allowRestart

class DDDestroyManagerResponse

Bases: CapNProtoResponseMsg

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

class DDPut

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID=0, persist=True)

get_sdict()

builder()

property clientID

property chkptID

property persist

class DDPutResponse

Bases: CapNProtoResponseMsg

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

class DDGet

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID=0)

get_sdict()

builder()

property clientID

property chkptID

class DDGetResponse

Bases: CapNProtoResponseMsg

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

class DDPop

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID=0)

get_sdict()

builder()

property clientID

property chkptID

class DDPopResponse

Bases: CapNProtoResponseMsg

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

class DDContains

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID=0)

get_sdict()

builder()

property clientID

property chkptID

class DDContainsResponse

Bases: CapNProtoResponseMsg

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

class DDLength

Bases: CapNProtoMsg

__init__(tag, clientID, respFLI, chkptID=0, broadcast=True)

get_sdict()

builder()

property clientID

property respFLI

property chkptID

property broadcast

class DDLengthResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property length

class DDClear

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID, respFLI, broadcast=True)

get_sdict()

builder()

property clientID

property chkptID

property respFLI

property broadcast

class DDClearResponse

Bases: CapNProtoResponseMsg

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

class DDManagerStats

Bases: CapNProtoMsg

__init__(tag, respFLI, broadcast=True)

get_sdict()

builder()

property respFLI

property broadcast

class DDManagerStatsResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property data

class DDManagerNewestChkptID

Bases: CapNProtoMsg

__init__(tag, respFLI, broadcast=True)

get_sdict()

builder()

property respFLI

property broadcast

class DDManagerNewestChkptIDResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property chkptID

property managerID

class DDIterator

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID=0)

get_sdict()

builder()

property clientID

property chkptID

class DDIteratorResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property iterID

class DDIteratorNext

Bases: CapNProtoMsg

__init__(tag, clientID, iterID)

get_sdict()

builder()

property clientID

property iterID

class DDIteratorNextResponse

Bases: CapNProtoResponseMsg

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

class DDKeys

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID, respFLI)

get_sdict()

builder()

property clientID

property chkptID

property respFLI

class DDKeysResponse

Bases: CapNProtoResponseMsg

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

class DDValues

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID, respFLI)

get_sdict()

builder()

property clientID

property chkptID

property respFLI

class DDValuesResponse

Bases: CapNProtoResponseMsg

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

class DDItems

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID, respFLI)

get_sdict()

builder()

property clientID

property chkptID

property respFLI

class DDItemsResponse

Bases: CapNProtoResponseMsg

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

class DDEmptyManagers

Bases: CapNProtoMsg

__init__(tag, respFLI)

get_sdict()

builder()

property respFLI

class DDEmptyManagersResponse

Bases: CapNProtoResponseMsg

__init__(tag, ref, err, errInfo, managers)

get_sdict()

builder()

property managers

class DDBatchPut

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID=0, persist=True)

get_sdict()

builder()

property clientID

property chkptID

property persist

class DDBatchPutResponse

Bases: CapNProtoResponseMsg

__init__(tag, ref, err, errInfo, numPuts, managerID)

get_sdict()

builder()

property numPuts

property managerID

class DDGetManagers

Bases: CapNProtoMsg

__init__(tag, respFLI)

get_sdict()

builder()

property respFLI

class DDGetManagersResponse

Bases: CapNProtoResponseMsg

__init__(tag, ref, err, errInfo, emptyManagers, managers)

get_sdict()

builder()

property emptyManagers

property managers

class DDManagerSync

Bases: CapNProtoMsg

__init__(tag, emptyManagerFLI, respFLI)

get_sdict()

builder()

property emptyManagerFLI

property respFLI

class DDManagerSyncResponse

Bases: CapNProtoResponseMsg

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

class DDManagerSetState

Bases: CapNProtoMsg

__init__(tag, state, respFLI)

get_sdict()

builder()

property state

property respFLI

class DDManagerSetStateResponse

Bases: CapNProtoResponseMsg

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

class DDMarkDrainedManagers

Bases: CapNProtoMsg

__init__(tag, respFLI, managerIDs)

get_sdict()

builder()

property respFLI

property managerIDs

class DDMarkDrainedManagersResponse

Bases: CapNProtoResponseMsg

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

class DDUnmarkDrainedManagers

Bases: CapNProtoMsg

__init__(tag, respFLI, managerIDs)

get_sdict()

builder()

property respFLI

property managerIDs

class DDUnmarkDrainedManagersResponse

Bases: CapNProtoResponseMsg

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

class DDGetMetaData

Bases: CapNProtoMsg

__init__(tag, respFLI)

get_sdict()

builder()

property respFLI

class DDGetMetaDataResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property serializedDdict

property numManagers

class DDManagerNodes

Bases: CapNProtoMsg

__init__(tag, respFLI)

get_sdict()

builder()

property respFLI

class DDManagerNodesResponse

Bases: CapNProtoResponseMsg

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

get_sdict()

builder()

property huids

class DDBPut

Bases: CapNProtoMsg

__init__(tag, clientID, chkptID, respFLI, managers, batch=False)

get_sdict()

builder()

property clientID

property chkptID

property respFLI

property managers

property batch

class DDBPutResponse

Bases: CapNProtoResponseMsg

__init__(tag, ref, err, errInfo, numPuts, managerID)

get_sdict()

builder()

property numPuts

property managerID

class DDDeregisterClient

Bases: CapNProtoMsg

__init__(tag, clientID, respFLI)

get_sdict()

builder()

property clientID

property respFLI

class DDDeregisterClientResponse

Bases: CapNProtoResponseMsg

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

class GSProcessCreate