Lines Matching refs:write_request
352 struct cache_mp_write_session_write_request *write_request; in on_mp_write_session_write_request_read1() local
358 write_request = get_cache_mp_write_session_write_request( in on_mp_write_session_write_request_read1()
361 result = qstate->read_func(qstate, &write_request->data_size, in on_mp_write_session_write_request_read1()
371 if (BUFSIZE_INVALID(write_request->data_size)) { in on_mp_write_session_write_request_read1()
378 write_request->data = calloc(1, write_request->data_size); in on_mp_write_session_write_request_read1()
379 assert(write_request->data != NULL); in on_mp_write_session_write_request_read1()
381 qstate->kevent_watermark = write_request->data_size; in on_mp_write_session_write_request_read1()
390 struct cache_mp_write_session_write_request *write_request; in on_mp_write_session_write_request_read2() local
394 write_request = get_cache_mp_write_session_write_request( in on_mp_write_session_write_request_read2()
397 result = qstate->read_func(qstate, write_request->data, in on_mp_write_session_write_request_read2()
398 write_request->data_size); in on_mp_write_session_write_request_read2()
416 struct cache_mp_write_session_write_request *write_request; in on_mp_write_session_write_request_process() local
424 write_request = get_cache_mp_write_session_write_request( in on_mp_write_session_write_request_process()
430 write_request->data, in on_mp_write_session_write_request_process()
431 write_request->data_size); in on_mp_write_session_write_request_process()