drops the data in the buffer and reports them as written

Releases this connection object. When a connection object is released, all :class:`Session` and :class:`Link` objects associ

Get the subject from the peer's certificate. :return: A string containing the full subject.

Tracer initializer.

Test if local ``endpoint`` is closed (ie has state :const:`proton.Endpoint.LOCAL_CLOSED`). :param endpoint: The local endpoi

Test if local ``endpoint`` is uninitialised (ie has state :const:`proton.Endpoint.LOCAL_UNINIT`). :param endpoint: The local

Test if remote ``endpoint`` is open (ie has state :const:`proton.Endpoint.LOCAL_ACTIVE`). :param endpoint: The remote endpoi

TLS close requires best efforts to send final closure or error alert record. Peer is not obligated to wait for it.

linkClosed is called when a link has been closed by both ends. It removes the link from the handlers maps and stops its goroutine.

Unsubscribe from the queue of interest to this link. */

call with lock held and task.working false

Log a message using a transport's logging mechanism. This can be useful in a debugging context as the log message will be pr

Call with sched lock

Performs equivalent check of std::fabs(lhs - rhs) <= margin But without the subtraction to allow for INFINITY in comparison

Call in proton goroutine. Max additional credit we can request.

sigh - would be nice if proton exported pn_strdup()

AMQP pair linked by TCP socket

Set the error condition, but don't close the driver. */

Returns ``size`` bytes from the head of the transport. It is an error to call this with a value of ``size`` that is greater