Navigation

Changeset 90:2c9444152e4b in freeDiameter for freeDiameter/tests/testdisp.c


Ignore:
Timestamp:
Dec 7, 2009, 6:32:30 PM (14 years ago)
Author:
Sebastien Decugis <sdecugis@nict.go.jp>
Branch:
default
Phase:
public
Message:

Added the dispatch thread code

File:
1 edited

Legend:

Unmodified
Added
Removed

  • freeDiameter/tests/testdisp.c

    r10 r90  
    106106        struct disp_hdl * hdl[NB_CB];
    107107        struct disp_when when;
     108        const char * ec;
    108109       
    109110        /* First, initialize the daemon modules */
    … …  
    150151                msg = new_msg( 0, cmd1, avp1, NULL, 0 );
    151152                memset(cbcalled, 0, sizeof(cbcalled));
    152                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     153                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    153154                CHECK( 1, cbcalled[0] );
    154155                CHECK( DISP_ACT_CONT, action );
    … …  
    174175                memset(cbcalled, 0, sizeof(cbcalled));
    175176                msg = new_msg( 0, cmd1, avp1, NULL, 0 );
    176                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     177                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    177178                CHECK( 1, cbcalled[0] );
    178179                CHECK( 0, cbcalled[1] );
    … …  
    185186                memset(cbcalled, 0, sizeof(cbcalled));
    186187                msg = new_msg( 1, cmd1, avp1, NULL, 0 );
    187                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     188                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    188189                CHECK( 1, cbcalled[0] );
    189190                CHECK( 1, cbcalled[1] );
    … …  
    196197                memset(cbcalled, 0, sizeof(cbcalled));
    197198                msg = new_msg( 2, cmd1, avp1, NULL, 0 );
    198                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     199                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    199200                CHECK( 1, cbcalled[0] );
    200201                CHECK( 0, cbcalled[1] );
    … …  
    230231                memset(cbcalled, 0, sizeof(cbcalled));
    231232                msg = new_msg( 0, cmd1, avp1, NULL, 0 );
    232                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     233                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    233234                CHECK( 1, cbcalled[0] );
    234235                CHECK( 1, cbcalled[1] );
    … …  
    240241                memset(cbcalled, 0, sizeof(cbcalled));
    241242                msg = new_msg( 2, cmd1, avp1, NULL, 0 );
    242                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     243                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    243244                CHECK( 1, cbcalled[0] );
    244245                CHECK( 1, cbcalled[1] );
    … …  
    250251                memset(cbcalled, 0, sizeof(cbcalled));
    251252                msg = new_msg( 2, cmd2, avp1, NULL, 0 );
    252                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     253                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    253254                CHECK( 1, cbcalled[0] );
    254255                CHECK( 0, cbcalled[1] );
    … …  
    260261                memset(cbcalled, 0, sizeof(cbcalled));
    261262                msg = new_msg( 1, cmd2, NULL, avp2, 0 );
    262                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     263                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    263264                CHECK( 1, cbcalled[0] );
    264265                CHECK( 0, cbcalled[1] );
    … …  
    310311                memset(cbcalled, 0, sizeof(cbcalled));
    311312                msg = new_msg( 0, cmd1, NULL, NULL, 0 );
    312                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     313                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    313314                CHECK( 1, cbcalled[0] );
    314315                CHECK( 0, cbcalled[1] );
    … …  
    322323                memset(cbcalled, 0, sizeof(cbcalled));
    323324                msg = new_msg( 0, cmd1, avp1, NULL, 0 );
    324                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     325                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    325326                CHECK( 1, cbcalled[0] );
    326327                CHECK( 1, cbcalled[1] );
    … …  
    334335                memset(cbcalled, 0, sizeof(cbcalled));
    335336                msg = new_msg( 1, cmd2, avp1, NULL, 0 );
    336                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     337                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    337338                CHECK( 1, cbcalled[0] );
    338339                CHECK( 1, cbcalled[1] );
    … …  
    346347                memset(cbcalled, 0, sizeof(cbcalled));
    347348                msg = new_msg( 1, cmd1, avp1, NULL, 0 );
    348                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     349                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    349350                CHECK( 1, cbcalled[0] );
    350351                CHECK( 1, cbcalled[1] );
    … …  
    358359                memset(cbcalled, 0, sizeof(cbcalled));
    359360                msg = new_msg( 1, cmd1, avp1, avp2, 0 );
    360                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     361                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    361362                CHECK( 1, cbcalled[0] );
    362363                CHECK( 1, cbcalled[1] );
    … …  
    371372                memset(cbcalled, 0, sizeof(cbcalled));
    372373                msg = new_msg( 1, cmd1, NULL, avp2, 1 );
    373                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     374                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    374375                CHECK( 1, cbcalled[0] );
    375376                CHECK( 0, cbcalled[1] );
    … …  
    384385                memset(cbcalled, 0, sizeof(cbcalled));
    385386                msg = new_msg( 1, cmd1, NULL, avp2, 2 );
    386                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     387                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    387388                CHECK( 1, cbcalled[0] );
    388389                CHECK( 0, cbcalled[1] );
    … …  
    431432                memset(cbcalled, 0, sizeof(cbcalled));
    432433                msg = new_msg( 0, cmd1, avp1, NULL, 0 );
    433                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     434                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    434435                CHECK( 1, cbcalled[0] );
    435436                CHECK( 0, cbcalled[1] );
    … …  
    441442                memset(cbcalled, 0, sizeof(cbcalled));
    442443                msg = new_msg( 1, cmd2, avp1, avp2, 0 );
    443                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     444                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    444445                CHECK( 1, cbcalled[0] );
    445446                CHECK( 0, cbcalled[1] );
    … …  
    451452                memset(cbcalled, 0, sizeof(cbcalled));
    452453                msg = new_msg( 1, cmd2, avp1, avp2, 1 );
    453                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     454                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    454455                CHECK( 1, cbcalled[0] );
    455456                CHECK( 1, cbcalled[1] );
    … …  
    461462                memset(cbcalled, 0, sizeof(cbcalled));
    462463                msg = new_msg( 1, cmd2, avp1, avp2, 2 );
    463                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     464                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    464465                CHECK( 1, cbcalled[0] );
    465466                CHECK( 0, cbcalled[1] );
    … …  
    471472                memset(cbcalled, 0, sizeof(cbcalled));
    472473                msg = new_msg( 1, cmd1, avp1, avp2, 1 );
    473                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     474                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    474475                CHECK( 1, cbcalled[0] );
    475476                CHECK( 1, cbcalled[1] );
    … …  
    489490                        CHECK( 0, fd_msg_avp_add ( msg, MSG_BRW_LAST_CHILD, avp ) );
    490491                }
    491                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     492                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    492493                CHECK( 1, cbcalled[0] );
    493494                CHECK( 1, cbcalled[1] );
    … …  
    513514                memset(cbcalled, 0, sizeof(cbcalled));
    514515                msg = new_msg( 1, cmd1, avp1, avp2, 1 );
    515                 CHECK( 12345, fd_msg_dispatch ( &msg, sess, &action ) );
     516                CHECK( 12345, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    516517                CHECK( 1, cbcalled[0] );
    517518                CHECK( 1, cbcalled[1] );
    … …  
    535536                memset(cbcalled, 0, sizeof(cbcalled));
    536537                msg = new_msg( 1, cmd1, avp1, avp2, 1 );
    537                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     538                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    538539                CHECK( 1, cbcalled[0] );
    539540                CHECK( 1, cbcalled[1] );
    … …  
    557558                memset(cbcalled, 0, sizeof(cbcalled));
    558559                msg = new_msg( 1, cmd1, avp1, avp2, 1 );
    559                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     560                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    560561                CHECK( 1, cbcalled[0] );
    561562                CHECK( 1, cbcalled[1] );
    … …  
    588589                memset(cbcalled, 0, sizeof(cbcalled));
    589590                msg = new_msg( 2, cmd2, avp1, avp2, 2 );
    590                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     591                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    591592                CHECK( 1, cbcalled[0] );
    592593                CHECK( 1, cbcalled[1] );
    … …  
    600601                memset(cbcalled, 0, sizeof(cbcalled));
    601602                msg = new_msg( 2, cmd2, avp1, avp2, 2 );
    602                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     603                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    603604                CHECK( 1, cbcalled[0] );
    604605                CHECK( 0, cbcalled[1] );
    … …  
    613614                memset(cbcalled, 0, sizeof(cbcalled));
    614615                msg = new_msg( 2, cmd2, avp1, avp2, 2 );
    615                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     616                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    616617                CHECK( 1, cbcalled[0] );
    617618                CHECK( 1, cbcalled[1] );
    … …  
    626627                memset(cbcalled, 0, sizeof(cbcalled));
    627628                msg = new_msg( 2, cmd2, avp1, avp2, 2 );
    628                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     629                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    629630                CHECK( 1, cbcalled[0] );
    630631                CHECK( 1, cbcalled[1] );
    … …  
    639640                memset(cbcalled, 0, sizeof(cbcalled));
    640641                msg = new_msg( 2, cmd2, avp1, avp2, 2 );
    641                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     642                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    642643                CHECK( 1, cbcalled[0] );
    643644                CHECK( 1, cbcalled[1] );
    … …  
    652653                memset(cbcalled, 0, sizeof(cbcalled));
    653654                msg = new_msg( 2, cmd2, avp1, avp2, 2 );
    654                 CHECK( 0, fd_msg_dispatch ( &msg, sess, &action ) );
     655                CHECK( 0, fd_msg_dispatch ( &msg, sess, &action, &ec ) );
    655656                CHECK( 1, cbcalled[0] );
    656657                CHECK( 1, cbcalled[1] );
Note: See TracChangeset for help on using the changeset viewer.