http-client-private.h revision 93c9909f68f7d057e38cca3b4612ec8d0bf42999
#ifndef HTTP_CLIENT_PRIVATE_H
#define HTTP_CLIENT_PRIVATE_H
#include "connection.h"
#include "http-url.h"
#include "http-client.h"
/*
* Defaults
*/
#define HTTP_DEFAULT_PORT 80
#define HTTPS_DEFAULT_PORT 443
#define HTTP_CLIENT_DEFAULT_BACKOFF_TIME_MSECS (100)
/*
* Types
*/
struct http_client_host;
struct http_client_queue;
struct http_client_peer;
struct http_client_connection;
HASH_TABLE_DEFINE_TYPE(http_client_host, const char *,
struct http_client_host *);
struct http_client_peer *);
enum http_client_peer_addr_type {
};
struct http_client_peer_addr {
union {
struct {
const char *https_name; /* TLS SNI */
} tcp;
struct {
const char *path;
} un;
} a;
};
/*
* Objects
*/
struct http_client_request {
unsigned int refcount;
const char *label;
unsigned int id;
struct http_url origin_url;
const char *host_socket;
const char *authority;
struct http_client *client;
struct http_client_host *host;
struct http_client_queue *queue;
struct http_client_peer *peer;
struct http_client_connection *conn;
struct istream *payload_input;
struct ostream *payload_output;
struct timeval release_time;
struct timeval submit_time;
struct timeval response_time;
struct timeval timeout_time;
unsigned int timeout_msecs;
unsigned int attempts;
unsigned int redirects;
unsigned int delayed_error_status;
const char *delayed_error;
void *context;
void (*destroy_callback)(void *);
void *destroy_context;
enum http_request_state state;
unsigned int have_hdr_authorization:1;
unsigned int have_hdr_body_spec:1;
unsigned int have_hdr_connection:1;
unsigned int have_hdr_date:1;
unsigned int have_hdr_expect:1;
unsigned int have_hdr_host:1;
unsigned int have_hdr_user_agent:1;
unsigned int payload_sync:1;
unsigned int payload_sync_continue:1;
unsigned int payload_chunked:1;
unsigned int payload_wait:1;
unsigned int urgent:1;
unsigned int submitted:1;
unsigned int connect_tunnel:1;
unsigned int connect_direct:1;
unsigned int ssl_tunnel:1;
unsigned int preserve_exact_reason:1;
};
struct http_client_connection {
struct connection conn;
struct http_client_peer *peer;
struct http_client *client;
unsigned int refcount;
const char *label;
unsigned int id; // DEBUG: identify parallel connections
int connect_errno;
struct timeval connect_start_timestamp;
struct timeval connected_timestamp;
struct http_client_request *connect_request;
struct ssl_iostream *ssl_iostream;
struct http_response_parser *http_parser;
struct timeout *to_requests;
struct http_client_request *pending_request;
struct istream *incoming_payload;
struct io *io_req_payload;
struct ioloop *last_ioloop;
/* requests that have been sent, waiting for response */
connection into tunnel */
unsigned int connect_succeeded:1;
unsigned int closing:1;
unsigned int close_indicated:1;
};
struct http_client_peer {
struct http_client_peer_addr addr;
char *addr_name;
struct http_client *client;
/* queues using this peer */
/* active connections to this peer */
/* zero time-out for consolidating request handling */
struct timeout *to_req_handling;
/* connection retry */
struct timeval last_failure;
struct timeout *to_backoff;
unsigned int backoff_time_msecs;
connections */
};
struct http_client_queue {
struct http_client *client;
struct http_client_host *host;
char *name;
struct http_client_peer_addr addr;
char *addr_name;
/* current index in host->ips */
unsigned int ips_connect_idx;
/* the first IP that started the current round of connection attempts.
initially 0, and later set to the ip index of the last successful
connected IP */
unsigned int ips_connect_start_idx;
unsigned int connect_attempts;
/* peers we are trying to connect to;
this can be more than one when soft connect timeouts are enabled */
/* all requests associated to this queue
(ordered by earliest timeout first) */
/* delayed requests waiting to be released after delay */
/* requests pending in queue to be picked up by connections */
};
struct http_client_host {
struct http_client *client;
char *name;
/* the ip addresses DNS returned for this host */
unsigned int ips_count;
/* requests are managed on a per-port basis */
/* active DNS lookup */
struct dns_lookup *dns_lookup;
unsigned int unix_local:1;
};
struct http_client {
struct http_client_settings set;
struct ssl_iostream_context *ssl_ctx;
/* list of failed requests that are waiting for ioloop */
struct timeout *to_failing_requests;
struct connection_list *conn_list;
struct http_client_host *unix_host;
struct http_client_host *hosts_list;
struct http_client_peer *peers_list;
struct http_client_request *requests_list;
unsigned int requests_count;
};
/*
* Peer address
*/
static inline bool
{
return TRUE;
default:
break;
}
return FALSE;
}
static inline const char *
{
default:
break;
}
return NULL;
}
static inline const char *
{
return t_strdup_printf("[%s]:%u",
}
return t_strdup_printf("%s:%u",
default:
break;
}
i_unreached();
return "";
}
/*
* Request
*/
static inline const char *
{
}
}
static inline bool
{
}
/* Returns FALSE if unrefing destroyed the request entirely */
const struct http_response *response);
struct http_client_peer_addr *addr);
struct http_response *response);
const struct http_client_tunnel *tunnel,
struct http_response *response);
/*
* Connection
*/
static inline const char *
{
return t_strdup_printf("%s%s [%d]",
}
struct connection_list *http_client_connection_list_init(void);
struct http_client_connection *
/* Returns FALSE if unrefing destroyed the connection entirely */
struct http_client_connection *conn);
struct http_client_connection *conn);
struct http_client_connection *conn);
unsigned int
struct http_client_tunnel *tunnel);
/*
* Peer
*/
static inline const char *
{
return t_strconcat
}
}
unsigned int http_client_peer_addr_hash
(const struct http_client_peer_addr *peer1,
struct http_client_peer *
const struct http_client_peer_addr *addr);
struct http_client_queue *queue);
struct http_client_queue *queue);
struct http_client_queue *queue);
struct http_client_request *
bool no_urgent);
const char *reason);
unsigned int
unsigned int
/*
* Queue
*/
struct http_client_queue *
const struct http_client_peer_addr *addr);
struct http_client_request *req);
void
struct http_client_request *req);
struct http_client_request *
unsigned int
void
const struct http_client_peer_addr *addr);
/*
* Host
*/
static inline unsigned int
{
unsigned int i;
return i;
}
i_unreached();
}
struct http_client_host *
struct http_client_request *req);
/*
* Client
*/
const char **error_r);
struct http_client_request *req);
struct http_client_request *req);
#endif