123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615 |
- /* Copyright (c) 2014-2017, The Tor Project, Inc. */
- /* See LICENSE for licensing information */
- #include "orconfig.h"
- #include <math.h>
- #include <time.h>
- #define CONNECTION_PRIVATE
- #define DIRECTORY_PRIVATE
- #define DIRVOTE_PRIVATE
- #define ENTRYNODES_PRIVATE
- #define HIBERNATE_PRIVATE
- #define NETWORKSTATUS_PRIVATE
- #define ROUTERLIST_PRIVATE
- #define TOR_UNIT_TESTING
- #include "or.h"
- #include "config.h"
- #include "connection.h"
- #include "container.h"
- #include "control.h"
- #include "directory.h"
- #include "dirvote.h"
- #include "entrynodes.h"
- #include "hibernate.h"
- #include "microdesc.h"
- #include "networkstatus.h"
- #include "nodelist.h"
- #include "policies.h"
- #include "router.h"
- #include "routerlist.h"
- #include "routerset.h"
- #include "routerparse.h"
- #include "shared_random.h"
- #include "statefile.h"
- #include "test.h"
- #include "test_dir_common.h"
- #include "log_test_helpers.h"
- void construct_consensus(char **consensus_text_md);
- static authority_cert_t *mock_cert;
- static authority_cert_t *
- get_my_v3_authority_cert_m(void)
- {
- tor_assert(mock_cert);
- return mock_cert;
- }
- /* 4 digests + 3 sep + pre + post + NULL */
- static char output[4*BASE64_DIGEST256_LEN+3+2+2+1];
- static void
- mock_get_from_dirserver(uint8_t dir_purpose, uint8_t router_purpose,
- const char *resource, int pds_flags,
- download_want_authority_t want_authority)
- {
- (void)dir_purpose;
- (void)router_purpose;
- (void)pds_flags;
- (void)want_authority;
- tt_assert(resource);
- strlcpy(output, resource, sizeof(output));
- done:
- ;
- }
- static void
- test_routerlist_initiate_descriptor_downloads(void *arg)
- {
- const char *prose = "unhurried and wise, we perceive.";
- smartlist_t *digests = smartlist_new();
- (void)arg;
- for (int i = 0; i < 20; i++) {
- smartlist_add(digests, (char*)prose);
- }
- MOCK(directory_get_from_dirserver, mock_get_from_dirserver);
- initiate_descriptor_downloads(NULL, DIR_PURPOSE_FETCH_MICRODESC,
- digests, 3, 7, 0);
- UNMOCK(directory_get_from_dirserver);
- tt_str_op(output, OP_EQ, "d/"
- "dW5odXJyaWVkIGFuZCB3aXNlLCB3ZSBwZXJjZWl2ZS4-"
- "dW5odXJyaWVkIGFuZCB3aXNlLCB3ZSBwZXJjZWl2ZS4-"
- "dW5odXJyaWVkIGFuZCB3aXNlLCB3ZSBwZXJjZWl2ZS4-"
- "dW5odXJyaWVkIGFuZCB3aXNlLCB3ZSBwZXJjZWl2ZS4"
- ".z");
- done:
- smartlist_free(digests);
- }
- static int count = 0;
- static void
- mock_initiate_descriptor_downloads(const routerstatus_t *source,
- int purpose, smartlist_t *digests,
- int lo, int hi, int pds_flags)
- {
- (void)source;
- (void)purpose;
- (void)digests;
- (void)pds_flags;
- (void)hi;
- (void)lo;
- count += 1;
- }
- static void
- test_routerlist_launch_descriptor_downloads(void *arg)
- {
- smartlist_t *downloadable = smartlist_new();
- time_t now = time(NULL);
- char *cp;
- (void)arg;
- for (int i = 0; i < 100; i++) {
- cp = tor_malloc(DIGEST256_LEN);
- tt_assert(cp);
- crypto_rand(cp, DIGEST256_LEN);
- smartlist_add(downloadable, cp);
- }
- MOCK(initiate_descriptor_downloads, mock_initiate_descriptor_downloads);
- launch_descriptor_downloads(DIR_PURPOSE_FETCH_MICRODESC, downloadable,
- NULL, now);
- tt_int_op(3, OP_EQ, count);
- UNMOCK(initiate_descriptor_downloads);
- done:
- SMARTLIST_FOREACH(downloadable, char *, cp1, tor_free(cp1));
- smartlist_free(downloadable);
- }
- void
- construct_consensus(char **consensus_text_md)
- {
- networkstatus_t *vote = NULL;
- networkstatus_t *v1 = NULL, *v2 = NULL, *v3 = NULL;
- networkstatus_voter_info_t *voter = NULL;
- authority_cert_t *cert1=NULL, *cert2=NULL, *cert3=NULL;
- crypto_pk_t *sign_skey_1=NULL, *sign_skey_2=NULL, *sign_skey_3=NULL;
- crypto_pk_t *sign_skey_leg=NULL;
- time_t now = time(NULL);
- smartlist_t *votes = NULL;
- int n_vrs;
- tt_assert(!dir_common_authority_pk_init(&cert1, &cert2, &cert3,
- &sign_skey_1, &sign_skey_2,
- &sign_skey_3));
- sign_skey_leg = pk_generate(4);
- dir_common_construct_vote_1(&vote, cert1, sign_skey_1,
- &dir_common_gen_routerstatus_for_v3ns,
- &v1, &n_vrs, now, 1);
- networkstatus_vote_free(vote);
- tt_assert(v1);
- tt_int_op(n_vrs, OP_EQ, 4);
- tt_int_op(smartlist_len(v1->routerstatus_list), OP_EQ, 4);
- dir_common_construct_vote_2(&vote, cert2, sign_skey_2,
- &dir_common_gen_routerstatus_for_v3ns,
- &v2, &n_vrs, now, 1);
- networkstatus_vote_free(vote);
- tt_assert(v2);
- tt_int_op(n_vrs, OP_EQ, 4);
- tt_int_op(smartlist_len(v2->routerstatus_list), OP_EQ, 4);
- dir_common_construct_vote_3(&vote, cert3, sign_skey_3,
- &dir_common_gen_routerstatus_for_v3ns,
- &v3, &n_vrs, now, 1);
- tt_assert(v3);
- tt_int_op(n_vrs, OP_EQ, 4);
- tt_int_op(smartlist_len(v3->routerstatus_list), OP_EQ, 4);
- networkstatus_vote_free(vote);
- votes = smartlist_new();
- smartlist_add(votes, v1);
- smartlist_add(votes, v2);
- smartlist_add(votes, v3);
- *consensus_text_md = networkstatus_compute_consensus(votes, 3,
- cert1->identity_key,
- sign_skey_1,
- "AAAAAAAAAAAAAAAAAAAA",
- sign_skey_leg,
- FLAV_MICRODESC);
- tt_assert(*consensus_text_md);
- done:
- tor_free(voter);
- networkstatus_vote_free(v1);
- networkstatus_vote_free(v2);
- networkstatus_vote_free(v3);
- smartlist_free(votes);
- authority_cert_free(cert1);
- authority_cert_free(cert2);
- authority_cert_free(cert3);
- crypto_pk_free(sign_skey_1);
- crypto_pk_free(sign_skey_2);
- crypto_pk_free(sign_skey_3);
- crypto_pk_free(sign_skey_leg);
- }
- static int mock_usable_consensus_flavor_value = FLAV_NS;
- static int
- mock_usable_consensus_flavor(void)
- {
- return mock_usable_consensus_flavor_value;
- }
- static void
- test_router_pick_directory_server_impl(void *arg)
- {
- (void)arg;
- networkstatus_t *con_md = NULL;
- char *consensus_text_md = NULL;
- int flags = PDS_IGNORE_FASCISTFIREWALL|PDS_RETRY_IF_NO_SERVERS;
- or_options_t *options = get_options_mutable();
- const routerstatus_t *rs = NULL;
- options->UseMicrodescriptors = 1;
- char *router1_id = NULL, *router2_id = NULL, *router3_id = NULL;
- node_t *node_router1 = NULL, *node_router2 = NULL, *node_router3 = NULL;
- config_line_t *policy_line = NULL;
- time_t now = time(NULL);
- int tmp_dirport1, tmp_dirport3;
- (void)arg;
- MOCK(usable_consensus_flavor, mock_usable_consensus_flavor);
- /* With no consensus, we must be bootstrapping, regardless of time or flavor
- */
- mock_usable_consensus_flavor_value = FLAV_NS;
- tt_assert(networkstatus_consensus_is_bootstrapping(now));
- tt_assert(networkstatus_consensus_is_bootstrapping(now + 2000));
- tt_assert(networkstatus_consensus_is_bootstrapping(now + 2*24*60*60));
- tt_assert(networkstatus_consensus_is_bootstrapping(now - 2*24*60*60));
- mock_usable_consensus_flavor_value = FLAV_MICRODESC;
- tt_assert(networkstatus_consensus_is_bootstrapping(now));
- tt_assert(networkstatus_consensus_is_bootstrapping(now + 2000));
- tt_assert(networkstatus_consensus_is_bootstrapping(now + 2*24*60*60));
- tt_assert(networkstatus_consensus_is_bootstrapping(now - 2*24*60*60));
- /* Init SR subsystem. */
- MOCK(get_my_v3_authority_cert, get_my_v3_authority_cert_m);
- mock_cert = authority_cert_parse_from_string(AUTHORITY_CERT_1, NULL);
- sr_init(0);
- UNMOCK(get_my_v3_authority_cert);
- /* No consensus available, fail early */
- rs = router_pick_directory_server_impl(V3_DIRINFO, (const int) 0, NULL);
- tt_ptr_op(rs, OP_EQ, NULL);
- construct_consensus(&consensus_text_md);
- tt_assert(consensus_text_md);
- con_md = networkstatus_parse_vote_from_string(consensus_text_md, NULL,
- NS_TYPE_CONSENSUS);
- tt_assert(con_md);
- tt_int_op(con_md->flavor,OP_EQ, FLAV_MICRODESC);
- tt_assert(con_md->routerstatus_list);
- tt_int_op(smartlist_len(con_md->routerstatus_list), OP_EQ, 3);
- tt_assert(!networkstatus_set_current_consensus_from_ns(con_md,
- "microdesc"));
- /* If the consensus time or flavor doesn't match, we are still
- * bootstrapping */
- mock_usable_consensus_flavor_value = FLAV_NS;
- tt_assert(networkstatus_consensus_is_bootstrapping(now));
- tt_assert(networkstatus_consensus_is_bootstrapping(now + 2000));
- tt_assert(networkstatus_consensus_is_bootstrapping(now + 2*24*60*60));
- tt_assert(networkstatus_consensus_is_bootstrapping(now - 2*24*60*60));
- /* With a valid consensus for the current time and flavor, we stop
- * bootstrapping, even if we have no certificates */
- mock_usable_consensus_flavor_value = FLAV_MICRODESC;
- tt_assert(!networkstatus_consensus_is_bootstrapping(now + 2000));
- tt_assert(!networkstatus_consensus_is_bootstrapping(con_md->valid_after));
- tt_assert(!networkstatus_consensus_is_bootstrapping(con_md->valid_until));
- tt_assert(!networkstatus_consensus_is_bootstrapping(con_md->valid_until
- + 24*60*60));
- /* These times are outside the test validity period */
- tt_assert(networkstatus_consensus_is_bootstrapping(now));
- tt_assert(networkstatus_consensus_is_bootstrapping(now + 2*24*60*60));
- tt_assert(networkstatus_consensus_is_bootstrapping(now - 2*24*60*60));
- nodelist_set_consensus(con_md);
- nodelist_assert_ok();
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- /* We should not fail now we have a consensus and routerstatus_list
- * and nodelist are populated. */
- tt_ptr_op(rs, OP_NE, NULL);
- /* Manipulate the nodes so we get the dir server we expect */
- router1_id = tor_malloc(DIGEST_LEN);
- memset(router1_id, TEST_DIR_ROUTER_ID_1, DIGEST_LEN);
- router2_id = tor_malloc(DIGEST_LEN);
- memset(router2_id, TEST_DIR_ROUTER_ID_2, DIGEST_LEN);
- router3_id = tor_malloc(DIGEST_LEN);
- memset(router3_id, TEST_DIR_ROUTER_ID_3, DIGEST_LEN);
- node_router1 = node_get_mutable_by_id(router1_id);
- node_router2 = node_get_mutable_by_id(router2_id);
- node_router3 = node_get_mutable_by_id(router3_id);
- node_router1->is_possible_guard = 1;
- node_router1->is_running = 0;
- node_router3->is_running = 0;
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- tt_ptr_op(rs, OP_NE, NULL);
- tt_assert(tor_memeq(rs->identity_digest, router2_id, DIGEST_LEN));
- rs = NULL;
- node_router1->is_running = 1;
- node_router3->is_running = 1;
- node_router1->rs->is_v2_dir = 0;
- node_router3->rs->is_v2_dir = 0;
- tmp_dirport1 = node_router1->rs->dir_port;
- tmp_dirport3 = node_router3->rs->dir_port;
- node_router1->rs->dir_port = 0;
- node_router3->rs->dir_port = 0;
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- tt_ptr_op(rs, OP_NE, NULL);
- tt_assert(tor_memeq(rs->identity_digest, router2_id, DIGEST_LEN));
- rs = NULL;
- node_router1->rs->is_v2_dir = 1;
- node_router3->rs->is_v2_dir = 1;
- node_router1->rs->dir_port = tmp_dirport1;
- node_router3->rs->dir_port = tmp_dirport3;
- node_router1->is_valid = 0;
- node_router3->is_valid = 0;
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- tt_ptr_op(rs, OP_NE, NULL);
- tt_assert(tor_memeq(rs->identity_digest, router2_id, DIGEST_LEN));
- rs = NULL;
- node_router1->is_valid = 1;
- node_router3->is_valid = 1;
- /* Manipulate overloaded */
- node_router2->rs->last_dir_503_at = now;
- node_router3->rs->last_dir_503_at = now;
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- tt_ptr_op(rs, OP_NE, NULL);
- tt_assert(tor_memeq(rs->identity_digest, router1_id, DIGEST_LEN));
- node_router2->rs->last_dir_503_at = 0;
- node_router3->rs->last_dir_503_at = 0;
- /* Set a Fascist firewall */
- flags &= ~ PDS_IGNORE_FASCISTFIREWALL;
- policy_line = tor_malloc_zero(sizeof(config_line_t));
- policy_line->key = tor_strdup("ReachableORAddresses");
- policy_line->value = tor_strdup("accept *:442, reject *:*");
- options->ReachableORAddresses = policy_line;
- policies_parse_from_options(options);
- node_router1->rs->or_port = 444;
- node_router2->rs->or_port = 443;
- node_router3->rs->or_port = 442;
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- tt_ptr_op(rs, OP_NE, NULL);
- tt_assert(tor_memeq(rs->identity_digest, router3_id, DIGEST_LEN));
- node_router1->rs->or_port = 442;
- node_router2->rs->or_port = 443;
- node_router3->rs->or_port = 444;
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- tt_ptr_op(rs, OP_NE, NULL);
- tt_assert(tor_memeq(rs->identity_digest, router1_id, DIGEST_LEN));
- /* Fascist firewall and overloaded */
- node_router1->rs->or_port = 442;
- node_router2->rs->or_port = 443;
- node_router3->rs->or_port = 442;
- node_router3->rs->last_dir_503_at = now;
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- tt_ptr_op(rs, OP_NE, NULL);
- tt_assert(tor_memeq(rs->identity_digest, router1_id, DIGEST_LEN));
- node_router3->rs->last_dir_503_at = 0;
- /* Fascists against OR and Dir */
- policy_line = tor_malloc_zero(sizeof(config_line_t));
- policy_line->key = tor_strdup("ReachableAddresses");
- policy_line->value = tor_strdup("accept *:80, reject *:*");
- options->ReachableDirAddresses = policy_line;
- policies_parse_from_options(options);
- node_router1->rs->or_port = 442;
- node_router2->rs->or_port = 441;
- node_router3->rs->or_port = 443;
- node_router1->rs->dir_port = 80;
- node_router2->rs->dir_port = 80;
- node_router3->rs->dir_port = 81;
- node_router1->rs->last_dir_503_at = now;
- rs = router_pick_directory_server_impl(V3_DIRINFO, flags, NULL);
- tt_ptr_op(rs, OP_NE, NULL);
- tt_assert(tor_memeq(rs->identity_digest, router1_id, DIGEST_LEN));
- node_router1->rs->last_dir_503_at = 0;
- done:
- UNMOCK(usable_consensus_flavor);
- if (router1_id)
- tor_free(router1_id);
- if (router2_id)
- tor_free(router2_id);
- if (router3_id)
- tor_free(router3_id);
- if (options->ReachableORAddresses ||
- options->ReachableDirAddresses)
- policies_free_all();
- tor_free(consensus_text_md);
- networkstatus_vote_free(con_md);
- }
- static or_state_t *dummy_state = NULL;
- static or_state_t *
- get_or_state_replacement(void)
- {
- return dummy_state;
- }
- static void
- mock_directory_initiate_request(directory_request_t *req)
- {
- (void)req;
- return;
- }
- static circuit_guard_state_t *
- mock_circuit_guard_state_new(entry_guard_t *guard, unsigned state,
- entry_guard_restriction_t *rst)
- {
- (void) guard;
- (void) state;
- (void) rst;
- return NULL;
- }
- /** Test that we will use our directory guards to fetch mds even if we don't
- * have any dirinfo (tests bug #23862). */
- static void
- test_directory_guard_fetch_with_no_dirinfo(void *arg)
- {
- int retval;
- char *consensus_text_md = NULL;
- or_options_t *options = get_options_mutable();
- (void) arg;
- hibernate_set_state_for_testing_(HIBERNATE_STATE_LIVE);
- /* Initialize the SRV subsystem */
- MOCK(get_my_v3_authority_cert, get_my_v3_authority_cert_m);
- mock_cert = authority_cert_parse_from_string(AUTHORITY_CERT_1, NULL);
- sr_init(0);
- UNMOCK(get_my_v3_authority_cert);
- /* Initialize the entry node configuration from the ticket */
- options->UseEntryGuards = 1;
- options->StrictNodes = 1;
- get_options_mutable()->EntryNodes = routerset_new();
- routerset_parse(get_options_mutable()->EntryNodes,
- "2121212121212121212121212121212121212121", "foo");
- /* Mock some functions */
- dummy_state = tor_malloc_zero(sizeof(or_state_t));
- MOCK(get_or_state, get_or_state_replacement);
- MOCK(directory_initiate_request, mock_directory_initiate_request);
- /* we need to mock this one to avoid memleaks */
- MOCK(circuit_guard_state_new, mock_circuit_guard_state_new);
- /* Call guards_update_all() to simulate loading our state file (see
- * entry_guards_load_guards_from_state() and ticket #23989). */
- guards_update_all();
- /* Test logic: Simulate the arrival of a new consensus when we have no
- * dirinfo at all. Tor will need to fetch the mds from the consensus. Make
- * sure that Tor will use the specified entry guard instead of relying on the
- * fallback directories. */
- /* Fixup the dirconn that will deliver the consensus */
- dir_connection_t *conn = dir_connection_new(AF_INET);
- tor_addr_from_ipv4h(&conn->base_.addr, 0x7f000001);
- conn->base_.port = 8800;
- TO_CONN(conn)->address = tor_strdup("127.0.0.1");
- conn->base_.purpose = DIR_PURPOSE_FETCH_CONSENSUS;
- conn->requested_resource = tor_strdup("ns");
- /* Construct a consensus */
- construct_consensus(&consensus_text_md);
- tt_assert(consensus_text_md);
- /* Place the consensus in the dirconn */
- response_handler_args_t args;
- memset(&args, 0, sizeof(response_handler_args_t));
- args.status_code = 200;
- args.body = consensus_text_md;
- args.body_len = strlen(consensus_text_md);
- /* Update approx time so that the consensus is considered live */
- update_approx_time(time(NULL)+1010);
- setup_capture_of_logs(LOG_DEBUG);
- /* Now handle the consensus */
- retval = handle_response_fetch_consensus(conn, &args);
- tt_int_op(retval, OP_EQ, 0);
- /* Make sure that our primary guard was chosen */
- expect_log_msg_containing("Selected primary guard router3");
- done:
- tor_free(consensus_text_md);
- tor_free(dummy_state);
- connection_free_minimal(TO_CONN(conn));
- entry_guards_free_all();
- teardown_capture_of_logs();
- }
- static connection_t *mocked_connection = NULL;
- /* Mock connection_get_by_type_addr_port_purpose by returning
- * mocked_connection. */
- static connection_t *
- mock_connection_get_by_type_addr_port_purpose(int type,
- const tor_addr_t *addr,
- uint16_t port, int purpose)
- {
- (void)type;
- (void)addr;
- (void)port;
- (void)purpose;
- return mocked_connection;
- }
- #define TEST_ADDR_STR "127.0.0.1"
- #define TEST_DIR_PORT 12345
- static void
- test_routerlist_router_is_already_dir_fetching(void *arg)
- {
- (void)arg;
- tor_addr_port_t test_ap, null_addr_ap, zero_port_ap;
- /* Setup */
- tor_addr_parse(&test_ap.addr, TEST_ADDR_STR);
- test_ap.port = TEST_DIR_PORT;
- tor_addr_make_null(&null_addr_ap.addr, AF_INET6);
- null_addr_ap.port = TEST_DIR_PORT;
- tor_addr_parse(&zero_port_ap.addr, TEST_ADDR_STR);
- zero_port_ap.port = 0;
- MOCK(connection_get_by_type_addr_port_purpose,
- mock_connection_get_by_type_addr_port_purpose);
- /* Test that we never get 1 from a NULL connection */
- mocked_connection = NULL;
- tt_int_op(router_is_already_dir_fetching(&test_ap, 1, 1), OP_EQ, 0);
- tt_int_op(router_is_already_dir_fetching(&test_ap, 1, 0), OP_EQ, 0);
- tt_int_op(router_is_already_dir_fetching(&test_ap, 0, 1), OP_EQ, 0);
- /* We always expect 0 in these cases */
- tt_int_op(router_is_already_dir_fetching(&test_ap, 0, 0), OP_EQ, 0);
- tt_int_op(router_is_already_dir_fetching(NULL, 1, 1), OP_EQ, 0);
- tt_int_op(router_is_already_dir_fetching(&null_addr_ap, 1, 1), OP_EQ, 0);
- tt_int_op(router_is_already_dir_fetching(&zero_port_ap, 1, 1), OP_EQ, 0);
- /* Test that we get 1 with a connection in the appropriate circumstances */
- mocked_connection = connection_new(CONN_TYPE_DIR, AF_INET);
- tt_int_op(router_is_already_dir_fetching(&test_ap, 1, 1), OP_EQ, 1);
- tt_int_op(router_is_already_dir_fetching(&test_ap, 1, 0), OP_EQ, 1);
- tt_int_op(router_is_already_dir_fetching(&test_ap, 0, 1), OP_EQ, 1);
- /* Test that we get 0 even with a connection in the appropriate
- * circumstances */
- tt_int_op(router_is_already_dir_fetching(&test_ap, 0, 0), OP_EQ, 0);
- tt_int_op(router_is_already_dir_fetching(NULL, 1, 1), OP_EQ, 0);
- tt_int_op(router_is_already_dir_fetching(&null_addr_ap, 1, 1), OP_EQ, 0);
- tt_int_op(router_is_already_dir_fetching(&zero_port_ap, 1, 1), OP_EQ, 0);
- done:
- /* If a connection is never set up, connection_free chokes on it. */
- if (mocked_connection) {
- buf_free(mocked_connection->inbuf);
- buf_free(mocked_connection->outbuf);
- }
- tor_free(mocked_connection);
- UNMOCK(connection_get_by_type_addr_port_purpose);
- }
- #undef TEST_ADDR_STR
- #undef TEST_DIR_PORT
- #define NODE(name, flags) \
- { #name, test_routerlist_##name, (flags), NULL, NULL }
- #define ROUTER(name,flags) \
- { #name, test_router_##name, (flags), NULL, NULL }
- struct testcase_t routerlist_tests[] = {
- NODE(initiate_descriptor_downloads, 0),
- NODE(launch_descriptor_downloads, 0),
- NODE(router_is_already_dir_fetching, TT_FORK),
- ROUTER(pick_directory_server_impl, TT_FORK),
- { "directory_guard_fetch_with_no_dirinfo",
- test_directory_guard_fetch_with_no_dirinfo, TT_FORK, NULL, NULL },
- END_OF_TESTCASES
- };
|