37 static void	consume(evStream *str, size_t bytes);
219 consume(evStream *str, size_t bytes) {  in consume()  argument
220 	while (bytes > 0U) {  in consume()
221 		if (bytes < (size_t)str->iovCur->iov_len) {  in consume()
222 			str->iovCur->iov_len -= bytes;  in consume()
224 				((u_char *)str->iovCur->iov_base + bytes);  in consume()
225 			str->ioDone += bytes;  in consume()
226 			bytes = 0;  in consume()
228 			bytes -= str->iovCur->iov_len;  in consume()
258 	int bytes;  in writable()  local
262 	bytes = writev(fd, str->iovCur, str->iovCurCount);  in writable()
263 	if (bytes > 0) {  in writable()
266 		consume(str, bytes);  in writable()
268 		if (bytes < 0 && errno != EINTR) {  in writable()
281 	int bytes;  in readable()  local
285 	bytes = readv(fd, str->iovCur, str->iovCurCount);  in readable()
286 	if (bytes > 0) {  in readable()
289 		consume(str, bytes);  in readable()
291 		if (bytes == 0)  in readable()