nihilist/tor
1
0
Fork 0
mirror of https://gitlab.torproject.org/tpo/core/tor.git synced 2024-11-30 15:43:32 +01:00
Code Issues Packages Projects Releases Wiki Activity

log more verbosely when we accept or decline a router descriptor,

Browse Source 
to help track whether we received them when a relay operator claims
they got sent.


svn:r19213
This commit is contained in:
Roger Dingledine 2009-04-01 13:02:04 +00:00
parent b4ceb830e0
commit ee58153b50
5 changed files with 33 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/or/directory.c
View File

@ -267,7 +267,7 @@ directory_post_to_dirservers(uint8_t dir_purpose, uint8_t router_purpose,
if (extrainfo_len && router_supports_extrainfo(ds->digest, 1)) { if (extrainfo_len && router_supports_extrainfo(ds->digest, 1)) {
upload_len += extrainfo_len; upload_len += extrainfo_len;
log_info(LD_DIR, "Uploading an extrainfo (length %d)", log_info(LD_DIR, "Uploading an extrainfo too (length %d)",
(int) extrainfo_len); (int) extrainfo_len);
} }
tor_addr_from_ipv4h(&ds_addr, ds->addr); tor_addr_from_ipv4h(&ds_addr, ds->addr);

47
src/or/dirserv.c
View File

@ -611,7 +611,7 @@ dirserv_add_multiple_descriptors(const char *desc, uint8_t purpose,
SMARTLIST_FOREACH(list, routerinfo_t *, ri, { SMARTLIST_FOREACH(list, routerinfo_t *, ri, {
msg_out = NULL; msg_out = NULL;
tor_assert(ri->purpose == purpose); tor_assert(ri->purpose == purpose);
r_tmp = dirserv_add_descriptor(ri, &msg_out); r_tmp = dirserv_add_descriptor(ri, &msg_out, source);
if (WRA_MORE_SEVERE(r_tmp, r)) { if (WRA_MORE_SEVERE(r_tmp, r)) {
r = r_tmp; r = r_tmp;
*msg = msg_out; *msg = msg_out;
@ -652,7 +652,8 @@ dirserv_add_multiple_descriptors(const char *desc, uint8_t purpose,
/** Examine the parsed server descriptor in <b>ri</b> and maybe insert it into /** Examine the parsed server descriptor in <b>ri</b> and maybe insert it into
* the list of server descriptors. Set *<b>msg</b> to a message that should be * the list of server descriptors. Set *<b>msg</b> to a message that should be
* passed back to the origin of this descriptor. * passed back to the origin of this descriptor. Use <b>source</b> to produce
* better log messages.
* *
* Return the status of the operation * Return the status of the operation
* *
@ -660,20 +661,20 @@ dirserv_add_multiple_descriptors(const char *desc, uint8_t purpose,
* we re-load the cache. * we re-load the cache.
*/ */
was_router_added_t was_router_added_t
dirserv_add_descriptor(routerinfo_t *ri, const char **msg) dirserv_add_descriptor(routerinfo_t *ri, const char **msg, const char *source)
{ {
was_router_added_t r; was_router_added_t r;
routerinfo_t *ri_old; routerinfo_t *ri_old;
char *desc = NULL; char *desc, *nickname;
size_t desclen = 0; size_t desclen = 0;
/* If it's too big, refuse it now. Otherwise we'll cache it all over the /* If it's too big, refuse it now. Otherwise we'll cache it all over the
* network and it'll clog everything up. */ * network and it'll clog everything up. */
if (ri->cache_info.signed_descriptor_len > MAX_DESCRIPTOR_UPLOAD_SIZE) { if (ri->cache_info.signed_descriptor_len > MAX_DESCRIPTOR_UPLOAD_SIZE) {
log_notice(LD_DIR, "Somebody attempted to publish a router descriptor " log_notice(LD_DIR, "Somebody attempted to publish a router descriptor '%s'"
"with size %d. Either this is an attack, or the " " (source: %s) with size %d. Either this is an attack, or the "
"MAX_DESCRIPTOR_UPLOAD_SIZE (%d) constant is too low.", "MAX_DESCRIPTOR_UPLOAD_SIZE (%d) constant is too low.",
(int)ri->cache_info.signed_descriptor_len, ri->nickname, source, (int)ri->cache_info.signed_descriptor_len,
MAX_DESCRIPTOR_UPLOAD_SIZE); MAX_DESCRIPTOR_UPLOAD_SIZE);
*msg = "Router descriptor was too large"; *msg = "Router descriptor was too large";
control_event_or_authdir_new_descriptor("REJECTED", control_event_or_authdir_new_descriptor("REJECTED",
@ -692,8 +693,9 @@ dirserv_add_descriptor(routerinfo_t *ri, const char **msg)
&& router_differences_are_cosmetic(ri_old, ri) && router_differences_are_cosmetic(ri_old, ri)
&& !router_is_me(ri)) { && !router_is_me(ri)) {
log_info(LD_DIRSERV, log_info(LD_DIRSERV,
"Not replacing descriptor from '%s'; differences are cosmetic.", "Not replacing descriptor from '%s' (source: %s); "
ri->nickname); "differences are cosmetic.",
ri->nickname, source);
*msg = "Not replacing router descriptor; no information has changed since " *msg = "Not replacing router descriptor; no information has changed since "
"the last one with this identity."; "the last one with this identity.";
control_event_or_authdir_new_descriptor("DROPPED", control_event_or_authdir_new_descriptor("DROPPED",
@ -702,23 +704,24 @@ dirserv_add_descriptor(routerinfo_t *ri, const char **msg)
routerinfo_free(ri); routerinfo_free(ri);
return ROUTER_WAS_NOT_NEW; return ROUTER_WAS_NOT_NEW;
} }
if (control_event_is_interesting(EVENT_AUTHDIR_NEWDESCS)) {
/* Make a copy of desc, since router_add_to_routerlist might free /* Make a copy of desc, since router_add_to_routerlist might free
* ri and its associated signed_descriptor_t. */ * ri and its associated signed_descriptor_t. */
desclen = ri->cache_info.signed_descriptor_len; desclen = ri->cache_info.signed_descriptor_len;
desc = tor_strndup(ri->cache_info.signed_descriptor_body, desclen); desc = tor_strndup(ri->cache_info.signed_descriptor_body, desclen);
} nickname = tor_strdup(ri->nickname);
r = router_add_to_routerlist(ri, msg, 0, 0); r = router_add_to_routerlist(ri, msg, 0, 0);
if (!WRA_WAS_ADDED(r)) { if (!WRA_WAS_ADDED(r)) {
/* unless the routerinfo was fine, just out-of-date */ /* unless the routerinfo was fine, just out-of-date */
if (WRA_WAS_REJECTED(r) && desc) if (WRA_WAS_REJECTED(r))
control_event_or_authdir_new_descriptor("REJECTED", desc, desclen, *msg); control_event_or_authdir_new_descriptor("REJECTED", desc, desclen, *msg);
tor_free(desc); log_info(LD_DIRSERV,
"Did not add descriptor from '%s' (source: %s): %s.",
nickname, source, *msg);
} else { } else {
smartlist_t *changed; smartlist_t *changed;
if (desc) control_event_or_authdir_new_descriptor("ACCEPTED", desc, desclen, *msg);
control_event_or_authdir_new_descriptor("ACCEPTED", desc, desclen, *msg);
changed = smartlist_create(); changed = smartlist_create();
smartlist_add(changed, ri); smartlist_add(changed, ri);
@ -728,8 +731,12 @@ dirserv_add_descriptor(routerinfo_t *ri, const char **msg)
*msg = ri->is_valid ? "Descriptor for valid server accepted" : *msg = ri->is_valid ? "Descriptor for valid server accepted" :
"Descriptor for invalid server accepted"; "Descriptor for invalid server accepted";
} }
tor_free(desc); log_info(LD_DIRSERV,
"Added descriptor from '%s' (source: %s): %s.",
nickname, source, *msg);
} }
tor_free(desc);
tor_free(nickname);
return r; return r;
} }

3
src/or/or.h
View File

@ -3430,7 +3430,8 @@ enum was_router_added_t dirserv_add_multiple_descriptors(
const char *source, const char *source,
const char **msg); const char **msg);
enum was_router_added_t dirserv_add_descriptor(routerinfo_t *ri, enum was_router_added_t dirserv_add_descriptor(routerinfo_t *ri,
const char **msg); const char **msg,
const char *source);
int getinfo_helper_dirserv_unregistered(control_connection_t *conn, int getinfo_helper_dirserv_unregistered(control_connection_t *conn,
const char *question, char **answer); const char *question, char **answer);
void dirserv_free_descriptors(void); void dirserv_free_descriptors(void);

2
src/or/router.c
View File

@ -560,7 +560,7 @@ init_keys(void)
log_err(LD_GENERAL,"Generated a routerinfo we couldn't parse."); log_err(LD_GENERAL,"Generated a routerinfo we couldn't parse.");
return -1; return -1;
} }
if (!WRA_WAS_ADDED(dirserv_add_descriptor(ri, &m))) { if (!WRA_WAS_ADDED(dirserv_add_descriptor(ri, &m, "self"))) {
log_err(LD_GENERAL,"Unable to add own descriptor to directory: %s", log_err(LD_GENERAL,"Unable to add own descriptor to directory: %s",
m?m:"<unknown error>"); m?m:"<unknown error>");
return -1; return -1;

4
src/or/test.c
View File

@ -3080,9 +3080,9 @@ test_dir_format(void)
r1->cache_info.published_on = time(NULL); r1->cache_info.published_on = time(NULL);
r2->cache_info.published_on = time(NULL)-3*60*60; r2->cache_info.published_on = time(NULL)-3*60*60;
test_assert(router_dump_router_to_string(buf, 2048, r1, pk2)>0); test_assert(router_dump_router_to_string(buf, 2048, r1, pk2)>0);
test_eq(dirserv_add_descriptor(buf,&m), ROUTER_ADDED_NOTIFY_GENERATOR); test_eq(dirserv_add_descriptor(buf,&m,""), ROUTER_ADDED_NOTIFY_GENERATOR);
test_assert(router_dump_router_to_string(buf, 2048, r2, pk1)>0); test_assert(router_dump_router_to_string(buf, 2048, r2, pk1)>0);
test_eq(dirserv_add_descriptor(buf,&m), ROUTER_ADDED_NOTIFY_GENERATOR); test_eq(dirserv_add_descriptor(buf,&m,""), ROUTER_ADDED_NOTIFY_GENERATOR);
get_options()->Nickname = tor_strdup("DirServer"); get_options()->Nickname = tor_strdup("DirServer");
test_assert(!dirserv_dump_directory_to_string(&cp,pk3, 0)); test_assert(!dirserv_dump_directory_to_string(&cp,pk3, 0));
crypto_pk_get_digest(pk3, d); crypto_pk_get_digest(pk3, d);