summaryrefslogtreecommitdiff
path: root/source3
diff options
context:
space:
mode:
authorJeremy Allison <jra@samba.org>2006-05-20 02:09:35 +0000
committerGerald (Jerry) Carter <jerry@samba.org>2007-10-10 11:17:09 -0500
commit799f8c75b9af9f7b295637eee40ad66872c3211a (patch)
tree9b07a10425bec645fea9c4a9432b8926c0f3a59a /source3
parent4aead7efa30aed5b41bdf0156ee5be17a16700de (diff)
downloadsamba-799f8c75b9af9f7b295637eee40ad66872c3211a.tar.gz
samba-799f8c75b9af9f7b295637eee40ad66872c3211a.tar.bz2
samba-799f8c75b9af9f7b295637eee40ad66872c3211a.zip
r15729: Second part of Aleksey Fedoseev <fedoseev@ru.ibm.com> patch.
Jeremy. (This used to be commit 5137006233a0c2de94ce3da7340ff0032ef7426d)
Diffstat (limited to 'source3')
-rw-r--r--source3/torture/msgtest.c55
1 files changed, 54 insertions, 1 deletions
diff --git a/source3/torture/msgtest.c b/source3/torture/msgtest.c
index ede629be6b..035214b3a9 100644
--- a/source3/torture/msgtest.c
+++ b/source3/torture/msgtest.c
@@ -25,6 +25,24 @@
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
****************************************************************************/
@@ -85,7 +103,42 @@ void pong_message(int msg_type, struct process_id src, void *buf, size_t len)
if (pong_count != 2) {
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);