Mercurial > hg > freeDiameter
view tests/testdisp.c @ 1510:a2fb51309cd2
Add 3GPP TS 29.345 V15.1.0 (2019-09)
Add AVPs:
- App-Layer-User-Id, UTF8String, code 3801, section 6.3.2
- Assistance-info, Grouped, code 3802, section 6.3.3
- Assistance-Info-Validity-Timer, Unsigned32, code 3803, section 6.3.4
- Discovery-Type, Unsigned32, code 3804, section 6.3.5
- Filter-Id, OctetString, code 3805, section 6.3.9
- MAC-Address, UTF8String, code 3806, section 6.3.11
- Match-Report, Grouped, code 3807, section 6.3.12
- Operating-Channel, Unsigned32, code 3808, section 6.3.14
- P2P-Features, Unsigned32, code 3809, section 6.3.15
- ProSe-App-Code, OctetString, code 3810, section 6.3.16
- ProSe-App-Id, UTF8String, code 3811, section 6.3.17
- ProSe-App-Mask, OctetString, code 3812, section 6.3.18
- ProSe-Discovery-Filter, Grouped, code 3813, section 6.3.20
- PRR-Flags, Unsigned32, code 3814, section 6.3.21
- ProSe-Validity-Timer, Unsigned32, code 3815, section 6.3.22
- Requesting-EPUID, UTF8String, code 3816, section 6.3.23
- Targeted-EPUID, UTF8String, code 3817, section 6.3.26
- Time-Window, Unsigned32, code 3818, section 6.3.27
- WiFi-P2P-Assistance-Info, Grouped, code 3819, section 6.3.30
- WLAN-Assistance-Info, Grouped, code 3820, section 6.3.31
- WLAN-Link-Layer-Id, OctetString, code 3821, section 6.3.32
- WLAN-Link-Layer-Id-List, Grouped, code 3822, section 6.3.33
- Location-Update-Trigger, Grouped, code 3823, section 6.3.42
- Location-Update-Event-Type, Unsigned32, code 3824, section 6.3.43
- Change-Of-Area-Type, Grouped, code 3825, section 6.3.44
- Location-Update-Event-Trigger, Unsigned32, code 3826, section 6.3.45
- Report-Cardinality, Enumerated, code 3827, section 6.3.46
- Minimum-Interval-Time, Unsigned32, code 3828, section 6.3.47
- Periodic-Location-Type, Grouped, code 3829, section 6.3.48
- Location-Report-Interval-Time, Unsigned32, code 3830, section 6.3.49
- Total-Number-Of-Reports, Unsigned32, code 3831, section 6.3.50
- Validity-Time-Announce, Unsigned32, code 3832, section 6.3.36
- Validity-Time-Monitor, Unsigned32, code 3833, section 6.3.37
- Validity-Time-Communication, Unsigned32, code 3834, section 6.3.38
- ProSe-App-Code-Info, Grouped, code 3835, section 6.3.39
- MIC, OctetString, code 3836, section 6.3.40
- UTC-based-Counter, Unsigned32, code 3837, section 6.3.41
- ProSe-Match-Refresh-Timer, Unsigned32, code 3838, section 6.3.52
- ProSe-Metadata-Index-Mask, OctetString, code 3839, section 6.3.60
- App-Identifier, Grouped, code 3840, section 6.3.61
- OS-ID, OctetString, code 3841, section 6.3.62
- OS-App-ID, UTF8String, code 3842, section 6.3.63
- Requesting-RPAUID, UTF8String, code 3843, section 6.3.64
- Target-RPAUID, UTF8String, code 3844, section 6.3.65
- Target-PDUID, OctetString, code 3845, section 6.3.66
- ProSe-Restricted-Code, OctetString, code 3846, section 6.3.67
- ProSe-Restricted-Code-Suffix-Range, OctetString, code 3847, section 6.3.68
- Beginning-Suffix, OctetString, code 3848, section 6.3.69
- Ending-Suffix, OctetString, code 3849, section 6.3.70
- Discovery-Entry-ID, Unsigned32, code 3850, section 6.3.59
- Match-Timestamp, Time, code 3851, section 6.3.71
- PMR-Flags, Unsigned32, code 3852, section 6.3.57
- ProSe-Application-Metadata, UTF8String, code 3853, section 6.3.58
- Discovery-Auth-Request, Grouped, code 3854, section 6.3.53
- Discovery-Auth-Response, Grouped, code 3855, section 6.3.54
- Match-Request, Grouped, code 3856, section 6.3.55
- Match-Report-Info, Grouped, code 3857, section 6.3.56
- Banned-RPAUID, UTF8String, code 3858, section 6.3.73
- Banned-PDUID, OctetString, code 3859, section 6.3.74
- Code-Receiving-Security-Material, Grouped, code 3860, section 6.3.75
- Code-Sending-Security-Material, Grouped, code 3861, section 6.3.76
- DUSK, OctetString, code 3862, section 6.3.77
- DUIK, OctetString, code 3863, section 6.3.78
- DUCK, OctetString, code 3864, section 6.3.79
- MIC-Check-indicator, Unsigned32, code 3865, section 6.3.80
- Encrypted-Bitmask, OctetString, code 3866, section 6.3.81
- ProSe-App-Code-Suffix-Range, OctetString, code 3867, section 6.3.82
- PC5-tech, OctetString, code 3868, section 6.3.84
Note: Name conflict with 3GPP TS 29.154 Time-Window (4204).
Time-Window (3818) in 3GPP TS 29.345 V12.1.0 (2014-12) predates
Time-Window (4204) in 3GPP TS 29.154 V13.1.0 (2016-03).
author | Luke Mewburn <luke@mewburn.net> |
---|---|
date | Sun, 05 Apr 2020 08:27:37 +1000 |
parents | 90e0382e6579 |
children |
line wrap: on
line source
/********************************************************************************************************* * Software License Agreement (BSD License) * * Author: Sebastien Decugis <sdecugis@freediameter.net> * * * * Copyright (c) 2013, WIDE Project and NICT * * All rights reserved. * * * * Redistribution and use of this software in source and binary forms, with or without modification, are * * permitted provided that the following conditions are met: * * * * * Redistributions of source code must retain the above * * copyright notice, this list of conditions and the * * following disclaimer. * * * * * Redistributions in binary form must reproduce the above * * copyright notice, this list of conditions and the * * following disclaimer in the documentation and/or other * * materials provided with the distribution. * * * * * Neither the name of the WIDE Project or NICT nor the * * names of its contributors may be used to endorse or * * promote products derived from this software without * * specific prior written permission of WIDE Project and * * NICT. * * * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED * * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A * * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR * * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT * * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR * * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF * * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * *********************************************************************************************************/ #include "tests.h" #define Define_cb( __int, __extra ) \ int cb_##__int( struct msg ** msg, struct avp * avp, struct session * session, void * opaque, enum disp_action * action ) \ { \ CHECK( 1, msg ? 1 : 0 ); \ CHECK( 1, action ? 1 : 0 ); \ CHECK( sess, session ); \ if (opaque) { \ CHECK( 1, opaque == g_opaque ? 1 : 0 ); \ } \ *action = DISP_ACT_CONT; \ cbcalled[__int] += 1; \ do { \ __extra ; \ } while (0); \ return 0; \ } #define NB_CB 10 char cbcalled[NB_CB]; struct session * sess; void * g_opaque = (void *)"test"; /* cb_0 */ Define_cb( 0, ); /* cb_1 */ Define_cb( 1, ); /* cb_2 */ Define_cb( 2, ); /* cb_3 */ Define_cb( 3, ); /* cb_4 */ Define_cb( 4, ); /* cb_5 */ Define_cb( 5, ); /* cb_6 */ Define_cb( 6, return 12345 ); /* cb_7 */ Define_cb( 7, { CHECK( 1, avp ? 1 : 0 ); } ); /* cb_8 */ Define_cb( 8, { CHECK( 0, fd_msg_free( *msg ) ); *msg = NULL; } ); /* cb_9 */ Define_cb( 9, *action = DISP_ACT_SEND ); /* max: cb_<NB_CB - 1> */ /* Create a new message containing what we want */ struct msg * new_msg(int appid, struct dict_object * cmd, struct dict_object * avp1, struct dict_object * avp2, int val) { struct msg *new; struct avp *avp; union avp_value value; struct msg_hdr * msg_hdr = NULL; CHECK( 0, fd_msg_new ( cmd, 0, &new ) ); CHECK( 0, fd_msg_hdr ( new, &msg_hdr ) ); msg_hdr->msg_appl = appid; if (avp1) { CHECK( 0, fd_msg_avp_new ( avp1, 0, &avp ) ); value.u32 = 0; CHECK( 0, fd_msg_avp_setvalue ( avp, &value ) ); CHECK( 0, fd_msg_avp_add ( new, MSG_BRW_LAST_CHILD, avp ) ); } if (avp2) { CHECK( 0, fd_msg_avp_new ( avp2, 0, &avp ) ); value.u32 = val; CHECK( 0, fd_msg_avp_setvalue ( avp, &value ) ); CHECK( 0, fd_msg_avp_add ( new, MSG_BRW_LAST_CHILD, avp ) ); } return new; } /* Main test routine */ int main(int argc, char *argv[]) { struct dict_object * app1, * app2; struct dict_object * cmd1, * cmd2; struct dict_object * avp1, * avp2; /* avp2 is enumerated; they are both unsigned32 types */ struct dict_object * enu1, * enu2; struct msg * msg = NULL, *error; enum disp_action action; struct disp_hdl * hdl[NB_CB]; struct disp_when when; char * ec, *em; /* First, initialize the daemon modules */ INIT_FD(); /* Create a dummy session, we don't use it anyway */ #define DUMMY_SID "test.disp" CHECK( 0, fd_sess_new( &sess, DUMMY_SID, CONSTSTRLEN(DUMMY_SID), NULL, 0 ) ); memset(&when, 0xff, sizeof(when)); /* check that we don't use un-initialized parts */ /* Initialize dictionary objects */ { struct dict_object * enutype; struct dict_application_data app1_data = { 1, "Application test 1" }; struct dict_application_data app2_data = { 2, "Application test 2" }; struct dict_cmd_data cmd1_data = { 1, "Command test 1 (req)", CMD_FLAG_REQUEST, CMD_FLAG_REQUEST }; struct dict_cmd_data cmd2_data = { 1, "Command test 2 (ans)", CMD_FLAG_REQUEST, 0 }; struct dict_type_data type_data = { AVP_TYPE_UNSIGNED32, "Type test", NULL, NULL }; struct dict_avp_data avp1_data = { 10001, 0, "AVP test 1", 0, 0, AVP_TYPE_UNSIGNED32 }; struct dict_avp_data avp2_data = { 10002, 0, "AVP test 2", 0, 0, AVP_TYPE_UNSIGNED32 }; struct dict_enumval_data enu1_data = { "ENU test 1", { .u32 = 1 }}; struct dict_enumval_data enu2_data = { "ENU test 2", { .u32 = 2 }}; CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_APPLICATION, &app1_data, NULL, &app1 ) ); CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_APPLICATION, &app2_data, NULL, &app2 ) ); CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_COMMAND, &cmd1_data, NULL, &cmd1 ) ); CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_COMMAND, &cmd2_data, NULL, &cmd2 ) ); CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_TYPE, &type_data, NULL, &enutype ) ); CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_AVP, &avp1_data, NULL, &avp1 ) ); CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_AVP, &avp2_data, enutype, &avp2 ) ); CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_ENUMVAL, &enu1_data, enutype, &enu1 ) ); CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_ENUMVAL, &enu2_data, enutype, &enu2 ) ); } /* Register first handler, very simple test */ { CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, NULL, NULL, &hdl[0] ) ); CHECK( 1, hdl[0] ? 1 : 0 ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( NULL, hdl[0] ); CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, NULL, NULL, &hdl[0] ) ); /* Check this handler is called for a message */ msg = new_msg( 0, cmd1, avp1, NULL, 0 ); memset(cbcalled, 0, sizeof(cbcalled)); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( DISP_ACT_CONT, action ); /* Delete the message */ CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); } /* Handlers for applications */ { CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, &when, NULL, &hdl[0] ) ); when.app = app1; CHECK( 0, fd_disp_register( cb_1, DISP_HOW_APPID, &when, NULL, &hdl[1] ) ); when.app = app2; CHECK( 0, fd_disp_register( cb_2, DISP_HOW_APPID, &when, NULL, &hdl[2] ) ); when.avp = avp2; CHECK( 0, fd_disp_register( cb_3, DISP_HOW_APPID, &when, NULL, &hdl[3] ) ); when.avp = avp1; CHECK( 0, fd_disp_register( cb_4, DISP_HOW_APPID, &when, NULL, &hdl[4] ) ); /* Check the callbacks are called as appropriate */ memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 0, cmd1, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd1, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( 1, cbcalled[4] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[1], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[2], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[3], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[4], NULL ) ); } /* Handlers for commands */ { when.app = NULL; when.command = NULL; CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, &when, NULL, &hdl[0] ) ); CHECK( EINVAL, fd_disp_register( cb_1, DISP_HOW_CC, &when, NULL, &hdl[1] ) ); when.command = cmd1; CHECK( 0, fd_disp_register( cb_1, DISP_HOW_CC, &when, NULL, &hdl[1] ) ); /* cmd1 */ when.app = app2; CHECK( 0, fd_disp_register( cb_2, DISP_HOW_CC, &when, NULL, &hdl[2] ) ); /* app2 + cmd1 */ when.command = cmd2; when.app = NULL; when.avp = avp1; CHECK( 0, fd_disp_register( cb_3, DISP_HOW_CC, &when, NULL, &hdl[3] ) ); /* cmd2 (avp1 ignored) */ /* Check the callbacks are called as appropriate */ memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 0, cmd1, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd1, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd2, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd2, NULL, avp2, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[1], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[2], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[3], NULL ) ); } /* Handlers for AVPs */ { when.app = NULL; when.command = NULL; when.avp = NULL; CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, &when, NULL, &hdl[0] ) ); /* all */ CHECK( EINVAL, fd_disp_register( cb_1, DISP_HOW_AVP, &when, NULL, &hdl[1] ) ); when.avp = avp1; CHECK( 0, fd_disp_register( cb_1, DISP_HOW_AVP, &when, NULL, &hdl[1] ) ); /* avp1 */ when.command = cmd1; CHECK( 0, fd_disp_register( cb_2, DISP_HOW_AVP, &when, NULL, &hdl[2] ) ); /* avp1 + cmd1 */ when.command = NULL; when.app = app1; CHECK( 0, fd_disp_register( cb_3, DISP_HOW_AVP, &when, NULL, &hdl[3] ) ); /* avp1 + app1 */ when.command = cmd1; CHECK( 0, fd_disp_register( cb_4, DISP_HOW_AVP, &when, NULL, &hdl[4] ) ); /* avp1 + cmd1 + app1 */ when.app = NULL; when.command = NULL; when.avp = avp2; when.value = enu1; CHECK( 0, fd_disp_register( cb_5, DISP_HOW_AVP, &when, NULL, &hdl[5] ) ); /* avp2 */ when.value = enu2; CHECK( 0, fd_disp_register( cb_7, DISP_HOW_AVP, &when, NULL, &hdl[6] ) ); /* avp2 */ /* Check the callbacks are called as appropriate */ memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 0, cmd1, NULL, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 0, cbcalled[5] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 0, cmd1, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 0, cbcalled[5] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd2, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 0, cbcalled[5] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( 1, cbcalled[4] ); CHECK( 0, cbcalled[5] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, avp1, avp2, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( 1, cbcalled[4] ); CHECK( 1, cbcalled[5] ); CHECK( 1, cbcalled[7] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, NULL, avp2, 1 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 1, cbcalled[5] ); CHECK( 1, cbcalled[7] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, NULL, avp2, 2 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 1, cbcalled[5] ); CHECK( 1, cbcalled[7] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[1], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[2], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[3], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[4], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[5], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[6], NULL ) ); } /* Handlers for enum values */ { when.app = NULL; when.command = NULL; when.avp = NULL; when.value = NULL; CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, &when, NULL, &hdl[0] ) ); /* all */ CHECK( EINVAL, fd_disp_register( cb_1, DISP_HOW_AVP_ENUMVAL, &when, NULL, &hdl[1] ) ); when.value = enu1; CHECK( EINVAL, fd_disp_register( cb_1, DISP_HOW_AVP_ENUMVAL, &when, NULL, &hdl[1] ) ); when.avp = avp1; CHECK( EINVAL, fd_disp_register( cb_1, DISP_HOW_AVP_ENUMVAL, &when, NULL, &hdl[1] ) ); when.avp = avp2; CHECK( 0, fd_disp_register( cb_1, DISP_HOW_AVP_ENUMVAL, &when, NULL, &hdl[1] ) ); /* avp2, enu1 */ when.command = cmd1; CHECK( 0, fd_disp_register( cb_2, DISP_HOW_AVP_ENUMVAL, &when, NULL, &hdl[2] ) ); /* avp2, enu1 + cmd1 */ when.command = NULL; when.app = app1; when.value = enu2; CHECK( 0, fd_disp_register( cb_3, DISP_HOW_AVP_ENUMVAL, &when, NULL, &hdl[3] ) ); /* avp2, enu2 + app1 */ /* Check the callbacks are called as appropriate */ memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 0, cmd1, avp1, NULL, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd2, avp1, avp2, 0 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd2, avp1, avp2, 1 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd2, avp1, avp2, 2 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, avp1, avp2, 1 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd2, avp1, avp2, 1 ); { struct avp *avp; union avp_value value; CHECK( 0, fd_msg_avp_new ( avp2, 0, &avp ) ); value.u32 = 2; CHECK( 0, fd_msg_avp_setvalue ( avp, &value ) ); CHECK( 0, fd_msg_avp_add ( msg, MSG_BRW_LAST_CHILD, avp ) ); } CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( DISP_ACT_CONT, action ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[1], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[2], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[3], NULL ) ); } /* Test behavior of handlers */ { CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, &when, NULL, &hdl[0] ) ); CHECK( 0, fd_disp_register( cb_1, DISP_HOW_ANY, &when, NULL, &hdl[1] ) ); CHECK( 0, fd_disp_register( cb_6, DISP_HOW_ANY, &when, NULL, &hdl[2] ) ); CHECK( 0, fd_disp_register( cb_2, DISP_HOW_ANY, &when, NULL, &hdl[3] ) ); CHECK( 0, fd_disp_register( cb_3, DISP_HOW_ANY, &when, NULL, &hdl[4] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, avp1, avp2, 1 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[6] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, msg ? 1 : 0); CHECK( 1, em ? 1 : 0); CHECK( 0, fd_msg_free( error ) ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[1], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[2], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[3], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[4], NULL ) ); CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, &when, NULL, &hdl[0] ) ); CHECK( 0, fd_disp_register( cb_1, DISP_HOW_ANY, &when, NULL, &hdl[1] ) ); CHECK( 0, fd_disp_register( cb_8, DISP_HOW_ANY, &when, NULL, &hdl[2] ) ); CHECK( 0, fd_disp_register( cb_2, DISP_HOW_ANY, &when, NULL, &hdl[3] ) ); CHECK( 0, fd_disp_register( cb_3, DISP_HOW_ANY, &when, NULL, &hdl[4] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, avp1, avp2, 1 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[8] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( NULL, msg ); CHECK( NULL, em ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[1], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[2], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[3], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[4], NULL ) ); CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, &when, NULL, &hdl[0] ) ); CHECK( 0, fd_disp_register( cb_1, DISP_HOW_ANY, &when, NULL, &hdl[1] ) ); CHECK( 0, fd_disp_register( cb_9, DISP_HOW_ANY, &when, NULL, &hdl[2] ) ); CHECK( 0, fd_disp_register( cb_2, DISP_HOW_ANY, &when, NULL, &hdl[3] ) ); CHECK( 0, fd_disp_register( cb_3, DISP_HOW_ANY, &when, NULL, &hdl[4] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 1, cmd1, avp1, avp2, 1 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[9] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( DISP_ACT_SEND, action ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[1], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[2], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[3], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[4], NULL ) ); } /* Test order of handlers */ { when.app = app2; when.command = cmd2; when.avp = avp2; when.value = enu2; CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, &when, NULL, &hdl[0] ) ); CHECK( 0, fd_disp_register( cb_1, DISP_HOW_AVP_ENUMVAL, &when, NULL, &hdl[1] ) ); CHECK( 0, fd_disp_register( cb_2, DISP_HOW_AVP, &when, NULL, &hdl[2] ) ); CHECK( 0, fd_disp_register( cb_3, DISP_HOW_CC, &when, NULL, &hdl[3] ) ); CHECK( 0, fd_disp_register( cb_4, DISP_HOW_APPID, &when, NULL, &hdl[4] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd2, avp1, avp2, 2 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( 1, cbcalled[4] ); CHECK( 0, cbcalled[9] ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_register( cb_9, DISP_HOW_ANY, &when, NULL, &hdl[5] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd2, avp1, avp2, 2 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 0, cbcalled[1] ); CHECK( 0, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 1, cbcalled[9] ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[5], NULL ) ); CHECK( 0, fd_disp_register( cb_9, DISP_HOW_AVP_ENUMVAL, &when, NULL, &hdl[5] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd2, avp1, avp2, 2 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 1, cbcalled[9] ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[5], NULL ) ); CHECK( 0, fd_disp_register( cb_9, DISP_HOW_AVP, &when, NULL, &hdl[5] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd2, avp1, avp2, 2 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 0, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 1, cbcalled[9] ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[5], NULL ) ); CHECK( 0, fd_disp_register( cb_9, DISP_HOW_CC, &when, NULL, &hdl[5] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd2, avp1, avp2, 2 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( 0, cbcalled[4] ); CHECK( 1, cbcalled[9] ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[5], NULL ) ); CHECK( 0, fd_disp_register( cb_9, DISP_HOW_APPID, &when, NULL, &hdl[5] ) ); memset(cbcalled, 0, sizeof(cbcalled)); msg = new_msg( 2, cmd2, avp1, avp2, 2 ); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( 1, cbcalled[1] ); CHECK( 1, cbcalled[2] ); CHECK( 1, cbcalled[3] ); CHECK( 1, cbcalled[4] ); CHECK( 1, cbcalled[9] ); CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[5], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[0], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[1], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[2], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[3], NULL ) ); CHECK( 0, fd_disp_unregister( &hdl[4], NULL ) ); } /* Test application support advertisement */ { struct dict_object * vnd; struct dict_vendor_data vnd_data = { 1, "Vendor test" }; struct fd_app * app; CHECK( 0, fd_dict_new ( fd_g_config->cnf_dict, DICT_VENDOR, &vnd_data, NULL, &vnd ) ); CHECK( EINVAL, fd_disp_app_support ( vnd, NULL, 1, 0 ) ); CHECK( EINVAL, fd_disp_app_support ( app1, NULL, 0, 0 ) ); CHECK( 0, fd_disp_app_support ( app1, NULL, 1, 0 ) ); CHECK( 0, fd_disp_app_support ( app1, NULL, 0, 1 ) ); CHECK( 0, fd_disp_app_support ( app2, vnd, 1, 0 ) ); app = (struct fd_app *)(fd_g_config->cnf_apps.next); CHECK( 1, app->appid ); CHECK( 1, app->flags.auth ); CHECK( 1, app->flags.acct ); app = (struct fd_app *)(fd_g_config->cnf_apps.prev); CHECK( 2, app->appid ); CHECK( 1, app->flags.auth ); CHECK( 0, app->flags.acct ); #if 0 fd_log_debug("%s", fd_conf_dump(FD_DUMP_TEST_PARAMS)); #endif } /* Test opaque pointer management */ { void * ptr; CHECK( 0, fd_disp_register( cb_0, DISP_HOW_ANY, NULL, g_opaque, &hdl[0] ) ); /* Check this handler is called for a message */ msg = new_msg( 0, cmd1, avp1, NULL, 0 ); memset(cbcalled, 0, sizeof(cbcalled)); CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec, &em, &error ) ); CHECK( 1, cbcalled[0] ); CHECK( DISP_ACT_CONT, action ); /* Delete the message */ CHECK( 0, fd_msg_free( msg ) ); CHECK( 0, fd_disp_unregister( &hdl[0], &ptr ) ); CHECK( 1, ptr == g_opaque ? 1 : 0 ); } /* That's all for the tests yet */ PASSTEST(); }