[or-cvs] bugfixes and features: closer to making dirserv work
Roger Dingledine
arma at seul.org
Mon Sep 29 23:14:51 UTC 2003
Update of /home/or/cvsroot/src/or
In directory moria.mit.edu:/home2/arma/work/onion/cvs/src/or
Modified Files:
command.c directory.c dirserv.c main.c routers.c
Log Message:
bugfixes and features: closer to making dirserv work
fix a variety of seg faults
don't try to list OPs in running-routers
write cached-directory to disk when rebuilding the dir
on boot, dirservers load approved-routers file
on boot, dirservers load cached directory file
Index: command.c
===================================================================
RCS file: /home/or/cvsroot/src/or/command.c,v
retrieving revision 1.39
retrieving revision 1.40
diff -u -d -r1.39 -r1.40
--- command.c 27 Sep 2003 21:09:55 -0000 1.39
+++ command.c 29 Sep 2003 23:14:49 -0000 1.40
@@ -118,7 +118,7 @@
circ = circuit_get_by_aci_conn(cell->aci, conn);
if(!circ) {
- log_fn(LOG_WARNING,"received CREATED cell (aci %d) for unknown circ. Dropping.", cell->aci);
+ log_fn(LOG_INFO,"(aci %d) unknown circ (probably got a destroy earlier). Dropping.", cell->aci);
return;
}
Index: directory.c
===================================================================
RCS file: /home/or/cvsroot/src/or/directory.c,v
retrieving revision 1.38
retrieving revision 1.39
diff -u -d -r1.38 -r1.39
--- directory.c 29 Sep 2003 07:50:08 -0000 1.38
+++ directory.c 29 Sep 2003 23:14:49 -0000 1.39
@@ -186,6 +186,7 @@
log_fn(LOG_DEBUG,"headers '%s', body '%s'.",headers,body);
if(!strncasecmp(headers,"GET",3)) {
/* XXX should check url and http version */
+ log_fn(LOG_DEBUG,"Received GET command.");
dlen = dirserv_get_directory(&cp);
@@ -206,7 +207,7 @@
if(!strncasecmp(headers,"POST",4)) {
/* XXX should check url and http version */
- log_fn(LOG_DEBUG,"Received POST command, body '%s'", body);
+ log_fn(LOG_DEBUG,"Received POST command.");
cp = body;
if(dirserv_add_descriptor(&cp) < 0) {
log_fn(LOG_WARNING,"dirserv_add_descriptor() failed. Dropping.");
Index: dirserv.c
===================================================================
RCS file: /home/or/cvsroot/src/or/dirserv.c,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -d -r1.3 -r1.4
--- dirserv.c 29 Sep 2003 07:50:08 -0000 1.3
+++ dirserv.c 29 Sep 2003 23:14:49 -0000 1.4
@@ -4,6 +4,8 @@
#include "or.h"
+extern or_options_t options; /* command-line and config-file options */
+
static int the_directory_is_dirty = 1;
static char *the_directory = NULL;
static int the_directory_len = -1;
@@ -155,7 +157,7 @@
routerinfo_t *ri = NULL;
int i;
char *start, *end;
- char *desc_tmp = NULL;
+ char *desc_tmp = NULL, *cp;
size_t desc_len;
start = strstr(*desc, "router ");
@@ -170,12 +172,12 @@
end = start+strlen(start);
}
desc_len = end-start;
- desc_tmp = tor_malloc(desc_len+1);
+ cp = desc_tmp = tor_malloc(desc_len+1);
strncpy(desc_tmp, start, desc_len);
desc_tmp[desc_len]='\0';
/* Check: is the descriptor syntactically valid? */
- ri = router_get_entry_from_string(&desc_tmp);
+ ri = router_get_entry_from_string(&cp);
if (!ri) {
log(LOG_WARNING, "Couldn't parse descriptor");
goto err;
@@ -198,6 +200,7 @@
/* if so, decide whether to update it. */
if ((*desc_ent_ptr)->published > ri->published_on) {
/* We already have a newer descriptor */
+ log_fn(LOG_INFO,"We already have a newer desc for nickname %s. Ignoring.",ri->nickname);
goto err;
}
/* We don't have a newer one; we'll update this one. */
@@ -278,7 +281,7 @@
for (i = 0; i < n_descriptors; ++i) {
strncat(cp, descriptor_list[i]->descriptor, descriptor_list[i]->desc_len);
cp += descriptor_list[i]->desc_len;
- assert(!cp);
+ assert(!*cp);
}
/* These multiple strlen calls are inefficient, but dwarfed by the RSA
signature.
@@ -322,6 +325,7 @@
size_t dirserv_get_directory(const char **directory)
{
char *new_directory;
+ char filename[512];
if (the_directory_is_dirty) {
new_directory = tor_malloc(MAX_DIR_SIZE);
if (dirserv_dump_directory_to_string(new_directory, MAX_DIR_SIZE,
@@ -341,11 +345,16 @@
* router lists. This does more signature checking than is strictly
* necessary, but safe is better than sorry. */
new_directory = strdup(the_directory);
+ /* use a new copy of the dir, since get_dir_from_string scribbles on it */
if (router_get_dir_from_string(new_directory, get_identity_key())) {
log_fn(LOG_ERR, "We just generated a directory we can't parse. Dying.");
exit(0);
}
free(new_directory);
+ sprintf(filename,"%s/cached-directory", options.DataDirectory);
+ if(write_str_to_file(filename,the_directory) < 0) {
+ log_fn(LOG_WARNING, "Couldn't write cached directory to disk. Ignoring.");
+ }
} else {
log(LOG_INFO,"Directory still clean, reusing.");
}
Index: main.c
===================================================================
RCS file: /home/or/cvsroot/src/or/main.c,v
retrieving revision 1.111
retrieving revision 1.112
diff -u -d -r1.111 -r1.112
--- main.c 29 Sep 2003 07:50:08 -0000 1.111
+++ main.c 29 Sep 2003 23:14:49 -0000 1.112
@@ -502,7 +502,8 @@
crypto_pk_env_t *prkey;
/* OP's don't need keys. Just initialize the TLS context.*/
- if (!options.OnionRouter && !options.DirPort) {
+ if (!options.OnionRouter) {
+ assert(!options.DirPort);
if (tor_tls_context_new(NULL, 0, NULL)<0) {
log_fn(LOG_ERR, "Error creating TLS context for OP.");
return -1;
@@ -514,32 +515,31 @@
log_fn(LOG_ERR, "DataDirectory is too long.");
return -1;
}
- strcpy(keydir, options.DataDirectory);
- if (check_private_dir(keydir, 1)) {
+ if (check_private_dir(options.DataDirectory, 1)) {
return -1;
}
- strcat(keydir, "/keys");
+ sprintf(keydir,"%s/keys",options.DataDirectory);
if (check_private_dir(keydir, 1)) {
return -1;
}
cp = keydir + strlen(keydir); /* End of string. */
- assert(!*cp);
/* 1. Read identity key. Make it if none is found. */
- strcat(keydir, "/identity.key");
+ strcpy(cp, "/identity.key");
+ log_fn(LOG_INFO,"Reading/making identity key %s...",keydir);
prkey = init_key_from_file(keydir);
if (!prkey) return -1;
set_identity_key(prkey);
/* 2. Read onion key. Make it if none is found. */
- *cp = '\0';
- strcat(keydir, "/onion.key");
+ strcpy(cp, "/onion.key");
+ log_fn(LOG_INFO,"Reading/making onion key %s...",keydir);
prkey = init_key_from_file(keydir);
if (!prkey) return -1;
set_onion_key(prkey);
/* 3. Initialize link key and TLS context. */
- *cp = '\0';
- strcat(keydir, "/link.key");
+ strcpy(cp, "/link.key");
+ log_fn(LOG_INFO,"Reading/making link key %s...",keydir);
prkey = init_key_from_file(keydir);
if (!prkey) return -1;
set_link_key(prkey);
@@ -553,14 +553,14 @@
log_fn(LOG_ERR, "Error initializing descriptor.");
return -1;
}
- strcpy(keydir, options.DataDirectory);
- strcat(keydir, "/router.desc");
+ sprintf(keydir,"%s/router.desc", options.DataDirectory);
+ log_fn(LOG_INFO,"Dumping descriptor to %s...",keydir);
if (write_str_to_file(keydir, router_get_my_descriptor())) {
return -1;
}
/* 5. Dump fingerprint to 'fingerprint' */
- strcpy(keydir, options.DataDirectory);
- strcat(keydir, "/fingerprint");
+ sprintf(keydir,"%s/fingerprint", options.DataDirectory);
+ log_fn(LOG_INFO,"Dumping fingerprint to %s...",keydir);
assert(strlen(options.Nickname) <= MAX_NICKNAME_LEN);
strcpy(fingerprint, options.Nickname);
strcat(fingerprint, " ");
@@ -572,6 +572,30 @@
strcat(fingerprint, "\n");
if (write_str_to_file(keydir, fingerprint))
return -1;
+ if(!options.DirPort)
+ return 0;
+ /* 6. [dirserver only] load approved-routers file */
+ sprintf(keydir,"%s/approved-routers", options.DataDirectory);
+ log_fn(LOG_INFO,"Loading approved fingerprints from %s...",keydir);
+ if(dirserv_parse_fingerprint_file(keydir) < 0) {
+ log_fn(LOG_ERR, "Error loading fingerprints");
+ return -1;
+ }
+ /* 7. [dirserver only] load old directory, if it's there */
+ sprintf(keydir,"%s/cached-directory", options.DataDirectory);
+ log_fn(LOG_INFO,"Loading cached directory from %s...",keydir);
+ cp = read_file_to_str(keydir);
+ if(!cp) {
+ log_fn(LOG_INFO,"Cached directory %s not present. Ok.",keydir);
+ } else {
+ if(dirserv_init_from_directory_string(cp) < 0) {
+ log_fn(LOG_ERR, "Cached directory %s is corrupt", keydir);
+ free(cp);
+ return -1;
+ }
+ free(cp);
+ }
+ /* success */
return 0;
}
@@ -829,6 +853,8 @@
conn = connection_array[i];
if (conn->type != CONN_TYPE_OR || conn->state != OR_CONN_STATE_OPEN)
continue; /* only list successfully handshaked OR's. */
+ if(!conn->nickname) /* it's an OP, don't list it */
+ continue;
nickname_lst[n++] = conn->nickname;
}
length = n + 1; /* spaces + EOS + 1. */
Index: routers.c
===================================================================
RCS file: /home/or/cvsroot/src/or/routers.c,v
retrieving revision 1.56
retrieving revision 1.57
diff -u -d -r1.56 -r1.57
--- routers.c 28 Sep 2003 06:48:20 -0000 1.56
+++ routers.c 29 Sep 2003 23:14:49 -0000 1.57
@@ -669,7 +669,7 @@
NEXT_TOK();
TOK_IS(K_RECOMMENDED_SOFTWARE, "recommended-software");
if (tok.val.cmd.n_args != 1) {
- log_fn(LOG_WARNING, "Invalid recommded-software line");
+ log_fn(LOG_WARNING, "Invalid recommended-software line");
goto err;
}
versions = strdup(tok.val.cmd.args[0]);
@@ -677,7 +677,7 @@
NEXT_TOK();
TOK_IS(K_RUNNING_ROUTERS, "running-routers");
n_good_nicknames = tok.val.cmd.n_args;
- memcpy(good_nickname_lst, tok.val.cmd.args, n_good_nicknames);
+ memcpy(good_nickname_lst, tok.val.cmd.args, n_good_nicknames*sizeof(char *));
if (router_get_list_from_string_impl(&s, &new_dir,
n_good_nicknames, good_nickname_lst)) {
More information about the tor-commits
mailing list