TRPS_INSTANCE *trps=talloc(mem_ctx, TRPS_INSTANCE);
if (trps!=NULL) {
trps->hostname=NULL;
- trps->port=0;
+ trps->trps_port=0;
trps->cookie=NULL;
trps->conn=NULL;
trps->trpc=NULL;
{
TALLOC_CTX *tmp_ctx=talloc_new(NULL);
TR_NAME *label=NULL;
- char *s=talloc_asprintf(tmp_ctx, "%s:%u", trps->hostname, trps->port);
+ char *s=talloc_asprintf(tmp_ctx, "%s:%u", trps->hostname, trps->trps_port);
if (s==NULL)
goto cleanup;
label=tr_new_name(s);
/* verify we received a message we support, otherwise drop it now */
switch (tr_msg_get_msg_type(*msg)) {
case TRP_UPDATE:
+ trp_upd_set_peer(tr_msg_get_trp_upd(*msg), tr_dup_name(conn_peer));
/* update provenance if necessary */
trp_upd_add_to_provenance(tr_msg_get_trp_upd(*msg), trp_peer_get_label(peer));
- /* fall through to next case */
+ break;
case TRP_REQUEST:
trp_req_set_peer(tr_msg_get_trp_req(*msg), tr_dup_name(conn_peer));
TRPS_MSG_FUNC msg_handler,
TRP_AUTH_FUNC auth_handler,
const char *hostname,
- unsigned int port,
+ int port,
void *cookie,
int *fd_out,
size_t max_fd)
n_fd = tr_sock_listen_all(port, fd_out, max_fd);
if (n_fd == 0)
- tr_err("trps_get_listener: Error opening port %d.");
+ tr_err("trps_get_listener: Error opening port %d.", port);
else {
/* opening port succeeded */
tr_info("trps_get_listener: Opened port %d.", port);
trps->msg_handler = msg_handler;
trps->auth_handler = auth_handler;
trps->hostname = talloc_strdup(trps, hostname);
- trps->port = port;
+ trps->trps_port = port;
trps->cookie = cookie;
}
trp_route_get_peer(route)));
}
- /* Note that we leave the next hop empty since the recipient fills that in.
- * This is where we add the link cost (currently always 1) to the next peer. */
+ /*
+ * This is where we add the link cost (currently always 1) to the next peer.
+ *
+ * Here, set next_hop to our TID address/port rather than passing along our own
+ * next_hop. That is the one *we* use to forward requests. We are advertising
+ * ourselves as a hop for our peers.
+ */
if ((TRP_SUCCESS != trp_inforec_set_trust_router(rec,
trp_route_dup_trust_router(route),
trp_route_get_trust_router_port(route)))
||(TRP_SUCCESS != trp_inforec_set_next_hop(rec,
- trp_route_dup_next_hop(route),
- trp_route_get_next_hop_port(route)))
+ tr_new_name(trps->hostname),
+ trps->tids_port))
||(TRP_SUCCESS != trp_inforec_set_metric(rec,
trps_metric_add(trp_route_get_metric(route),
linkcost)))