Lines Matching refs:buffer
148 omapi_buffer_t *buffer; in omapi_connection_reader_trace() local
166 for (buffer = c -> inbufs; buffer -> next; in omapi_connection_reader_trace()
167 buffer = buffer -> next) in omapi_connection_reader_trace()
169 if (!BUFFER_BYTES_FREE (buffer)) { in omapi_connection_reader_trace()
170 status = omapi_buffer_new (&buffer -> next, MDL); in omapi_connection_reader_trace()
173 buffer = buffer -> next; in omapi_connection_reader_trace()
179 buffer = c -> inbufs; in omapi_connection_reader_trace()
182 bytes_to_read = BUFFER_BYTES_FREE (buffer); in omapi_connection_reader_trace()
185 if (buffer -> tail > buffer -> head) in omapi_connection_reader_trace()
186 read_len = sizeof (buffer -> buf) - buffer -> tail; in omapi_connection_reader_trace()
188 read_len = buffer -> head - buffer -> tail; in omapi_connection_reader_trace()
197 memcpy (&buffer -> buf [buffer -> tail], in omapi_connection_reader_trace()
209 &buffer -> buf [buffer -> tail], in omapi_connection_reader_trace()
241 iov [1].buf = &buffer -> buf [buffer -> tail]; in omapi_connection_reader_trace()
253 buffer -> tail += read_status; in omapi_connection_reader_trace()
255 if (buffer -> tail == sizeof buffer -> buf) in omapi_connection_reader_trace()
256 buffer -> tail = 0; in omapi_connection_reader_trace()
274 omapi_buffer_t *buffer; in omapi_connection_copyin() local
293 for (buffer = c -> outbufs; in omapi_connection_copyin()
294 buffer -> next; buffer = buffer -> next) in omapi_connection_copyin()
300 buffer = c -> outbufs; in omapi_connection_copyin()
306 if (!BUFFER_BYTES_FREE (buffer)) { in omapi_connection_copyin()
307 status = (omapi_buffer_new (&buffer -> next, MDL)); in omapi_connection_copyin()
310 buffer = buffer -> next; in omapi_connection_copyin()
313 if (buffer -> tail > buffer -> head) in omapi_connection_copyin()
314 copy_len = sizeof (buffer -> buf) - buffer -> tail; in omapi_connection_copyin()
316 copy_len = buffer -> head - buffer -> tail; in omapi_connection_copyin()
332 memcpy (&buffer -> buf [buffer -> tail], in omapi_connection_copyin()
334 buffer -> tail += copy_len; in omapi_connection_copyin()
337 if (buffer -> tail == sizeof buffer -> buf) in omapi_connection_copyin()
338 buffer -> tail = 0; in omapi_connection_copyin()
371 omapi_buffer_t *buffer; in omapi_connection_copyout() local
385 buffer = c -> inbufs; in omapi_connection_copyout()
388 if (!buffer) in omapi_connection_copyout()
390 if (BYTES_IN_BUFFER (buffer)) { in omapi_connection_copyout()
391 if (buffer -> head == (sizeof buffer -> buf) - 1) in omapi_connection_copyout()
394 first_byte = buffer -> head + 1; in omapi_connection_copyout()
396 if (first_byte > buffer -> tail) { in omapi_connection_copyout()
397 bytes_this_copy = (sizeof buffer -> buf - in omapi_connection_copyout()
401 buffer -> tail - first_byte; in omapi_connection_copyout()
414 &buffer -> buf [first_byte], in omapi_connection_copyout()
421 memcpy (bufp, &buffer -> buf [first_byte], in omapi_connection_copyout()
426 buffer -> head = first_byte + bytes_this_copy - 1; in omapi_connection_copyout()
430 if (!BYTES_IN_BUFFER (buffer)) in omapi_connection_copyout()
431 buffer = buffer -> next; in omapi_connection_copyout()
435 buffer = (omapi_buffer_t *)0; in omapi_connection_copyout()
439 omapi_buffer_reference (&buffer, in omapi_connection_copyout()
444 if (buffer) { in omapi_connection_copyout()
446 (&c -> inbufs, buffer, MDL); in omapi_connection_copyout()
447 omapi_buffer_dereference (&buffer, MDL); in omapi_connection_copyout()
458 omapi_buffer_t *buffer; in omapi_connection_writer() local
469 buffer = c -> outbufs; in omapi_connection_writer()
472 if (!buffer) in omapi_connection_writer()
474 if (BYTES_IN_BUFFER (buffer)) { in omapi_connection_writer()
475 if (buffer -> head == (sizeof buffer -> buf) - 1) in omapi_connection_writer()
478 first_byte = buffer -> head + 1; in omapi_connection_writer()
480 if (first_byte > buffer -> tail) { in omapi_connection_writer()
481 bytes_this_write = (sizeof buffer -> buf - in omapi_connection_writer()
485 buffer -> tail - first_byte; in omapi_connection_writer()
488 &buffer -> buf [first_byte], in omapi_connection_writer()
529 iov [1].buf = &buffer -> buf [buffer -> tail]; in omapi_connection_writer()
544 buffer -> head = first_byte + bytes_written - 1; in omapi_connection_writer()
554 if (!BYTES_IN_BUFFER (buffer)) in omapi_connection_writer()
555 buffer = buffer -> next; in omapi_connection_writer()
559 buffer = (omapi_buffer_t *)0; in omapi_connection_writer()
563 omapi_buffer_reference (&buffer, in omapi_connection_writer()
568 if (buffer) { in omapi_connection_writer()
569 omapi_buffer_reference (&c -> outbufs, buffer, MDL); in omapi_connection_writer()
570 omapi_buffer_dereference (&buffer, MDL); in omapi_connection_writer()
657 status = omapi_connection_put_uint32 (c, data -> u.buffer.len); in omapi_connection_write_typed_data()
660 if (data -> u.buffer.len) in omapi_connection_write_typed_data()
662 (c, data -> u.buffer.value, in omapi_connection_write_typed_data()
663 data -> u.buffer.len); in omapi_connection_write_typed_data()