Merge branch 'ticket40237_035_01' into ticket40237_043_01

This commit is contained in:
David Goulet 2021-01-12 10:46:25 -05:00
commit 60da5d6222
13 changed files with 121 additions and 64 deletions

5
changes/ticket40237 Normal file
View File

@ -0,0 +1,5 @@
o Major bugfixes (onion service v3):
- Stop requiring a live consensus for v3 clients and services to work. The
use of a reasonably live consensus will allow v3 to work properly in most
cases if the network failed to generate a consensus for more than 2 hours
in a row. Fixes bug 40237; bugfix on 0.3.5.1-alpha.

View File

@ -2155,7 +2155,8 @@ hs_service_callback(time_t now, const or_options_t *options)
/* We need to at least be able to build circuits and that we actually have /* We need to at least be able to build circuits and that we actually have
* a working network. */ * a working network. */
if (!have_completed_a_circuit() || net_is_disabled() || if (!have_completed_a_circuit() || net_is_disabled() ||
networkstatus_get_live_consensus(now) == NULL) { !networkstatus_get_reasonably_live_consensus(now,
usable_consensus_flavor())) {
goto end; goto end;
} }

View File

@ -17,6 +17,7 @@
#include "feature/hs/hs_common.h" #include "feature/hs/hs_common.h"
#include "feature/hs/hs_client.h" #include "feature/hs/hs_client.h"
#include "feature/hs/hs_descriptor.h" #include "feature/hs/hs_descriptor.h"
#include "feature/nodelist/microdesc.h"
#include "feature/nodelist/networkstatus.h" #include "feature/nodelist/networkstatus.h"
#include "feature/rend/rendcache.h" #include "feature/rend/rendcache.h"
@ -739,7 +740,9 @@ cached_client_descriptor_has_expired(time_t now,
/* We use the current consensus time to see if we should expire this /* We use the current consensus time to see if we should expire this
* descriptor since we use consensus time for all other parts of the protocol * descriptor since we use consensus time for all other parts of the protocol
* as well (e.g. to build the blinded key and compute time periods). */ * as well (e.g. to build the blinded key and compute time periods). */
const networkstatus_t *ns = networkstatus_get_live_consensus(now); const networkstatus_t *ns =
networkstatus_get_reasonably_live_consensus(now,
usable_consensus_flavor());
/* If we don't have a recent consensus, consider this entry expired since we /* If we don't have a recent consensus, consider this entry expired since we
* will want to fetch a new HS desc when we get a live consensus. */ * will want to fetch a new HS desc when we get a live consensus. */
if (!ns) { if (!ns) {

View File

@ -29,6 +29,7 @@
#include "feature/hs/hs_descriptor.h" #include "feature/hs/hs_descriptor.h"
#include "feature/hs/hs_ident.h" #include "feature/hs/hs_ident.h"
#include "feature/nodelist/describe.h" #include "feature/nodelist/describe.h"
#include "feature/nodelist/microdesc.h"
#include "feature/nodelist/networkstatus.h" #include "feature/nodelist/networkstatus.h"
#include "feature/nodelist/nodelist.h" #include "feature/nodelist/nodelist.h"
#include "feature/nodelist/routerset.h" #include "feature/nodelist/routerset.h"
@ -1207,9 +1208,10 @@ can_client_refetch_desc(const ed25519_public_key_t *identity_pk,
goto cannot; goto cannot;
} }
/* Without a live consensus we can't do any client actions. It is needed to /* Without a usable consensus we can't do any client actions. It is needed
* compute the hashring for a service. */ * to compute the hashring for a service. */
if (!networkstatus_get_live_consensus(approx_time())) { if (!networkstatus_get_reasonably_live_consensus(approx_time(),
usable_consensus_flavor())) {
log_info(LD_REND, "Can't fetch descriptor for service %s because we " log_info(LD_REND, "Can't fetch descriptor for service %s because we "
"are missing a live consensus. Stalling connection.", "are missing a live consensus. Stalling connection.",
safe_str_client(ed25519_fmt(identity_pk))); safe_str_client(ed25519_fmt(identity_pk)));

View File

@ -26,6 +26,7 @@
#include "feature/hs/hs_service.h" #include "feature/hs/hs_service.h"
#include "feature/hs_common/shared_random_client.h" #include "feature/hs_common/shared_random_client.h"
#include "feature/nodelist/describe.h" #include "feature/nodelist/describe.h"
#include "feature/nodelist/microdesc.h"
#include "feature/nodelist/networkstatus.h" #include "feature/nodelist/networkstatus.h"
#include "feature/nodelist/nodelist.h" #include "feature/nodelist/nodelist.h"
#include "feature/nodelist/routerset.h" #include "feature/nodelist/routerset.h"
@ -275,7 +276,9 @@ hs_get_time_period_num(time_t now)
if (now != 0) { if (now != 0) {
current_time = now; current_time = now;
} else { } else {
networkstatus_t *ns = networkstatus_get_live_consensus(approx_time()); networkstatus_t *ns =
networkstatus_get_reasonably_live_consensus(approx_time(),
usable_consensus_flavor());
current_time = ns ? ns->valid_after : approx_time(); current_time = ns ? ns->valid_after : approx_time();
} }
@ -1084,7 +1087,8 @@ hs_in_period_between_tp_and_srv,(const networkstatus_t *consensus, time_t now))
time_t srv_start_time, tp_start_time; time_t srv_start_time, tp_start_time;
if (!consensus) { if (!consensus) {
consensus = networkstatus_get_live_consensus(now); consensus = networkstatus_get_reasonably_live_consensus(now,
usable_consensus_flavor());
if (!consensus) { if (!consensus) {
return 0; return 0;
} }
@ -1329,7 +1333,9 @@ hs_get_responsible_hsdirs(const ed25519_public_key_t *blinded_pk,
sorted_nodes = smartlist_new(); sorted_nodes = smartlist_new();
/* Make sure we actually have a live consensus */ /* Make sure we actually have a live consensus */
networkstatus_t *c = networkstatus_get_live_consensus(approx_time()); networkstatus_t *c =
networkstatus_get_reasonably_live_consensus(approx_time(),
usable_consensus_flavor());
if (!c || smartlist_len(c->routerstatus_list) == 0) { if (!c || smartlist_len(c->routerstatus_list) == 0) {
log_warn(LD_REND, "No live consensus so we can't get the responsible " log_warn(LD_REND, "No live consensus so we can't get the responsible "
"hidden service directories."); "hidden service directories.");

View File

@ -23,6 +23,7 @@
#include "feature/hs_common/shared_random_client.h" #include "feature/hs_common/shared_random_client.h"
#include "feature/keymgt/loadkey.h" #include "feature/keymgt/loadkey.h"
#include "feature/nodelist/describe.h" #include "feature/nodelist/describe.h"
#include "feature/nodelist/microdesc.h"
#include "feature/nodelist/networkstatus.h" #include "feature/nodelist/networkstatus.h"
#include "feature/nodelist/nickname.h" #include "feature/nodelist/nickname.h"
#include "feature/nodelist/node_select.h" #include "feature/nodelist/node_select.h"
@ -2483,7 +2484,8 @@ should_rotate_descriptors(hs_service_t *service, time_t now)
tor_assert(service); tor_assert(service);
ns = networkstatus_get_live_consensus(now); ns = networkstatus_get_reasonably_live_consensus(now,
usable_consensus_flavor());
if (ns == NULL) { if (ns == NULL) {
goto no_rotation; goto no_rotation;
} }
@ -3083,7 +3085,8 @@ should_service_upload_descriptor(const hs_service_t *service,
} }
/* Don't upload desc if we don't have a live consensus */ /* Don't upload desc if we don't have a live consensus */
if (!networkstatus_get_live_consensus(now)) { if (!networkstatus_get_reasonably_live_consensus(now,
usable_consensus_flavor())) {
goto cannot; goto cannot;
} }

View File

@ -12,6 +12,7 @@
#include "app/config/config.h" #include "app/config/config.h"
#include "feature/dircommon/voting_schedule.h" #include "feature/dircommon/voting_schedule.h"
#include "feature/nodelist/microdesc.h"
#include "feature/nodelist/networkstatus.h" #include "feature/nodelist/networkstatus.h"
#include "lib/encoding/binascii.h" #include "lib/encoding/binascii.h"
@ -36,7 +37,9 @@ int
get_voting_interval(void) get_voting_interval(void)
{ {
int interval; int interval;
networkstatus_t *consensus = networkstatus_get_live_consensus(time(NULL)); networkstatus_t *consensus =
networkstatus_get_reasonably_live_consensus(time(NULL),
usable_consensus_flavor());
if (consensus) { if (consensus) {
interval = (int)(consensus->fresh_until - consensus->valid_after); interval = (int)(consensus->fresh_until - consensus->valid_after);
@ -141,7 +144,8 @@ sr_get_current(const networkstatus_t *ns)
if (ns) { if (ns) {
consensus = ns; consensus = ns;
} else { } else {
consensus = networkstatus_get_live_consensus(approx_time()); consensus = networkstatus_get_reasonably_live_consensus(approx_time(),
usable_consensus_flavor());
} }
/* Ideally we would never be asked for an SRV without a live consensus. Make /* Ideally we would never be asked for an SRV without a live consensus. Make
* sure this assumption is correct. */ * sure this assumption is correct. */
@ -164,7 +168,8 @@ sr_get_previous(const networkstatus_t *ns)
if (ns) { if (ns) {
consensus = ns; consensus = ns;
} else { } else {
consensus = networkstatus_get_live_consensus(approx_time()); consensus = networkstatus_get_reasonably_live_consensus(approx_time(),
usable_consensus_flavor());
} }
/* Ideally we would never be asked for an SRV without a live consensus. Make /* Ideally we would never be asked for an SRV without a live consensus. Make
* sure this assumption is correct. */ * sure this assumption is correct. */
@ -236,10 +241,14 @@ sr_state_get_start_time_of_current_protocol_run(void)
int voting_interval = get_voting_interval(); int voting_interval = get_voting_interval();
time_t beginning_of_curr_round; time_t beginning_of_curr_round;
/* This function is not used for voting purposes, so if we have a live /* This function is not used for voting purposes, so if we have a reasonably
consensus, use its valid-after as the beginning of the current round, * live consensus, use its valid-after as the beginning of the current
otherwise resort to the voting schedule which should always exist. */ * round. If we have no consensus but we're an authority, use our own
networkstatus_t *ns = networkstatus_get_live_consensus(approx_time()); * schedule. Otherwise, try using our view of the voting interval to figure
* out when the current round _should_ be starting. */
networkstatus_t *ns =
networkstatus_get_reasonably_live_consensus(approx_time(),
usable_consensus_flavor());
if (ns) { if (ns) {
beginning_of_curr_round = ns->valid_after; beginning_of_curr_round = ns->valid_after;
} else { } else {

View File

@ -362,7 +362,7 @@ node_set_hsdir_index(node_t *node, const networkstatus_t *ns)
tor_assert(node); tor_assert(node);
tor_assert(ns); tor_assert(ns);
if (!networkstatus_is_live(ns, now)) { if (!networkstatus_consensus_reasonably_live(ns, now)) {
static struct ratelim_t live_consensus_ratelim = RATELIM_INIT(30 * 60); static struct ratelim_t live_consensus_ratelim = RATELIM_INIT(30 * 60);
log_fn_ratelim(&live_consensus_ratelim, LOG_INFO, LD_GENERAL, log_fn_ratelim(&live_consensus_ratelim, LOG_INFO, LD_GENERAL,
"Not setting hsdir index with a non-live consensus."); "Not setting hsdir index with a non-live consensus.");

View File

@ -462,9 +462,10 @@ test_hsdir_revision_counter_check(void *arg)
static networkstatus_t mock_ns; static networkstatus_t mock_ns;
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_live_consensus(time_t now) mock_networkstatus_get_reasonably_live_consensus(time_t now, int flavor)
{ {
(void) now; (void) now;
(void) flavor;
return &mock_ns; return &mock_ns;
} }
@ -485,8 +486,8 @@ test_client_cache(void *arg)
/* Initialize HSDir cache subsystem */ /* Initialize HSDir cache subsystem */
init_test(); init_test();
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
/* Set consensus time */ /* Set consensus time */
parse_rfc1123_time("Sat, 26 Oct 1985 13:00:00 UTC", parse_rfc1123_time("Sat, 26 Oct 1985 13:00:00 UTC",

View File

@ -66,16 +66,18 @@ static networkstatus_t mock_ns;
/* Always return NULL. */ /* Always return NULL. */
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_live_consensus_false(time_t now) mock_networkstatus_get_reasonably_live_consensus_false(time_t now, int flavor)
{ {
(void) now; (void) now;
(void) flavor;
return NULL; return NULL;
} }
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_live_consensus(time_t now) mock_networkstatus_get_reasonably_live_consensus(time_t now, int flavor)
{ {
(void) now; (void) now;
(void) flavor;
return &mock_ns; return &mock_ns;
} }
@ -379,8 +381,8 @@ test_client_pick_intro(void *arg)
ed25519_keypair_t service_kp; ed25519_keypair_t service_kp;
hs_descriptor_t *desc = NULL; hs_descriptor_t *desc = NULL;
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
(void) arg; (void) arg;
@ -631,15 +633,15 @@ test_descriptor_fetch(void *arg)
get_options_mutable()->FetchHidServDescriptors = 1; get_options_mutable()->FetchHidServDescriptors = 1;
/* 2. We don't have a live consensus. */ /* 2. We don't have a live consensus. */
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus_false); mock_networkstatus_get_reasonably_live_consensus_false);
ret = hs_client_refetch_hsdesc(&service_pk); ret = hs_client_refetch_hsdesc(&service_pk);
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
tt_int_op(ret, OP_EQ, HS_CLIENT_FETCH_MISSING_INFO); tt_int_op(ret, OP_EQ, HS_CLIENT_FETCH_MISSING_INFO);
/* From now on, return a live consensus. */ /* From now on, return a live consensus. */
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
/* 3. Not enough dir information. */ /* 3. Not enough dir information. */
MOCK(router_have_minimum_dir_info, MOCK(router_have_minimum_dir_info,
@ -681,7 +683,7 @@ test_descriptor_fetch(void *arg)
done: done:
connection_free_minimal(ENTRY_TO_CONN(ec)); connection_free_minimal(ENTRY_TO_CONN(ec));
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
UNMOCK(router_have_minimum_dir_info); UNMOCK(router_have_minimum_dir_info);
hs_free_all(); hs_free_all();
} }
@ -879,8 +881,8 @@ test_desc_has_arrived_cleanup(void *arg)
hs_init(); hs_init();
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
MOCK(connection_mark_unattached_ap_, MOCK(connection_mark_unattached_ap_,
mock_connection_mark_unattached_ap_); mock_connection_mark_unattached_ap_);
MOCK(router_have_minimum_dir_info, MOCK(router_have_minimum_dir_info,
@ -952,7 +954,7 @@ test_desc_has_arrived_cleanup(void *arg)
tor_free(desc_str); tor_free(desc_str);
hs_free_all(); hs_free_all();
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
UNMOCK(connection_mark_unattached_ap_); UNMOCK(connection_mark_unattached_ap_);
UNMOCK(router_have_minimum_dir_info); UNMOCK(router_have_minimum_dir_info);
} }
@ -973,8 +975,8 @@ test_close_intro_circuits_new_desc(void *arg)
/* This is needed because of the client cache expiration timestamp is based /* This is needed because of the client cache expiration timestamp is based
* on having a consensus. See cached_client_descriptor_has_expired(). */ * on having a consensus. See cached_client_descriptor_has_expired(). */
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
/* Set consensus time */ /* Set consensus time */
parse_rfc1123_time("Sat, 26 Oct 1985 13:00:00 UTC", parse_rfc1123_time("Sat, 26 Oct 1985 13:00:00 UTC",
@ -1100,7 +1102,7 @@ test_close_intro_circuits_new_desc(void *arg)
hs_descriptor_free(desc1); hs_descriptor_free(desc1);
hs_descriptor_free(desc2); hs_descriptor_free(desc2);
hs_free_all(); hs_free_all();
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
} }
static void static void

View File

@ -360,9 +360,10 @@ mock_networkstatus_get_latest_consensus(void)
} }
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_live_consensus(time_t now) mock_networkstatus_get_reasonably_live_consensus(time_t now, int flavor)
{ {
(void) now; (void) now;
(void) flavor;
tt_assert(mock_ns); tt_assert(mock_ns);
@ -382,6 +383,8 @@ test_responsible_hsdirs(void *arg)
MOCK(networkstatus_get_latest_consensus, MOCK(networkstatus_get_latest_consensus,
mock_networkstatus_get_latest_consensus); mock_networkstatus_get_latest_consensus);
MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_reasonably_live_consensus);
ns = networkstatus_get_latest_consensus(); ns = networkstatus_get_latest_consensus();
@ -418,6 +421,8 @@ test_responsible_hsdirs(void *arg)
smartlist_clear(ns->routerstatus_list); smartlist_clear(ns->routerstatus_list);
networkstatus_vote_free(mock_ns); networkstatus_vote_free(mock_ns);
cleanup_nodelist(); cleanup_nodelist();
UNMOCK(networkstatus_get_reasonably_live_consensus);
} }
static void static void
@ -467,6 +472,8 @@ test_desc_reupload_logic(void *arg)
hs_init(); hs_init();
MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_reasonably_live_consensus);
MOCK(router_have_minimum_dir_info, MOCK(router_have_minimum_dir_info,
mock_router_have_minimum_dir_info); mock_router_have_minimum_dir_info);
MOCK(get_or_state, MOCK(get_or_state,
@ -905,9 +912,11 @@ static smartlist_t *service_responsible_hsdirs = NULL;
static smartlist_t *client_responsible_hsdirs = NULL; static smartlist_t *client_responsible_hsdirs = NULL;
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_live_consensus_service(time_t now) mock_networkstatus_get_reasonably_live_consensus_service(time_t now,
int flavor)
{ {
(void) now; (void) now;
(void) flavor;
if (mock_service_ns) { if (mock_service_ns) {
return mock_service_ns; return mock_service_ns;
@ -923,13 +932,14 @@ mock_networkstatus_get_live_consensus_service(time_t now)
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_latest_consensus_service(void) mock_networkstatus_get_latest_consensus_service(void)
{ {
return mock_networkstatus_get_live_consensus_service(0); return mock_networkstatus_get_reasonably_live_consensus_service(0, 0);
} }
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_live_consensus_client(time_t now) mock_networkstatus_get_reasonably_live_consensus_client(time_t now, int flavor)
{ {
(void) now; (void) now;
(void) flavor;
if (mock_client_ns) { if (mock_client_ns) {
return mock_client_ns; return mock_client_ns;
@ -945,7 +955,7 @@ mock_networkstatus_get_live_consensus_client(time_t now)
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_latest_consensus_client(void) mock_networkstatus_get_latest_consensus_client(void)
{ {
return mock_networkstatus_get_live_consensus_client(0); return mock_networkstatus_get_reasonably_live_consensus_client(0, 0);
} }
/* Mock function because we are not trying to test the close circuit that does /* Mock function because we are not trying to test the close circuit that does
@ -1405,8 +1415,8 @@ run_reachability_scenario(const reachability_cfg_t *cfg, int num_scenario)
* === Client setup === * === Client setup ===
*/ */
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus_client); mock_networkstatus_get_reasonably_live_consensus_client);
MOCK(networkstatus_get_latest_consensus, MOCK(networkstatus_get_latest_consensus,
mock_networkstatus_get_latest_consensus_client); mock_networkstatus_get_latest_consensus_client);
@ -1430,14 +1440,14 @@ run_reachability_scenario(const reachability_cfg_t *cfg, int num_scenario)
tt_int_op(smartlist_len(client_responsible_hsdirs), OP_EQ, 6); tt_int_op(smartlist_len(client_responsible_hsdirs), OP_EQ, 6);
UNMOCK(networkstatus_get_latest_consensus); UNMOCK(networkstatus_get_latest_consensus);
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
/* /*
* === Service setup === * === Service setup ===
*/ */
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus_service); mock_networkstatus_get_reasonably_live_consensus_service);
MOCK(networkstatus_get_latest_consensus, MOCK(networkstatus_get_latest_consensus,
mock_networkstatus_get_latest_consensus_service); mock_networkstatus_get_latest_consensus_service);
@ -1464,7 +1474,7 @@ run_reachability_scenario(const reachability_cfg_t *cfg, int num_scenario)
tt_int_op(smartlist_len(service_responsible_hsdirs), OP_EQ, 8); tt_int_op(smartlist_len(service_responsible_hsdirs), OP_EQ, 8);
UNMOCK(networkstatus_get_latest_consensus); UNMOCK(networkstatus_get_latest_consensus);
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
/* Some testing of the values we just got from the client and service. */ /* Some testing of the values we just got from the client and service. */
tt_mem_op(&client_blinded_pk, OP_EQ, &service_blinded_pk, tt_mem_op(&client_blinded_pk, OP_EQ, &service_blinded_pk,
@ -1715,8 +1725,8 @@ test_client_service_hsdir_set_sync(void *arg)
MOCK(networkstatus_get_latest_consensus, MOCK(networkstatus_get_latest_consensus,
mock_networkstatus_get_latest_consensus); mock_networkstatus_get_latest_consensus);
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
MOCK(get_or_state, MOCK(get_or_state,
get_or_state_replacement); get_or_state_replacement);
MOCK(hs_desc_encode_descriptor, MOCK(hs_desc_encode_descriptor,

View File

@ -81,9 +81,10 @@
static networkstatus_t mock_ns; static networkstatus_t mock_ns;
static networkstatus_t * static networkstatus_t *
mock_networkstatus_get_live_consensus(time_t now) mock_networkstatus_get_reasonably_live_consensus(time_t now, int flavor)
{ {
(void) now; (void) now;
(void) flavor;
return &mock_ns; return &mock_ns;
} }
@ -1345,8 +1346,8 @@ test_rotate_descriptors(void *arg)
hs_init(); hs_init();
MOCK(get_or_state, get_or_state_replacement); MOCK(get_or_state, get_or_state_replacement);
MOCK(circuit_mark_for_close_, mock_circuit_mark_for_close); MOCK(circuit_mark_for_close_, mock_circuit_mark_for_close);
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
/* Descriptor rotation happens with a consensus with a new SRV. */ /* Descriptor rotation happens with a consensus with a new SRV. */
@ -1434,7 +1435,7 @@ test_rotate_descriptors(void *arg)
hs_free_all(); hs_free_all();
UNMOCK(get_or_state); UNMOCK(get_or_state);
UNMOCK(circuit_mark_for_close_); UNMOCK(circuit_mark_for_close_);
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
} }
/** Test building descriptors: picking intro points, setting up their link /** Test building descriptors: picking intro points, setting up their link
@ -1454,8 +1455,8 @@ test_build_update_descriptors(void *arg)
MOCK(get_or_state, MOCK(get_or_state,
get_or_state_replacement); get_or_state_replacement);
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
dummy_state = or_state_new(); dummy_state = or_state_new();
@ -1685,8 +1686,8 @@ test_build_descriptors(void *arg)
MOCK(get_or_state, MOCK(get_or_state,
get_or_state_replacement); get_or_state_replacement);
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
dummy_state = or_state_new(); dummy_state = or_state_new();
@ -1786,8 +1787,8 @@ test_upload_descriptors(void *arg)
hs_init(); hs_init();
MOCK(get_or_state, MOCK(get_or_state,
get_or_state_replacement); get_or_state_replacement);
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
dummy_state = or_state_new(); dummy_state = or_state_new();

View File

@ -167,6 +167,15 @@ mock_networkstatus_get_live_consensus(time_t now)
return &mock_consensus; return &mock_consensus;
} }
/* Mock function to immediately return our local 'mock_consensus'. */
static networkstatus_t *
mock_networkstatus_get_reasonably_live_consensus(time_t now, int flavor)
{
(void) now;
(void) flavor;
return &mock_consensus;
}
static void static void
test_get_state_valid_until_time(void *arg) test_get_state_valid_until_time(void *arg)
{ {
@ -179,6 +188,8 @@ test_get_state_valid_until_time(void *arg)
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_live_consensus);
MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_reasonably_live_consensus);
retval = parse_rfc1123_time("Mon, 20 Apr 2015 01:00:00 UTC", retval = parse_rfc1123_time("Mon, 20 Apr 2015 01:00:00 UTC",
&mock_consensus.fresh_until); &mock_consensus.fresh_until);
@ -235,7 +246,7 @@ test_get_state_valid_until_time(void *arg)
} }
done: done:
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
} }
/** Test the function that calculates the start time of the current SRV /** Test the function that calculates the start time of the current SRV
@ -251,6 +262,8 @@ test_get_start_time_of_current_run(void *arg)
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_live_consensus);
MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_reasonably_live_consensus);
retval = parse_rfc1123_time("Mon, 20 Apr 2015 01:00:00 UTC", retval = parse_rfc1123_time("Mon, 20 Apr 2015 01:00:00 UTC",
&mock_consensus.fresh_until); &mock_consensus.fresh_until);
@ -335,6 +348,7 @@ test_get_start_time_of_current_run(void *arg)
/* Next test is testing it without a consensus to use the testing voting /* Next test is testing it without a consensus to use the testing voting
* interval . */ * interval . */
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_live_consensus);
UNMOCK(networkstatus_get_reasonably_live_consensus);
/* Now let's alter the voting schedule and check the correctness of the /* Now let's alter the voting schedule and check the correctness of the
* function. Voting interval of 10 seconds, means that an SRV protocol run * function. Voting interval of 10 seconds, means that an SRV protocol run
@ -366,8 +380,8 @@ test_get_start_time_functions(void *arg)
(void) arg; (void) arg;
int retval; int retval;
MOCK(networkstatus_get_live_consensus, MOCK(networkstatus_get_reasonably_live_consensus,
mock_networkstatus_get_live_consensus); mock_networkstatus_get_reasonably_live_consensus);
retval = parse_rfc1123_time("Mon, 20 Apr 2015 01:00:00 UTC", retval = parse_rfc1123_time("Mon, 20 Apr 2015 01:00:00 UTC",
&mock_consensus.fresh_until); &mock_consensus.fresh_until);
@ -388,7 +402,7 @@ test_get_start_time_functions(void *arg)
start_time_of_protocol_run); start_time_of_protocol_run);
done: done:
UNMOCK(networkstatus_get_live_consensus); UNMOCK(networkstatus_get_reasonably_live_consensus);
} }
static void static void