http.c File Reference

#include <ctype.h>
#include <errno.h>
#include <unistd.h>
#include <string.h>
#include <signal.h>
#include <sys/types.h>
#include <sys/socket.h>
#include "gwlib.h"
#include "gwlib/regex.h"

Include dependency graph for http.c:

Go to the source code of this file.

Data Structures

struct HTTPEntity

struct HTTPServer

struct HTTPClient

struct port

struct server

Defines

#define DUMP_RESPONSE   1

#define HTTP_SERVER_TIMEOUT   60

#define HTTP_MAX_FOLLOW   5

#define MAX_SERVERS   32

#define MAX_HEADER_LENGTH   256

Enumerations

enum { HTTP_PORT = 80, HTTPS_PORT = 443 }

enum { limbo, running, terminating }

enum body_expectation { expect_no_body, expect_body_if_indicated, expect_body }

enum entity_state {
  reading_headers, reading_chunked_body_len, reading_chunked_body_data, reading_chunked_body_crlf,
  reading_chunked_body_trailer, reading_body_until_eof, reading_body_with_length, body_error,
  entity_done
}

Functions

int read_some_headers (Connection *conn, List *headers)

int parse_http_version (Octstr *version)

void proxy_add_authentication (List *headers)

void proxy_init (void)

void proxy_shutdown (void)

int proxy_used_for_host (Octstr *host, Octstr *url)

void http_use_proxy (Octstr *hostname, int port, int ssl, List *exceptions, Octstr *username, Octstr *password, Octstr *exceptions_regex)

void http_close_proxy (void)

void deduce_body_state (HTTPEntity *ent)

HTTPEntity * entity_create (enum body_expectation exp)

void entity_destroy (HTTPEntity *ent)

void read_chunked_body_len (HTTPEntity *ent, Connection *conn)

void read_chunked_body_data (HTTPEntity *ent, Connection *conn)

void read_chunked_body_crlf (HTTPEntity *ent, Connection *conn)

void read_chunked_body_trailer (HTTPEntity *ent, Connection *conn)

void read_body_until_eof (HTTPEntity *ent, Connection *conn)

void read_body_with_length (HTTPEntity *ent, Connection *conn)

int entity_read (HTTPEntity *ent, Connection *conn)

int send_request (HTTPServer *trans)

Octstr * build_response (List *headers, Octstr *body)

HTTPServer * server_create (HTTPCaller *caller, int method, Octstr *url, List *headers, Octstr *body, int follow_remaining, Octstr *certkeyfile)

void server_destroy (void *p)

void conn_pool_item_destroy (void *item)

void conn_pool_init (void)

void conn_pool_shutdown (void)

Octstr * conn_pool_key (Octstr *host, int port, int ssl, Octstr *certfile, Octstr *our_host)

Connection * conn_pool_get (Octstr *host, int port, int ssl, Octstr *certkeyfile, Octstr *our_host)

void check_pool_conn (Connection *conn, void *data)

void conn_pool_put (Connection *conn, Octstr *host, int port, int ssl, Octstr *certfile, Octstr *our_host)

HTTPCaller * http_caller_create (void)

void http_caller_destroy (HTTPCaller *caller)

void http_caller_signal_shutdown (HTTPCaller *caller)

Octstr * get_redirection_location (HTTPServer *trans)

int client_read_status (HTTPServer *trans)

int response_expectation (int method, int status)

void handle_transaction (Connection *conn, void *data)

Octstr * build_request (char *method_name, Octstr *path_or_url, Octstr *host, long port, List *headers, Octstr *request_body)

HTTPURLParse * http_urlparse_create (void)

void http_urlparse_destroy (HTTPURLParse *p)

void parse_dump (HTTPURLParse *p)

HTTPURLParse * parse_url (Octstr *url)

void parse2trans (HTTPURLParse *p, HTTPServer *t)

Connection * get_connection (HTTPServer *trans)

void write_request_thread (void *arg)

void start_client_threads (void)

void http_set_interface (const Octstr *our_host)

void http_set_client_timeout (long timeout)

