test_radius_acct.c File Reference

#include <unistd.h>
#include <string.h>
#include "gwlib/gwlib.h"
#include "radius/radius_pdu.h"

Go to the source code of this file.

Functions
static int	update_table (RADIUS_PDU *pdu, Dict **table)
static void	server (int lport, int pport)
int	main (int argc, char **argv)

Function Documentation

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 211 of file test_radius_acct.c.

References gwlib_init(), panic, and server().

                                {
    int lport, pport;
    
    gwlib_init();

    if (argc != 3)
        panic(0, "usage: test_radius_acct <your RADIUS acct port> <remote RADIUS port>");
    
    lport = atoi(argv[1]);
    pport = atoi(argv[2]);

    server(lport, pport);

    return 0;
}

server()

static void server ( int  lport, int  pport  )

static

Definition at line 122 of file test_radius_acct.c.

References debug(), dict_create(), dict_key_count(), from, info(), octstr_create, octstr_destroy(), octstr_duplicate, octstr_get_cstr, octstr_imm(), panic, radius_authenticate_pdu(), radius_pdu_create(), radius_pdu_destroy(), radius_pdu_pack(), radius_pdu_unpack(), radius_table, RADIUS_PDU::type_name, RADIUS_PDU::u, udp_bind(), udp_client_socket(), udp_create_address(), udp_get_ip(), udp_get_port(), udp_recvfrom(), udp_sendto(), and update_table().

Referenced by cgw_handle_op(), cgw_listener(), cgw_open_send_connection(), cgw_read_op(), cgw_receiver(), cgw_send_loop(), cgw_sender(), cgw_wait_command(), emi2_do_send(), emi2_emimsg_send(), emi2_get_timeouttime(), emi2_handle_smscreq(), emi2_idleprocessing(), emi2_idletimeout_handling(), emi2_keepalive_handling(), emi2_listener(), emi2_receiver(), emi2_send_loop(), emi2_sender(), emi2_wait(), handle_operation(), main(), open_send_connection(), return_reply(), and wait_for_ack().

{
    int i;
    int ss, cs; /* server and client socket */
    Octstr *data, *from, *addr;
    /* pid_t pid = getpid(); */
    Dict *radius_table;

    /* create client binding */
    cs = udp_client_socket();
    addr = udp_create_address(octstr_create("localhost"), pport);

    /* create server binding */
    ss = udp_bind(lport, "0.0.0.0");
    if (ss == -1)
        panic(0, "Couldn't set up server socket for port %d.", lport);

    /* init hash table */
    radius_table = dict_create(30, (void (*)(void *))octstr_destroy);

    i = 1;
    while (1) {
        RADIUS_PDU *pdu, *r;
        Octstr *rdata;
        int forward = 0;

        /* get request */
        if (udp_recvfrom(ss, &data, &from) == -1)
            panic(0, "Couldn't receive request data from NAS");
        info(0, "Got data from NAS <%s:%d>", 
             octstr_get_cstr(udp_get_ip(from)), udp_get_port(from));

        /*
        debug("",0,"Saving PDU packet");
        f = fopen(octstr_get_cstr(octstr_format("/tmp/radius-pdu.%ld.%d", pid, i)), "w");
        octstr_print(f, data);
        fclose(f);
        */
        
        pdu = radius_pdu_unpack(data);
        info(0, "PDU type: %s", pdu->type_name);

        /* XXX authenticator md5 check does not work?! */
        /* radius_authenticate_pdu(pdu, data, octstr_imm("radius")); */

        /* store to hash table if not present yet */
        forward = update_table(pdu, &radius_table);

        /* create response PDU for NAS */
        r = radius_pdu_create(0x05, pdu);

        /* 
         * create response authenticator 
         * code+identifier(req)+length+authenticator(req)+(attributes)+secret 
         */
        r->u.Accounting_Response.identifier = pdu->u.Accounting_Request.identifier;
        r->u.Accounting_Response.authenticator = 
            octstr_duplicate(pdu->u.Accounting_Request.authenticator);

        rdata = radius_pdu_pack(r);

        /* creates response autenticator in encoded PDU */
        radius_authenticate_pdu(r, &rdata, octstr_imm("radius"));

        /* forward request to remote RADIUS server only if table updated */
        if (forward) {
            if (udp_sendto(cs, data, addr) == -1)
                panic(0, "Couldn't send to remote RADIUS.");
            if (udp_recvfrom(cs, &data, &from) == -1)
                panic(0, "Couldn't receive from remote RADIUS.");
            info(0, "Got data from remote RADIUS <%s:%d>", 
                 octstr_get_cstr(udp_get_ip(from)), udp_get_port(from));
        }

        /* send response to NAS */
        if (udp_sendto(ss, rdata, from) == -1)
            panic(0, "Couldn't send response data to NAS.");

        radius_pdu_destroy(pdu);
        radius_pdu_destroy(r);

        octstr_destroy(rdata);
        i++;

        debug("",0,"Mapping table contains %ld elements", 
              dict_key_count(radius_table)); 
    }
}

update_table()

static int update_table ( RADIUS_PDU *  pdu, Dict **  table  )

static

Definition at line 75 of file test_radius_acct.c.

References RADIUS_PDU::attr, dict_get(), dict_put(), dict_remove(), error(), info(), octstr_compare(), octstr_destroy(), octstr_get_cstr, octstr_imm(), RADIUS_PDU::type, type, and warning().

Referenced by server().

{
    Octstr *client_ip, *msisdn;
    Octstr *type;
    int ret = 0;
    
    client_ip = msisdn = NULL;

    /* only add if we have a Accounting-Request PDU */
    if (pdu->type == 0x04) {

        /* check if we have a START or STOP event */
        type = dict_get(pdu->attr, octstr_imm("Acct-Status-Type"));
        
        /* grep the needed data */
        client_ip = dict_get(pdu->attr, octstr_imm("Framed-IP-Address"));
        msisdn = dict_get(pdu->attr, octstr_imm("Calling-Station-Id"));

        if (octstr_compare(type, octstr_imm("1")) == 0) {
            /* START */
            if (dict_get(*table, client_ip) == NULL) {
                dict_put(*table, client_ip, msisdn); 
                info(0, "RADIUS: Mapping `%s <-> %s' added.",
                     octstr_get_cstr(client_ip), octstr_get_cstr(msisdn));
                ret = 1;
            } else {
                warning(0, "RADIUS: Duplicate mapping for `%s <-> %s' received",
                        octstr_get_cstr(client_ip), octstr_get_cstr(msisdn));
            }
        }
        else if (octstr_compare(type, octstr_imm("2")) == 0) {
            /* STOP */
            msisdn = dict_get(*table, client_ip);
            dict_remove(*table, client_ip);
        }
        else {
            error(0, "RADIUS: unknown Acct-Status-Type `%s' received.", 
                  octstr_get_cstr(type));
        }
    }

    octstr_destroy(client_ip);
    octstr_destroy(msisdn);

    return ret;
}