tid/tid_req.c

   1 /*
   2  * Copyright (c) 2012, 2014-2015, JANET(UK)
   3  * All rights reserved.
   4  *
   5  * Redistribution and use in source and binary forms, with or without
   6  * modification, are permitted provided that the following conditions
   7  * are met:
   8  *
   9  * 1. Redistributions of source code must retain the above copyright
  10  *    notice, this list of conditions and the following disclaimer.
  11  *
  12  * 2. Redistributions in binary form must reproduce the above copyright
  13  *    notice, this list of conditions and the following disclaimer in the
  14  *    documentation and/or other materials provided with the distribution.
  15  *
  16  * 3. Neither the name of JANET(UK) nor the names of its contributors
  17  *    may be used to endorse or promote products derived from this software
  18  *    without specific prior written permission.
  19  *
  20  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  21  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  22  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
  23  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
  24  * COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
  25  * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
  26  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
  27  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  28  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
  29  * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  30  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
  31  * OF THE POSSIBILITY OF SUCH DAMAGE.
  32  *
  33  */
  34
  35 #include <stdio.h>
  36 #include <unistd.h>
  37 #include <stdlib.h>
  38 #include <assert.h>
  39 #include <talloc.h>
  40
  41 #include <tid_internal.h>
  42 #include <tr_debug.h>
  43
  44 #include <jansson.h>
  45
  46 static int destroy_tid_req(TID_REQ *req)
  47 {
  48   if (req->json_references)
  49     json_decref(req->json_references);
  50   if (req->free_conn) {
  51     if (req->conn)
  52       close(req->conn);
  53     if (req->gssctx) {
  54       OM_uint32 minor;
  55       gss_delete_sec_context( &minor, &req->gssctx, NULL);
  56     }
  57   }
  58   if (req->rp_realm!=NULL)
  59     tr_free_name(req->rp_realm);
  60   if (req->realm!=NULL)
  61     tr_free_name(req->realm);
  62   if (req->comm!=NULL)
  63     tr_free_name(req->comm);
  64   if (req->orig_coi!=NULL)
  65     tr_free_name(req->orig_coi);
  66   return 0;
  67 }
  68
  69 TID_REQ *tid_req_new()
  70 {
  71   TID_REQ *req = talloc_zero(NULL, TID_REQ);
  72   if(!req)
  73     return NULL;
  74   talloc_set_destructor(req, destroy_tid_req);
  75   req->json_references = json_array();
  76   assert(req->json_references);
  77   req->conn = -1;
  78   req->free_conn = 1;
  79   return req;
  80 }
  81
  82 TID_REQ *tid_req_get_next_req(TID_REQ *req)
  83 {
  84   return(req->next_req);
  85 }
  86
  87 void tid_req_set_next_req(TID_REQ *req, TID_REQ *next_req)
  88 {
  89   req->next_req = next_req;
  90 }
  91
  92 int tid_req_get_resp_sent(TID_REQ *req)
  93 {
  94   return(req->resp_sent);
  95 }
  96
  97 void tid_req_set_resp_sent(TID_REQ *req, int resp_sent)
  98 {
  99   req->resp_sent = resp_sent;
 100 }
 101
 102 int tid_req_get_conn(TID_REQ *req)
 103 {
 104   return(req->conn);
 105 }
 106
 107 void tid_req_set_conn(TID_REQ *req, int conn)
 108 {
 109   req->conn = conn;
 110 }
 111
 112 gss_ctx_id_t tid_req_get_gssctx(TID_REQ *req)
 113 {
 114   return(req->gssctx);
 115 }
 116
 117 void tid_req_set_gssctx(TID_REQ *req, gss_ctx_id_t gssctx)
 118 {
 119   req->gssctx = gssctx;
 120 }
 121
 122 int tid_req_get_resp_rcvd(TID_REQ *req)
 123 {
 124   return(req->resp_rcvd);
 125 }
 126
 127 void tid_req_set_resp_rcvd(TID_REQ *req, int resp_rcvd)
 128 {
 129   req->resp_rcvd = resp_rcvd;
 130 }
 131
 132 TR_NAME *tid_req_get_rp_realm(TID_REQ *req)
 133 {
 134   return(req->rp_realm);
 135 }
 136
 137 void tid_req_set_rp_realm(TID_REQ *req, TR_NAME *rp_realm)
 138 {
 139   req->rp_realm = rp_realm;
 140 }
 141
 142 TR_NAME *tid_req_get_realm(TID_REQ *req)
 143 {
 144   return(req->realm);
 145 }
 146
 147 void tid_req_set_realm(TID_REQ *req, TR_NAME *realm)
 148 {
 149   req->realm = realm;
 150 }
 151
 152 TR_NAME *tid_req_get_comm(TID_REQ *req)
 153 {
 154   return(req->comm);
 155 }
 156
 157 void tid_req_set_comm(TID_REQ *req, TR_NAME *comm)
 158 {
 159   req->comm = comm;
 160 }
 161
 162 TR_NAME *tid_req_get_orig_coi(TID_REQ *req)
 163 {
 164   return(req->orig_coi);
 165 }
 166
 167 void tid_req_set_rp_orig_coi(TID_REQ *req, TR_NAME *orig_coi)
 168 {
 169   req->orig_coi = orig_coi;
 170 }
 171
 172 TIDC_RESP_FUNC *tid_req_get_resp_func(TID_REQ *req)
 173 {
 174   return(req->resp_func);
 175 }
 176
 177 void tid_req_set_resp_func(TID_REQ *req, TIDC_RESP_FUNC *resp_func)
 178 {
 179   req->resp_func = resp_func;
 180 }
 181
 182 void *tid_req_get_cookie(TID_REQ *req)
 183 {
 184   return(req->cookie);
 185 }
 186
 187 void tid_req_set_cookie(TID_REQ *req, void *cookie)
 188 {
 189   req->cookie = cookie;
 190 }
 191
 192 TID_REQ *tid_dup_req (TID_REQ *orig_req)
 193 {
 194   TID_REQ *new_req = NULL;
 195
 196   if (NULL == (new_req = talloc_zero(orig_req, TID_REQ))) {
 197     tr_crit("tid_dup_req: Can't allocated duplicate request.");
 198     return NULL;
 199   }
 200
 201   /* Memcpy for flat fields, not valid until names are duped. */
 202   memcpy(new_req, orig_req, sizeof(TID_REQ));
 203   json_incref(new_req->json_references);
 204   new_req->free_conn = 0;
 205
 206   if ((NULL == (new_req->rp_realm = tr_dup_name(orig_req->rp_realm))) ||
 207       (NULL == (new_req->realm = tr_dup_name(orig_req->realm))) ||
 208       (NULL == (new_req->comm = tr_dup_name(orig_req->comm)))) {
 209         tr_crit("tid_dup_req: Can't duplicate request (names).");
 210   }
 211
 212   if (orig_req->orig_coi) {
 213     if (NULL == (new_req->orig_coi = tr_dup_name(orig_req->orig_coi))) {
 214       tr_crit("tid_dup_req: Can't duplicate request (orig_coi).");
 215     }
 216   }
 217
 218   return new_req;
 219 }
 220
 221
 222 void tid_req_cleanup_json( TID_REQ *req, json_t *ref)
 223 {
 224   (void) json_array_append_new(req->json_references, ref);
 225 }
 226
 227 void tid_req_free(TID_REQ *req)
 228 {
 229   talloc_free(req);
 230 }
 231
 232 int tid_req_add_path(TID_REQ *req,
 233                      const char *this_system, unsigned port)
 234 {
 235   char *path_element = talloc_asprintf(req, "%s:%u",
 236                                        this_system, port);
 237   if (!req->path) {
 238     req->path = json_array();
 239     if (!req->path)
 240       return -1;
 241     tid_req_cleanup_json(req, req->path);
 242   }
 243   return json_array_append( req->path, json_string(path_element));
 244 }
 245
 246
 247
 248 void tid_srvr_get_address(const TID_SRVR_BLK *blk,
 249                           const struct sockaddr **out_addr,
 250                           size_t *out_len)
 251 {
 252   struct sockaddr_in *sa = NULL;
 253     assert(blk);
 254     sa = talloc_zero(blk, struct sockaddr_in);
 255     sa->sin_family = AF_INET;
 256     sa->sin_addr = blk->aaa_server_addr;
 257     sa->sin_port = htons(2083);
 258     *out_addr = (struct sockaddr *) sa;
 259     *out_len = sizeof( struct sockaddr_in);
 260 }
 261
 262 DH *tid_srvr_get_dh( TID_SRVR_BLK *blk)
 263 {
 264   assert(blk);
 265   return blk->aaa_server_dh;
 266 }
 267
 268 const TR_NAME *tid_srvr_get_key_name(
 269                                     const TID_SRVR_BLK *blk)
 270 {
 271   assert(blk);
 272   return blk->key_name;
 273 }