lib/conn.c

   1 /* See the file COPYING for licensing information.  */
   2
   3 #include <assert.h>
   4 #include <radsec/radsec.h>
   5 #include <radsec/radsec-impl.h>
   6
   7 int
   8 rs_conn_create (struct rs_context *ctx, struct rs_connection **conn,
   9                 const char *config)
  10 {
  11   struct rs_connection *c;
  12
  13   c = (struct rs_connection *) malloc (sizeof(struct rs_connection));
  14   if (c)
  15     {
  16       memset (c, 0, sizeof(struct rs_connection));
  17       c->ctx = ctx;
  18       if (config)
  19         {
  20           struct rs_realm *r = rs_conf_find_realm (ctx, config);
  21           if (r)
  22             {
  23               struct rs_peer *p;
  24
  25               c->type = r->type;
  26               c->peers = r->peers; /* FIXME: Copy instead?  */
  27               for (p = c->peers; p; p = p->next)
  28                 p->conn = c;
  29             }
  30         }
  31     }
  32   if (conn)
  33     *conn = c;
  34   return c ? RSE_OK : rs_err_ctx_push (ctx, RSE_NOMEM, NULL);
  35 }
  36
  37 void
  38 rs_conn_set_type (struct rs_connection *conn, rs_conn_type_t type)
  39 {
  40   conn->type = type;
  41 }
  42
  43
  44 struct rs_error *
  45 _rs_resolv (struct evutil_addrinfo **addr, rs_conn_type_t type,
  46             const char *hostname, const char *service)
  47 {
  48   int err;
  49   struct evutil_addrinfo hints, *res = NULL;
  50
  51   memset (&hints, 0, sizeof(struct evutil_addrinfo));
  52   hints.ai_family = AF_UNSPEC;  /* v4 or v6.  */
  53   hints.ai_flags = AI_ADDRCONFIG;
  54   switch (type)
  55     {
  56     case RS_CONN_TYPE_NONE:
  57       return _rs_err_create (RSE_INVALID_CONN, __FILE__, __LINE__, NULL, NULL);
  58     case RS_CONN_TYPE_TCP:
  59       /* Fall through.  */
  60     case RS_CONN_TYPE_TLS:
  61       hints.ai_socktype = SOCK_STREAM;
  62       hints.ai_protocol = IPPROTO_TCP;
  63       break;
  64     case RS_CONN_TYPE_UDP:
  65       /* Fall through.  */
  66     case RS_CONN_TYPE_DTLS:
  67       hints.ai_socktype = SOCK_DGRAM;
  68       hints.ai_protocol = IPPROTO_UDP;
  69       break;
  70     }
  71   err = evutil_getaddrinfo (hostname, service, &hints, &res);
  72   if (err)
  73     return _rs_err_create (RSE_BADADDR, __FILE__, __LINE__,
  74                            "%s:%s: bad host name or service name (%s)",
  75                            hostname, service, evutil_gai_strerror(err));
  76   *addr = res;                  /* Simply use first result.  */
  77   return NULL;
  78 }
  79
  80 int
  81 rs_conn_add_listener (struct rs_connection *conn, rs_conn_type_t type,
  82                       const char *hostname, int port)
  83 {
  84   return rs_err_conn_push_fl (conn, RSE_NOSYS, __FILE__, __LINE__,
  85                               "%s: NYI", __func__);
  86 }
  87
  88 void
  89 rs_conn_destroy (struct rs_connection *conn)
  90 {
  91   struct rs_peer *p;
  92
  93 #warning "TODO: Disconnect active_peer."
  94
  95   for (p = conn->peers; p; p = p->next)
  96     {
  97       if (p->addr)
  98         evutil_freeaddrinfo (p->addr);
  99       if (p->secret)
 100         rs_free (conn->ctx, p->secret);
 101     }
 102
 103   if (conn->evb)
 104     event_base_free (conn->evb);
 105 }
 106
 107 int
 108 rs_conn_set_eventbase (struct rs_connection *conn, struct event_base *eb)
 109 {
 110   return rs_err_conn_push_fl (conn, RSE_NOSYS, __FILE__, __LINE__,
 111                               "%s: NYI", __func__);
 112 }
 113
 114 int
 115 rs_conn_set_callbacks (struct rs_connection *conn, struct rs_conn_callbacks *cb)
 116 {
 117   return rs_err_conn_push_fl (conn, RSE_NOSYS, __FILE__, __LINE__,
 118                               "%s: NYI", __func__);
 119 }
 120
 121 int
 122 rs_conn_select_server (struct rs_connection *conn, const char *name)
 123 {
 124   return rs_err_conn_push_fl (conn, RSE_NOSYS, __FILE__, __LINE__,
 125                               "%s: NYI", __func__);
 126 }
 127
 128 int
 129 rs_conn_get_current_server (struct rs_connection *conn, const char *name,
 130                             size_t buflen)
 131 {
 132   return rs_err_conn_push_fl (conn, RSE_NOSYS, __FILE__, __LINE__,
 133                               "%s: NYI", __func__);
 134 }
 135
 136 int rs_conn_fd (struct rs_connection *conn)
 137 {
 138   assert (conn);
 139   assert (conn->active_peer);
 140   return conn->active_peer->fd;
 141 }