atexit callback sets _stay_down flag so that gc doesn't try to start up again in other atexit handlers

Chain result through serialization to recvd

Chain cancellation from f to recvd

clear any ioloop event handler called once at close

Deserialize with Futures

callback for unsetting _flushed flag.

get default sockopts as attributes

no-op on non-Windows

Get selector-compatible loop Returns an object with ``add_reader`` family of methods, either the loop itself or a SelectorThread instance.

initialize the ioloop event handler

initialize the ioloop event handler

Function for actually starting a paramiko tunnel, to be passed to multiprocessing.Process(target=this), and not called directly.

The PUSH socket for use in the zmq message destructor callback.

Make sure that futures are removed from the event list when they resolve Avoids delaying cleanup until the next send/recv event, whic

set default sockopts as attributes

Try passwordless login with shell ssh command.

Unschedule callback for a raw socket

Unschedule callback for a raw socket

Schedule callback for a raw socket

Schedule callback for a raw socket

Bind the socket to an address. This causes the socket to listen on a network port. Sockets on the other side of this connect

The message content as a Python bytes object. The first time this property is accessed, a copy of the message contents is made. From

Cancel underlying poll if request has been cancelled

cast unicode or bytes to bytes

cast bytes or unicode to unicode

Check that zmq.h has an appropriate version.

Close the socket. If linger is specified, LINGER sockopt will be set prior to closing. This can be called to close the sock

Whether the socket is closed

Configure GSSAPI authentication Currently this is a no-op because there is nothing to configure with GSSAPI.

Connect to a remote 0MQ socket. Parameters ---------- addr : str The address string. This has the form '

Enqueue ZMQ address for connecting on ctrl_socket. See zmq.Socket.connect for details.

Consume messages

Decorator for adding a Context to a function. Usage:: @context() def foo(ctx): ... .. versionadded:: 15.3

Fixture for shared context

Fixture to track contexts used in tests For cleanup purposes

Create a bound socket pair using a random port.

Create zmq certificates. Returns the file paths to the public and secret certificate files.

Create CURVE certificates for a test

generate a Z85 key pair for use with zmq.CURVE security Requires libzmq (≥ 4.0) to have been built with CURVE support. .. versionadded:: lib

generate a Z85 key pair for use with zmq.CURVE security Requires libzmq (≥ 4.0) to have been built with CURVE support. Returns -------

Compute the public key corresponding to a secret key for use with zmq.CURVE security Requires libzmq (≥ 4.2) to have been built with CURVE su

Compute the public key corresponding to a private key for use with zmq.CURVE security Requires libzmq (≥ 4.2) to have been built with CURVE s

generate `enum: ZMQ_CONST` block for constant_enums.pxi

decode Z85 bytes to raw bytes, accepts ASCII string

Start a zeromq device (gevent-compatible). Unlike the true zmq.device, this does not release the GIL. Parameters ---------- device_t

Deprecated alias for zmq.proxy .. deprecated:: libzmq-3.2 .. deprecated:: 13.0