rpki.https.http_queue Class Reference
Inherits object.
List of all members.
Detailed Description
Queue of pending HTTP requests for a single destination. This class
is very tightly coupled to http_client; http_client handles the HTTP
stream itself, this class provides a slightly higher-level API.
Definition at line 929 of file https.py.
Member Function Documentation
def rpki.https.http_queue.__init__ |
( |
|
self, |
|
|
|
hostport, |
|
|
|
cert = None , |
|
|
|
key = None , |
|
|
|
ta = () | |
|
) |
| | |
def rpki.https.http_queue.detach |
( |
|
self, |
|
|
|
client_ | |
|
) |
| | |
Detatch a client from this queue. Silently ignores attempting to
detach a client that is not attached to this queue, to simplify
handling of what otherwise would be a nasty set of race
conditions.
Definition at line 986 of file https.py.
def rpki.https.http_queue.request |
( |
|
self, |
|
|
|
requests | |
|
) |
| | |
Append http_request object(s) to this queue.
Definition at line 948 of file https.py.
def rpki.https.http_queue.restart |
( |
|
self |
) |
|
Send next request for this queue, if we can. This may involve
starting a new http_client stream, reusing an existing idle
stream, or just ignoring this request if there's an active client
stream already; in the last case, handling of the response (or
exception, or timeout) for the query currently in progress will
call this method when it's time to kick out the next query.
Definition at line 955 of file https.py.
def rpki.https.http_queue.return_result |
( |
|
self, |
|
|
|
result | |
|
) |
| | |
Client stream has returned a result, which we need to pass along
to the original caller. Result may be either an HTTP response
message or an exception. In either case, once we're done
processing this result, kick off next message in the queue, if any.
Definition at line 997 of file https.py.
def rpki.https.http_queue.send_request |
( |
|
self |
) |
|
Kick out the next query in this queue, if any.
Definition at line 979 of file https.py.
Member Data Documentation
The documentation for this class was generated from the following file: