Lines Matching refs:kevent_watermark
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()
311 qstate->kevent_watermark = sizeof(size_t); in on_mp_write_session_mapper()
316 qstate->kevent_watermark = 0; in on_mp_write_session_mapper()
321 qstate->kevent_watermark = 0; in on_mp_write_session_mapper()
326 qstate->kevent_watermark = 0; in on_mp_write_session_mapper()
378 qstate->kevent_watermark = write_request->data_size; in on_mp_write_session_write_request_read1()
397 if (result < 0 || (size_t)result != qstate->kevent_watermark) { in on_mp_write_session_write_request_read2()
404 qstate->kevent_watermark = 0; in on_mp_write_session_write_request_read2()
431 qstate->kevent_watermark = sizeof(int); in on_mp_write_session_write_request_process()
461 qstate->kevent_watermark = sizeof(int); in on_mp_write_session_write_response_write1()
465 qstate->kevent_watermark = 0; in on_mp_write_session_write_response_write1()
486 qstate->kevent_watermark = 0; in on_mp_write_session_abandon_notification()
505 qstate->kevent_watermark = 0; in on_mp_write_session_close_notification()