Public Member Functions | Public Attributes | Static Public Attributes

rpki.http.http_queue Class Reference

Inherits object.

Collaboration diagram for rpki.http.http_queue:
Collaboration graph

List of all members.

Public Member Functions

def __init__
def detach
def request
def restart
def return_result
def send_request

Public Attributes

 client
 hostport
 queue

Static Public Attributes

 log = log_method

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 766 of file http.py.


Member Function Documentation

def rpki.http.http_queue.__init__ (   self,
  hostport 
)

Definition at line 775 of file http.py.

def rpki.http.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 819 of file http.py.

def rpki.http.http_queue.request (   self,
  requests 
)
Append http_request object(s) to this queue.

Definition at line 781 of file http.py.

def rpki.http.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 788 of file http.py.

def rpki.http.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 830 of file http.py.

def rpki.http.http_queue.send_request (   self  ) 
Kick out the next query in this queue, if any.

Definition at line 812 of file http.py.


Member Data Documentation

Definition at line 778 of file http.py.

Definition at line 777 of file http.py.

rpki.http.http_queue.log = log_method [static]

Definition at line 773 of file http.py.

Definition at line 779 of file http.py.


The documentation for this class was generated from the following file:
 All Classes Namespaces Files Functions Variables