Lines Matching defs:write_request

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