Lines Matching refs:read_response

415 	struct cache_mp_read_session_read_response	*read_response;  in on_mp_read_session_read_request_process()  local
419 read_response = get_cache_mp_read_session_read_response( in on_mp_read_session_read_request_process()
423 read_response->error_code = cache_mp_read( in on_mp_read_session_read_request_process()
425 &read_response->data_size); in on_mp_read_session_read_request_process()
427 if (read_response->error_code == 0) { in on_mp_read_session_read_request_process()
428 read_response->data = malloc(read_response->data_size); in on_mp_read_session_read_request_process()
429 assert(read_response != NULL); in on_mp_read_session_read_request_process()
430 read_response->error_code = cache_mp_read( in on_mp_read_session_read_request_process()
432 read_response->data, in on_mp_read_session_read_request_process()
433 &read_response->data_size); in on_mp_read_session_read_request_process()
437 if (read_response->error_code == 0) in on_mp_read_session_read_request_process()
451 struct cache_mp_read_session_read_response *read_response; in on_mp_read_session_read_response_write1() local
455 read_response = get_cache_mp_read_session_read_response( in on_mp_read_session_read_response_write1()
458 result = qstate->write_func(qstate, &read_response->error_code, in on_mp_read_session_read_response_write1()
460 if (read_response->error_code == 0) { in on_mp_read_session_read_response_write1()
461 result += qstate->write_func(qstate, &read_response->data_size, in on_mp_read_session_read_response_write1()
470 qstate->kevent_watermark = read_response->data_size; in on_mp_read_session_read_response_write1()
491 struct cache_mp_read_session_read_response *read_response; in on_mp_read_session_read_response_write2() local
495 read_response = get_cache_mp_read_session_read_response( in on_mp_read_session_read_response_write2()
497 result = qstate->write_func(qstate, read_response->data, in on_mp_read_session_read_response_write2()
498 read_response->data_size); in on_mp_read_session_read_response_write2()