sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-03-09 08:58:35 +03:00
Code

r15729: Second part of Aleksey Fedoseev <fedoseev@ru.ibm.com> patch.

Browse Source 
Jeremy.
(This used to be commit 5137006233a0c2de94ce3da7340ff0032ef7426d)
This commit is contained in:
Jeremy Allison 2006-05-20 02:09:35 +00:00 committed by Gerald (Jerry) Carter
parent 4aead7efa3
commit 799f8c75b9
1 changed files with 54 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
source3/torture/msgtest.c
View File

@ -25,6 +25,24 @@
static int pong_count; static int pong_count;
/* samba4 timeval functions */
double timeval_elapsed2(const struct timeval *tv1, const struct timeval *tv2)
{
return (tv2->tv_sec - tv1->tv_sec) +
(tv2->tv_usec - tv1->tv_usec)*1.0e-6;
}
/**
return the number of seconds elapsed since a given time
*/
double timeval_elapsed(const struct timeval *tv)
{
struct timeval tv2 = timeval_current();
return timeval_elapsed2(tv, &tv2);
}
/**************************************************************************** /****************************************************************************
a useful function for testing the message system a useful function for testing the message system
****************************************************************************/ ****************************************************************************/
@ -85,7 +103,42 @@ void pong_message(int msg_type, struct process_id src, void *buf, size_t len)
if (pong_count != 2) { if (pong_count != 2) {
fprintf(stderr, "Duplicate filter failed (%d).\n", pong_count); fprintf(stderr, "Duplicate filter failed (%d).\n", pong_count);
exit(1); }
/* Speed testing */
pong_count = 0;
{
struct timeval tv = timeval_current();
size_t timelimit = n;
size_t ping_count = 0;
printf("Sending pings for %d seconds\n", timelimit);
while (timeval_elapsed(&tv) < timelimit) {
if(message_send_pid(pid_to_procid(pid), MSG_PING,
buf, 11, False)) ping_count++;
if(message_send_pid(pid_to_procid(pid), MSG_PING,
NULL, 0, False)) ping_count++;
while (ping_count > pong_count + 20) {
message_dispatch();
}
}
printf("waiting for %d remaining replies (done %d)\n",
ping_count - pong_count, pong_count);
while (timeval_elapsed(&tv) < 30 && pong_count < ping_count) {
message_dispatch();
}
if (ping_count != pong_count) {
fprintf(stderr, "ping test failed! received %d, sent %d\n",
pong_count, ping_count);
}
printf("ping rate of %.0f messages/sec\n",
(ping_count+pong_count)/timeval_elapsed(&tv));
} }
return (0); return (0);