[or-cvs] Add an as-yet-unused "EXTENDED" flag to SETEVENTS to indica...
Nick Mathewson
nickm at seul.org
Wed Oct 12 04:31:46 UTC 2005
Update of /home/or/cvsroot/tor/src/or
In directory moria:/tmp/cvs-serv23133/src/or
Modified Files:
control.c or.h routerlist.c
Log Message:
Add an as-yet-unused "EXTENDED" flag to SETEVENTS to indicate that the client can handle extra labeled info in its events. Add moreinfo to the "what is ready for downloading" msg so we can investigate digest-related download rules
Index: control.c
===================================================================
RCS file: /home/or/cvsroot/tor/src/or/control.c,v
retrieving revision 1.138
retrieving revision 1.139
diff -u -d -r1.138 -r1.139
--- control.c 5 Oct 2005 02:09:27 -0000 1.138
+++ control.c 12 Oct 2005 04:31:44 -0000 1.139
@@ -845,6 +845,7 @@
{
uint16_t event_code;
uint32_t event_mask = 0;
+ unsigned int extended = 0;
if (STATE_IS_V0(conn->state)) {
if (len % 2) {
@@ -868,7 +869,10 @@
SPLIT_SKIP_SPACE|SPLIT_IGNORE_BLANK, 0);
SMARTLIST_FOREACH(events, const char *, ev,
{
- if (!strcasecmp(ev, "CIRC"))
+ if (!strcasecmp(ev, "EXTENDED")) {
+ extended = 1;
+ continue;
+ } else if (!strcasecmp(ev, "CIRC"))
event_code = EVENT_CIRCUIT_STATUS;
else if (!strcasecmp(ev, "STREAM"))
event_code = EVENT_STREAM_STATUS;
@@ -903,6 +907,7 @@
smartlist_free(events);
}
conn->event_mask = event_mask;
+ conn->control_events_are_extended = extended;
control_update_global_event_mask();
send_control_done(conn);
Index: or.h
===================================================================
RCS file: /home/or/cvsroot/tor/src/or/or.h,v
retrieving revision 1.710
retrieving revision 1.711
diff -u -d -r1.710 -r1.711
--- or.h 7 Oct 2005 19:25:01 -0000 1.710
+++ or.h 12 Oct 2005 04:31:44 -0000 1.711
@@ -604,6 +604,9 @@
unsigned has_sent_end:1; /**< For debugging; only used on edge connections.
* Set once we've set the stream end,
* and check in circuit_about_to_close_connection(). */
+ /** For control connections only. If set, we send extended info with control
+ * events as appropriate. */
+ unsigned int control_events_are_extended:1;
int s; /**< Our socket; -1 if this connection is closed. */
int poll_index; /* XXXX rename. */
@@ -777,6 +780,12 @@
*/
unsigned int is_named:1; /**< Do we believe the nickname that this OR gives
* us? */
+ unsigned int xx_is_recognized:1; /**< Temporary: do we think that this
+ * descriptor's digest is recognized?
+ */
+ unsigned int xx_is_extra_new:1; /**< Temporary: do we think that this
+ * descriptor's digest is recognized?
+ */
/* The below items are used only by authdirservers for
* reachability testing. */
@@ -1065,7 +1074,7 @@
uint8_t purpose; /**< Why are we creating this circuit? */
/**
- * The rend_query field holds y portion of y.onion (nul-terminated)
+ * The rend_query field holds the y portion of y.onion (nul-terminated)
* if purpose is C_INTRODUCING or C_ESTABLISH_REND, or is a C_GENERAL
* for a hidden service, or is S_*.
*/
Index: routerlist.c
===================================================================
RCS file: /home/or/cvsroot/tor/src/or/routerlist.c,v
retrieving revision 1.335
retrieving revision 1.336
diff -u -d -r1.335 -r1.336
--- routerlist.c 11 Oct 2005 01:57:28 -0000 1.335
+++ routerlist.c 12 Oct 2005 04:31:44 -0000 1.336
@@ -34,6 +34,8 @@
static void trusted_dir_server_free(trusted_dir_server_t *ds);
static void update_networkstatus_cache_downloads(time_t now);
static void update_networkstatus_client_downloads(time_t now);
+static int routerdesc_digest_is_recognized(const char *identity,
+ const char *digest);
/****************************************************************************/
@@ -1416,6 +1418,7 @@
smartlist_t *routers = smartlist_create(), *changed = smartlist_create();
char fp[HEX_DIGEST_LEN+1];
const char *msg;
+ int xx_n_unrecognized = 0;
router_parse_list_from_string(&s, routers);
@@ -1424,6 +1427,8 @@
SMARTLIST_FOREACH(routers, routerinfo_t *, ri,
{
base16_encode(fp, sizeof(fp), ri->identity_digest, DIGEST_LEN);
+ if (! ri->xx_is_recognized)
+ ++xx_n_unrecognized;
if (requested_fingerprints) {
if (smartlist_string_isin(requested_fingerprints, fp)) {
smartlist_string_remove(requested_fingerprints, fp);
@@ -1441,6 +1446,12 @@
smartlist_add(changed, ri);
});
+ if (xx_n_unrecognized && !from_cache) {
+ log_fn(LOG_WARN, "Under proposed rules I would reject %d of the %d desc(s)"
+ " I just downloaded because no networkstatus can confirm their"
+ " digest(s).", xx_n_unrecognized, smartlist_len(routers));
+ }
+
control_event_descriptors_changed(changed);
router_rebuild_store(0);
@@ -1692,6 +1703,24 @@
_compare_digest_to_routerstatus_entry);
}
+/** DOCDOC */
+static int
+routerdesc_digest_is_recognized(const char *identity, const char *digest)
+{
+ routerstatus_t *rs;
+ if (!networkstatus_list)
+ return 0;
+
+ SMARTLIST_FOREACH(networkstatus_list, networkstatus_t *, ns,
+ {
+ if (!(rs = networkstatus_find_entry(ns, identity)))
+ continue;
+ if (!memcmp(rs->descriptor_digest, digest, DIGEST_LEN))
+ return 1;
+ });
+ return 0;
+}
+
/* XXXX These should be configurable, perhaps? NM */
#define AUTHORITY_NS_CACHE_INTERVAL 10*60
#define NONAUTHORITY_NS_CACHE_INTERVAL 15*60
@@ -2529,6 +2558,11 @@
if (router->is_running && ds) {
ds->n_networkstatus_failures = 0;
}
+ if (!router->xx_is_recognized) {
+ router->xx_is_recognized = routerdesc_digest_is_recognized(
+ router->identity_digest, router->signed_descriptor_digest);
+ }
+ router->xx_is_extra_new = router->published_on > rs->status.published_on;
});
}
@@ -2549,7 +2583,8 @@
int mirror = server_mode(get_options()) && get_options()->DirPort;
/* these are just used for logging */
int n_not_ready = 0, n_in_progress = 0, n_uptodate = 0, n_skip_old = 0,
- n_obsolete = 0;
+ n_obsolete = 0, xx_n_unrecognized = 0, xx_n_extra_new = 0, xx_n_both = 0,
+ xx_n_unrec_old = 0;
if (!routerstatus_list)
return superseded;
@@ -2624,6 +2659,14 @@
// log_fn(LOG_NOTICE, "No status for %s", fp);
continue;
}
+ if (!ri->xx_is_recognized) {
+ ++xx_n_unrecognized;
+ if (ri->xx_is_extra_new)
+ ++xx_n_both;
+ }
+ if (ri->xx_is_extra_new)
+ ++xx_n_extra_new;
+
/* Change this "or" to be an "and" once dirs generate hashes right.
* Remove the version check once older versions are uncommon.
* XXXXX. NM */
@@ -2642,6 +2685,8 @@
* No need to download it. */
// log_fn(LOG_NOTICE, "Up-to-date status for %s", fp);
++n_skip_old;
+ if (!ri->xx_is_recognized)
+ ++xx_n_unrec_old;
rs->should_download = 0;
--n_downloadable;
} /* else {
@@ -2663,9 +2708,14 @@
"%d are up to date; %d are in progress; "
"%d are not ready to retry; "
"%d are not published recently enough to be worthwhile; "
- "%d are running pre-0.1.1.6 Tors and aren't stale enough to replace.",
+ "%d are running pre-0.1.1.6 Tors and aren't stale enough to replace. "
+ "%d have unrecognized descriptor hashes; %d are newer than the dirs "
+ "have told us about; %d are both unrecognized and newer than any "
+ "publication date in the networkstatus; %d are both "
+ "unrecognized and running a pre-0.1.1.6 version.",
n_downloadable, n_uptodate, n_in_progress, n_not_ready,
- n_obsolete, n_skip_old);
+ n_obsolete, n_skip_old, xx_n_unrecognized, xx_n_extra_new, xx_n_both,
+ xx_n_unrec_old);
if (!n_downloadable)
return superseded;
More information about the tor-commits
mailing list