ipc/chromium/src/third_party/libevent/test/bench_http.c

Wed, 31 Dec 2014 06:09:35 +0100

author
Michael Schloh von Bennewitz <michael@schloh.com>
date
Wed, 31 Dec 2014 06:09:35 +0100
changeset 0
6474c204b198
permissions
-rw-r--r--

Cloned upstream origin tor-browser at tor-browser-31.3.0esr-4.5-1-build1
revision ID fc1c9ff7c1b2defdbc039f12214767608f46423f for hacking purpose.

     1 /*
     2  * Copyright 2008-2012 Niels Provos and Nick Mathewson
     3  *
     4  * Redistribution and use in source and binary forms, with or without
     5  * modification, are permitted provided that the following conditions
     6  * are met:
     7  * 1. Redistributions of source code must retain the above copyright
     8  *    notice, this list of conditions and the following disclaimer.
     9  * 2. Redistributions in binary form must reproduce the above copyright
    10  *    notice, this list of conditions and the following disclaimer in the
    11  *    documentation and/or other materials provided with the distribution.
    12  * 4. The name of the author may not be used to endorse or promote products
    13  *    derived from this software without specific prior written permission.
    14  *
    15  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
    16  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
    17  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
    18  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
    19  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
    20  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
    21  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
    22  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
    23  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
    24  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
    25  *
    26  */
    28 #include <sys/types.h>
    29 #include <sys/stat.h>
    30 #ifdef WIN32
    31 #include <winsock2.h>
    32 #else
    33 #include <sys/socket.h>
    34 #include <sys/resource.h>
    35 #include <sys/time.h>
    36 #include <unistd.h>
    37 #endif
    38 #include <fcntl.h>
    39 #include <signal.h>
    40 #include <stdlib.h>
    41 #include <stdio.h>
    42 #include <string.h>
    43 #include <errno.h>
    45 #include "event2/event.h"
    46 #include "event2/buffer.h"
    47 #include "event2/util.h"
    48 #include "event2/http.h"
    49 #include "event2/thread.h"
    51 static void http_basic_cb(struct evhttp_request *req, void *arg);
    53 static char *content;
    54 static size_t content_len = 0;
    56 static void
    57 http_basic_cb(struct evhttp_request *req, void *arg)
    58 {
    59 	struct evbuffer *evb = evbuffer_new();
    61 	evbuffer_add(evb, content, content_len);
    63 	/* allow sending of an empty reply */
    64 	evhttp_send_reply(req, HTTP_OK, "Everything is fine", evb);
    66 	evbuffer_free(evb);
    67 }
    69 #if LIBEVENT_VERSION_NUMBER >= 0x02000200
    70 static void
    71 http_ref_cb(struct evhttp_request *req, void *arg)
    72 {
    73 	struct evbuffer *evb = evbuffer_new();
    75 	evbuffer_add_reference(evb, content, content_len, NULL, NULL);
    77 	/* allow sending of an empty reply */
    78 	evhttp_send_reply(req, HTTP_OK, "Everything is fine", evb);
    80 	evbuffer_free(evb);
    81 }
    82 #endif
    84 int
    85 main(int argc, char **argv)
    86 {
    87 	struct event_config *cfg = event_config_new();
    88 	struct event_base *base;
    89 	struct evhttp *http;
    90 	int i;
    91 	int c;
    92 	int use_iocp = 0;
    93 	unsigned short port = 8080;
    94 	char *endptr = NULL;
    96 #ifdef WIN32
    97 	WSADATA WSAData;
    98 	WSAStartup(0x101, &WSAData);
    99 #else
   100 	if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)
   101 		return (1);
   102 #endif
   104 	for (i = 1; i < argc; ++i) {
   105 		if (*argv[i] != '-')
   106 			continue;
   108 		c = argv[i][1];
   110 		if ((c == 'p' || c == 'l') && i + 1 >= argc) {
   111 			fprintf(stderr, "-%c requires argument.\n", c);
   112 			exit(1);
   113 		}
   115 		switch (c) {
   116 		case 'p':
   117 			if (i+1 >= argc || !argv[i+1]) {
   118 				fprintf(stderr, "Missing port\n");
   119 				exit(1);
   120 			}
   121 			port = (int)strtol(argv[i+1], &endptr, 10);
   122 			if (*endptr != '\0') {
   123 				fprintf(stderr, "Bad port\n");
   124 				exit(1);
   125 			}
   126 			break;
   127 		case 'l':
   128 			if (i+1 >= argc || !argv[i+1]) {
   129 				fprintf(stderr, "Missing content length\n");
   130 				exit(1);
   131 			}
   132 			content_len = (size_t)strtol(argv[i+1], &endptr, 10);
   133 			if (*endptr != '\0' || content_len == 0) {
   134 				fprintf(stderr, "Bad content length\n");
   135 				exit(1);
   136 			}
   137 			break;
   138 #ifdef WIN32
   139 		case 'i':
   140 			use_iocp = 1;
   141 			evthread_use_windows_threads();
   142 			event_config_set_flag(cfg,EVENT_BASE_FLAG_STARTUP_IOCP);
   143 			break;
   144 #endif
   145 		default:
   146 			fprintf(stderr, "Illegal argument \"%c\"\n", c);
   147 			exit(1);
   148 		}
   149 	}
   151 	base = event_base_new_with_config(cfg);
   152 	if (!base) {
   153 		fprintf(stderr, "creating event_base failed. Exiting.\n");
   154 		return 1;
   155 	}
   157 	http = evhttp_new(base);
   159 	content = malloc(content_len);
   160 	if (content == NULL) {
   161 		fprintf(stderr, "Cannot allocate content\n");
   162 		exit(1);
   163 	} else {
   164 		int i = 0;
   165 		for (i = 0; i < (int)content_len; ++i)
   166 			content[i] = (i & 255);
   167 	}
   169 	evhttp_set_cb(http, "/ind", http_basic_cb, NULL);
   170 	fprintf(stderr, "/ind - basic content (memory copy)\n");
   172 #ifdef _EVENT2_EVENT_H_
   173 	evhttp_set_cb(http, "/ref", http_ref_cb, NULL);
   174 	fprintf(stderr, "/ref - basic content (reference)\n");
   175 #endif
   177 	fprintf(stderr, "Serving %d bytes on port %d using %s\n",
   178 	    (int)content_len, port,
   179 	    use_iocp? "IOCP" : event_base_get_method(base));
   181 	evhttp_bind_socket(http, "0.0.0.0", port);
   183 	if (use_iocp) {
   184 		struct timeval tv={99999999,0};
   185 		event_base_loopexit(base, &tv);
   186 	}
   187 	event_base_dispatch(base);
   189 	/* NOTREACHED */
   190 	return (0);
   191 }

mercurial