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