Mercurial > hg > freeDiameter

annotate extensions/test_app/ta_bench.c @ 1294:22cc3a9dd216

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Updated copyright information
author Sebastien Decugis <sdecugis@freediameter.net>
date Thu, 18 Jun 2015 23:01:08 +0800
parents 0fa8207cc91a
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
1 /*********************************************************************************************************
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
2 * Software License Agreement (BSD License) *
740
4a9f08d6b6ba Updated my mail address
Sebastien Decugis <sdecugis@nict.go.jp>
parents: 706
diff changeset
3 * Author: Sebastien Decugis <sdecugis@freediameter.net> *
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
4 * *
1294
22cc3a9dd216 Updated copyright information
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1291
diff changeset
5 * Copyright (c) 2015, WIDE Project and NICT *
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
6 * All rights reserved. *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
7 * *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
8 * Redistribution and use of this software in source and binary forms, with or without modification, are *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
9 * permitted provided that the following conditions are met: *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
10 * *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
11 * * Redistributions of source code must retain the above *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
12 * copyright notice, this list of conditions and the *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
13 * following disclaimer. *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
14 * *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
15 * * Redistributions in binary form must reproduce the above *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
16 * copyright notice, this list of conditions and the *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
17 * following disclaimer in the documentation and/or other *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
18 * materials provided with the distribution. *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
19 * *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
20 * * Neither the name of the WIDE Project or NICT nor the *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
21 * names of its contributors may be used to endorse or *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
22 * promote products derived from this software without *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
23 * specific prior written permission of WIDE Project and *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
24 * NICT. *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
25 * *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
26 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
27 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
28 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
29 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
30 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
31 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
32 * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
33 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. *
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
34 *********************************************************************************************************/
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
35
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
36 /* Create and send a message, and receive it */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
37
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
38 #include "test_app.h"
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
39 #include <stdio.h>
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
40
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
41 #ifndef __APPLE__ /* they deprecated the semaphore there... */
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
42 #include <semaphore.h>
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
43
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
44 #define my_sem_t sem_t
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
45 #define my_sem_init sem_init
1291
0fa8207cc91a Fix a few mistakes
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1290
diff changeset
46 #define my_sem_destroy sem_destroy
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
47 #define my_sem_timedwait sem_timedwait
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
48 #define my_sem_post sem_post
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
49
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
50 #else // on APPLE
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
51 #include <sched.h>
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
52 #include <dispatch/dispatch.h>
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
53
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
54 #define my_sem_t dispatch_semaphore_t
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
55
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
56 static int my_sem_init(my_sem_t * s, int pshared, unsigned int value ) {
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
57 *s = dispatch_semaphore_create(value);
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
58 if (*s == NULL)
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
59 return ENOMEM;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
60 return 0;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
61 }
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
62
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
63 static int my_sem_destroy(my_sem_t *s) {
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
64 dispatch_release(*s);
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
65 *s = NULL;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
66 return 0;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
67 }
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
68
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
69 static int my_sem_timedwait(my_sem_t * s, struct timespec *ts) {
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
70 struct timespec tsn;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
71 int64_t nsec;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
72 dispatch_time_t when;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
73
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
74 CHECK_SYS( clock_gettime(CLOCK_REALTIME, &tsn) );
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
75
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
76 nsec = (ts->tv_sec * 1000000000) + ts->tv_nsec
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
77 - (tsn.tv_sec * 1000000000) - tsn.tv_nsec;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
78
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
79 when = dispatch_time ( DISPATCH_TIME_NOW, nsec );
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
80
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
81 return dispatch_semaphore_wait ( *s, when ) ? ETIMEDOUT : 0;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
82 }
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
83
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
84 static int my_sem_post(my_sem_t *s) {
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
85 dispatch_semaphore_signal(*s);
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
86 return 0;
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
87 }
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
88
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
89 #endif // APPLE
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
90
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
91
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
92
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
93 struct ta_mess_info {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
94 int32_t randval; /* a random value to store in Test-AVP */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
95 struct timespec ts; /* Time of sending the message */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
96 };
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
97
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
98 static my_sem_t ta_sem; /* To handle the concurrency */
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
99
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
100 /* Cb called when an answer is received */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
101 static void ta_cb_ans(void * data, struct msg ** msg)
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
102 {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
103 struct ta_mess_info * mi = (struct ta_mess_info *)data;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
104 struct timespec ts;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
105 struct avp * avp;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
106 struct avp_hdr * hdr;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
107 unsigned long dur;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
108
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
109 CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &ts), return );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
110
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
111 /* Value of Result Code */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
112 CHECK_FCT_DO( fd_msg_search_avp ( *msg, ta_res_code, &avp), return );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
113 if (avp) {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
114 CHECK_FCT_DO( fd_msg_avp_hdr( avp, &hdr ), return );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
115 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
116 if (!avp || !hdr || hdr->avp_value->i32 != 2001) {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
117 /* error */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
118 CHECK_POSIX_DO( pthread_mutex_lock(&ta_conf->stats_lock), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
119 ta_conf->stats.nb_errs++;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
120 CHECK_POSIX_DO( pthread_mutex_unlock(&ta_conf->stats_lock), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
121 goto end;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
122 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
123
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
124 /* Check value of Test-AVP */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
125 CHECK_FCT_DO( fd_msg_search_avp ( *msg, ta_avp, &avp), return );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
126 if (avp) {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
127 CHECK_FCT_DO( fd_msg_avp_hdr( avp, &hdr ), return );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
128 ASSERT(hdr->avp_value->i32 == mi->randval);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
129 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
130
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
131 /* Compute how long it took */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
132 dur = ((ts.tv_sec - mi->ts.tv_sec) * 1000000) + ((ts.tv_nsec - mi->ts.tv_nsec) / 1000);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
133
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
134 /* Add this value to the stats */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
135 CHECK_POSIX_DO( pthread_mutex_lock(&ta_conf->stats_lock), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
136
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
137 if (ta_conf->stats.nb_recv) {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
138 /* Ponderate in the avg */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
139 ta_conf->stats.avg = (ta_conf->stats.avg * ta_conf->stats.nb_recv + dur) / (ta_conf->stats.nb_recv + 1);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
140 /* Min, max */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
141 if (dur < ta_conf->stats.shortest)
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
142 ta_conf->stats.shortest = dur;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
143 if (dur > ta_conf->stats.longest)
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
144 ta_conf->stats.longest = dur;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
145 } else {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
146 ta_conf->stats.shortest = dur;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
147 ta_conf->stats.longest = dur;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
148 ta_conf->stats.avg = dur;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
149 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
150 ta_conf->stats.nb_recv++;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
151
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
152 CHECK_POSIX_DO( pthread_mutex_unlock(&ta_conf->stats_lock), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
153
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
154 end:
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
155 /* Free the message */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
156 CHECK_FCT_DO(fd_msg_free(*msg), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
157 *msg = NULL;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
158
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
159 free(mi);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
160
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
161 /* Post the semaphore */
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
162 CHECK_SYS_DO( my_sem_post(&ta_sem), );
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
163
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
164 return;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
165 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
166
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
167 /* Create a test message */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
168 static void ta_bench_test_message()
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
169 {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
170 struct msg * req = NULL;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
171 struct avp * avp;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
172 union avp_value val;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
173 struct ta_mess_info * mi = NULL;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
174
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
175 TRACE_DEBUG(FULL, "Creating a new message for sending.");
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
176
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
177 /* Create the request */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
178 CHECK_FCT_DO( fd_msg_new( ta_cmd_r, MSGFL_ALLOC_ETEID, &req ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
179
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
180 /* Create a new session */
706
4ffbc9f1e922 Large UNTESTED commit with the following changes:
Sebastien Decugis <sdecugis@nict.go.jp>
parents: 662
diff changeset
181 #define TEST_APP_SID_OPT "app_testb"
924
877592751fee Fix (tentative) for invalid handling of sessions fast creation/destruction as pointed by Yusuke Okura -- http://lists.freediameter.net/pipermail/help/2013-February/000584.html and http://lists.freediameter.net/pipermail/help/2013-February/000589.html -- Thank you very much
Sebastien Decugis <sdecugis@freediameter.net>
parents: 879
diff changeset
182 CHECK_FCT_DO( fd_msg_new_session( req, (os0_t)TEST_APP_SID_OPT, CONSTSTRLEN(TEST_APP_SID_OPT) ), goto out );
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
183
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
184 /* Create the random value to store with the session */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
185 mi = malloc(sizeof(struct ta_mess_info));
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
186 if (mi == NULL) {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
187 fd_log_debug("malloc failed: %s", strerror(errno));
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
188 goto out;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
189 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
190
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
191 mi->randval = (int32_t)random();
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
192
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
193 /* Now set all AVPs values */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
194
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
195 /* Set the Destination-Realm AVP */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
196 {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
197 CHECK_FCT_DO( fd_msg_avp_new ( ta_dest_realm, 0, &avp ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
198 val.os.data = (unsigned char *)(ta_conf->dest_realm);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
199 val.os.len = strlen(ta_conf->dest_realm);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
200 CHECK_FCT_DO( fd_msg_avp_setvalue( avp, &val ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
201 CHECK_FCT_DO( fd_msg_avp_add( req, MSG_BRW_LAST_CHILD, avp ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
202 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
203
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
204 /* Set the Destination-Host AVP if needed*/
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
205 if (ta_conf->dest_host) {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
206 CHECK_FCT_DO( fd_msg_avp_new ( ta_dest_host, 0, &avp ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
207 val.os.data = (unsigned char *)(ta_conf->dest_host);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
208 val.os.len = strlen(ta_conf->dest_host);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
209 CHECK_FCT_DO( fd_msg_avp_setvalue( avp, &val ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
210 CHECK_FCT_DO( fd_msg_avp_add( req, MSG_BRW_LAST_CHILD, avp ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
211 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
212
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
213 /* Set Origin-Host & Origin-Realm */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
214 CHECK_FCT_DO( fd_msg_add_origin ( req, 0 ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
215
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
216 /* Set the User-Name AVP if needed*/
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
217 if (ta_conf->user_name) {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
218 CHECK_FCT_DO( fd_msg_avp_new ( ta_user_name, 0, &avp ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
219 val.os.data = (unsigned char *)(ta_conf->user_name);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
220 val.os.len = strlen(ta_conf->user_name);
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
221 CHECK_FCT_DO( fd_msg_avp_setvalue( avp, &val ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
222 CHECK_FCT_DO( fd_msg_avp_add( req, MSG_BRW_LAST_CHILD, avp ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
223 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
224
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
225 /* Set the Test-AVP AVP */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
226 {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
227 CHECK_FCT_DO( fd_msg_avp_new ( ta_avp, 0, &avp ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
228 val.i32 = mi->randval;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
229 CHECK_FCT_DO( fd_msg_avp_setvalue( avp, &val ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
230 CHECK_FCT_DO( fd_msg_avp_add( req, MSG_BRW_LAST_CHILD, avp ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
231 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
232
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
233 CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &mi->ts), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
234
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
235 /* Send the request */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
236 CHECK_FCT_DO( fd_msg_send( &req, ta_cb_ans, mi ), goto out );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
237
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
238 /* Increment the counter */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
239 CHECK_POSIX_DO( pthread_mutex_lock(&ta_conf->stats_lock), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
240 ta_conf->stats.nb_sent++;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
241 CHECK_POSIX_DO( pthread_mutex_unlock(&ta_conf->stats_lock), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
242
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
243 out:
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
244 return;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
245 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
246
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
247 /* The function called when the signal is received */
658
f198d16fa7f4 Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents: 575
diff changeset
248 static void ta_bench_start() {
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
249 struct timespec end_time, now;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
250 struct ta_stats start, end;
1206
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
251 int nsec = 0;
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
252
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
253 /* Save the initial stats */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
254 CHECK_POSIX_DO( pthread_mutex_lock(&ta_conf->stats_lock), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
255 memcpy(&start, &ta_conf->stats, sizeof(struct ta_stats));
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
256 CHECK_POSIX_DO( pthread_mutex_unlock(&ta_conf->stats_lock), );
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
257
575
66f188b3ca84 Configurable parameters for the benchmark mode
Sebastien Decugis <sdecugis@nict.go.jp>
parents: 572
diff changeset
258 /* We will run for ta_conf->bench_duration seconds */
1195
16f2d2f15e5b Allow better usage in benchmark mode
Sebastien Decugis <sdecugis@freediameter.net>
parents: 974
diff changeset
259 LOG_N("Starting benchmark client, %ds", ta_conf->bench_duration);
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
260 CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &end_time), );
575
66f188b3ca84 Configurable parameters for the benchmark mode
Sebastien Decugis <sdecugis@nict.go.jp>
parents: 572
diff changeset
261 end_time.tv_sec += ta_conf->bench_duration;
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
262
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
263 /* Now loop until timeout is reached */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
264 do {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
265 /* Do not create more that NB_CONCURRENT_MESSAGES in paralel */
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
266 int ret = my_sem_timedwait(&ta_sem, &end_time);
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
267 if (ret == -1) {
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
268 ret = errno;
1206
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
269 if (ret != ETIMEDOUT) {
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
270 CHECK_POSIX_DO(ret, ); /* Just to log it */
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
271 }
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
272 break;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
273 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
274
856
c0f92000c42a Avoid using sem_timedwait that is not available on OS X
Sebastien Decugis <sdecugis@freediameter.net>
parents: 740
diff changeset
275 /* Update the current time */
c0f92000c42a Avoid using sem_timedwait that is not available on OS X
Sebastien Decugis <sdecugis@freediameter.net>
parents: 740
diff changeset
276 CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &now), );
c0f92000c42a Avoid using sem_timedwait that is not available on OS X
Sebastien Decugis <sdecugis@freediameter.net>
parents: 740
diff changeset
277
c0f92000c42a Avoid using sem_timedwait that is not available on OS X
Sebastien Decugis <sdecugis@freediameter.net>
parents: 740
diff changeset
278 if (!TS_IS_INFERIOR(&now, &end_time))
c0f92000c42a Avoid using sem_timedwait that is not available on OS X
Sebastien Decugis <sdecugis@freediameter.net>
parents: 740
diff changeset
279 break;
c0f92000c42a Avoid using sem_timedwait that is not available on OS X
Sebastien Decugis <sdecugis@freediameter.net>
parents: 740
diff changeset
280
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
281 /* Create and send a new test message */
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
282 ta_bench_test_message();
856
c0f92000c42a Avoid using sem_timedwait that is not available on OS X
Sebastien Decugis <sdecugis@freediameter.net>
parents: 740
diff changeset
283 } while (1);
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
284
1206
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
285 do {
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
286 CHECK_POSIX_DO( pthread_mutex_lock(&ta_conf->stats_lock), );
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
287 CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &now), ); /* Re-read the time because we might have spent some time wiating for the mutex */
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
288 memcpy(&end, &ta_conf->stats, sizeof(struct ta_stats));
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
289 CHECK_POSIX_DO( pthread_mutex_unlock(&ta_conf->stats_lock), );
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
290
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
291 /* Now, display the statistics */
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
292 LOG_N( "------- app_test Benchmark results, end sending +%ds ---------", nsec);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
293 if (now.tv_nsec >= end_time.tv_nsec) {
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
294 LOG_N( " Executing for: %d.%06ld sec",
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
295 (int)(now.tv_sec + ta_conf->bench_duration - end_time.tv_sec),
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
296 (long)(now.tv_nsec - end_time.tv_nsec) / 1000);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
297 } else {
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
298 LOG_N( " Executing for: %d.%06ld sec",
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
299 (int)(now.tv_sec + ta_conf->bench_duration - 1 - end_time.tv_sec),
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
300 (long)(now.tv_nsec + 1000000000 - end_time.tv_nsec) / 1000);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
301 }
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
302 LOG_N( " %llu messages sent", end.nb_sent - start.nb_sent);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
303 LOG_N( " %llu error(s) received", end.nb_errs - start.nb_errs);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
304 LOG_N( " %llu answer(s) received", end.nb_recv - start.nb_recv);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
305 LOG_N( " Overall:");
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
306 LOG_N( " fastest: %ld.%06ld sec.", end.shortest / 1000000, end.shortest % 1000000);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
307 LOG_N( " slowest: %ld.%06ld sec.", end.longest / 1000000, end.longest % 1000000);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
308 LOG_N( " Average: %ld.%06ld sec.", end.avg / 1000000, end.avg % 1000000);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
309 LOG_N( " Throughput: %llu messages / sec", (end.nb_recv - start.nb_recv) / (( now.tv_sec + ta_conf->bench_duration - end_time.tv_sec ) + ((now.tv_nsec - end_time.tv_nsec) / 1000000000)));
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
310 LOG_N( "-------------------------------------");
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
311
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
312 nsec ++;
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
313 sleep(1);
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
314 } while ( (end.nb_sent - start.nb_sent) > (end.nb_errs - start.nb_errs) + (end.nb_recv - start.nb_recv) );
ef7c5e39badf Show benchmark statistics until all answers are received
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1195
diff changeset
315 LOG_N( "--------------- Test Complete --------------");
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
316
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
317 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
318
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
319
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
320 int ta_bench_init(void)
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
321 {
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
322 CHECK_SYS( my_sem_init( &ta_sem, 0, ta_conf->bench_concur) );
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
323
658
f198d16fa7f4 Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents: 575
diff changeset
324 CHECK_FCT( fd_event_trig_regcb(ta_conf->signal, "test_app.bench", ta_bench_start ) );
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
325
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
326 return 0;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
327 }
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
328
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
329 void ta_bench_fini(void)
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
330 {
658
f198d16fa7f4 Initial commit for 1.1.0:
Sebastien Decugis <sdecugis@nict.go.jp>
parents: 575
diff changeset
331 // CHECK_FCT_DO( fd_sig_unregister(ta_conf->signal), /* continue */ );
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
332
1290
7945c75972b0 Fix test_app for Mac OS X. Need to retest on other systems.
Sebastien Decugis <sdecugis@freediameter.net>
parents: 1206
diff changeset
333 CHECK_SYS_DO( my_sem_destroy(&ta_sem), );
572
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
334
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
335 return;
b1b56d4682d0 Added benchmark mode in test_app
Sebastien Decugis <sdecugis@nict.go.jp>
parents:
diff changeset
336 };
"Welcome to our mercurial repository"