Searched refs:kevent_watermark (Results 1 – 5 of 5) sorted by relevance
96 if (qstate->kevent_watermark == 0) in on_mp_read_session_request_read1()97 qstate->kevent_watermark = sizeof(size_t); in on_mp_read_session_request_read1()121 qstate->kevent_watermark = c_mp_rs_request->entry_length; in on_mp_read_session_request_read1()140 if (result < 0 || (size_t)result != qstate->kevent_watermark) { in on_mp_read_session_request_read2()147 qstate->kevent_watermark = 0; in on_mp_read_session_request_read2()318 qstate->kevent_watermark = sizeof(int); in on_mp_read_session_request_process()345 qstate->kevent_watermark = sizeof(int); in on_mp_read_session_response_write1()349 qstate->kevent_watermark = 0; in on_mp_read_session_response_write1()368 if (qstate->kevent_watermark == 0) { in on_mp_read_session_mapper()369 qstate->kevent_watermark = sizeof(int); in on_mp_read_session_mapper()[all …]
97 if (qstate->kevent_watermark == 0) in on_mp_write_session_request_read1()98 qstate->kevent_watermark = sizeof(size_t); in on_mp_write_session_request_read1()126 qstate->kevent_watermark = c_mp_ws_request->entry_length; in on_mp_write_session_request_read1()145 if (result < 0 || (size_t)result != qstate->kevent_watermark) { in on_mp_write_session_request_read2()152 qstate->kevent_watermark = 0; in on_mp_write_session_request_read2()249 qstate->kevent_watermark = sizeof(int); in on_mp_write_session_request_process()275 qstate->kevent_watermark = sizeof(int); in on_mp_write_session_response_write1()279 qstate->kevent_watermark = 0; in on_mp_write_session_response_write1()298 if (qstate->kevent_watermark == 0) { in on_mp_write_session_mapper()299 qstate->kevent_watermark = sizeof(int); in on_mp_write_session_mapper()[all …]
236 qstate->kevent_watermark = 0; in on_query_startup() 254 if (qstate->kevent_watermark == 0) { in on_rw_mapper() 255 qstate->kevent_watermark = sizeof(int); in on_rw_mapper() 265 qstate->kevent_watermark = sizeof(size_t); in on_rw_mapper() 269 qstate->kevent_watermark = sizeof(size_t); in on_rw_mapper() 309 if (qstate->kevent_watermark == 0) in on_write_request_read1() 310 qstate->kevent_watermark = sizeof(size_t) * 3; in on_write_request_read1() 352 qstate->kevent_watermark = write_request->entry_length + in on_write_request_read1() 379 if (result != (ssize_t)qstate->kevent_watermark) { in on_write_request_read2() 385 qstate->kevent_watermark in on_write_request_read2() 1226 init_query_state(int sockfd,size_t kevent_watermark,uid_t euid,gid_t egid) init_query_state() argument [all...]
263 NOTE_LOWAT, qstate->kevent_watermark, qstate); in accept_connection()315 (qstate->kevent_watermark <= (size_t)event_data->data)) || in process_socket_event()346 } while ((qstate->kevent_watermark == 0) && in process_socket_event()403 if (qstate->kevent_watermark > MAX_SOCKET_IO_SIZE) { in process_socket_event()414 qstate->kevent_watermark); in process_socket_event()418 qstate->io_buffer_size = qstate->kevent_watermark; in process_socket_event()435 NOTE_LOWAT, qstate->kevent_watermark, qstate); in process_socket_event()
76 size_t kevent_watermark; /* bytes to be sent/received */ member