* \brief Implement directory HTTP protocol.
**/
+/* In-points to directory.c:
+ *
+ * - directory_post_to_dirservers(), called from
+ * router_upload_dir_desc_to_dirservers() in router.c
+ * upload_service_descriptor() in rendservice.c
+ * - directory_get_from_dirserver(), called from
+ * rend_client_refetch_renddesc() in rendclient.c
+ * run_scheduled_events() in main.c
+ * do_hup() in main.c
+ * - connection_dir_process_inbuf(), called from
+ * connection_process_inbuf() in connection.c
+ * - connection_dir_finished_flushing(), called from
+ * connection_finished_flushing() in connection.c
+ * - connection_dir_finished_connecting(), called from
+ * connection_finished_connecting() in connection.c
+ */
+
+static void
+directory_initiate_command(routerinfo_t *router, uint8_t purpose,
+ const char *payload, int payload_len);
static void directory_send_command(connection_t *conn, int purpose,
const char *payload, int payload_len);
static int directory_handle_command(connection_t *conn);
/********* END VARIABLES ************/
+/** Start a connection to every known directory server, using
+ * connection purpose 'purpose' and uploading the payload 'payload'
+ * (length 'payload_len'). The purpose should be one of
+ * 'DIR_PURPOSE_UPLOAD_DIR' or 'DIR_PURPOSE_UPLOAD_RENDDESC'.
+ */
+void
+directory_post_to_dirservers(uint8_t purpose, const char *payload,
+ int payload_len)
+{
+ int i;
+ routerinfo_t *router;
+ routerlist_t *rl;
+
+ router_get_routerlist(&rl);
+ if(!rl)
+ return;
+
+ for(i=0; i < smartlist_len(rl->routers); i++) {
+ router = smartlist_get(rl->routers, i);
+ if(router->dir_port > 0)
+ directory_initiate_command(router, purpose, payload, payload_len);
+ }
+}
+
+/** Start a connection to a random running directory server, using
+ * connection purpose 'purpose' requesting 'payload' (length
+ * 'payload_len'). The purpose should be one of
+ * 'DIR_PURPOSE_FETCH_DIR' or 'DIR_PURPOSE_FETCH_RENDDESC'.
+ */
+void
+directory_get_from_dirserver(uint8_t purpose, const char *payload,
+ int payload_len)
+{
+ directory_initiate_command(router_pick_directory_server(),
+ purpose, payload, payload_len);
+}
+
/** Launch a new connection to the directory server <b>router</b> to upload or
* download a service or rendezvous descriptor. <b>purpose</b> determines what
* kind of directory connection we're launching, and must be one of
* of the HTTP post. When fetching a rendezvous descriptor, <b>payload</b>
* and <b>payload_len</b> are the service ID we want to fetch.
*/
-void directory_initiate_command(routerinfo_t *router, int purpose,
- const char *payload, int payload_len) {
+static void
+directory_initiate_command(routerinfo_t *router, uint8_t purpose,
+ const char *payload, int payload_len)
+{
connection_t *conn;
switch (purpose)
* null-terminate it (this modifies headers!) and return 0.
* Otherwise, return -1.
*/
-int parse_http_url(char *headers, char **url) {
+static int
+parse_http_url(char *headers, char **url)
+{
char *s, *tmp;
s = (char *)eat_whitespace_no_nl(headers);
* (else leave it alone), and return 0.
* Otherwise, return -1.
*/
-int parse_http_response(char *headers, int *code, char **message) {
+static int
+parse_http_response(char *headers, int *code, char **message)
+{
int n1, n2;
tor_assert(headers && code);
* service descriptor. On finding one, write a response into
* conn-\>outbuf. If the request is unrecognized, send a 404.
* Always return 0. */
-static int directory_handle_command_get(connection_t *conn,
- char *headers, char *body,
- int body_len) {
+static int
+directory_handle_command_get(connection_t *conn, char *headers,
+ char *body, int body_len)
+{
size_t dlen;
const char *cp;
char *url;
* service descriptor. On finding one, process it and write a
* response into conn-\>outbuf. If the request is unrecognized, send a
* 404. Always return 0. */
-static int directory_handle_command_post(connection_t *conn,
- char *headers, char *body,
- int body_len) {
+static int
+directory_handle_command_post(connection_t *conn, char *headers,
+ char *body, int body_len)
+{
const char *cp;
char *url;
log_fn(LOG_INFO, "A directory has arrived.");
- /* just for testing */
-// directory_initiate_command(router_pick_directory_server(),
-// DIR_PURPOSE_FETCH_RENDDESC, "foo", 3);
-
has_fetched_directory=1;
if(options.ORPort) { /* connect to them all */
if(!options.DirPort) {
/* NOTE directory servers do not currently fetch directories.
* Hope this doesn't bite us later. */
- directory_initiate_command(router_pick_directory_server(),
- DIR_PURPOSE_FETCH_DIR, NULL, 0);
+ directory_get_from_dirserver(DIR_PURPOSE_FETCH_DIR, NULL, 0);
} else {
/* We're a directory; dump any old descriptors. */
dirserv_remove_old_servers();
rend_services_introduce();
} else {
/* fetch a new directory */
- directory_initiate_command(router_pick_directory_server(),
- DIR_PURPOSE_FETCH_DIR, NULL, 0);
+ directory_get_from_dirserver(DIR_PURPOSE_FETCH_DIR, NULL, 0);
}
if(options.ORPort) {
router_rebuild_descriptor();
extern char *circuit_state_to_string[];
circuit_t *circuit_new(uint16_t p_circ_id, connection_t *p_conn);
void circuit_close_all_marked(void);
-void circuit_free_cpath(crypt_path_t *cpath);
int _circuit_mark_for_close(circuit_t *circ);
#define circuit_mark_for_close(c) \
/********************************* directory.c ***************************/
-void directory_initiate_command(routerinfo_t *router, int purpose,
- const char *payload, int payload_len);
+void directory_post_to_dirservers(uint8_t purpose, const char *payload,
+ int payload_len);
+void directory_get_from_dirserver(uint8_t purpose, const char *payload,
+ int payload_len);
int connection_dir_process_inbuf(connection_t *conn);
int connection_dir_finished_flushing(connection_t *conn);
int connection_dir_finished_connecting(connection_t *conn);
char *rend_client_get_random_intro(char *query);
int rend_parse_rendezvous_address(char *address);
-int rend_client_send_establish_rendezvous(circuit_t *circ);
int rend_client_send_introduction(circuit_t *introcirc, circuit_t *rendcirc);
/********************************* rendcommon.c ***************************/
void router_retry_connections(void);
void router_upload_dir_desc_to_dirservers(void);
-void router_post_to_dirservers(uint8_t purpose, const char *payload, int payload_len);
int router_compare_to_my_exit_policy(connection_t *conn);
routerinfo_t *router_get_my_routerinfo(void);
const char *router_get_my_descriptor(void);
log_fn(LOG_WARN, "No descriptor; skipping upload");
return;
}
- router_post_to_dirservers(DIR_PURPOSE_UPLOAD_DIR, s, strlen(s));
-}
-
-/** Start a connection to every known directory server, using
- * connection purpose 'purpose' and uploading the payload 'payload'
- * (length 'payload_len'). The purpose should be one of
- * 'DIR_PURPOSE_UPLOAD_DIR' or 'DIR_PURPOSE_UPLOAD_RENDDESC'.
- */
-/* XXXX This is misnamed; it shouldn't be a router-only function; it should
- * XXXX be in directory, since rendservice uses it too. */
-void router_post_to_dirservers(uint8_t purpose, const char *payload, int payload_len) {
- int i;
- routerinfo_t *router;
- routerlist_t *rl;
-
- router_get_routerlist(&rl);
- if(!rl)
- return;
-
- for(i=0; i < smartlist_len(rl->routers); i++) {
- router = smartlist_get(rl->routers, i);
- if(router->dir_port > 0)
- directory_initiate_command(router, purpose, payload, payload_len);
- }
+ directory_post_to_dirservers(DIR_PURPOSE_UPLOAD_DIR, s, strlen(s));
}
/** Append the comma-separated sequence of exit policies in <b>s</b> to the
projects / thirdparty / tor.git / commitdiff
