12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463 |
- /* Copyright 2001-2003 Roger Dingledine, Matej Pfajfar. */
- /* See LICENSE for licensing information */
- /* $Id$ */
- /**
- * \file routerparse.c
- *
- * \brief Code to parse and validate router descriptors and directories.
- **/
- /* This is required on rh7 to make strptime not complain.
- */
- #define _GNU_SOURCE
- #include "or.h"
- /****************************************************************************/
- extern or_options_t options; /* command-line and config-file options */
- /** Enumeration of possible token types. The ones starting with K_
- * correspond to directory 'keywords'. _UNRECOGNIZED is for an
- * unrecognized keyword; _ERR is an error in the tokenizing process,
- * _EOF is an end-of-file marker, and _NIL is used to encode
- * not-a-token.
- */
- typedef enum {
- K_ACCEPT,
- K_DIRECTORY_SIGNATURE,
- K_RECOMMENDED_SOFTWARE,
- K_REJECT,
- K_ROUTER,
- K_SIGNED_DIRECTORY,
- K_SIGNING_KEY,
- K_ONION_KEY,
- K_LINK_KEY, /* XXXX obsolete; remove in June. */
- K_ROUTER_SIGNATURE,
- K_PUBLISHED,
- K_RUNNING_ROUTERS,
- K_PLATFORM,
- K_OPT,
- K_BANDWIDTH,
- K_PORTS,
- K_DIRCACHEPORT,
- K_CONTACT,
- K_NETWORK_STATUS,
- _UNRECOGNIZED,
- _ERR,
- _EOF,
- _NIL
- } directory_keyword;
- /** Structure to hold a single directory token.
- *
- * We parse a directory by breaking it into "tokens", each consisting
- * of a keyword, a line full of arguments, and a binary object. The
- * arguments and object are both optional, depending on the keyword
- * type.
- */
- typedef struct directory_token_t {
- directory_keyword tp; /**< Type of the token. */
- int n_args; /**< Number of elements in args */
- char **args; /**< Array of arguments from keyword line. */
- char *object_type; /**< -----BEGIN [object_type]-----*/
- int object_size; /**< Bytes in object_body */
- char *object_body; /**< Contents of object, base64-decoded. */
- crypto_pk_env_t *key; /**< For public keys only. */
- char *error; /**< For _ERR tokens only. */
- } directory_token_t;
- /* ********************************************************************** */
- /** We use a table of rules to decide how to parse each token type. */
- /** Rules for how many arguments a keyword can take. */
- typedef enum {
- NO_ARGS, /**< (1) no arguments, ever */
- ARGS, /**< (2) a list of arguments separated by spaces */
- CONCAT_ARGS, /**< or (3) the rest of the line, treated as a single argument. */
- } arg_syntax;
- /** Rules for whether the keyword needs an object. */
- typedef enum {
- NO_OBJ, /**< (1) no object, ever */
- NEED_OBJ, /**< (2) object is required */
- NEED_KEY, /**< (3) object is required, and must be a public key. */
- OBJ_OK, /**< or (4) object is optional. */
- } obj_syntax;
- /** Rules for where a keyword can appear. */
- typedef enum {
- ANY = 0, /**< Appears in router descriptor or in directory sections. */
- DIR_ONLY, /**< Appears only in directory. */
- RTR_ONLY, /**< Appears only in router descriptor or runningrouters */
- } where_syntax;
- /** Table mapping keywords to token value and to argument rules. */
- static struct {
- char *t; int v; arg_syntax s; obj_syntax os; where_syntax ws;
- } token_table[] = {
- { "accept", K_ACCEPT, ARGS, NO_OBJ, RTR_ONLY },
- { "directory-signature", K_DIRECTORY_SIGNATURE, ARGS, NEED_OBJ,DIR_ONLY},
- { "reject", K_REJECT, ARGS, NO_OBJ, RTR_ONLY },
- { "router", K_ROUTER, ARGS, NO_OBJ, RTR_ONLY },
- { "recommended-software",K_RECOMMENDED_SOFTWARE,ARGS, NO_OBJ, DIR_ONLY },
- { "signed-directory", K_SIGNED_DIRECTORY, NO_ARGS, NO_OBJ, DIR_ONLY },
- { "signing-key", K_SIGNING_KEY, NO_ARGS, NEED_KEY,RTR_ONLY },
- { "onion-key", K_ONION_KEY, NO_ARGS, NEED_KEY,RTR_ONLY },
- { "link-key", K_LINK_KEY, NO_ARGS, NEED_KEY,RTR_ONLY },
- { "router-signature", K_ROUTER_SIGNATURE, NO_ARGS, NEED_OBJ,RTR_ONLY },
- { "running-routers", K_RUNNING_ROUTERS, ARGS, NO_OBJ, DIR_ONLY },
- { "ports", K_PORTS, ARGS, NO_OBJ, RTR_ONLY },
- { "bandwidth", K_BANDWIDTH, ARGS, NO_OBJ, RTR_ONLY },
- { "platform", K_PLATFORM, CONCAT_ARGS, NO_OBJ, RTR_ONLY },
- { "published", K_PUBLISHED, CONCAT_ARGS, NO_OBJ, ANY },
- { "opt", K_OPT, CONCAT_ARGS, OBJ_OK, ANY },
- { "dircacheport", K_DIRCACHEPORT, ARGS, NO_OBJ, RTR_ONLY },
- { "contact", K_CONTACT, CONCAT_ARGS, NO_OBJ, ANY },
- { "network-status", K_NETWORK_STATUS, NO_ARGS, NO_OBJ, DIR_ONLY },
- { NULL, -1 }
- };
- /* static function prototypes */
- static int router_add_exit_policy(routerinfo_t *router,directory_token_t *tok);
- static struct exit_policy_t *router_parse_exit_policy(directory_token_t *tok);
- static int router_get_hash_impl(const char *s, char *digest,
- const char *start_str, const char *end_str);
- static void token_free(directory_token_t *tok);
- static smartlist_t *find_all_exitpolicy(smartlist_t *s);
- static directory_token_t *find_first_by_keyword(smartlist_t *s,
- directory_keyword keyword);
- static int tokenize_string(const char *start, const char *end,
- smartlist_t *out, int is_dir);
- static directory_token_t *get_next_token(const char **s, where_syntax where);
- static int check_directory_signature(const char *digest,
- directory_token_t *tok,
- crypto_pk_env_t *pkey);
- /** Set <b>digest</b> to the SHA-1 digest of the hash of the directory in
- * <b>s</b>. Return 0 on success, nonzero on failure.
- */
- int router_get_dir_hash(const char *s, char *digest)
- {
- return router_get_hash_impl(s,digest,
- "signed-directory","\ndirectory-signature");
- }
- /** Set <b>digest</b> to the SHA-1 digest of the hash of the first router in
- * <b>s</b>. Return 0 on success, nonzero on failure.
- */
- int router_get_router_hash(const char *s, char *digest)
- {
- return router_get_hash_impl(s,digest,
- "router ","\nrouter-signature");
- }
- /** Set <b>digest</b> to the SHA-1 digest of the hash of the running-routers
- * string in <b>s</b>. Return 0 on success, nonzero on failure.
- */
- int router_get_runningrouters_hash(const char *s, char *digest)
- {
- return router_get_hash_impl(s,digest,
- "network-status","\ndirectory-signature");
- }
- /** Parse a date of the format "YYYY-MM-DD hh:mm:ss" and store the result into
- * *<b>t</b>.
- */
- /* XXX this should go in util.c, yes? -RD */
- static int parse_time(const char *cp, time_t *t)
- {
- struct tm st_tm;
- #ifdef HAVE_STRPTIME
- if (!strptime(cp, "%Y-%m-%d %H:%M:%S", &st_tm)) {
- log_fn(LOG_WARN, "Published time was unparseable"); return -1;
- }
- #else
- unsigned int year=0, month=0, day=0, hour=100, minute=100, second=100;
- if (sscanf(cp, "%u-%u-%u %u:%u:%u", &year, &month,
- &day, &hour, &minute, &second) < 6) {
- log_fn(LOG_WARN, "Published time was unparseable"); return -1;
- }
- if (year < 1970 || month < 1 || month > 12 || day < 1 || day > 31 ||
- hour > 23 || minute > 59 || second > 61) {
- log_fn(LOG_WARN, "Published time was nonsensical"); return -1;
- }
- st_tm.tm_year = year;
- st_tm.tm_mon = month-1;
- st_tm.tm_mday = day;
- st_tm.tm_hour = hour;
- st_tm.tm_min = minute;
- st_tm.tm_sec = second;
- #endif
- *t = tor_timegm(&st_tm);
- return 0;
- }
- /**
- * Find the first instance of "recommended-software ...\n" at the start of
- * a line; return a newly allocated string containing the "..." portion.
- * Return NULL if no such instance was found.
- */
- static char *
- get_recommended_software_from_directory(const char *str)
- {
- #define REC "recommended-software "
- const char *cp = str, *eol;
- int len = strlen(REC);
- cp = str;
- if (strncmp(str, REC, len)==0) {
- cp += len;
- } else {
- cp = strstr(str, "\n"REC);
- if (!cp)
- return NULL;
- cp += len+1;
- }
- eol = strchr(cp, '\n');
- if (!eol)
- return NULL;
- return tor_strndup(cp, eol-cp);
- #undef REC
- }
- /** Return 1 if <b>myversion</b> is not in <b>versionlist</b>, and if at least
- * one version of Tor on <b>versionlist</b> is newer than <b>myversion</b>.
- * Otherwise return 0.
- * (versionlist is a comma-separated list of version strings,
- * optionally prefixed with "Tor". Versions that can't be parsed are
- * ignored.) */
- /* static */ int is_obsolete_version(const char *myversion,
- const char *versionlist) {
- const char *vl;
- char *version, *comma, *cp;
- tor_version_t mine, other;
- int found_newer = 0, r;
- vl = versionlist;
- log_fn(LOG_DEBUG,"checking '%s' in '%s'.", myversion, versionlist);
- if (tor_version_parse(myversion, &mine)) {
- log_fn(LOG_ERR, "I couldn't parse my own version (%s)", myversion);
- tor_assert(0);
- }
- for(;;) {
- comma = strchr(vl, ',');
- version = tor_strndup(vl, comma?(comma-vl):strlen(vl));
- cp = version;
- while (isspace(*cp))
- ++cp;
- if (!strncmp(cp, "Tor ", 4))
- cp += 4;
- if (tor_version_parse(cp, &other)) {
- /* Couldn't parse other; it can't be a match. */
- } else {
- r = tor_version_compare(&mine, &other);
- if (r==0) {
- tor_free(version);
- return 0; /* It's a match. */
- } else if (r<0) {
- found_newer = 1;
- }
- }
- tor_free(version);
- if (comma)
- vl = comma+1;
- else
- break;
- }
- if (!found_newer) {
- log_fn(LOG_WARN, "This version of Tor (%s) is newer than any on the recommended list (%s)",
- myversion, versionlist);
- return 0;
- } else {
- return 1;
- }
- }
- /* Return 0 if myversion is supported; else log a message and return
- * -1 (or exit if ignoreversions is false) */
- int check_software_version_against_directory(const char *directory,
- int ignoreversion)
- {
- char *v;
- v = get_recommended_software_from_directory(directory);
- if (!v) {
- log_fn(LOG_WARN, "No recommended-versions string found in directory");
- return -1;
- }
- if (!is_obsolete_version(VERSION, v)) {
- tor_free(v);
- return 0;
- }
- log(ignoreversion ? LOG_WARN : LOG_ERR,
- "You are running Tor version %s, which will not work with this network.\n"
- "Please use %s%s.",
- VERSION, strchr(v,',') ? "one of " : "", v);
- tor_free(v);
- if(ignoreversion) {
- log(LOG_WARN, "IgnoreVersion is set. If it breaks, we told you so.");
- return -1;
- } else {
- fflush(0);
- tor_cleanup();
- exit(0);
- return -1; /* never reached */
- }
- }
- /** Parse a directory from <b>str</b> and, when done, store the
- * resulting routerlist in *<b>dest</b>, freeing the old value if necessary.
- * If <b>pkey</b> is provided, we check the directory signature with pkey.
- */
- int /* Should be static; exposed for unit tests */
- router_parse_routerlist_from_directory(const char *str,
- routerlist_t **dest,
- crypto_pk_env_t *pkey)
- {
- directory_token_t *tok;
- char digest[DIGEST_LEN];
- routerlist_t *new_dir = NULL;
- char *versions = NULL;
- smartlist_t *good_nickname_list = NULL;
- time_t published_on;
- int i, r;
- const char *end, *cp;
- smartlist_t *tokens = NULL;
- char dirnickname[MAX_NICKNAME_LEN+1];
- if (router_get_dir_hash(str, digest)) {
- log_fn(LOG_WARN, "Unable to compute digest of directory");
- goto err;
- }
- log_fn(LOG_DEBUG,"Received directory hashes to %s",hex_str(digest,4));
- /* Check signature first, before we try to tokenize. */
- cp = str;
- while (cp && (end = strstr(cp+1, "\ndirectory-signature")))
- cp = end;
- if (cp == str || !cp) {
- log_fn(LOG_WARN, "No signature found on directory."); goto err;
- }
- ++cp;
- tokens = smartlist_create();
- if (tokenize_string(cp,strchr(cp,'\0'),tokens,1)) {
- log_fn(LOG_WARN, "Error tokenizing directory signature"); goto err;
- }
- if (smartlist_len(tokens) != 1) {
- log_fn(LOG_WARN, "Unexpected number of tokens in signature"); goto err;
- }
- tok=smartlist_get(tokens,0);
- if(tok->tp != K_DIRECTORY_SIGNATURE) {
- log_fn(LOG_WARN,"Expected a single directory signature"); goto err;
- }
- if (check_directory_signature(digest, tok, pkey)<0) {
- goto err;
- }
- /* now we know tok->n_args == 1, so it's safe to access tok->args[0] */
- strlcpy(dirnickname, tok->args[0], sizeof(dirnickname));
- SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
- smartlist_free(tokens);
- tokens = NULL;
- /* Now that we know the signature is okay, check the version. */
- check_software_version_against_directory(str, options.IgnoreVersion);
- /* Now try to parse the first part of the directory. */
- if ((end = strstr(str,"\nrouter "))) {
- ++end;
- } else if ((end = strstr(str, "\ndirectory-signature"))) {
- ++end;
- } else {
- end = str + strlen(str);
- }
- tokens = smartlist_create();
- if (tokenize_string(str,end,tokens,1)) {
- log_fn(LOG_WARN, "Error tokenizing directory"); goto err;
- }
- if (smartlist_len(tokens) < 1) {
- log_fn(LOG_WARN, "Impossibly short directory header"); goto err;
- }
- if ((tok = find_first_by_keyword(tokens, _UNRECOGNIZED))) {
- log_fn(LOG_WARN, "Unrecognized keyword in \"%s\"; can't parse directory.",
- tok->args[0]);
- goto err;
- }
- tok = smartlist_get(tokens,0);
- if (tok->tp != K_SIGNED_DIRECTORY) {
- log_fn(LOG_WARN, "Directory doesn't start with signed-directory.");
- goto err;
- }
- if (!(tok = find_first_by_keyword(tokens, K_PUBLISHED))) {
- log_fn(LOG_WARN, "Missing published time on directory.");
- goto err;
- }
- tor_assert(tok->n_args == 1);
- if (parse_time(tok->args[0], &published_on) < 0) {
- goto err;
- }
- if (!(tok = find_first_by_keyword(tokens, K_RECOMMENDED_SOFTWARE))) {
- log_fn(LOG_WARN, "Missing recommended-software line from directory.");
- goto err;
- }
- if (tok->n_args != 1) {
- log_fn(LOG_WARN, "Invalid recommended-software line"); goto err;
- }
- versions = tor_strdup(tok->args[0]);
- if (!(tok = find_first_by_keyword(tokens, K_RUNNING_ROUTERS))) {
- log_fn(LOG_WARN, "Missing running-routers line from directory.");
- goto err;
- }
- good_nickname_list = smartlist_create();
- for (i=0; i<tok->n_args; ++i) {
- smartlist_add(good_nickname_list, tok->args[i]);
- }
- tok->n_args = 0; /* Don't free the strings in good_nickname_lst yet. */
- /* Read the router list from s, advancing s up past the end of the last
- * router. */
- str = end;
- if (router_parse_list_from_string(&str, &new_dir,
- good_nickname_list, published_on)) {
- log_fn(LOG_WARN, "Error reading routers from directory");
- goto err;
- }
- new_dir->software_versions = versions; versions = NULL;
- new_dir->published_on = published_on;
- SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
- smartlist_free(tokens);
- tokens = NULL;
- /* Determine if my routerinfo is considered verified. */
- {
- static int have_warned_about_unverified_status = 0;
- routerinfo_t *me = router_get_my_routerinfo();
- if(me) {
- router_update_status_from_smartlist(me, published_on,
- good_nickname_list);
- if(me->is_verified == 0 && !have_warned_about_unverified_status) {
- log_fn(LOG_WARN,"Dirserver %s lists your server as unverified. Please consider sending your identity fingerprint to the tor-ops.", dirnickname);
- /* XXX008 can we print the name of the dirserver above? how to get it */
- have_warned_about_unverified_status = 1;
- }
- }
- }
- if (*dest)
- routerlist_free(*dest);
- *dest = new_dir;
- r = 0;
- goto done;
- err:
- r = -1;
- if (new_dir)
- routerlist_free(new_dir);
- tor_free(versions);
- done:
- if (tokens) {
- SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
- smartlist_free(tokens);
- }
- if (good_nickname_list) {
- SMARTLIST_FOREACH(good_nickname_list, char *, n, tor_free(n));
- smartlist_free(good_nickname_list);
- }
- return r;
- }
- running_routers_t *
- router_parse_runningrouters(const char *str)
- {
- char digest[DIGEST_LEN];
- running_routers_t *new_list = NULL;
- directory_token_t *tok;
- time_t published_on;
- int i;
- smartlist_t *tokens = NULL;
- if (router_get_runningrouters_hash(str, digest)) {
- log_fn(LOG_WARN, "Unable to compute digest of directory");
- goto err;
- }
- tokens = smartlist_create();
- if (tokenize_string(str,str+strlen(str),tokens,1)) {
- log_fn(LOG_WARN, "Error tokenizing directory"); goto err;
- }
- if ((tok = find_first_by_keyword(tokens, _UNRECOGNIZED))) {
- log_fn(LOG_WARN, "Unrecognized keyword in \"%s\"; can't parse directory.",
- tok->args[0]);
- goto err;
- }
- tok = smartlist_get(tokens,0);
- if (tok->tp != K_NETWORK_STATUS) {
- log_fn(LOG_WARN, "Network-status starts with wrong token");
- goto err;
- }
- if (!(tok = find_first_by_keyword(tokens, K_PUBLISHED))) {
- log_fn(LOG_WARN, "Missing published time on directory.");
- goto err;
- }
- tor_assert(tok->n_args == 1);
- if (parse_time(tok->args[0], &published_on) < 0) {
- goto err;
- }
- if (!(tok = find_first_by_keyword(tokens, K_RUNNING_ROUTERS))) {
- log_fn(LOG_WARN, "Missing running-routers line from directory.");
- goto err;
- }
- new_list = tor_malloc_zero(sizeof(running_routers_t));
- new_list->published_on = published_on;
- new_list->running_routers = smartlist_create();
- for (i=0;i<tok->n_args;++i) {
- smartlist_add(new_list->running_routers, tok->args[i]);
- }
- if (!(tok = find_first_by_keyword(tokens, K_DIRECTORY_SIGNATURE))) {
- log_fn(LOG_WARN, "Missing signature on directory");
- goto err;
- }
- if (check_directory_signature(digest, tok, NULL)<0) {
- goto err;
- }
- goto done;
- err:
- running_routers_free(new_list);
- new_list = NULL;
- done:
- if (tokens) {
- SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
- smartlist_free(tokens);
- }
- return new_list;
- }
- static int check_directory_signature(const char *digest,
- directory_token_t *tok,
- crypto_pk_env_t *pkey)
- {
- char signed_digest[PK_BYTES];
- if (tok->n_args == 1) {
- routerinfo_t *r = router_get_by_nickname(tok->args[0]);
- log_fn(LOG_DEBUG, "Got directory signed by %s", tok->args[0]);
- if (r && r->is_trusted_dir) {
- pkey = r->identity_pkey;
- } else if (!r && pkey) {
- /* pkey provided for debugging purposes. */
- } else if (!r) {
- log_fn(LOG_WARN, "Directory was signed by unrecognized server %s",
- tok->args[0]);
- return -1;
- } else if (r && !r->is_trusted_dir) {
- log_fn(LOG_WARN, "Directory was signed by non-trusted server %s",
- tok->args[0]);
- return -1;
- }
- } else if (tok->n_args > 1) {
- /* XXX008 Nick: shouldn't we check for <1 too? */
- log_fn(LOG_WARN, "Too many arguments to directory-signature");
- return -1;
- }
- if (strcmp(tok->object_type, "SIGNATURE") || tok->object_size != 128) {
- log_fn(LOG_WARN, "Bad object type or length on directory signature");
- return -1;
- }
- if (pkey) {
- if (crypto_pk_public_checksig(pkey, tok->object_body, 128, signed_digest)
- != 20) {
- log_fn(LOG_WARN, "Error reading directory: invalid signature.");
- return -1;
- }
- log_fn(LOG_DEBUG,"Signed directory hash starts %s", hex_str(signed_digest,4));
- if (memcmp(digest, signed_digest, 20)) {
- log_fn(LOG_WARN, "Error reading directory: signature does not match.");
- return -1;
- }
- } else {
- /* XXXX008 freak out, unless testing. */
- }
- return 0;
- }
- /** Given a string *<b>s</b> containing a concatenated sequence of router
- * descriptors, parses them and stores the result in *<b>dest</b>. If
- * good_nickname_list is provided, then routers are marked as
- * running/nonrunning and verified/unverified based on their status in the
- * list. Otherwise, all routers are marked running and verified. Advances
- * *s to a point immediately following the last router entry. Returns 0 on
- * success and -1 on failure.
- */
- int
- router_parse_list_from_string(const char **s, routerlist_t **dest,
- smartlist_t *good_nickname_list,
- time_t published_on)
- {
- routerinfo_t *router;
- smartlist_t *routers;
- const char *end;
- tor_assert(s && *s);
- routers = smartlist_create();
- while (1) {
- *s = eat_whitespace(*s);
- /* Don't start parsing the rest of *s unless it contains a router. */
- if (strncmp(*s, "router ", 7)!=0)
- break;
- if ((end = strstr(*s+1, "\nrouter "))) {
- end++;
- } else if ((end = strstr(*s+1, "\ndirectory-signature"))) {
- end++;
- } else {
- end = *s+strlen(*s);
- }
- router = router_parse_entry_from_string(*s, end);
- *s = end;
- if (!router) {
- log_fn(LOG_WARN, "Error reading router; skipping");
- continue;
- }
- if (good_nickname_list) {
- router_update_status_from_smartlist(router, published_on,
- good_nickname_list);
- } else {
- router->is_running = 1; /* start out assuming all dirservers are up */
- router->is_verified = 1;
- router->status_set_at = time(NULL);
- }
- smartlist_add(routers, router);
- log_fn(LOG_DEBUG,"just added router #%d.",smartlist_len(routers));
- }
- if (*dest)
- routerlist_free(*dest);
- *dest = tor_malloc(sizeof(routerlist_t));
- (*dest)->routers = routers;
- (*dest)->software_versions = NULL;
- return 0;
- }
- /** Helper function: reads a single router entry from *<b>s</b> ...
- * *<b>end</b>. Mallocs a new router and returns it if all goes well, else
- * returns NULL.
- */
- routerinfo_t *router_parse_entry_from_string(const char *s,
- const char *end) {
- routerinfo_t *router = NULL;
- char signed_digest[128];
- char digest[128];
- smartlist_t *tokens = NULL, *exit_policy_tokens = NULL;
- directory_token_t *tok;
- int t;
- int ports_set, bw_set;
- if (!end) {
- end = s + strlen(s);
- }
- if (router_get_router_hash(s, digest) < 0) {
- log_fn(LOG_WARN, "Couldn't compute router hash.");
- return NULL;
- }
- tokens = smartlist_create();
- if (tokenize_string(s,end,tokens,0)) {
- log_fn(LOG_WARN, "Error tokeninzing router descriptor."); goto err;
- }
- if (smartlist_len(tokens) < 2) {
- log_fn(LOG_WARN, "Impossibly short router descriptor.");
- goto err;
- }
- if ((tok = find_first_by_keyword(tokens, _UNRECOGNIZED))) {
- log_fn(LOG_WARN, "Unrecognized keyword in \"%s\"; skipping descriptor.",
- tok->args[0]);
- goto err;
- }
- tok = smartlist_get(tokens,0);
- if (tok->tp != K_ROUTER) {
- log_fn(LOG_WARN,"Entry does not start with \"router\"");
- goto err;
- }
- router = tor_malloc_zero(sizeof(routerinfo_t));
- router->onion_pkey = router->identity_pkey = NULL;
- ports_set = bw_set = 0;
- if (tok->n_args == 2 || tok->n_args == 5 || tok->n_args == 6) {
- router->nickname = tor_strdup(tok->args[0]);
- if (strlen(router->nickname) > MAX_NICKNAME_LEN) {
- log_fn(LOG_WARN,"Router nickname too long.");
- goto err;
- }
- if (strspn(router->nickname, LEGAL_NICKNAME_CHARACTERS) !=
- strlen(router->nickname)) {
- log_fn(LOG_WARN, "Router nickname contains illegal characters.");
- goto err;
- }
- router->address = tor_strdup(tok->args[1]);
- router->addr = 0;
- if (tok->n_args >= 5) {
- router->or_port = atoi(tok->args[2]);
- router->socks_port = atoi(tok->args[3]);
- router->dir_port = atoi(tok->args[4]);
- ports_set = 1;
- }
- } else {
- log_fn(LOG_WARN,"Wrong # of arguments to \"router\" (%d)",tok->n_args);
- goto err;
- }
- tok = find_first_by_keyword(tokens, K_PORTS);
- if (tok && ports_set) {
- log_fn(LOG_WARN,"Redundant ports line");
- goto err;
- } else if (tok) {
- if (tok->n_args != 3) {
- log_fn(LOG_WARN,"Wrong # of arguments to \"ports\"");
- goto err;
- }
- router->or_port = atoi(tok->args[0]);
- router->socks_port = atoi(tok->args[1]);
- router->dir_port = atoi(tok->args[2]);
- ports_set = 1;
- }
- tok = find_first_by_keyword(tokens, K_DIRCACHEPORT);
- if (tok) {
- if (router->dir_port)
- log_fn(LOG_WARN,"Redundant dircacheport line");
- if (tok->n_args != 1) {
- log_fn(LOG_WARN,"Wrong # of arguments to \"dircacheport\"");
- goto err;
- }
- router->dir_port = atoi(tok->args[0]);
- }
- tok = find_first_by_keyword(tokens, K_BANDWIDTH);
- if (tok && bw_set) {
- log_fn(LOG_WARN,"Redundant bandwidth line");
- goto err;
- } else if (tok) {
- /* XXX set this to "< 3" once 0.0.7 is obsolete */
- if (tok->n_args < 2) {
- log_fn(LOG_WARN,"Not enough arguments to \"bandwidth\"");
- goto err;
- }
- router->bandwidthrate = atoi(tok->args[0]);
- router->bandwidthburst = atoi(tok->args[1]);
- if(tok->n_args > 2)
- router->advertisedbandwidth = atoi(tok->args[2]);
- bw_set = 1;
- }
- if (!(tok = find_first_by_keyword(tokens, K_PUBLISHED))) {
- log_fn(LOG_WARN, "Missing published time"); goto err;
- }
- tor_assert(tok->n_args == 1);
- if (parse_time(tok->args[0], &router->published_on) < 0)
- goto err;
- if (!(tok = find_first_by_keyword(tokens, K_ONION_KEY))) {
- log_fn(LOG_WARN, "Missing onion key"); goto err;
- }
- /* XXX Check key length */
- router->onion_pkey = tok->key;
- tok->key = NULL; /* Prevent free */
- if ((tok = find_first_by_keyword(tokens, K_LINK_KEY))) {
- log_fn(LOG_INFO, "Skipping obsolete link-key");
- }
- if (!(tok = find_first_by_keyword(tokens, K_SIGNING_KEY))) {
- log_fn(LOG_WARN, "Missing identity key"); goto err;
- }
- /* XXX Check key length */
- router->identity_pkey = tok->key;
- tok->key = NULL; /* Prevent free */
- if (crypto_pk_get_digest(router->identity_pkey,router->identity_digest)){
- log_fn(LOG_WARN, "Couldn't calculate key digest"); goto err;
- }
- if ((tok = find_first_by_keyword(tokens, K_PLATFORM))) {
- router->platform = tor_strdup(tok->args[0]);
- }
- exit_policy_tokens = find_all_exitpolicy(tokens);
- SMARTLIST_FOREACH(exit_policy_tokens, directory_token_t *, t,
- if (router_add_exit_policy(router,t)<0) {
- log_fn(LOG_WARN,"Error in exit policy"); goto err;}
- );
- if (!(tok = find_first_by_keyword(tokens, K_ROUTER_SIGNATURE))) {
- log_fn(LOG_WARN, "Missing router signature"); goto err;
- }
- if (strcmp(tok->object_type, "SIGNATURE") || tok->object_size != 128) {
- log_fn(LOG_WARN, "Bad object type or length on router signature");
- goto err;
- }
- if ((t=crypto_pk_public_checksig(router->identity_pkey, tok->object_body,
- 128, signed_digest)) != 20) {
- log_fn(LOG_WARN, "Invalid signature %d",t); goto err;
- }
- if (memcmp(digest, signed_digest, 20)) {
- log_fn(LOG_WARN, "Mismatched signature"); goto err;
- }
- if (!ports_set) {
- log_fn(LOG_WARN,"No ports declared; failing."); goto err;
- }
- if (!bw_set) {
- log_fn(LOG_WARN,"No bandwidth declared; failing."); goto err;
- }
- if(!router->or_port) {
- log_fn(LOG_WARN,"or_port unreadable or 0. Failing.");
- goto err;
- }
- if (!router->bandwidthrate) {
- log_fn(LOG_WARN,"bandwidthrate unreadable or 0. Failing.");
- goto err;
- }
- if (!router->platform) {
- router->platform = tor_strdup("<unknown>");
- }
- log_fn(LOG_DEBUG,"or_port %d, socks_port %d, dir_port %d, bandwidthrate %u, bandwidthburst %u.",
- router->or_port, router->socks_port, router->dir_port,
- (unsigned) router->bandwidthrate, (unsigned) router->bandwidthburst);
- goto done;
- return router;
- err:
- routerinfo_free(router);
- router = NULL;
- done:
- if (tokens) {
- SMARTLIST_FOREACH(tokens, directory_token_t *, tok, token_free(tok));
- smartlist_free(tokens);
- }
- if (exit_policy_tokens) {
- smartlist_free(exit_policy_tokens);
- }
- return router;
- }
- /** Parse the exit policy in the string <b>s</b> and return it.
- */
- struct exit_policy_t *
- router_parse_exit_policy_from_string(const char *s)
- {
- directory_token_t *tok = NULL;
- const char *cp;
- char *tmp;
- struct exit_policy_t *r;
- int len, idx;
- /* *s might not end with \n, so we need to extend it with one. */
- len = strlen(s);
- cp = tmp = tor_malloc(len+2);
- for (idx = 0; idx < len; ++idx) {
- tmp[idx] = tolower(s[idx]);
- }
- tmp[len]='\n';
- tmp[len+1]='\0';
- tok = get_next_token(&cp, RTR_ONLY);
- if (tok->tp == _ERR) {
- log_fn(LOG_WARN, "Error reading exit policy: %s", tok->error);
- goto err;
- }
- if (tok->tp != K_ACCEPT && tok->tp != K_REJECT) {
- log_fn(LOG_WARN, "Expected 'accept' or 'reject'.");
- goto err;
- }
- /* Now that we've gotten an exit policy, add it to the router. */
- r = router_parse_exit_policy(tok);
- goto done;
- err:
- r = NULL;
- done:
- free(tmp);
- token_free(tok);
- return r;
- }
- int router_add_exit_policy_from_string(routerinfo_t *router, const char *s)
- {
- struct exit_policy_t *newe, *tmpe;
- newe = router_parse_exit_policy_from_string(s);
- if (!newe)
- return -1;
- for (tmpe = router->exit_policy; tmpe; tmpe=tmpe->next)
- ;
- tmpe->next = newe;
- return 0;
- }
- static int router_add_exit_policy(routerinfo_t *router,directory_token_t *tok)
- {
- struct exit_policy_t *newe, **tmpe;
- newe = router_parse_exit_policy(tok);
- if (!newe)
- return -1;
- for (tmpe = &router->exit_policy; *tmpe; tmpe=&((*tmpe)->next))
- ;
- *tmpe = newe;
- return 0;
- }
- /** Given a K_ACCEPT or K_REJECT token and a router, create a new exit_policy_t
- * corresponding to the token, and add it to <b>router</b> */
- static struct exit_policy_t *
- router_parse_exit_policy(directory_token_t *tok) {
- struct exit_policy_t*newe;
- struct in_addr in;
- char *arg, *address, *mask, *port, *endptr;
- int bits;
- tor_assert(tok->tp == K_REJECT || tok->tp == K_ACCEPT);
- if (tok->n_args != 1)
- return NULL;
- arg = tok->args[0];
- newe = tor_malloc_zero(sizeof(struct exit_policy_t));
- newe->string = tor_malloc(8+strlen(arg));
- if (tok->tp == K_REJECT) {
- strcpy(newe->string, "reject ");
- newe->policy_type = EXIT_POLICY_REJECT;
- } else {
- strcpy(newe->string, "accept ");
- newe->policy_type = EXIT_POLICY_ACCEPT;
- }
- strcat(newe->string, arg); /* can't overflow */
- address = arg;
- mask = strchr(arg,'/');
- port = strchr(mask?mask:arg,':');
- /* Break 'arg' into separate strings. 'arg' was already strdup'd by
- * _router_get_next_token, so it's safe to modify.
- */
- if (mask)
- *mask++ = 0;
- if (port)
- *port++ = 0;
- if (strcmp(address, "*") == 0) {
- newe->addr = 0;
- } else if (tor_inet_aton(address, &in) != 0) {
- newe->addr = ntohl(in.s_addr);
- } else {
- log_fn(LOG_WARN, "Malformed IP %s in exit policy; rejecting.",
- address);
- goto policy_read_failed;
- }
- if (!mask) {
- if (strcmp(address, "*") == 0)
- newe->msk = 0;
- else
- newe->msk = 0xFFFFFFFFu;
- } else {
- endptr = NULL;
- bits = (int) strtol(mask, &endptr, 10);
- if (!*endptr) {
- /* strtol handled the whole mask. */
- newe->msk = ~((1<<(32-bits))-1);
- } else if (tor_inet_aton(mask, &in) != 0) {
- newe->msk = ntohl(in.s_addr);
- } else {
- log_fn(LOG_WARN, "Malformed mask %s on exit policy; rejecting.",
- mask);
- goto policy_read_failed;
- }
- }
- if (!port || strcmp(port, "*") == 0) {
- newe->prt_min = 0;
- newe->prt_max = 65535;
- } else {
- endptr = NULL;
- newe->prt_min = (uint16_t) strtol(port, &endptr, 10);
- if (*endptr == '-') {
- port = endptr+1;
- endptr = NULL;
- newe->prt_max = (uint16_t) strtol(port, &endptr, 10);
- if (*endptr) {
- log_fn(LOG_WARN, "Malformed port %s on exit policy; rejecting.",
- port);
- }
- } else if (*endptr) {
- log_fn(LOG_WARN, "Malformed port %s on exit policy; rejecting.",
- port);
- goto policy_read_failed;
- } else {
- newe->prt_max = newe->prt_min;
- }
- }
- in.s_addr = htonl(newe->addr);
- address = tor_strdup(inet_ntoa(in));
- in.s_addr = htonl(newe->msk);
- log_fn(LOG_DEBUG,"%s %s/%s:%d-%d",
- newe->policy_type == EXIT_POLICY_REJECT ? "reject" : "accept",
- address, inet_ntoa(in), newe->prt_min, newe->prt_max);
- tor_free(address);
- newe->next = NULL;
- return newe;
- policy_read_failed:
- tor_assert(newe->string);
- log_fn(LOG_WARN,"Couldn't parse line '%s'. Dropping", newe->string);
- tor_free(newe->string);
- free(newe);
- return NULL;
- }
- /*
- * Low-level tokenizer for router descriptors and directories.
- */
- /** Free all resources allocated for <b>tok</b> */
- static void
- token_free(directory_token_t *tok)
- {
- int i;
- tor_assert(tok);
- if (tok->args) {
- for (i = 0; i < tok->n_args; ++i) {
- tor_free(tok->args[i]);
- }
- tor_free(tok->args);
- }
- tor_free(tok->object_type);
- tor_free(tok->object_body);
- if (tok->key)
- crypto_free_pk_env(tok->key);
- tor_free(tok);
- }
- /** Helper function: read the next token from *s, advance *s to the end
- * of the token, and return the parsed token. If 'where' is DIR_ONLY
- * or RTR_ONLY, reject all tokens of the wrong type.
- */
- static directory_token_t *
- get_next_token(const char **s, where_syntax where) {
- const char *next, *obstart;
- int i, done, allocated, is_opt;
- directory_token_t *tok;
- arg_syntax a_syn;
- obj_syntax o_syn = NO_OBJ;
- #define RET_ERR(msg) \
- do { if (tok) token_free(tok); \
- tok = tor_malloc_zero(sizeof(directory_token_t));\
- tok->tp = _ERR; \
- tok->error = msg; \
- goto done_tokenizing; } while (0)
- tok = tor_malloc_zero(sizeof(directory_token_t));
- tok->tp = _ERR;
- *s = eat_whitespace(*s);
- if (!**s) {
- tok->tp = _EOF;
- return tok;
- }
- next = find_whitespace(*s);
- if (!next) {
- tok->error = "Unexpected EOF"; return tok;
- }
- /* It's a keyword... but which one? */
- is_opt = !strncmp("opt", *s, next-*s);
- if (is_opt) {
- *s = eat_whitespace(next);
- next = NULL;
- if (**s)
- next = find_whitespace(*s);
- if (!**s || !next) {
- RET_ERR("opt without keyword");
- }
- }
- for (i = 0; token_table[i].t ; ++i) {
- if (!strncmp(token_table[i].t, *s, next-*s)) {
- /* We've found the keyword. */
- tok->tp = token_table[i].v;
- a_syn = token_table[i].s;
- o_syn = token_table[i].os;
- if (token_table[i].ws != ANY && token_table[i].ws != where) {
- if (where == DIR_ONLY) {
- RET_ERR("Found a router-only token in a directory section");
- } else {
- RET_ERR("Found a directory-only token in a router descriptor");
- }
- }
- if (a_syn == ARGS) {
- /* This keyword takes multiple arguments. */
- i = 0;
- done = (*next == '\n');
- allocated = 32;
- tok->args = tor_malloc(sizeof(char*)*32);
- *s = eat_whitespace_no_nl(next);
- while (**s != '\n' && !done) {
- next = find_whitespace(*s);
- if (*next == '\n')
- done = 1;
- if (i == allocated) {
- allocated *= 2;
- tok->args = tor_realloc(tok->args,sizeof(char*)*allocated);
- }
- tok->args[i++] = tor_strndup(*s,next-*s);
- *s = eat_whitespace_no_nl(next+1);
- }
- tok->n_args = i;
- } else if (a_syn == CONCAT_ARGS) {
- /* The keyword takes the line as a single argument */
- *s = eat_whitespace_no_nl(next);
- next = strchr(*s, '\n');
- if (!next)
- RET_ERR("Unexpected EOF");
- tok->args = tor_malloc(sizeof(char*));
- tok->args[0] = tor_strndup(*s,next-*s);
- tok->n_args = 1;
- *s = eat_whitespace_no_nl(next+1);
- } else {
- /* The keyword takes no arguments. */
- tor_assert(a_syn == NO_ARGS);
- *s = eat_whitespace_no_nl(next);
- if (**s != '\n') {
- RET_ERR("Unexpected arguments");
- }
- tok->n_args = 0;
- *s = eat_whitespace_no_nl(*s+1);
- }
- break;
- }
- }
- if (tok->tp == _ERR) {
- if (is_opt) {
- tok->tp = K_OPT;
- *s = eat_whitespace_no_nl(next);
- next = strchr(*s,'\n');
- if (!next)
- RET_ERR("Unexpected EOF");
- tok->args = tor_malloc(sizeof(char*));
- tok->args[0] = tor_strndup(*s,next-*s);
- tok->n_args = 1;
- *s = eat_whitespace_no_nl(next+1);
- a_syn = OBJ_OK;
- } else {
- tok->tp = _UNRECOGNIZED;
- next = strchr(*s, '\n');
- if (!next) {
- RET_ERR("Unexpected EOF");
- }
- tok->args = tor_malloc(sizeof(char*));
- tok->args[0] = tor_strndup(*s,next-*s);
- tok->n_args = 1;
- *s = next+1;
- o_syn = OBJ_OK;
- }
- }
- *s = eat_whitespace(*s);
- if (strncmp(*s, "-----BEGIN ", 11)) {
- goto done_tokenizing;
- }
- obstart = *s;
- *s += 11; /* length of "-----BEGIN ". */
- next = strchr(*s, '\n');
- if (next-*s < 6 || strncmp(next-5, "-----\n", 6)) {
- RET_ERR("Malformed object: bad begin line");
- }
- tok->object_type = tor_strndup(*s, next-*s-5);
- *s = next+1;
- next = strstr(*s, "-----END ");
- if (!next) {
- RET_ERR("Malformed object: missing end line");
- }
- if (!strcmp(tok->object_type, "RSA PUBLIC KEY")) {
- if (strncmp(next, "-----END RSA PUBLIC KEY-----\n", 29))
- RET_ERR("Malformed object: mismatched end line");
- next = strchr(next,'\n')+1;
- tok->key = crypto_new_pk_env();
- if (crypto_pk_read_public_key_from_string(tok->key, obstart, next-obstart))
- RET_ERR("Couldn't parse public key.");
- *s = next;
- } else {
- tok->object_body = tor_malloc(next-*s); /* really, this is too much RAM. */
- i = base64_decode(tok->object_body, 256, *s, next-*s);
- if (i<0) {
- RET_ERR("Malformed object: bad base64-encoded data");
- }
- tok->object_size = i;
- *s = next + 9; /* length of "-----END ". */
- i = strlen(tok->object_type);
- if (strncmp(*s, tok->object_type, i) || strncmp(*s+i, "-----\n", 6)) {
- RET_ERR("Malformed object: mismatched end tag");
- }
- *s += i+6;
- }
- switch(o_syn)
- {
- case NO_OBJ:
- if (tok->object_body)
- RET_ERR("Unexpected object for keyword");
- if (tok->key)
- RET_ERR("Unexpected public key for keyword");
- break;
- case NEED_OBJ:
- if (!tok->object_body)
- RET_ERR("Missing object for keyword");
- break;
- case NEED_KEY:
- if (!tok->key)
- RET_ERR("Missing publid key for keyword");
- break;
- case OBJ_OK:
- break;
- }
- done_tokenizing:
- #if 0
- for (i = 0; token_table[i].t ; ++i) {
- if (token_table[i].v == tok->tp) {
- fputs(token_table[i].t, stdout);
- break;
- i = -1;
- }
- }
- if (i) {
- if (tok->tp == _UNRECOGNIZED) fputs("UNRECOGNIZED", stdout);
- if (tok->tp == _ERR) fputs("ERR",stdout);
- if (tok->tp == _EOF) fputs("EOF",stdout);
- if (tok->tp == _NIL) fputs("_NIL",stdout);
- }
- for(i = 0; i < tok->n_args; ++i) {
- fprintf(stdout," \"%s\"", tok->args[i]);
- }
- if (tok->error) { fprintf(stdout," *%s*", tok->error); }
- fputs("\n",stdout);
- #endif
- return tok;
- #undef RET_ERR
- }
- /** Read all tokens from a string between <b>start</b> and <b>end</b>, and add
- * them to <b>out</b>. If <b>is_dir</b> is true, reject all non-directory
- * tokens; else reject all non-routerdescriptor tokens.
- */
- static int
- tokenize_string(const char *start, const char *end, smartlist_t *out,
- int is_dir)
- {
- const char **s;
- directory_token_t *tok = NULL;
- where_syntax where = is_dir ? DIR_ONLY : RTR_ONLY;
- s = &start;
- while (*s < end && (!tok || tok->tp != _EOF)) {
- tok = get_next_token(s, where);
- if (tok->tp == _ERR) {
- log_fn(LOG_WARN, "parse error: %s", tok->error);
- return -1;
- }
- smartlist_add(out, tok);
- *s = eat_whitespace(*s);
- }
- return 0;
- }
- /** Find the first token in <b>s</b> whose keyword is <b>keyword</b>; return
- * NULL if no such keyword is found.
- */
- static directory_token_t *
- find_first_by_keyword(smartlist_t *s, directory_keyword keyword)
- {
- SMARTLIST_FOREACH(s, directory_token_t *, t, if (t->tp == keyword) return t);
- return NULL;
- }
- /** Return a newly allocated smartlist of all accept or reject tokens in
- * <b>s</b>.
- */
- static smartlist_t *
- find_all_exitpolicy(smartlist_t *s)
- {
- smartlist_t *out = smartlist_create();
- SMARTLIST_FOREACH(s, directory_token_t *, t,
- if (t->tp == K_ACCEPT || t->tp == K_REJECT)
- smartlist_add(out,t));
- return out;
- }
- /** Compute the SHA digest of the substring of <b>s</b> taken from the first
- * occurrence of <b>start_str</b> through the first newline after the first
- * subsequent occurrence of <b>end_str</b>; store the 20-byte result in
- * <b>digest</b>; return 0 on success.
- *
- * If no such substring exists, return -1.
- */
- static int router_get_hash_impl(const char *s, char *digest,
- const char *start_str,
- const char *end_str)
- {
- char *start, *end;
- start = strstr(s, start_str);
- if (!start) {
- log_fn(LOG_WARN,"couldn't find \"%s\"",start_str);
- return -1;
- }
- if (start != s && *(start-1) != '\n') {
- log_fn(LOG_WARN, "first occurance of \"%s\" is not at the start of a line",
- start_str);
- return -1;
- }
- end = strstr(start+strlen(start_str), end_str);
- if (!end) {
- log_fn(LOG_WARN,"couldn't find \"%s\"",end_str);
- return -1;
- }
- end = strchr(end, '\n');
- if (!end) {
- log_fn(LOG_WARN,"couldn't find EOL");
- return -1;
- }
- ++end;
- if (crypto_digest(start, end-start, digest)) {
- log_fn(LOG_WARN,"couldn't compute digest");
- return -1;
- }
- return 0;
- }
- int tor_version_parse(const char *s, tor_version_t *out)
- {
- char *eos=NULL, *cp=NULL;
- /* Format is:
- * NUM dot NUM dot NUM [ ( pre | rc | dot ) NUM [ -cvs ] ]
- */
- tor_assert(s && out);
- memset(out, 0, sizeof(tor_version_t));
- /* Get major. */
- out->major = strtol(s,&eos,10);
- if (!eos || eos==s || *eos != '.') return -1;
- cp = eos+1;
- /* Get minor */
- out->minor = strtol(cp,&eos,10);
- if (!eos || eos==cp || *eos != '.') return -1;
- cp = eos+1;
- /* Get micro */
- out->micro = strtol(cp,&eos,10);
- if (!eos || eos==cp) return -1;
- if (!*eos) {
- out->status = VER_RELEASE;
- out->patchlevel = 0;
- out->cvs = IS_NOT_CVS;
- return 0;
- }
- cp = eos;
- /* Get status */
- if (*cp == '.') {
- out->status = VER_RELEASE;
- ++cp;
- } else if (0==strncmp(cp, "pre", 3)) {
- out->status = VER_PRE;
- cp += 3;
- } else if (0==strncmp(cp, "rc", 2)) {
- out->status = VER_RC;
- cp += 2;
- } else {
- return -1;
- }
- /* Get patchlevel */
- out->patchlevel = strtol(cp,&eos,10);
- if (!eos || eos==cp) return -1;
- cp = eos;
- /* Get cvs status. */
- if (!*eos) {
- out->cvs = IS_NOT_CVS;
- } else if (0==strcmp(cp, "-cvs")) {
- out->cvs = IS_CVS;
- } else {
- return -1;
- }
- return 0;
- }
- /** Compare two tor versions; Return <0 if a < b; 0 if a ==b, >0 if a >
- * b. */
- int tor_version_compare(tor_version_t *a, tor_version_t *b)
- {
- int i;
- tor_assert(a && b);
- if ((i = a->major - b->major))
- return i;
- else if ((i = a->minor - b->minor))
- return i;
- else if ((i = a->micro - b->micro))
- return i;
- else if ((i = a->status - b->status))
- return i;
- else if ((i = a->patchlevel - b->patchlevel))
- return i;
- else if ((i = a->cvs - b->cvs))
- return i;
- else
- return 0;
- }
- /*
- Local Variables:
- mode:c
- indent-tabs-mode:nil
- c-basic-offset:2
- End:
- */
|