Lines Matching refs:rbuffer_size
172 d = memmem_safe(b->rbuffer, b->rbuffer_size, "\r\n", 2); in bus_socket_auth_verify_client()
176 e = memmem_safe(d + 2, b->rbuffer_size - (d - (char*) b->rbuffer) - 2, "\r\n", 2); in bus_socket_auth_verify_client()
181 f = memmem_safe(e + 2, b->rbuffer_size - (e - (char*) b->rbuffer) - 2, "\r\n", 2); in bus_socket_auth_verify_client()
244 b->rbuffer_size -= (start - (char*) b->rbuffer); in bus_socket_auth_verify_client()
245 memmove(b->rbuffer, start, b->rbuffer_size); in bus_socket_auth_verify_client()
385 if (b->rbuffer_size < 1) in bus_socket_auth_verify_server()
392 if (b->rbuffer_size < 3) in bus_socket_auth_verify_server()
402 e = memmem_safe(line, b->rbuffer_size - b->auth_rbegin, "\r\n", 2); in bus_socket_auth_verify_server()
463 b->rbuffer_size -= (e + 2 - (char*) b->rbuffer); in bus_socket_auth_verify_server()
464 memmove(b->rbuffer, e + 2, b->rbuffer_size); in bus_socket_auth_verify_server()
531 n = MAX(256u, b->rbuffer_size * 2); in bus_socket_read_auth()
536 if (b->rbuffer_size >= n) in bus_socket_read_auth()
545 iov = IOVEC_MAKE((uint8_t *)b->rbuffer + b->rbuffer_size, n - b->rbuffer_size); in bus_socket_read_auth()
579 b->rbuffer_size += k; in bus_socket_read_auth()
1092 if (bus->rbuffer_size < sizeof(struct bus_header)) { in bus_socket_read_message_need()
1141 assert(bus->rbuffer_size >= size); in bus_socket_make_message()
1148 if (bus->rbuffer_size > size) { in bus_socket_make_message()
1150 bus->rbuffer_size - size); in bus_socket_make_message()
1171 bus->rbuffer_size -= size; in bus_socket_make_message()
1202 if (bus->rbuffer_size >= need) in bus_socket_read_message()
1211 iov = IOVEC_MAKE((uint8_t *)bus->rbuffer + bus->rbuffer_size, need - bus->rbuffer_size); in bus_socket_read_message()
1245 bus->rbuffer_size += k; in bus_socket_read_message()
1284 if (bus->rbuffer_size >= need) in bus_socket_read_message()