Lines Matching refs:write_request
308 struct cache_write_request *write_request; in on_write_request_read1() local
316 write_request = get_cache_write_request(&qstate->request); in on_write_request_read1()
318 result = qstate->read_func(qstate, &write_request->entry_length, in on_write_request_read1()
321 &write_request->cache_key_size, sizeof(size_t)); in on_write_request_read1()
323 &write_request->data_size, sizeof(size_t)); in on_write_request_read1()
330 if (BUFSIZE_INVALID(write_request->entry_length) || in on_write_request_read1()
331 BUFSIZE_INVALID(write_request->cache_key_size) || in on_write_request_read1()
332 (BUFSIZE_INVALID(write_request->data_size) && in on_write_request_read1()
333 (write_request->data_size != 0))) { in on_write_request_read1()
338 write_request->entry = calloc(1, in on_write_request_read1()
339 write_request->entry_length + 1); in on_write_request_read1()
340 assert(write_request->entry != NULL); in on_write_request_read1()
342 write_request->cache_key = calloc(1, in on_write_request_read1()
343 write_request->cache_key_size + in on_write_request_read1()
345 assert(write_request->cache_key != NULL); in on_write_request_read1()
346 memcpy(write_request->cache_key, qstate->eid_str, in on_write_request_read1()
349 if (write_request->data_size != 0) { in on_write_request_read1()
350 write_request->data = calloc(1, in on_write_request_read1()
351 write_request->data_size); in on_write_request_read1()
352 assert(write_request->data != NULL); in on_write_request_read1()
355 qstate->kevent_watermark = write_request->entry_length + in on_write_request_read1()
356 write_request->cache_key_size + in on_write_request_read1()
357 write_request->data_size; in on_write_request_read1()
368 struct cache_write_request *write_request; in on_write_request_read2() local
372 write_request = get_cache_write_request(&qstate->request); in on_write_request_read2()
374 result = qstate->read_func(qstate, write_request->entry, in on_write_request_read2()
375 write_request->entry_length); in on_write_request_read2()
376 result += qstate->read_func(qstate, write_request->cache_key + in on_write_request_read2()
377 qstate->eid_str_length, write_request->cache_key_size); in on_write_request_read2()
378 if (write_request->data_size != 0) in on_write_request_read2()
379 result += qstate->read_func(qstate, write_request->data, in on_write_request_read2()
380 write_request->data_size); in on_write_request_read2()
386 write_request->cache_key_size += qstate->eid_str_length; in on_write_request_read2()
389 if (write_request->data_size != 0) in on_write_request_read2()
400 struct cache_write_request *write_request; in on_write_request_process() local
407 write_request = get_cache_write_request(&qstate->request); in on_write_request_process()
410 s_configuration, write_request->entry); in on_write_request_process()
416 " entry '%s'. aborting request", write_request->entry); in on_write_request_process()
425 write_request->entry); in on_write_request_process()
434 "can't write to it", write_request->entry); in on_write_request_process()
446 write_request->cache_key, in on_write_request_process()
447 write_request->cache_key_size, in on_write_request_process()
448 write_request->data, in on_write_request_process()
449 write_request->data_size); in on_write_request_process()
473 struct cache_write_request *write_request; in on_negative_write_request_process() local
480 write_request = get_cache_write_request(&qstate->request); in on_negative_write_request_process()
483 s_configuration, write_request->entry); in on_negative_write_request_process()
490 " entry '%s'. aborting request", write_request->entry); in on_negative_write_request_process()
499 write_request->entry); in on_negative_write_request_process()
508 "can't write to it", write_request->entry); in on_negative_write_request_process()
527 write_request->cache_key, in on_negative_write_request_process()
528 write_request->cache_key_size, in on_negative_write_request_process()