Create a Socket associated with this Context. Parameters ---------- socket_type : int The socket type, which can

s.connect(addr) Connect to a remote 0MQ socket. Returns a context manager which will call disconnect on exit. .. versionadd

wait for me to finish, like Thread.join. Reimplemented appropriately by subclasses.

Poll the registered 0MQ or native fds for I/O. If there are currently events ready to be processed, this function will return immediately.

s.bind(addr) Bind the socket to an address. This causes the socket to listen on a network port. Sockets on the other side of

wrap send_multipart to prevent state_changed on each partial send

call recv in a way that raises if there is nothing to receive

Returns a global Context instance. Most single-process applications have a single, global Context. Use this method instead of passing

call recv_multipart in a way that raises if there is nothing to receive

Create a bound socket pair using a random port.

p.register(socket, flags=POLLIN|POLLOUT) Register a 0MQ socket or native fd for I/O monitoring. register(s,0) is equivalent to unreg

Close or terminate the context. Context termination is performed in the following steps: - Any blocking operations currently in prog

send, which will only block current greenlet state_changed always fires exactly once (success or fail) at the end of this method.

internal utility for checking zmq return condition and raising the appropriate Exception class

recv, which will only block current greenlet state_changed always fires exactly once (success or fail) at the end of this method.

set default socket options for new sockets created by this Context .. versionadded:: 13.0

Create and bind the ZAP socket

trigger state_changed on getsockopt(EVENTS)

wrap recv_multipart to prevent state_changed on each partial recv

Bind this socket to a random port in a range. If the port range is unspecified, the system will choose the port. Parameters

get default socket options for new sockets created by this Context .. versionadded:: 13.0

internal utility for checking zmq return condition and raising the appropriate Exception class

recv_into, which will only block current greenlet

Remove a 0MQ socket or native fd for I/O monitoring. Parameters ---------- socket : Socket The socket instance to

Check if client can connect to server using tcp transport

Return edge-triggered file descriptor for this socket. This is a read-only edge-triggered file descriptor for both read and write events on t

Receive a Python object as a message using json to serialize. Keyword arguments are passed on to json.loads Parameters -----

Format a record.

Is the garbage collection thread currently running? Includes checks for process shutdown or fork.

set socket option

Check for libzmq raises ZMQVersionError if current zmq version is not at least min_version min_version_info is a tuple of integers, and will

Send a Python object as a message using json to serialize. Keyword arguments are passed on to json.dumps Parameters --------

Shadow an existing libzmq socket address is a zmq.Socket or an integer (or FFI pointer) representing the address of the libzmq socket

start a timer to fire only once like signal.alarm, but with better resolution than integer seconds.

Allow IP address(es). Connections from addresses not explicitly allowed will be rejected. - For NULL, all clients from this address

Fixture to create sockets, while tracking them for cleanup

raise ENOTSUP if socket is closed Does not do a deep check

Enqueue a random port on the given interface for binding on in_socket. See zmq.Socket.bind_to_random_port for details. .. ve

Close all sockets associated with this context and then terminate the context. .. warning:: destroy involves calling :me

Returns the current thread’s IOLoop.

make a call, retrying if interrupted with EINTR

Log a message to stderr

Receive a message with a custom deserialization function. .. versionadded:: 17 Parameters ---------- deserialize : c

Send a message with a custom serialization function. .. versionadded:: 17 Parameters ---------- msg : The message to

Get event loop Notice if event loop has changed, and register init_io_state on activation of a new event loop

Send a ZAP reply to finish the authentication.

Enqueue a random port on the given interface for binding on out_socket. See zmq.Socket.bind_to_random_port for details. .. v

Close the socket. If linger is specified, LINGER sockopt will be set prior to closing. Note: closing a zmq Socket may not c

Receive a Python object as a message using UNSAFE pickle to serialize. .. warning:: Never deserialize an untrusted mess

Receive a unicode string, as sent by send_string. Parameters ---------- flags : int Any valid flags for :func:`So

Send a Python object as a message using pickle to serialize. .. warning:: Never deserialize an untrusted message with p

Configure CURVE authentication for a given domain. CURVE authentication uses a directory that holds all public client certificates, i

Disconnect from a remote 0MQ socket (undoes a call to connect). .. versionadded:: libzmq-3.2 .. versionadded:: 13.0

Return a connected PAIR socket ready to receive the event notifications. .. versionadded:: libzmq-4.0 .. versionadded:: 14.0

Register a callback to be called on each send There will be two arguments:: callback(msg, status) * `msg` will be the l

Send a Python unicode string as a message with an encoding. 0MQ communicates with raw bytes, so you must encode/decode text (str) aro

Stop the authentication thread

Close the ZAP socket

Subscribe to a topic Only for SUB sockets. .. versionadded:: 15.3

Wait for 0MQ to be done with the message or until `timeout`. Parameters ---------- timeout : float default: -1, w

Get a C buffer from a memoryview

cast an address input to bytes Expects a str, but accepts bytes and raises informative TypeError otherwise.

getsockopt, retrying interrupted calls checks rc, raising ZMQError on failure.

Enqueue a random port on the given interface for binding on mon_socket. See zmq.Socket.bind_to_random_port for details. .. v

Flush pending messages. This method safely handles all pending incoming and/or outgoing messages, bypassing the inner loop, passing t

Get a Frame option or property. See the 0MQ API documentation for zmq_msg_get and zmq_msg_gets for details on specific optio

Get the value of a socket option. See the 0MQ API documentation for details on specific options. .. versionchanged:: 27

Override in subclass

Receive a message. With flags=NOBLOCK, this raises :class:`ZMQError` if no messages have arrived; otherwise, this waits unti

wrap run_device in try/catch ETERM

Returns True if we are currently sending to the stream.

Set socket options. See the 0MQ API documentation for details on specific options. Parameters ---------- op

Start the authentication thread