|
|
@@ -1,121 +0,0 @@ |
|
|
|
/* |
|
|
|
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 <assert.h> |
|
|
|
#include <stdio.h> |
|
|
|
|
|
|
|
#include <httperf.h> |
|
|
|
#include <event.h> |
|
|
|
|
|
|
|
#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); |
|
|
|
} |