| S | |
| selector, MessageChannel | |
| send | |
| send_mval, InmHelper | |
| sendrecv, InmHelper | |
| sendrecv_mval, InmHelper | |
| SerialMessageChannel | |
| set_format_val_conv, MessageFactory | |
| set_format_val_size, MessageFactory | |
| set_make_val_int_size, MessageFactory | |
| set_timeout | |
| srcadr | |
| SRCADR_SIZE, MessageHeader | |
| StandardMessage | |
| StandardRegisters | |
| StandardResults | |
| StandardTypes | |
| STDERR, StandardRegisters | |
| STDIN, StandardRegisters | |
| STDIO, StandardRegisters | |
| STDIO_H, StandardRegisters | |
| STDIO_L, StandardRegisters | |
| STDIOERR, StandardRegisters | |
| STDIOERR_H, StandardRegisters | |
| STDIOERR_L, StandardRegisters | |
| STDOUT, StandardRegisters | |
| Str, ValueConversions | |
| str_encoding, MessageFactory | |
| str_val_conv, MessageFactory | |
| Strictness | |
| SUCCESS, ResultCode | |
| T | |
| tcp_port, InetMessageChannel | |
| timeout, MessageChannel | |
| TIMEOUT_DIVISOR | |
| to_bytes | |
| Tuple, ValueConversions | |
| typ, Message | |
| Typ, InmHelper | |
| TYPE, StandardResults | |
| type_enum_class, MessageFactory | |
| U | |
| udp_port, InetMessageChannel | |
| UNROUTABLE, ResultCode | |
| Utility Functions | |
| V | |
| val, Message | |
| ValueConversions | |
| Variables | |
| VC, InmHelper | |
| Z | |
| ZERO_DURATION |
A selector object compatible with the ones provided by the standard library module selectors.
self.selector
Implements MessageChannel.send.
def send( self, dstadr, msg, msg_id = None, srcadr = None, link_adr = None )
Constructs and sends an INM message.
def send( self, dstadr, typ, val, int_size = None, msg_id = None, srcadr = None, link_adr = None )
Sends an INM message.
def send( self, dstadr, msg, msg_id = None, srcadr = None, link_adr = None )
Implements MessageChannel.send.
def send( self, dstadr, msg, msg_id = None, srcadr = None, link_adr = None, in_link_adr = None, envelope_dstadr = None, send_cc = True )
Implements MessageChannel.send.
def send( self, dstadr, msg, msg_id = None, srcadr = None, link_adr = None )
Constructs and sends an INM message with a multipart message value.
def send_mval( self, dstadr, typ, mval, int_size = None, msg_id = None, srcadr = None, link_adr = None )
First constructs and sends an INM message, then attempts to receive one.
def sendrecv( self, dstadr, typ, val, int_size = None, msg_id = None, srcadr = None, link_adr = None )
First constructs and sends an INM message with a multipart value, then attempts to receive a message.
def sendrecv_mval( self, dstadr, typ, mval, int_size = None, msg_id = None, srcadr = None, link_adr = None )
A BinaryMessageChannel that sends and receives messages via a serial port.
class SerialMessageChannel( BinaryMessageChannel )
Sets the value formatting conversion specifier associated with a specified message type.
def set_format_val_conv( self, tlv_type, conv )
Sets the value formatting field sizes associated with a specified message type.
def set_format_val_size( self, tlv_type, size )
Sets the value construction integer field sizes associated with a specified message type.
def set_make_val_int_size( self, tlv_type, int_size )
Overrides MessageChannel.set_timeout.
def set_timeout( self, timeout )
Updates the timeout attribute.
def set_timeout( self, timeout )
Overrides MessageChannel.set_timeout.
def set_timeout( self, timeout )
Overrides MessageChannel.set_timeout.
def set_timeout( self, timeout )
Default INM source address of messages sent via this MessageChannel.
self.srcadr
Source INM node address.
self.srcadr
Size in bytes of the source address field in an INM message header.
SRCADR_SIZE = 1
Concrete Message subclass for standard-size INM messages.
class StandardMessage( Message )
Name of text encoding to use when making and formatting message values.
self.str_encoding
Conversion for string-formatted message values.
self.str_val_conv
Port number of TCP socket used by this InetMessageChannel.
self.tcp_port
Receive timeout.
self.timeout
If a receive timeout is set on a RoutingMessageChannel, the timeout set on each of the recv_channels will be the primary timeout divided by TIMEOUT_DIVISOR times the number of receive channels.
TIMEOUT_DIVISOR = 10.0
If a receive timeout is set on a SerialMessageChannel, the timeout set for each attempt to read data from the underlying serial port API will be the primary timeout divided by TIMEOUT_DIVISOR.
TIMEOUT_DIVISOR = 10.0
Converts the Message to a bytes object containing the message in standard binary on-wire format.
def to_bytes( self, formatter = None )
Converts the MessageHeader to a bytes object containing the header in standard binary on-wire format.
def to_bytes( self, formatter = None )
Message type identifier.
self.typ
Shorthand alias of StandardTypes.
Typ = inm.StandardTypes
Enum class to use for conversion of message type identifiers.
self.type_enum_class
Port number of UDP socket used by this InetMessageChannel.
self.udp_port
Message value/payload.
self.val
Shorthand alias of ValueConversions.
VC = inm.ValueConversions
A datetime.timedelta representing a zero duration.
ZERO_DURATION = datetime.timedelta( )