ipserver.core package

IpServer’s Module Index

ipserver.core.pipeline module

class Pipeline

Bases: abc.ABC

closed_socket(conn_sock)

Parameters

conn_sock (ConnSock) –

closed_socket_server(socket_server)

Parameters

socket_server (SocketServer) –

complete()

complete_receive(conn_sock, receive_binary, send_binary=None)

Parameters

• conn_sock (ConnSock) –

• receive_binary (bytes) –

• send_binary (bytes) –

complete_send(conn_sock, binary)

Parameters

• conn_sock (ConnSock) –

• binary (bytes) –

connected(socket)

Parameters

socket (socket) –

create_socket(socket_server)

Parameters

socket_server (SocketServer) –

deny_socket(conn_sock)

Parameters

conn_sock (ConnSock) –

digest_auth_load(users)

Parameters

users (dict) –

digest_auth_veirfy(httpio, username, auth_data, users)

Parameters

• httpio (HttpIo) –

• username (str) –

• auth_data (dict) –

• users (dict) –

get_filename(conn_sock, direction, filename)

Parameters

• conn_sock (ConnSock) –

• direction (int) –

• filename (str) –

get_http_app_path(httpio, root_path, request_path, translate_path)

Parameters

• httpio (HttpIo) –

• root_path –

• request_path (str) –

• translate_path (str) –

init_configure(arguments, conf_ags)

Parameters

• arguments (dict) –

• conf_ags –

initialize(config, socket_server)

Parameters

• config (Config) –

• socket_server (SocketServer) –

interactive_input(action, line, conn_sock, conn_bucket)

Parameters

• action (str) –

• line (str) –

• conn_sock (ConnSock) –

• conn_bucket (ConnBucket) –

is_enable_file_upload(httpio, request_path)

Parameters

• httpio (HttpIo) –

• request_path (str) –

kick_quiet_interval(conn_bucket)

Parameters

conn_bucket (ConnBucket) –

post_accept(conn_sock, conn_bucket)

Parameters

• conn_sock (ConnSock) –

• conn_bucket (ConnBucket) –

post_configure(args)

Parameters

args (argparse.Namespace) –

post_forwarding_receive(conn_sock, binary)

Parameters

• conn_sock (ConnSock) –

• binary (bytes) –

post_http_file_upload(httpio, mpart)

Parameters

httpio (HttpIo) –

post_http_forwarding_request(httpio, forwarding_url, req_headers, res_headers, response, binary)

Parameters

• httpio (HttpIo) –

• forwarding_url (str) –

• req_headers (HTTPMessage) –

• res_headers (HTTPMessage) –

• binary (bytes) –

post_receive(conn_sock, binary)

Parameters

• conn_sock (ConnSock) –

• binary (bytes) –

post_send(conn_sock, binary)

Parameters

• conn_sock (ConnSock) –

• binary (bytes) –

pre_configure(args)

Parameters

args (argparse.Namespace) –

pre_dump_write(file, binary, filename, conn_sock, direction)

Parameters

• file (File) –

• binary (bytes) –

• filename (str) –

• conn_sock (ConnSock) –

• direction (int) –

pre_forwarding_send(conn_sock, binary)

Parameters

• conn_sock (ConnSock) –

• binary (bytes) –

pre_http_file_upload(httpio, mpart)

Parameters

httpio (HttpIo) –

pre_http_forwarding_request(httpio, forwarding_url, req_headers)

Parameters

• httpio (HttpIo) –

• forwarding_url (str) –

• req_headers (HTTPMessage) –

pre_http_process(http_opt, path, httpio)

Parameters

• http_opt (str) –

• path (str) –

• httpio (HttpIo) –

pre_http_respond(httpio)

Parameters

httpio (HttpIo) –

pre_send(conn_sock, binary)

Parameters

• conn_sock (ConnSock) –

• binary (bytes) –

start_listen(socket_server, conn_bucket)

Parameters

• socket_server (SocketServer) –

• conn_bucket (ConnBucket) –

verify_restriction(conn_sock, allow)

Parameters

• conn_sock (ConnSock) –

• allow (bool) –