RPKI Engine 1.0
|
Public Member Functions | |
def | __init__ |
def | __repr__ |
def | chunk_body |
def | chunk_discard_crlf |
def | chunk_discard_trailer |
def | chunk_header |
def | collect_incoming_data |
def | found_terminator |
def | get_buffer |
def | handle_body |
def | handle_close |
def | handle_error |
def | handle_timeout |
def | restart |
def | update_timeout |
Public Attributes | |
buffer | |
chunk_handler | |
msg | |
timer | |
Static Public Attributes | |
log = log_method | |
show_tracebacks = False |
def rpki.http.http_stream.chunk_body | ( | self | ) |
def rpki.http.http_stream.chunk_discard_crlf | ( | self | ) |
def rpki.http.http_stream.chunk_discard_trailer | ( | self | ) |
def rpki.http.http_stream.chunk_header | ( | self | ) |
def rpki.http.http_stream.collect_incoming_data | ( | self, | |
data | |||
) |
def rpki.http.http_stream.found_terminator | ( | self | ) |
Asynchat reported that it found whatever terminator we set, so figure out what to do next. This can be messy, because we can be in any of several different states: @li We might be handling chunked HTTP, in which case we have to initialize the chunk decoder; @li We might have found the end of the message body, in which case we can (finally) process it; or @li We might have just gotten to the end of the message headers, in which case we have to parse them to figure out which of three separate mechanisms (chunked, content-length, TCP close) is going to tell us how to find the end of the message body.
def rpki.http.http_stream.get_buffer | ( | self | ) |
def rpki.http.http_stream.handle_body | ( | self | ) |
def rpki.http.http_stream.handle_close | ( | self | ) |
Wrapper around asynchat connection close handler, so that we can log the event, cancel timer, and so forth.
Reimplemented in rpki.http.http_client.
def rpki.http.http_stream.handle_error | ( | self | ) |
Asynchat (or asyncore, or somebody) raised an exception. See whether it's one we should just pass along, otherwise log a stack trace and close the stream.
Reimplemented in rpki.http.http_client.
def rpki.http.http_stream.handle_timeout | ( | self | ) |
Inactivity timer expired, close connection with prejudice.
Reimplemented in rpki.http.http_client.
def rpki.http.http_stream.restart | ( | self | ) |
def rpki.http.http_stream.update_timeout | ( | self | ) |
rpki.http.http_stream.log = log_method [static] |
rpki.http.http_stream.show_tracebacks = False [static] |