sntp/libevent/bufferevent_filter.c

81 	struct bufferevent *underlying;
84 	/** True iff we have received an EOF callback from the underlying
126 /** Return 1 iff bevf's underlying bufferevent's output buffer is at or
133 	struct bufferevent *u = bevf->underlying;
165 bufferevent_filter_new(struct bufferevent *underlying,
175 	if (!underlying)
187 	if (bufferevent_init_common_(&bufev_f->bev, underlying->ev_base,
196 	bufev_f->underlying = underlying;
203 	bufferevent_setcb(bufev_f->underlying,
210 	bufferevent_incref_(underlying);
212 	bufferevent_enable(underlying, EV_READ|EV_WRITE);
213 	bufferevent_suspend_read_(underlying, BEV_SUSPEND_FILT_READ);
227 		 * underlying for the first time.  This decref is an
230 		if (BEV_UPCAST(bevf->underlying)->refcnt < 2) {
234 			bufferevent_free(bevf->underlying);
237 		if (bevf->underlying) {
238 			if (bevf->underlying->errorcb == be_filter_eventcb)
239 				bufferevent_setcb(bevf->underlying,
241 			bufferevent_unsuspend_read_(bevf->underlying,
265 		bufferevent_unsuspend_read_(bevf->underlying,
279 		bufferevent_suspend_read_(bevf->underlying,
307 		res = bevf->process_in(bevf->underlying->input,
314 		 evbuffer_get_length(bevf->underlying->input) &&
336 		 * filter unless we're writing data, and the underlying
357 			    bevf->underlying->wm_write.high)
358 				limit = bevf->underlying->wm_write.high -
359 				    evbuffer_get_length(bevf->underlying->output);
362 			    bevf->underlying->output,
376 			/* Or if we have filled the underlying output buffer. */
420 /* Called when the underlying socket has read. */
422 be_filter_readcb(struct bufferevent *underlying, void *me_)
458 /* Called when the underlying socket has drained enough that we can write to
461 be_filter_writecb(struct bufferevent *underlying, void *me_)
481 /* Called when the underlying socket has given us an error */
483 be_filter_eventcb(struct bufferevent *underlying, short what, void *me_)
522 	bufferevent_flush(bevf->underlying, iotype, mode);
537 		data->ptr = bevf->underlying;