libevent/dist/bufferevent_sock.c

136 	struct bufferevent *bufev = arg;
137 	struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
140 	    (bufev->enabled & EV_WRITE) &&
141 	    !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
145 		if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) {
154 	struct bufferevent *bufev = arg;
155 	struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
161 	bufferevent_incref_and_lock_(bufev);
171 	input = bufev->input;
177 	if (bufev->wm_read.high != 0) {
178 		howmuch = bufev->wm_read.high - evbuffer_get_length(input);
181 			bufferevent_wm_suspend_read(bufev);
217 	bufferevent_trigger_nolock_(bufev, EV_READ, 0);
225 	bufferevent_disable(bufev, EV_READ);
226 	bufferevent_run_eventcb_(bufev, what, 0);
229 	bufferevent_decref_and_unlock_(bufev);
235 	struct bufferevent *bufev = arg;
236 	struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
242 	bufferevent_incref_and_lock_(bufev);
265 			event_del(&bufev->ev_write);
266 			event_del(&bufev->ev_read);
267 			bufferevent_run_eventcb_(bufev, BEV_EVENT_ERROR, 0);
271 			bufferevent_socket_set_conn_address_fd_(bufev, fd);
273 			if (BEV_IS_ASYNC(bufev)) {
274 				event_del(&bufev->ev_write);
275 				bufferevent_async_set_connected_(bufev);
276 				bufferevent_run_eventcb_(bufev,
281 			bufferevent_run_eventcb_(bufev,
283 			if (!(bufev->enabled & EV_WRITE) ||
285 				event_del(&bufev->ev_write);
296 	if (evbuffer_get_length(bufev->output)) {
297 		evbuffer_unfreeze(bufev->output, 1);
298 		res = evbuffer_write_atmost(bufev->output, fd, atmost);
299 		evbuffer_freeze(bufev->output, 1);
318 	if (evbuffer_get_length(bufev->output) == 0) {
319 		event_del(&bufev->ev_write);
327 		bufferevent_trigger_nolock_(bufev, EV_WRITE, 0);
333 	if (evbuffer_get_length(bufev->output) == 0) {
334 		event_del(&bufev->ev_write);
339 	bufferevent_disable(bufev, EV_WRITE);
340 	bufferevent_run_eventcb_(bufev, what, 0);
343 	bufferevent_decref_and_unlock_(bufev);
351 	struct bufferevent *bufev;
366 	bufev = &bufev_p->bev;
367 	evbuffer_set_flags(bufev->output, EVBUFFER_FLAG_DRAINS_TO_FD);
369 	event_assign(&bufev->ev_read, bufev->ev_base, fd,
370 	    EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev);
371 	event_assign(&bufev->ev_write, bufev->ev_base, fd,
372 	    EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev);
374 	evbuffer_add_cb(bufev->output, bufferevent_socket_outbuf_cb, bufev);
376 	evbuffer_freeze(bufev->input, 0);
377 	evbuffer_freeze(bufev->output, 1);
379 	return bufev;
559 	struct bufferevent *bufev;
561 	if (!(bufev = bufferevent_socket_new(NULL, fd, 0)))
564 	bufferevent_setcb(bufev, readcb, writecb, eventcb, cbarg);
566 	return bufev;
571 be_socket_enable(struct bufferevent *bufev, short event)
574 	    bufferevent_add_event_(&bufev->ev_read, &bufev->timeout_read) == -1)
577 	    bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1)
583 be_socket_disable(struct bufferevent *bufev, short event)
585 	struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
587 		if (event_del(&bufev->ev_read) == -1)
592 		if (event_del(&bufev->ev_write) == -1)
599 be_socket_destruct(struct bufferevent *bufev)
601 	struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
603 	EVUTIL_ASSERT(BEV_IS_SOCKET(bufev));
605 	fd = event_get_fd(&bufev->ev_read);
622 be_socket_setfd(struct bufferevent *bufev, evutil_socket_t fd)
624 	struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
626 	BEV_LOCK(bufev);
627 	EVUTIL_ASSERT(BEV_IS_SOCKET(bufev));
629 	event_del(&bufev->ev_read);
630 	event_del(&bufev->ev_write);
632 	evbuffer_unfreeze(bufev->input, 0);
633 	evbuffer_unfreeze(bufev->output, 1);
635 	event_assign(&bufev->ev_read, bufev->ev_base, fd,
636 	    EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev);
637 	event_assign(&bufev->ev_write, bufev->ev_base, fd,
638 	    EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev);
641 		bufferevent_enable(bufev, bufev->enabled);
645 	BEV_UNLOCK(bufev);
650 bufferevent_priority_set(struct bufferevent *bufev, int priority)
653 	struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
655 	BEV_LOCK(bufev);
656 	if (BEV_IS_ASYNC(bufev) || BEV_IS_FILTER(bufev) || BEV_IS_PAIR(bufev))
659 	if (event_priority_set(&bufev->ev_read, priority) == -1)
661 	if (event_priority_set(&bufev->ev_write, priority) == -1)
668 	BEV_UNLOCK(bufev);
674 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev)
678 	BEV_LOCK(bufev);
679 	if (!BEV_IS_SOCKET(bufev))
682 	bufev->ev_base = base;
684 	res = event_base_set(base, &bufev->ev_read);
688 	res = event_base_set(base, &bufev->ev_write);
690 	BEV_UNLOCK(bufev);