Navigation


Changeset 120:d7acdc46134d in freeDiameter for extensions/test_app/ta_cli.c


Ignore:
Timestamp:
Dec 9, 2009, 5:36:38 PM (14 years ago)
Author:
Sebastien Decugis <sdecugis@nict.go.jp>
Branch:
default
Phase:
public
Message:

Renamed several extensions

File:
1 moved

Legend:

Unmodified
Added
Removed
  • extensions/test_app/ta_cli.c

    r99 r120  
    4040 */
    4141
    42 #include "app_test.h"
     42#include "test_app.h"
    4343
    4444#include <stdio.h>
    4545
    46 static struct session_handler * atst_cli_reg = NULL;
    47 
    48 struct atst_mess_info {
     46static struct session_handler * ta_cli_reg = NULL;
     47
     48struct ta_mess_info {
    4949        int32_t         randval;        /* a random value to store in Test-AVP */
    5050        struct timespec ts;             /* Time of sending the message */
     
    5252
    5353/* Cb called when an answer is received */
    54 static void atst_cb_ans(void * data, struct msg ** msg)
    55 {
    56         struct atst_mess_info * mi = NULL;
     54static void ta_cb_ans(void * data, struct msg ** msg)
     55{
     56        struct ta_mess_info * mi = NULL;
    5757        struct timespec ts;
    5858        struct session * sess;
     
    6868                ASSERT( new == 0 );
    6969               
    70                 CHECK_FCT_DO( fd_sess_state_retrieve( atst_cli_reg, sess, &mi ), return );
     70                CHECK_FCT_DO( fd_sess_state_retrieve( ta_cli_reg, sess, &mi ), return );
    7171                TRACE_DEBUG( INFO, "%p %p", mi, data);
    7272                ASSERT( (void *)mi == data );
     
    7777       
    7878        /* Value of Test-AVP */
    79         CHECK_FCT_DO( fd_msg_search_avp ( *msg, atst_avp, &avp), return );
     79        CHECK_FCT_DO( fd_msg_search_avp ( *msg, ta_avp, &avp), return );
    8080        if (avp) {
    8181                CHECK_FCT_DO( fd_msg_avp_hdr( avp, &hdr ), return );
     
    8686       
    8787        /* Value of Result Code */
    88         CHECK_FCT_DO( fd_msg_search_avp ( *msg, atst_res_code, &avp), return );
     88        CHECK_FCT_DO( fd_msg_search_avp ( *msg, ta_res_code, &avp), return );
    8989        if (avp) {
    9090                CHECK_FCT_DO( fd_msg_avp_hdr( avp, &hdr ), return );
     
    9595       
    9696        /* Value of Origin-Host */
    97         CHECK_FCT_DO( fd_msg_search_avp ( *msg, atst_origin_host, &avp), return );
     97        CHECK_FCT_DO( fd_msg_search_avp ( *msg, ta_origin_host, &avp), return );
    9898        if (avp) {
    9999                CHECK_FCT_DO( fd_msg_avp_hdr( avp, &hdr ), return );
     
    104104       
    105105        /* Value of Origin-Realm */
    106         CHECK_FCT_DO( fd_msg_search_avp ( *msg, atst_origin_realm, &avp), return );
     106        CHECK_FCT_DO( fd_msg_search_avp ( *msg, ta_origin_realm, &avp), return );
    107107        if (avp) {
    108108                CHECK_FCT_DO( fd_msg_avp_hdr( avp, &hdr ), return );
     
    136136
    137137/* Create a test message */
    138 static void atst_cli_test_message(void)
     138static void ta_cli_test_message(void)
    139139{
    140140        struct msg * req = NULL;
    141141        struct avp * avp;
    142142        union avp_value val;
    143         struct atst_mess_info * mi = NULL, *svg;
     143        struct ta_mess_info * mi = NULL, *svg;
    144144        struct session *sess = NULL;
    145145       
     
    147147       
    148148        /* Create the request from template */
    149         CHECK_FCT_DO( fd_msg_new( atst_cmd_r, MSGFL_ALLOC_ETEID, &req ), goto out );
     149        CHECK_FCT_DO( fd_msg_new( ta_cmd_r, MSGFL_ALLOC_ETEID, &req ), goto out );
    150150       
    151151        /* Create a new session */
     
    153153       
    154154        /* Create the random value to store with the session */
    155         mi = malloc(sizeof(struct atst_mess_info));
     155        mi = malloc(sizeof(struct ta_mess_info));
    156156        if (mi == NULL) {
    157157                fd_log_debug("malloc failed: %s", strerror(errno));
     
    167167                char * sid;
    168168                CHECK_FCT_DO( fd_sess_getsid ( sess, &sid ), goto out );
    169                 CHECK_FCT_DO( fd_msg_avp_new ( atst_sess_id, 0, &avp ), goto out );
     169                CHECK_FCT_DO( fd_msg_avp_new ( ta_sess_id, 0, &avp ), goto out );
    170170                val.os.data = sid;
    171171                val.os.len  = strlen(sid);
     
    177177        /* Set the Destination-Realm AVP */
    178178        {
    179                 CHECK_FCT_DO( fd_msg_avp_new ( atst_dest_realm, 0, &avp ), goto out  );
    180                 val.os.data = (unsigned char *)(atst_conf->dest_realm);
    181                 val.os.len  = strlen(atst_conf->dest_realm);
     179                CHECK_FCT_DO( fd_msg_avp_new ( ta_dest_realm, 0, &avp ), goto out  );
     180                val.os.data = (unsigned char *)(ta_conf->dest_realm);
     181                val.os.len  = strlen(ta_conf->dest_realm);
    182182                CHECK_FCT_DO( fd_msg_avp_setvalue( avp, &val ), goto out  );
    183183                CHECK_FCT_DO( fd_msg_avp_add( req, MSG_BRW_LAST_CHILD, avp ), goto out  );
     
    185185       
    186186        /* Set the Destination-Host AVP if needed*/
    187         if (atst_conf->dest_host) {
    188                 CHECK_FCT_DO( fd_msg_avp_new ( atst_dest_host, 0, &avp ), goto out  );
    189                 val.os.data = (unsigned char *)(atst_conf->dest_host);
    190                 val.os.len  = strlen(atst_conf->dest_host);
     187        if (ta_conf->dest_host) {
     188                CHECK_FCT_DO( fd_msg_avp_new ( ta_dest_host, 0, &avp ), goto out  );
     189                val.os.data = (unsigned char *)(ta_conf->dest_host);
     190                val.os.len  = strlen(ta_conf->dest_host);
    191191                CHECK_FCT_DO( fd_msg_avp_setvalue( avp, &val ), goto out  );
    192192                CHECK_FCT_DO( fd_msg_avp_add( req, MSG_BRW_LAST_CHILD, avp ), goto out  );
     
    199199        /* Set the Test-AVP AVP */
    200200        {
    201                 CHECK_FCT_DO( fd_msg_avp_new ( atst_avp, 0, &avp ), goto out  );
     201                CHECK_FCT_DO( fd_msg_avp_new ( ta_avp, 0, &avp ), goto out  );
    202202                val.i32 = mi->randval;
    203203                CHECK_FCT_DO( fd_msg_avp_setvalue( avp, &val ), goto out  );
     
    211211       
    212212        /* Store this value in the session */
    213         CHECK_FCT_DO( fd_sess_state_store ( atst_cli_reg, sess, &mi ), goto out );
     213        CHECK_FCT_DO( fd_sess_state_store ( ta_cli_reg, sess, &mi ), goto out );
    214214       
    215215        /* Log sending the message */
    216         fprintf(stderr, "SEND %x to '%s' (%s)\n", svg->randval, atst_conf->dest_realm, atst_conf->dest_host?:"-" );
     216        fprintf(stderr, "SEND %x to '%s' (%s)\n", svg->randval, ta_conf->dest_realm, ta_conf->dest_host?:"-" );
    217217        fflush(stderr);
    218218       
    219219        /* Send the request */
    220         CHECK_FCT_DO( fd_msg_send( &req, atst_cb_ans, svg ), goto out );
     220        CHECK_FCT_DO( fd_msg_send( &req, ta_cb_ans, svg ), goto out );
    221221
    222222out:
     
    225225}
    226226
    227 int atst_cli_init(void)
    228 {
    229         CHECK_FCT( fd_sess_handler_create(&atst_cli_reg, free) );
    230        
    231         CHECK_FCT( atst_sig_init(atst_cli_test_message) );
     227int ta_cli_init(void)
     228{
     229        CHECK_FCT( fd_sess_handler_create(&ta_cli_reg, free) );
     230       
     231        CHECK_FCT( ta_sig_init(ta_cli_test_message) );
    232232       
    233233        return 0;
    234234}
    235235
    236 void atst_cli_fini(void)
    237 {
    238         (void) fd_sess_handler_destroy(&atst_cli_reg);
    239        
    240         atst_sig_fini();
     236void ta_cli_fini(void)
     237{
     238        (void) fd_sess_handler_destroy(&ta_cli_reg);
     239       
     240        ta_sig_fini();
    241241       
    242242        return;
Note: See TracChangeset for help on using the changeset viewer.