read_request
read_request(*in, buflen);
read_request(*in, buflen);
void read_request(mockfs_buf_in& in, ssize_t& res);
init_cache_read_request(struct cache_read_request *read_request)
memset(read_request, 0, sizeof(struct cache_read_request));
finalize_cache_read_request(struct cache_read_request *read_request)
free(read_request->entry);
free(read_request->cache_key);
struct cache_read_request *read_request;
read_request = get_cache_read_request(&qstate->request);
&read_request->entry_length, sizeof(size_t));
&read_request->cache_key_size, sizeof(size_t));
if (BUFSIZE_INVALID(read_request->entry_length) ||
BUFSIZE_INVALID(read_request->cache_key_size)) {
read_request->entry = calloc(1,
read_request->entry_length + 1);
assert(read_request->entry != NULL);
read_request->cache_key = calloc(1,
read_request->cache_key_size +
assert(read_request->cache_key != NULL);
memcpy(read_request->cache_key, qstate->eid_str,
qstate->kevent_watermark = read_request->entry_length +
read_request->cache_key_size;
struct cache_read_request *read_request;
read_request = get_cache_read_request(&qstate->request);
result = qstate->read_func(qstate, read_request->entry,
read_request->entry_length);
read_request->cache_key + qstate->eid_str_length,
read_request->cache_key_size);
read_request->cache_key_size += qstate->eid_str_length;
struct cache_read_request *read_request;
read_request = get_cache_read_request(&qstate->request);
s_configuration, read_request->entry);
"entry '%s'. aborting request", read_request->entry);
read_request->entry);
memset(read_request->cache_key, 0, qstate->eid_str_length);
read_request->cache_key,
read_request->cache_key_size, NULL,
read_request->cache_key,
read_request->cache_key_size,
read_request->cache_key,
read_request->cache_key_size, NULL,
read_request->cache_key,
read_request->cache_key_size,
read_request->entry, COMMON_AGENT);
read_request->cache_key +
read_request->cache_key_size -
read_request->cache_key,
read_request->cache_key_size,
read_request->cache_key,
read_request->cache_key_size,