cuberite/libevent
1
0
Fork 0
mirror of https://github.com/cuberite/libevent.git synced 2025-09-16 15:56:15 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add evhttp_connection_get_base() to get the event_base from an http connection

Browse Source 
Based on a patch by Mark Ellzey from 27 July 2010.

Closes ticket 3052406
This commit is contained in:
Nick Mathewson 2010-10-21 12:19:28 -04:00
parent 1213d3dd8b
commit cd00079b22
3 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
http.c
View File

@ -3045,6 +3045,11 @@ evhttp_request_get_connection(struct evhttp_request *req)
return req->evcon; return req->evcon;
} }
struct event_base *
evhttp_connection_get_base(struct evhttp_connection *conn)
{
return conn->base;
}
void void
evhttp_request_set_chunked_cb(struct evhttp_request *req, evhttp_request_set_chunked_cb(struct evhttp_request *req,

5
include/event2/http.h
View File

@ -383,6 +383,11 @@ int evhttp_request_is_owned(struct evhttp_request *req);
*/ */
struct evhttp_connection *evhttp_request_get_connection(struct evhttp_request *req); struct evhttp_connection *evhttp_request_get_connection(struct evhttp_request *req);
/**
* Returns the underlying event_base for this connection
*/
struct event_base *evhttp_connection_get_base(struct evhttp_connection *req);
void evhttp_connection_set_max_headers_size(struct evhttp_connection *evcon, void evhttp_connection_set_max_headers_size(struct evhttp_connection *evcon,
ev_ssize_t new_max_headers_size); ev_ssize_t new_max_headers_size);

2
test/regress_http.c
View File

@ -670,6 +670,8 @@ _http_connection_test(int persistent)
evcon = evhttp_connection_new("127.0.0.1", port); evcon = evhttp_connection_new("127.0.0.1", port);
tt_assert(evcon); tt_assert(evcon);
tt_assert(evhttp_connection_get_base(evcon) == NULL);
/* /*
* At this point, we want to schedule a request to the HTTP * At this point, we want to schedule a request to the HTTP
* server using our make request method. * server using our make request method.