#include <time.h>
#include <talloc.h>
-#include <trust_router/tr_name.h>
+#include <tr_name_internal.h>
#include <trp_internal.h>
-#include <tr_gss.h>
+#include <tr_gss_names.h>
#include <trp_ptable.h>
#include <tr_debug.h>
static int trp_peer_destructor(void *object)
{
TRP_PEER *peer=talloc_get_type_abort(object, TRP_PEER);
+ if (peer->label!=NULL)
+ tr_free_name(peer->label);
if (peer->servicename!=NULL)
tr_free_name(peer->servicename);
return 0;
TRP_PEER *peer=talloc(memctx, TRP_PEER);
if (peer!=NULL) {
peer->next=NULL;
+ peer->label=NULL;
peer->server=NULL;
peer->servicename=NULL;
peer->gss_names=NULL;
peer->incoming_status=PEER_DISCONNECTED;
peer->conn_status_cb=NULL;
peer->conn_status_cookie=NULL;
+ peer->filters=NULL;
talloc_set_destructor((void *)peer, trp_peer_destructor);
}
return peer;
* Do not modify or free the label. */
TR_NAME *trp_peer_get_label(TRP_PEER *peer)
{
- TR_GSS_NAMES_ITER *iter=tr_gss_names_iter_new(NULL);
- TR_NAME *name=NULL;
+ char *s=NULL;
- /* for now, use the first gss name */
- if (iter!=NULL) {
- name=tr_gss_names_iter_first(iter, peer->gss_names);
- talloc_free(iter);
+ if (peer->label==NULL) {
+ s=talloc_asprintf(NULL, "%s:%u", peer->server, peer->port);
+ if (s!=NULL) {
+ peer->label=tr_new_name(s);
+ talloc_free(s);
+ }
}
- return name;
+ return peer->label;
}
/* Get a name that identifies this peer for display to the user, etc.
void trp_peer_set_gss_names(TRP_PEER *peer, TR_GSS_NAMES *gss_names)
{
if (peer->gss_names!=NULL)
- talloc_free(peer->gss_names);
+ tr_gss_names_free(peer->gss_names);
peer->gss_names=gss_names;
talloc_steal(peer, gss_names);
peer->conn_status_cookie=cookie;
}
+/**
+ * Set the filter associated with this peer. Any existing filter will be freed. Takes responsibility for
+ * freeing the new filter.
+ *
+ * @param peer Peer to modify
+ * @param filts New filter to attach to the peer
+ */
+void trp_peer_set_filters(TRP_PEER *peer, TR_FILTER_SET *filts)
+{
+ if (peer->filters!=NULL)
+ tr_filter_set_free(peer->filters);
+
+ peer->filters=filts;
+ talloc_steal(peer, filts);
+}
+
+TR_FILTER *trp_peer_get_filter(TRP_PEER *peer, TR_FILTER_TYPE ftype)
+{
+ return tr_filter_set_get(peer->filters, ftype);
+}
+
struct timespec *trp_peer_get_last_conn_attempt(TRP_PEER *peer)
{
return &(peer->last_conn_attempt);