Lines Matching refs:read_request
583 struct cache_read_request *read_request; in on_read_request_read1() local
591 read_request = get_cache_read_request(&qstate->request); in on_read_request_read1()
594 &read_request->entry_length, sizeof(size_t)); in on_read_request_read1()
596 &read_request->cache_key_size, sizeof(size_t)); in on_read_request_read1()
603 if (BUFSIZE_INVALID(read_request->entry_length) || in on_read_request_read1()
604 BUFSIZE_INVALID(read_request->cache_key_size)) { in on_read_request_read1()
609 read_request->entry = calloc(1, in on_read_request_read1()
610 read_request->entry_length + 1); in on_read_request_read1()
611 assert(read_request->entry != NULL); in on_read_request_read1()
613 read_request->cache_key = calloc(1, in on_read_request_read1()
614 read_request->cache_key_size + in on_read_request_read1()
616 assert(read_request->cache_key != NULL); in on_read_request_read1()
617 memcpy(read_request->cache_key, qstate->eid_str, in on_read_request_read1()
620 qstate->kevent_watermark = read_request->entry_length + in on_read_request_read1()
621 read_request->cache_key_size; in on_read_request_read1()
632 struct cache_read_request *read_request; in on_read_request_read2() local
636 read_request = get_cache_read_request(&qstate->request); in on_read_request_read2()
638 result = qstate->read_func(qstate, read_request->entry, in on_read_request_read2()
639 read_request->entry_length); in on_read_request_read2()
641 read_request->cache_key + qstate->eid_str_length, in on_read_request_read2()
642 read_request->cache_key_size); in on_read_request_read2()
648 read_request->cache_key_size += qstate->eid_str_length; in on_read_request_read2()
660 struct cache_read_request *read_request; in on_read_request_process() local
671 read_request = get_cache_read_request(&qstate->request); in on_read_request_process()
674 s_configuration, read_request->entry); in on_read_request_process()
680 "entry '%s'. aborting request", read_request->entry); in on_read_request_process()
689 read_request->entry); in on_read_request_process()
698 memset(read_request->cache_key, 0, qstate->eid_str_length); in on_read_request_process()
719 read_request->cache_key, in on_read_request_process()
720 read_request->cache_key_size, NULL, in on_read_request_process()
728 read_request->cache_key, in on_read_request_process()
729 read_request->cache_key_size, in on_read_request_process()
739 read_request->cache_key, in on_read_request_process()
740 read_request->cache_key_size, NULL, in on_read_request_process()
748 read_request->cache_key, in on_read_request_process()
749 read_request->cache_key_size, in on_read_request_process()
763 read_request->entry, COMMON_AGENT); in on_read_request_process()
769 read_request->cache_key + in on_read_request_process()
771 read_request->cache_key_size - in on_read_request_process()
782 read_request->cache_key, in on_read_request_process()
783 read_request->cache_key_size, in on_read_request_process()
795 read_request->cache_key, in on_read_request_process()
796 read_request->cache_key_size, in on_read_request_process()