*** empty log message ***

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 <assert.h>
+#include <stdio.h>
+
+#include <httperf.h>
+#include <localevent.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);
+}

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 <httperf.h>
+#include <object.h>
+
+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 */