2 Unix SMB/CIFS implementation.
3 Copyright (C) Andrew Tridgell 2000
5 This program is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation; either version 2 of the License, or
8 (at your option) any later version.
10 This program is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 GNU General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with this program; if not, write to the Free Software
17 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
21 test code for internal messaging
26 static int pong_count
;
29 /* samba4 timeval functions */
31 double timeval_elapsed2(const struct timeval
*tv1
, const struct timeval
*tv2
)
33 return (tv2
->tv_sec
- tv1
->tv_sec
) +
34 (tv2
->tv_usec
- tv1
->tv_usec
)*1.0e-6;
38 return the number of seconds elapsed since a given time
40 double timeval_elapsed(const struct timeval
*tv
)
42 struct timeval tv2
= timeval_current();
43 return timeval_elapsed2(tv
, &tv2
);
46 /****************************************************************************
47 a useful function for testing the message system
48 ****************************************************************************/
49 void pong_message(int msg_type
, struct process_id src
, void *buf
, size_t len
)
54 int main(int argc
, char *argv
[])
62 setup_logging(argv
[0],True
);
64 lp_load(dyn_CONFIGFILE
,False
,False
,False
,True
);
69 fprintf(stderr
, "%s: Usage - %s pid count\n", argv
[0], argv
[0]);
76 message_register(MSG_PONG
, pong_message
);
79 message_send_pid(pid_to_procid(pid
), MSG_PING
, NULL
, 0, True
);
82 while (pong_count
< i
) {
87 /* Now test that the duplicate filtering code works. */
90 safe_strcpy(buf
, "1234567890", sizeof(buf
)-1);
93 message_send_pid(pid_to_procid(getpid()), MSG_PING
,
95 message_send_pid(pid_to_procid(getpid()), MSG_PING
,
104 if (pong_count
!= 2) {
105 fprintf(stderr
, "Duplicate filter failed (%d).\n", pong_count
);
113 struct timeval tv
= timeval_current();
114 size_t timelimit
= n
;
115 size_t ping_count
= 0;
117 printf("Sending pings for %d seconds\n", timelimit
);
118 while (timeval_elapsed(&tv
) < timelimit
) {
119 if(message_send_pid(pid_to_procid(pid
), MSG_PING
,
120 buf
, 11, False
)) ping_count
++;
121 if(message_send_pid(pid_to_procid(pid
), MSG_PING
,
122 NULL
, 0, False
)) ping_count
++;
124 while (ping_count
> pong_count
+ 20) {
129 printf("waiting for %d remaining replies (done %d)\n",
130 ping_count
- pong_count
, pong_count
);
131 while (timeval_elapsed(&tv
) < 30 && pong_count
< ping_count
) {
135 if (ping_count
!= pong_count
) {
136 fprintf(stderr
, "ping test failed! received %d, sent %d\n",
137 pong_count
, ping_count
);
140 printf("ping rate of %.0f messages/sec\n",
141 (ping_count
+pong_count
)/timeval_elapsed(&tv
));