From 5bbd09889bd606c589c91b8f456c542a09f41224 Mon Sep 17 00:00:00 2001 From: tbbulloc Date: Mon, 4 Jun 2007 00:41:22 +0000 Subject: [PATCH] *** empty log message *** --- httperf/src/localevent.c | 121 +++++++++++++++++++++++++++++++++++++++ httperf/src/localevent.h | 93 ++++++++++++++++++++++++++++++ 2 files changed, 214 insertions(+) create mode 100755 httperf/src/localevent.c create mode 100755 httperf/src/localevent.h diff --git a/httperf/src/localevent.c b/httperf/src/localevent.c new file mode 100755 index 0000000..54f292e --- /dev/null +++ b/httperf/src/localevent.c @@ -0,0 +1,121 @@ +/* + httperf -- a tool for measuring web server performance + Copyright 2000-2007 Hewlett-Packard Company and Contributors listed in + AUTHORS file. Originally contributed by David Mosberger-Tang + + This file is part of httperf, a web server performance measurment + tool. + + This program is free software; you can redistribute it and/or + modify it under the terms of the GNU General Public License as + published by the Free Software Foundation; either version 2 of the + License, or (at your option) any later version. + + In addition, as a special exception, the copyright holders give + permission to link the code of this work with the OpenSSL project's + "OpenSSL" library (or with modified versions of it that use the same + license as the "OpenSSL" library), and distribute linked combinations + including the two. You must obey the GNU General Public License in + all respects for all of the code used other than "OpenSSL". If you + modify this file, you may extend this exception to your version of the + file, but you are not obligated to do so. If you do not wish to do + so, delete this exception statement from your version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + 02110-1301, USA +*/ + +#include +#include + +#include +#include + +#define MAX_NUM_OPS 4 + +static const char * const event_name[EV_NUM_EVENT_TYPES] = + { + "EV_PERF_SAMPLE", + "EV_HOSTNAME_LOOKUP_START", + "EV_HOSTNAME_LOOKUP_STOP", + "EV_SESS_NEW", + "EV_SESS_FAILED", + "EV_SESS_DESTROYED", + "EV_CONN_NEW", + "EV_CONN_CONNECTING", + "EV_CONN_CONNECTED", + "EV_CONN_CLOSE", + "EV_CONN_DESTROYED", + "EV_CONN_FAILED", + "EV_CONN_TIMEOUT", + "EV_CALL_NEW", + "EV_CALL_ISSUE", + "EV_CALL_SEND_START", + "EV_CALL_SEND_RAW_DATA", + "EV_CALL_SEND_STOP", + "EV_CALL_RECV_START", + "EV_CALL_RECV_HDR", + "EV_CALL_RECV_RAW_DATA", + "EV_CALL_RECV_DATA", + "EV_CALL_RECV_FOOTER", + "EV_CALL_RECV_STOP", + "EV_CALL_DESTROYED" + }; + +typedef struct Event_Action + { + int num_ops; + struct closure + { + Event_Handler op; + Any_Type arg; + } + closure[MAX_NUM_OPS]; + } +Event_Action; + +static Event_Action action[EV_NUM_EVENT_TYPES] = {{0, }}; + +void +event_register_handler (Event_Type et, Event_Handler handler, Any_Type arg) +{ + struct closure *c; + int n; + + n = action[et].num_ops; + if (n >= MAX_NUM_OPS) + { + fprintf (stderr, "event_register_handler: sorry, attempted to register " + "more than %d handlers\n", MAX_NUM_OPS); + exit (1); + } + c = action[et].closure + n; + c->op = handler; + c->arg = arg; + action[et].num_ops = n + 1; +} + +void +event_signal (Event_Type type, Object *obj, Any_Type arg) +{ + Event_Action *act = action + type; + struct closure *c, *end; + + if (DBG > 1) + { + assert (NELEMS (event_name) == EV_NUM_EVENT_TYPES); + fprintf (stderr, "event_signal: %s (obj=%p,arg=%lx)\n", + event_name[type], obj, arg.l); + } + + end = &act->closure[act->num_ops]; + for (c = &act->closure[0]; c < end; ++c) + (*c->op) (type, obj, c->arg, arg); +} diff --git a/httperf/src/localevent.h b/httperf/src/localevent.h new file mode 100755 index 0000000..73a6537 --- /dev/null +++ b/httperf/src/localevent.h @@ -0,0 +1,93 @@ +/* + httperf -- a tool for measuring web server performance + Copyright 2000-2007 Hewlett-Packard Company and Contributors listed in + AUTHORS file. Originally contributed by David Mosberger-Tang + + This file is part of httperf, a web server performance measurment + tool. + + This program is free software; you can redistribute it and/or + modify it under the terms of the GNU General Public License as + published by the Free Software Foundation; either version 2 of the + License, or (at your option) any later version. + + In addition, as a special exception, the copyright holders give + permission to link the code of this work with the OpenSSL project's + "OpenSSL" library (or with modified versions of it that use the same + license as the "OpenSSL" library), and distribute linked combinations + including the two. You must obey the GNU General Public License in + all respects for all of the code used other than "OpenSSL". If you + modify this file, you may extend this exception to your version of the + file, but you are not obligated to do so. If you do not wish to do + so, delete this exception statement from your version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA + 02110-1301, USA +*/ + +#ifndef localevent_h +#define localevent_h + +#include +#include + +typedef enum Event_Type + { + EV_PERF_SAMPLE, + + EV_HOSTNAME_LOOKUP_START, + EV_HOSTNAME_LOOKUP_STOP, + + EV_SESS_NEW, + EV_SESS_FAILED, + EV_SESS_DESTROYED, + + EV_CONN_NEW, + EV_CONN_CONNECTING, + EV_CONN_CONNECTED, + EV_CONN_CLOSE, /* connection closed */ + EV_CONN_DESTROYED, + EV_CONN_FAILED, /* failed for reasons other than timeout */ + EV_CONN_TIMEOUT, + + EV_CALL_NEW, + EV_CALL_ISSUE, + EV_CALL_SEND_START, + EV_CALL_SEND_RAW_DATA, + EV_CALL_SEND_STOP, + EV_CALL_RECV_START, + EV_CALL_RECV_HDR, + EV_CALL_RECV_RAW_DATA, + EV_CALL_RECV_DATA, + EV_CALL_RECV_FOOTER, + EV_CALL_RECV_STOP, + EV_CALL_DESTROYED, + + EV_NUM_EVENT_TYPES + } +Event_Type; + +typedef struct Event + { + Event_Type type; + Object *obj; + Any_Type arg; + } +Event; + +typedef void (*Event_Handler) (Event_Type type, Object *obj, + Any_Type registration_time_arg, + Any_Type signal_time_arg); + +extern void event_register_handler (Event_Type et, Event_Handler handler, + Any_Type arg); +extern void event_signal (Event_Type type, Object *obj, Any_Type arg); + +#endif /* localevent_h */