void http_start_request (HTTPCaller *caller, int method, Octstr *url, List *headers, Octstr *body, int follow, void *id, Octstr *certkeyfile)

void * http_receive_result_real (HTTPCaller *caller, int *status, Octstr **final_url, List **headers, Octstr **body, int blocking)

int http_get_real (int method, Octstr *url, List *request_headers, Octstr **final_url, List **reply_headers, Octstr **reply_body)

void client_init (void)

void client_shutdown (void)

HTTPClient * client_create (int port, Connection *conn, Octstr *ip)

void client_destroy (void *client)

void client_reset (HTTPClient *p)

int client_is_persistent (List *headers, int use_version_1_0)

int port_match (void *client, void *port)

void port_init (void)

void port_shutdown (void)

Octstr * port_key (int port)

void port_add (int port)

void port_remove (int port)

void port_put_request (HTTPClient *client)

HTTPClient * port_get_request (int port)

int parse_request_line (int *method, Octstr **url, int *use_version_1_0, Octstr *line)

void receive_request (Connection *conn, void *data)

void server_thread (void *dummy)

void start_server_thread (void)

int http_open_port_if (int port, int ssl, Octstr *interface)

int http_open_port (int port, int ssl)

void http_close_port (int port)

void http_close_all_ports (void)

List * parse_cgivars (Octstr *url)

HTTPClient * http_accept_request (int port, Octstr **client_ip, Octstr **url, List **headers, Octstr **body, List **cgivars)

const char * http_reason_phrase (int status)

void http_send_reply (HTTPClient *client, int status, List *headers, Octstr *body)

void http_close_client (HTTPClient *client)

void server_init (void)

void destroy_struct_server (void *p)

void destroy_int_pointer (void *p)

void server_shutdown (void)

void http_destroy_cgiargs (List *args)

Octstr * http_cgi_variable (List *list, char *name)

int header_is_called (Octstr *header, char *name)

List * http_create_empty_headers (void)

void http_destroy_headers (List *headers)

void http_header_add (List *headers, char *name, char *contents)

void http_header_get (List *headers, long i, Octstr **name, Octstr **value)

Octstr * http_header_value (List *headers, Octstr *name)

List * http_header_duplicate (List *headers)

void http_header_pack (List *headers)

void http_append_headers (List *to, List *from)

void http_header_combine (List *old_headers, List *new_headers)

Octstr * http_header_find_first_real (List *headers, char *name, const char *file, long line, const char *func)

List * http_header_find_all (List *headers, char *name)

long http_header_remove_all (List *headers, char *name)

void http_remove_hop_headers (List *headers)

void http_header_mark_transformation (List *headers, Octstr *new_body, Octstr *new_type)

void http_header_get_content_type (List *headers, Octstr **type, Octstr **charset)

void http_header_add_element (List *list, Octstr *value, long start, long end)

long http_header_quoted_string_len (Octstr *header, long start)

List * http_header_split_value (Octstr *value)

List * http_header_split_auth_value (Octstr *value)

void http_header_dump (List *headers)

void http_cgivar_dump (List *cgiargs)

void http_cgivar_dump_into (List *cgiargs, Octstr *os)

int http_something_accepted (List *headers, char *header_name, char *what)

int http_type_accepted (List *headers, char *type)

int http_charset_accepted (List *headers, char *charset)

void http_add_basic_auth (List *headers, Octstr *username, Octstr *password)

Octstr * http_get_header_parameter (Octstr *value, Octstr *parameter)

void http_init (void)

void http_shutdown (void)

int http_status_class (int code)

int http_name2method (Octstr *method)

char * http_method2name (int method)

Variables

int http_client_timeout = 240

enum { ... } run_status

Octstr * http_interface = NULL

Mutex * proxy_mutex = NULL

Octstr * proxy_hostname = NULL

int proxy_port = 0

int proxy_ssl = 0

Octstr * proxy_username = NULL

Octstr * proxy_password = NULL

List * proxy_exceptions = NULL

regex_t * proxy_exceptions_regex = NULL

List * pending_requests = NULL

Mutex * client_thread_lock = NULL

volatile sig_atomic_t client_threads_are_running = 0

