cuberite/libevent
1
0
Fork 0
mirror of https://github.com/cuberite/libevent.git synced 2025-09-18 08:49:57 -04:00
Code Issues Packages Projects Releases Wiki Activity

http-connect: make it win32 compilable

Browse Source 
Fixes: commit 1d34498ea31134bd7a8fcadcb95910b30a479e19 ("sample: add HTTP
CONNECT tunnelling example using libevent http layer")
This commit is contained in:
Azat Khuzhin 2016-01-12 02:03:12 +03:00
parent a1609a87d7
commit 1bf7595644
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
sample/http-connect.c
View File

@ -1,10 +1,11 @@
#include "event2/event-config.h"
#include <event2/event.h> #include <event2/event.h>
#include <event2/http.h> #include <event2/http.h>
#include <event2/http_struct.h> #include <event2/http_struct.h>
#include <event2/buffer.h> #include <event2/buffer.h>
#include <stdlib.h> #include <stdlib.h>
#include <stdio.h> #include <stdio.h>
#include <unistd.h>
#include <limits.h> #include <limits.h>
#define VERIFY(cond) do { \ #define VERIFY(cond) do { \
@ -13,6 +14,8 @@
} \ } \
} while (0); \ } while (0); \
#define URL_MAX 4096
struct connect_base struct connect_base
{ {
struct evhttp_connection *evcon; struct evhttp_connection *evcon;
@ -21,13 +24,20 @@ struct connect_base
static void get_cb(struct evhttp_request *req, void *arg) static void get_cb(struct evhttp_request *req, void *arg)
{ {
ev_ssize_t len;
struct evbuffer *evbuf;
VERIFY(req); VERIFY(req);
evbuffer_write(req->input_buffer, STDOUT_FILENO);
evbuf = evhttp_request_get_input_buffer(req);
len = evbuffer_get_length(evbuf);
fwrite(evbuffer_pullup(evbuf, len), len, 1, stdout);
evbuffer_drain(evbuf, len);
} }
static void connect_cb(struct evhttp_request *proxy_req, void *arg) static void connect_cb(struct evhttp_request *proxy_req, void *arg)
{ {
char buffer[PATH_MAX]; char buffer[URL_MAX];
struct connect_base *base = arg; struct connect_base *base = arg;
struct evhttp_connection *evcon = base->evcon; struct evhttp_connection *evcon = base->evcon;
@ -38,13 +48,13 @@ static void connect_cb(struct evhttp_request *proxy_req, void *arg)
struct evhttp_request *req = evhttp_request_new(get_cb, NULL); struct evhttp_request *req = evhttp_request_new(get_cb, NULL);
evhttp_add_header(req->output_headers, "Connection", "close"); evhttp_add_header(req->output_headers, "Connection", "close");
VERIFY(!evhttp_make_request(evcon, req, EVHTTP_REQ_GET, VERIFY(!evhttp_make_request(evcon, req, EVHTTP_REQ_GET,
evhttp_uri_join(location, buffer, PATH_MAX))); evhttp_uri_join(location, buffer, URL_MAX)));
} }
} }
int main(int argc, const char **argv) int main(int argc, const char **argv)
{ {
char buffer[PATH_MAX]; char buffer[URL_MAX];
struct evhttp_uri *host_port; struct evhttp_uri *host_port;
struct evhttp_uri *location; struct evhttp_uri *location;
@ -95,7 +105,7 @@ int main(int argc, const char **argv)
evhttp_add_header(req->output_headers, "Connection", "keep-alive"); evhttp_add_header(req->output_headers, "Connection", "keep-alive");
evhttp_add_header(req->output_headers, "Proxy-Connection", "keep-alive"); evhttp_add_header(req->output_headers, "Proxy-Connection", "keep-alive");
evutil_snprintf(buffer, PATH_MAX, "%s:%d", evutil_snprintf(buffer, URL_MAX, "%s:%d",
evhttp_uri_get_host(host_port), evhttp_uri_get_port(host_port)); evhttp_uri_get_host(host_port), evhttp_uri_get_port(host_port));
evhttp_make_request(evcon, req, EVHTTP_REQ_CONNECT, buffer); evhttp_make_request(evcon, req, EVHTTP_REQ_CONNECT, buffer);