|
@@ -2105,6 +2105,7 @@ build_all_descriptors(time_t now)
|
|
static hs_service_intro_point_t *
|
|
static hs_service_intro_point_t *
|
|
pick_intro_point(unsigned int direct_conn, smartlist_t *exclude_nodes)
|
|
pick_intro_point(unsigned int direct_conn, smartlist_t *exclude_nodes)
|
|
{
|
|
{
|
|
|
|
+ const or_options_t *options = get_options();
|
|
const node_t *node;
|
|
const node_t *node;
|
|
extend_info_t *info = NULL;
|
|
extend_info_t *info = NULL;
|
|
hs_service_intro_point_t *ip = NULL;
|
|
hs_service_intro_point_t *ip = NULL;
|
|
@@ -2113,11 +2114,19 @@ pick_intro_point(unsigned int direct_conn, smartlist_t *exclude_nodes)
|
|
/* Single onion flags. */
|
|
/* Single onion flags. */
|
|
router_crn_flags_t direct_flags = flags | CRN_PREF_ADDR | CRN_DIRECT_CONN;
|
|
router_crn_flags_t direct_flags = flags | CRN_PREF_ADDR | CRN_DIRECT_CONN;
|
|
|
|
|
|
- node = router_choose_random_node(exclude_nodes, get_options()->ExcludeNodes,
|
|
|
|
|
|
+ node = router_choose_random_node(exclude_nodes, options->ExcludeNodes,
|
|
direct_conn ? direct_flags : flags);
|
|
direct_conn ? direct_flags : flags);
|
|
- /* Unable to find a node. When looking for a node for a direct connection,
|
|
|
|
- * we could try a 3-hop path instead. We'll add support for this in a later
|
|
|
|
- * release. */
|
|
|
|
|
|
+
|
|
|
|
+ /* If we are in single onion mode, retry node selection for a 3-hop
|
|
|
|
+ * path */
|
|
|
|
+ if (direct_conn && !node) {
|
|
|
|
+ log_info(LD_REND,
|
|
|
|
+ "Unable to find an intro point that we can connect to "
|
|
|
|
+ "directly, falling back to a 3-hop path.");
|
|
|
|
+ node = router_choose_random_node(exclude_nodes, options->ExcludeNodes,
|
|
|
|
+ flags);
|
|
|
|
+ }
|
|
|
|
+
|
|
if (!node) {
|
|
if (!node) {
|
|
goto err;
|
|
goto err;
|
|
}
|
|
}
|
|
@@ -2644,7 +2653,7 @@ launch_intro_point_circuits(hs_service_t *service)
|
|
* circuits using the current map. */
|
|
* circuits using the current map. */
|
|
FOR_EACH_DESCRIPTOR_BEGIN(service, desc) {
|
|
FOR_EACH_DESCRIPTOR_BEGIN(service, desc) {
|
|
/* Keep a ref on if we need a direct connection. We use this often. */
|
|
/* Keep a ref on if we need a direct connection. We use this often. */
|
|
- unsigned int direct_conn = service->config.is_single_onion;
|
|
|
|
|
|
+ bool direct_conn = service->config.is_single_onion;
|
|
|
|
|
|
DIGEST256MAP_FOREACH_MODIFY(desc->intro_points.map, key,
|
|
DIGEST256MAP_FOREACH_MODIFY(desc->intro_points.map, key,
|
|
hs_service_intro_point_t *, ip) {
|
|
hs_service_intro_point_t *, ip) {
|
|
@@ -2655,8 +2664,15 @@ launch_intro_point_circuits(hs_service_t *service)
|
|
if (hs_circ_service_get_intro_circ(ip)) {
|
|
if (hs_circ_service_get_intro_circ(ip)) {
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
-
|
|
|
|
ei = get_extend_info_from_intro_point(ip, direct_conn);
|
|
ei = get_extend_info_from_intro_point(ip, direct_conn);
|
|
|
|
+
|
|
|
|
+ /* If we can't connect directly to the intro point, get an extend_info
|
|
|
|
+ * for a multi-hop path instead. */
|
|
|
|
+ if (ei == NULL && direct_conn) {
|
|
|
|
+ direct_conn = false;
|
|
|
|
+ ei = get_extend_info_from_intro_point(ip, 0);
|
|
|
|
+ }
|
|
|
|
+
|
|
if (ei == NULL) {
|
|
if (ei == NULL) {
|
|
/* This is possible if we can get a node_t but not the extend info out
|
|
/* This is possible if we can get a node_t but not the extend info out
|
|
* of it. In this case, we remove the intro point and a new one will
|
|
* of it. In this case, we remove the intro point and a new one will
|
|
@@ -2668,7 +2684,7 @@ launch_intro_point_circuits(hs_service_t *service)
|
|
|
|
|
|
/* Launch a circuit to the intro point. */
|
|
/* Launch a circuit to the intro point. */
|
|
ip->circuit_retries++;
|
|
ip->circuit_retries++;
|
|
- if (hs_circ_launch_intro_point(service, ip, ei) < 0) {
|
|
|
|
|
|
+ if (hs_circ_launch_intro_point(service, ip, ei, direct_conn) < 0) {
|
|
log_info(LD_REND, "Unable to launch intro circuit to node %s "
|
|
log_info(LD_REND, "Unable to launch intro circuit to node %s "
|
|
"for service %s.",
|
|
"for service %s.",
|
|
safe_str_client(extend_info_describe(ei)),
|
|
safe_str_client(extend_info_describe(ei)),
|