FDSet * client_fdset = NULL

char * http_methods []

Dict * conn_pool

Mutex * conn_pool_lock

List * active_connections

Mutex * port_mutex = NULL

Dict * port_collection = NULL

Mutex * server_thread_lock = NULL

volatile sig_atomic_t server_thread_is_running = 0

long server_thread_id = -1

FDSet * server_fdset = NULL

List * new_server_sockets = NULL

List * closed_server_sockets = NULL

int keep_servers_open = 0

Define Documentation

#define DUMP_RESPONSE 1

Definition at line 88 of file http.c.

#define HTTP_MAX_FOLLOW 5

Definition at line 651 of file http.c.

#define HTTP_SERVER_TIMEOUT 60

Definition at line 94 of file http.c.
Referenced by start_server_thread().

#define MAX_HEADER_LENGTH 256

Definition at line 2819 of file http.c.

#define MAX_SERVERS 32

Definition at line 2052 of file http.c.
Referenced by server_thread().

Enumeration Type Documentation

anonymous enum

Enumeration values:

HTTP_PORT

HTTPS_PORT

Definition at line 104 of file http.c.
00104 { HTTP_PORT = 80, 00105 HTTPS_PORT = 443 };

anonymous enum

Enumeration values:

limbo

running

terminating

Definition at line 111 of file http.c.
00111 { 00112 limbo, 00113 running, 00114 terminating 00115 } run_status = limbo;

enum body_expectation

Enumeration values:

expect_no_body

expect_body_if_indicated

expect_body

Definition at line 329 of file http.c.
00329 { 00330 /* 00331 * Message must not have a body, even if the headers indicate one. 00332 * (i.e. response to HEAD method). 00333 */ 00334 expect_no_body, 00335 /* 00336 * Message will have a body if Content-Length or Transfer-Encoding 00337 * headers are present (i.e. most request methods). 00338 */ 00339 expect_body_if_indicated, 00340 /* 00341 * Message will have a body, possibly zero-length. 00342 * (i.e. 200 OK responses to a GET method.) 00343 */ 00344 expect_body 00345 };

enum entity_state

Enumeration values:

reading_headers

reading_chunked_body_len

reading_chunked_body_data

reading_chunked_body_crlf

reading_chunked_body_trailer

reading_body_until_eof

reading_body_with_length

body_error

entity_done

Definition at line 347 of file http.c.
Referenced by entity_read().
00347 { 00348 reading_headers, 00349 reading_chunked_body_len, 00350 reading_chunked_body_data, 00351 reading_chunked_body_crlf, 00352 reading_chunked_body_trailer, 00353 reading_body_until_eof, 00354 reading_body_with_length, 00355 body_error, 00356 entity_done 00357 };

Function Documentation

Octstr* build_request ( char * method_name,

Octstr * path_or_url,

Octstr * host,

long port,

List * headers,

Octstr * request_body

) [static]

Definition at line 1170 of file http.c.
References gwlist_get(), gwlist_len(), octstr_append(), octstr_format(), octstr_format_append(), octstr_imm(), and port.
Referenced by send_request().
01173 { 01174 /* XXX headers missing */ 01175 Octstr *request; 01176 int i; 01177 01178 request = octstr_format("%s %S HTTP/1.1\r\n", 01179 method_name, path_or_url); 01180 01181 octstr_format_append(request, "Host: %S", host); 01182 if (port != HTTP_PORT) 01183 octstr_format_append(request, ":%ld", port); 01184 octstr_append(request, octstr_imm("\r\n")); 01185 #ifdef USE_KEEPALIVE 01186 octstr_append(request, octstr_imm("Connection: keep-alive\r\n")); 01187 #endif 01188 01189 for (i = 0; headers != NULL && i < gwlist_len(headers); ++i) { 01190 octstr_append(request, gwlist_get(headers, i)); 01191 octstr_append(request, octstr_imm("\r\n")); 01192 } 01193 octstr_append(request, octstr_imm("\r\n")); 01194 01195 if (request_body != NULL) 01196 octstr_append(request, request_body); 01197 01198 return request; 01199 }