Lines Matching refs:c_mp_rs_request
92 struct cache_mp_read_session_request *c_mp_rs_request; in on_mp_read_session_request_read1() local
101 c_mp_rs_request = get_cache_mp_read_session_request( in on_mp_read_session_request_read1()
105 &c_mp_rs_request->entry_length, sizeof(size_t)); in on_mp_read_session_request_read1()
112 if (BUFSIZE_INVALID(c_mp_rs_request->entry_length)) { in on_mp_read_session_request_read1()
117 c_mp_rs_request->entry = calloc(1, in on_mp_read_session_request_read1()
118 c_mp_rs_request->entry_length + 1); in on_mp_read_session_request_read1()
119 assert(c_mp_rs_request->entry != NULL); in on_mp_read_session_request_read1()
121 qstate->kevent_watermark = c_mp_rs_request->entry_length; in on_mp_read_session_request_read1()
131 struct cache_mp_read_session_request *c_mp_rs_request; in on_mp_read_session_request_read2() local
135 c_mp_rs_request = get_cache_mp_read_session_request(&qstate->request); in on_mp_read_session_request_read2()
137 result = qstate->read_func(qstate, c_mp_rs_request->entry, in on_mp_read_session_request_read2()
138 c_mp_rs_request->entry_length); in on_mp_read_session_request_read2()
156 struct cache_mp_read_session_request *c_mp_rs_request; in on_mp_read_session_request_process() local
174 c_mp_rs_request = get_cache_mp_read_session_request(&qstate->request); in on_mp_read_session_request_process()
177 s_configuration, c_mp_rs_request->entry); in on_mp_read_session_request_process()
183 " aborting request", c_mp_rs_request->entry); in on_mp_read_session_request_process()
192 c_mp_rs_request->entry); in on_mp_read_session_request_process()
233 c_mp_rs_request->entry, MULTIPART_AGENT); in on_mp_read_session_request_process()