kris/httperf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Updated confusing and jumbled source formatting to something approximating OpenBSD's Kernel Normal Form

Browse Source 
Used GNU indent with the following options: -nbad -nbap -bbb -nbc -br -brs -c33 -cd33 -cdb -ce -ci4 -cli0 -di16 -fc1 -fca -hnl -i8 -ip4 -l79 -lp -npcs -nprs -psl -saf -sai -saw -sc -nsob -nss -ts8
This commit is contained in:
tedbullock 2007-07-13 04:20:48 +00:00
parent debafb721b
commit 991cc96c68
1 changed files with 164 additions and 172 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

336
httperf/src/timer.c
View File

@ -1,36 +1,34 @@
/* /*
httperf -- a tool for measuring web server performance * httperf -- a tool for measuring web server performance Copyright 2000-2007
Copyright 2000-2007 Hewlett-Packard Company and Contributors listed in * Hewlett-Packard Company and Contributors listed in AUTHORS file. Originally
AUTHORS file. Originally contributed by David Mosberger-Tang * contributed by David Mosberger-Tang
*
This file is part of httperf, a web server performance measurment * This file is part of httperf, a web server performance measurment tool.
tool. *
* This program is free software; you can redistribute it and/or modify it
This program is free software; you can redistribute it and/or * under the terms of the GNU General Public License as published by the Free
modify it under the terms of the GNU General Public License as * Software Foundation; either version 2 of the License, or (at your option)
published by the Free Software Foundation; either version 2 of the * any later version.
License, or (at your option) any later version. *
* In addition, as a special exception, the copyright holders give permission
In addition, as a special exception, the copyright holders give * to link the code of this work with the OpenSSL project's "OpenSSL" library
permission to link the code of this work with the OpenSSL project's * (or with modified versions of it that use the same license as the "OpenSSL"
"OpenSSL" library (or with modified versions of it that use the same * library), and distribute linked combinations including the two. You must
license as the "OpenSSL" library), and distribute linked combinations * obey the GNU General Public License in all respects for all of the code
including the two. You must obey the GNU General Public License in * used other than "OpenSSL". If you modify this file, you may extend this
all respects for all of the code used other than "OpenSSL". If you * exception to your version of the file, but you are not obligated to do so.
modify this file, you may extend this exception to your version of the * If you do not wish to do so, delete this exception statement from your
file, but you are not obligated to do so. If you do not wish to do * version.
so, delete this exception statement from your version. *
* This program is distributed in the hope that it will be useful, but WITHOUT
This program is distributed in the hope that it will be useful, * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
but WITHOUT ANY WARRANTY; without even the implied warranty of * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * more details.
General Public License for more details. *
* You should have received a copy of the GNU General Public License along
You should have received a copy of the GNU General Public License * with this program; if not, write to the Free Software Foundation, Inc., 51
along with this program; if not, write to the Free Software * Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA */
02110-1301, USA
*/
#include <assert.h> #include <assert.h>
#include <errno.h> #include <errno.h>
@ -46,171 +44,165 @@
#define WHEEL_SIZE 4096 #define WHEEL_SIZE 4096
#if 1 #if 1
static Time now; static Time now;
#endif #endif
static Time next_tick; static Time next_tick;
static Timer *timer_free_list = 0; static Timer *timer_free_list = 0;
static Timer *t_curr = 0; static Timer *t_curr = 0;
/* What a wheel is made of, no? */ /*
* What a wheel is made of, no?
*/
static Timer_Queue wheel[WHEEL_SIZE], *curr = 0; static Timer_Queue wheel[WHEEL_SIZE], *curr = 0;
static void static void
done (Timer *t) done(Timer * t)
{ {
t->q.next = timer_free_list; t->q.next = timer_free_list;
t->q.prev = 0; t->q.prev = 0;
timer_free_list = t; timer_free_list = t;
} }
Time Time
timer_now_forced (void) timer_now_forced(void)
{ {
struct timeval tv; struct timeval tv;
gettimeofday (&tv, 0); gettimeofday(&tv, 0);
return tv.tv_sec + tv.tv_usec*1e-6; return tv.tv_sec + tv.tv_usec * 1e-6;
} }
Time Time
timer_now (void) timer_now(void)
{ {
if(param.use_timer_cache) if (param.use_timer_cache)
return now; return now;
else else
return timer_now_forced (); return timer_now_forced();
} }
void void
timer_init (void) timer_init(void)
{ {
now = timer_now_forced (); now = timer_now_forced();
memset (wheel, 0, sizeof (wheel)); memset(wheel, 0, sizeof(wheel));
next_tick = timer_now () + TIMER_INTERVAL; next_tick = timer_now() + TIMER_INTERVAL;
curr = wheel;
}
void
timer_tick (void)
{
Timer *t, *t_next;
assert (!t_curr);
now = timer_now_forced ();
while (timer_now () >= next_tick)
{
for (t = curr->next; t && t->delta == 0; t = t_next)
{
t_curr = t;
(*t->func) (t, t->arg);
t_next = t->q.next;
done (t);
}
t_curr = 0;
curr->next = t;
if (t)
{
t->q.prev = (Timer *) curr;
--t->delta;
}
next_tick += TIMER_INTERVAL;
if (++curr >= wheel + WHEEL_SIZE)
curr = wheel; curr = wheel;
}
}
Timer*
timer_schedule (Timer_Callback timeout, Any_Type arg, Time delay)
{
Timer_Queue *spoke;
Timer *t, *p;
u_long ticks;
u_long delta;
Time behind;
if (timer_free_list)
{
t = timer_free_list;
timer_free_list = t->q.next;
}
else
{
t = malloc (sizeof (*t));
if (!t)
{
fprintf (stderr, "%s.timer_schedule: %s\n",
prog_name, strerror (errno));
return 0;
}
}
memset (t, 0, sizeof (*t));
t->func = timeout;
t->arg = arg;
behind = (timer_now () - next_tick);
if (behind > 0.0)
delay += behind;
if (delay < 0.0)
ticks = 1;
else
{
ticks = (delay + TIMER_INTERVAL / 2.0) * (1.0 / TIMER_INTERVAL);
if (!ticks)
ticks = 1; /* minimum delay is a tick */
}
spoke = curr + (ticks % WHEEL_SIZE);
if (spoke >= wheel + WHEEL_SIZE)
spoke -= WHEEL_SIZE;
delta = ticks / WHEEL_SIZE;
p = (Timer *) spoke;
while (p->q.next && delta > p->q.next->delta)
{
delta -= p->q.next->delta;
p = p->q.next;
}
t->q.next = p->q.next;
t->q.prev = p;
p->q.next = t;
t->delta = delta;
if (t->q.next)
{
t->q.next->q.prev = t;
t->q.next->delta -= delta;
}
if (DBG > 2)
fprintf (stderr, "timer_schedule: t=%p, delay=%gs, arg=%lx\n",
t, delay, arg.l);
return t;
} }
void void
timer_cancel (Timer *t) timer_tick(void)
{ {
if (DBG > 2) Timer *t, *t_next;
fprintf (stderr, "timer_cancel: t=%p\n", t);
assert (t->q.prev); assert(!t_curr);
/* A module MUST NOT call timer_cancel() for a timer that is now = timer_now_forced();
currently being processed (whose timeout has expired). */
if (t_curr == t)
{
fprintf (stderr, "timer_cancel() called on currently active timer!\n");
return;
}
if (t->q.next) while (timer_now() >= next_tick) {
{ for (t = curr->next; t && t->delta == 0; t = t_next) {
t->q.next->delta += t->delta; t_curr = t;
t->q.next->q.prev = t->q.prev; (*t->func) (t, t->arg);
} t_next = t->q.next;
t->q.prev->q.next = t->q.next; done(t);
done (t); }
t_curr = 0;
curr->next = t;
if (t) {
t->q.prev = (Timer *) curr;
--t->delta;
}
next_tick += TIMER_INTERVAL;
if (++curr >= wheel + WHEEL_SIZE)
curr = wheel;
}
}
Timer *
timer_schedule(Timer_Callback timeout, Any_Type arg, Time delay)
{
Timer_Queue *spoke;
Timer *t, *p;
u_long ticks;
u_long delta;
Time behind;
if (timer_free_list) {
t = timer_free_list;
timer_free_list = t->q.next;
} else {
t = malloc(sizeof(*t));
if (!t) {
fprintf(stderr, "%s.timer_schedule: %s\n",
prog_name, strerror(errno));
return 0;
}
}
memset(t, 0, sizeof(*t));
t->func = timeout;
t->arg = arg;
behind = (timer_now() - next_tick);
if (behind > 0.0)
delay += behind;
if (delay < 0.0)
ticks = 1;
else {
ticks =
(delay + TIMER_INTERVAL / 2.0) * (1.0 / TIMER_INTERVAL);
if (!ticks)
ticks = 1; /* minimum delay is a tick */
}
spoke = curr + (ticks % WHEEL_SIZE);
if (spoke >= wheel + WHEEL_SIZE)
spoke -= WHEEL_SIZE;
delta = ticks / WHEEL_SIZE;
p = (Timer *) spoke;
while (p->q.next && delta > p->q.next->delta) {
delta -= p->q.next->delta;
p = p->q.next;
}
t->q.next = p->q.next;
t->q.prev = p;
p->q.next = t;
t->delta = delta;
if (t->q.next) {
t->q.next->q.prev = t;
t->q.next->delta -= delta;
}
if (DBG > 2)
fprintf(stderr, "timer_schedule: t=%p, delay=%gs, arg=%lx\n",
t, delay, arg.l);
return t;
}
void
timer_cancel(Timer * t)
{
if (DBG > 2)
fprintf(stderr, "timer_cancel: t=%p\n", t);
assert(t->q.prev);
/*
* A module MUST NOT call timer_cancel() for a timer that is currently
* being processed (whose timeout has expired).
*/
if (t_curr == t) {
fprintf(stderr,
"timer_cancel() called on currently active timer!\n");
return;
}
if (t->q.next) {
t->q.next->delta += t->delta;
t->q.next->q.prev = t->q.prev;
}
t->q.prev->q.next = t->q.next;
done(t);
} }