50 static void	consume(evStream *str, size_t bytes);
234 consume(evStream *str, size_t bytes) {  in consume()  argument
235 	while (bytes > 0U) {  in consume()
236 		if (bytes < (size_t)str->iovCur->iov_len) {  in consume()
237 			str->iovCur->iov_len -= bytes;  in consume()
239 				((u_char *)str->iovCur->iov_base + bytes);  in consume()
240 			str->ioDone += bytes;  in consume()
241 			bytes = 0;  in consume()
243 			bytes -= str->iovCur->iov_len;  in consume()
273 	int bytes;  in writable()  local
277 	bytes = writev(fd, str->iovCur, str->iovCurCount);  in writable()
278 	if (bytes > 0) {  in writable()
281 		consume(str, bytes);  in writable()
283 		if (bytes < 0 && errno != EINTR) {  in writable()
296 	int bytes;  in readable()  local
300 	bytes = readv(fd, str->iovCur, str->iovCurCount);  in readable()
301 	if (bytes > 0) {  in readable()
304 		consume(str, bytes);  in readable()
306 		if (bytes == 0)  in readable()