dmsg_lnk_span_t *lspan;
int count;
int maxcount = 2;
+#ifdef REQUIRE_SYMMETRICAL
uint32_t lastdist = DMSG_SPAN_MAXDIST;
uint32_t lastrnss = 0;
+#endif
info.node = node;
info.relay = NULL;
relay->source_rt->any.link->node != slink->node ||
relay->source_rt->any.link->dist >= slink->dist);
relay = dmsg_generate_relay(conn, slink);
+#ifdef REQUIRE_SYMMETRICAL
lastdist = slink->dist;
lastrnss = slink->rnss;
+#endif
/*
* Match (created new relay), get the next relay to
dmsg_generate_relay(h2span_conn_t *conn, h2span_link_t *slink)
{
h2span_relay_t *relay;
- h2span_node_t *node;
dmsg_msg_t *msg;
- node = slink->node;
-
relay = dmsg_alloc(sizeof(*relay));
relay->conn = conn;
relay->source_rt = slink->state;
h2span_cluster_t *cls;
h2span_node_t *node;
h2span_link_t *slink;
- h2span_relay_t *relay;
pthread_mutex_lock(&cluster_mtx);
- relay = NULL;
RB_FOREACH(cls, h2span_cluster_tree, &cluster_tree) {
RB_FOREACH(node, h2span_node_tree, &cls->tree) {
RB_FOREACH(slink, h2span_link_tree, &node->tree) {