Lines Matching defs:bev
163 http_readcb(struct bufferevent *bev, void *arg)
167 event_debug(("%s: %s\n", __func__, EVBUFFER_DATA(bev->input)));
169 if (evbuffer_find(bev->input,
175 done = evhttp_parse_firstline(req, bev->input);
179 done = evhttp_parse_headers(req, bev->input);
190 bufferevent_disable(bev, EV_READ);
199 http_writecb(struct bufferevent *bev, void *arg)
201 if (EVBUFFER_LENGTH(bev->output) == 0) {
203 bufferevent_enable(bev, EV_READ);
209 http_errorcb(struct bufferevent *bev, short what, void *arg)
299 struct bufferevent *bev = arg;
303 bufferevent_write(bev, http_request, strlen(http_request));
310 struct bufferevent *bev;
329 bev = bufferevent_new(fd, http_readcb, http_writecb,
337 bufferevent_write(bev, http_request, strlen(http_request));
340 event_once(-1, EV_TIMEOUT, http_complete_write, bev, &tv);
350 bufferevent_free(bev);
356 bev = bufferevent_new(fd, http_readcb, http_writecb,
365 bufferevent_write(bev, http_request, strlen(http_request));
369 bufferevent_free(bev);
395 http_badreq_errorcb(struct bufferevent *bev, short what, void *arg)
402 http_badreq_readcb(struct bufferevent *bev, void *arg)
407 event_debug(("%s: %s\n", __func__, EVBUFFER_DATA(bev->input)));
409 if (evbuffer_find(bev->input,
413 bufferevent_disable(bev, EV_READ);
418 if (evbuffer_find(bev->input,
424 done = evhttp_parse_firstline(req, bev->input);
428 done = evhttp_parse_headers(req, bev->input);
439 evbuffer_drain(bev->input, EVBUFFER_LENGTH(bev->input));
442 shutdown(bev->ev_read.ev_fd, SHUT_WR);
456 struct bufferevent *bev;
476 bev = bufferevent_new(fd, http_badreq_readcb, http_writecb,
478 bufferevent_enable(bev, EV_READ);
486 event_once(-1, EV_TIMEOUT, http_badreq_successcb, bev, &tv);
490 bufferevent_free(bev);
504 bev = bufferevent_new(fd, http_badreq_readcb, http_writecb,
506 bufferevent_enable(bev, EV_READ);
514 bufferevent_write(bev, http_request, strlen(http_request));
518 event_once(-1, EV_TIMEOUT, http_badreq_successcb, bev, &tv);
946 http_failure_readcb(struct bufferevent *bev, void *arg)
949 if (evbuffer_find(bev->input, (const unsigned char*) what, strlen(what)) != NULL) {
951 bufferevent_disable(bev, EV_READ);
962 struct bufferevent *bev;
975 bev = bufferevent_new(fd, http_failure_readcb, http_writecb,
980 bufferevent_write(bev, http_request, strlen(http_request));
984 bufferevent_free(bev);
1229 struct bufferevent *bev;
1250 bev = bufferevent_new(fd, http_readcb, http_writecb,
1252 bufferevent_base_set(base, bev);
1260 bufferevent_write(bev, http_request, strlen(http_request));
1264 bufferevent_free(bev);
1285 http_chunked_readcb(struct bufferevent *bev, void *arg)
1291 http_chunked_errorcb(struct bufferevent *bev, short what, void *arg)
1304 done = evhttp_parse_firstline(req, EVBUFFER_INPUT(bev));
1308 done = evhttp_parse_headers(req, EVBUFFER_INPUT(bev));
1320 header = evbuffer_readline(EVBUFFER_INPUT(bev));
1328 if (strncmp((char *)EVBUFFER_DATA(EVBUFFER_INPUT(bev)),
1332 evbuffer_drain(EVBUFFER_INPUT(bev), 13 + 2);
1334 header = evbuffer_readline(EVBUFFER_INPUT(bev));
1342 if (strncmp((char *)EVBUFFER_DATA(EVBUFFER_INPUT(bev)),
1346 evbuffer_drain(EVBUFFER_INPUT(bev), 18 + 2);
1348 header = evbuffer_readline(EVBUFFER_INPUT(bev));
1356 if (strncmp((char *)EVBUFFER_DATA(EVBUFFER_INPUT(bev)),
1360 evbuffer_drain(EVBUFFER_INPUT(bev), 8 + 2);
1362 header = evbuffer_readline(EVBUFFER_INPUT(bev));
1378 http_chunked_writecb(struct bufferevent *bev, void *arg)
1380 if (EVBUFFER_LENGTH(EVBUFFER_OUTPUT(bev)) == 0) {
1382 bufferevent_enable(bev, EV_READ);
1420 struct bufferevent *bev;
1437 bev = bufferevent_new(fd,
1447 bufferevent_write(bev, http_request, strlen(http_request));
1506 struct bufferevent *bev;
1519 bev = bufferevent_new(fd, http_readcb, http_writecb,
1532 bufferevent_write(bev, http_start_request, strlen(http_start_request));
1536 bufferevent_free(bev);
1613 struct bufferevent *bev;
1659 bufferevent_free(state->bev);
1664 terminate_readcb(struct bufferevent *bev, void *arg)
1667 evbuffer_drain(bev->output, -1);
1674 struct bufferevent *bev = NULL;
1690 bev = bufferevent_new(fd, terminate_readcb, http_writecb,
1694 terminate_state.bev = bev;
1701 bufferevent_write(bev, http_request, strlen(http_request));