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()
381 			qstate->kevent_watermark = 0;  in on_mp_read_session_mapper()
386 			qstate->kevent_watermark = 0;  in on_mp_read_session_mapper()
391 			qstate->kevent_watermark = 0;  in on_mp_read_session_mapper()
438 		qstate->kevent_watermark = sizeof(size_t) + sizeof(int);  in on_mp_read_session_read_request_process()
440 		qstate->kevent_watermark = sizeof(int);  in on_mp_read_session_read_request_process()
463 		if (result < 0 || (size_t)result != qstate->kevent_watermark) {  in on_mp_read_session_read_response_write1()
470 		qstate->kevent_watermark = read_response->data_size;  in on_mp_read_session_read_response_write1()
473 		if (result < 0 || (size_t)result != qstate->kevent_watermark) {  in on_mp_read_session_read_response_write1()
480 		qstate->kevent_watermark = 0;  in on_mp_read_session_read_response_write1()
499 	if (result < 0 || (size_t)result != qstate->kevent_watermark) {  in on_mp_read_session_read_response_write2()
509 	qstate->kevent_watermark = sizeof(int);  in on_mp_read_session_read_response_write2()
530 	qstate->kevent_watermark = 0;  in on_mp_read_session_close_notification()