src/modules/proto_vmps/vmps.c

   1 /*
   2  * vmps.c       Handle VMPS traffic.
   3  *
   4  * Version:     $Id$
   5  *
   6  *   This program is free software; you can redistribute it and/or modify
   7  *   it under the terms of the GNU General Public License as published by
   8  *   the Free Software Foundation; either version 2 of the License, or
   9  *   (at your option) any later version.
  10  *
  11  *   This program is distributed in the hope that it will be useful,
  12  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  *   GNU General Public License for more details.
  15  *
  16  *   You should have received a copy of the GNU General Public License
  17  *   along with this program; if not, write to the Free Software
  18  *   Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  19  *
  20  * Copyright 2007  The FreeRADIUS server project
  21  * Copyright 2007  Alan DeKok <aland@deployingradius.com>
  22  */
  23
  24 RCSID("$Id$")
  25
  26 #include <freeradius-devel/radiusd.h>
  27 #include <freeradius-devel/protocol.h>
  28 #include <freeradius-devel/process.h>
  29 #include <freeradius-devel/modules.h>
  30 #include <freeradius-devel/rad_assert.h>
  31
  32 #include "vqp.h"
  33
  34 static int vmps_process(REQUEST *request)
  35 {
  36         DEBUG2("Doing VMPS");
  37         process_post_auth(0, request);
  38         DEBUG2("Done VMPS");
  39
  40         request->reply->code = PW_CODE_ACCESS_ACCEPT;
  41
  42         return 0;
  43 }
  44
  45 /*
  46  *      Check if an incoming request is "ok"
  47  *
  48  *      It takes packets, not requests.  It sees if the packet looks
  49  *      OK.  If so, it does a number of sanity checks on it.
  50  */
  51 static int vqp_socket_recv(rad_listen_t *listener)
  52 {
  53         RADIUS_PACKET   *packet;
  54         RAD_REQUEST_FUNP fun = NULL;
  55         RADCLIENT       *client;
  56
  57         packet = vqp_recv(listener->fd);
  58         if (!packet) {
  59                 ERROR("%s", fr_strerror());
  60                 return 0;
  61         }
  62
  63         if ((client = client_listener_find(listener,
  64                                            &packet->src_ipaddr,
  65                                            packet->src_port)) == NULL) {
  66                 rad_free(&packet);
  67                 return 0;
  68         }
  69
  70         /*
  71          *      Do new stuff.
  72          */
  73         fun = vmps_process;
  74
  75         if (!request_receive(NULL, listener, packet, client, fun)) {
  76                 rad_free(&packet);
  77                 return 0;
  78         }
  79
  80         return 1;
  81 }
  82
  83
  84 /*
  85  *      Send an authentication response packet
  86  */
  87 static int vqp_socket_send(rad_listen_t *listener, REQUEST *request)
  88 {
  89         rad_assert(request->listener == listener);
  90         rad_assert(listener->send == vqp_socket_send);
  91
  92         if (vqp_encode(request->reply, request->packet) < 0) {
  93                 DEBUG2("Failed encoding packet: %s\n", fr_strerror());
  94                 return -1;
  95         }
  96
  97         return vqp_send(request->reply);
  98 }
  99
 100
 101 static int vqp_socket_encode(UNUSED rad_listen_t *listener, REQUEST *request)
 102 {
 103         return vqp_encode(request->reply, request->packet);
 104 }
 105
 106
 107 static int vqp_socket_decode(UNUSED rad_listen_t *listener, REQUEST *request)
 108 {
 109         return vqp_decode(request->packet);
 110 }
 111
 112 extern fr_protocol_t proto_vmps;
 113 fr_protocol_t proto_vmps = {
 114         .magic          = RLM_MODULE_INIT,
 115         .name           = "vmps",
 116         .inst_size      = sizeof(listen_socket_t),
 117         .parse          = common_socket_parse,
 118         .recv           = vqp_socket_recv,
 119         .send           = vqp_socket_send,
 120         .print          = common_socket_print,
 121         .encode         = vqp_socket_encode,
 122         .decode         = vqp_socket_decode
 123 };