usr.sbin/syslogd/syslogd.c

329 int	 tcpbuf_countmsg(struct bufferevent *bufev);
1290 tcp_readcb(struct bufferevent *bufev, void *arg)
1296 	while (EVBUFFER_LENGTH(bufev->input) > 0) {
1300 		len = octet_counting(bufev->input, &msg, 1);
1302 			len = non_transparent_framing(bufev->input, &msg);
1318 		evbuffer_drain(bufev->input, len);
1321 	if (EVBUFFER_LENGTH(bufev->input) >= 5 + 1 + LOG_MAXLINE + 1) {
1322 		log_debug(", use %zu bytes", EVBUFFER_LENGTH(bufev->input));
1323 		EVBUFFER_DATA(bufev->input)[5 + 1 + LOG_MAXLINE] = '\0';
1324 		printline(p->p_hostname, EVBUFFER_DATA(bufev->input));
1325 		evbuffer_drain(bufev->input, -1);
1326 	} else if (EVBUFFER_LENGTH(bufev->input) > 0)
1327 		log_debug(", buffer %zu bytes", EVBUFFER_LENGTH(bufev->input));
1331 tcp_closecb(struct bufferevent *bufev, short event, void *arg)
1374 tcp_dropcb(struct bufferevent *bufev, void *arg)
1382 	    f->f_un.f_forw.f_loghost, EVBUFFER_LENGTH(bufev->input));
1383 	evbuffer_drain(bufev->input, -1);
1387 tcp_writecb(struct bufferevent *bufev, void *arg)
1407 tcp_errorcb(struct bufferevent *bufev, short event, void *arg)
1430 	bufferevent_disable(bufev, EV_READ|EV_WRITE);
1439 	buf = EVBUFFER_DATA(bufev->output);
1440 	end = buf + EVBUFFER_LENGTH(bufev->output);
1441 	if (buf < end && !((l = octet_counting(bufev->output, &p, 0)) > 0 &&
1445 				evbuffer_drain(bufev->output, p - buf + 1);
1451 			evbuffer_drain(bufev->output, -1);
1467 	struct bufferevent	*bufev = f->f_un.f_forw.f_bufev;
1484 	bufferevent_setfd(bufev, s);
1485 	bufferevent_setcb(bufev, tcp_dropcb, tcp_writecb, tcp_errorcb, f);
1490 	bufferevent_enable(bufev, EV_READ|EV_WRITE);
1513 		buffertls_set(&f->f_un.f_forw.f_buftls, bufev,
1525 	bufferevent_disable(bufev, EV_READ|EV_WRITE);
1611 tcpbuf_countmsg(struct bufferevent *bufev)
1616 	buf = EVBUFFER_DATA(bufev->output);
1617 	end = buf + EVBUFFER_LENGTH(bufev->output);