Lines Matching refs:write_request

305 	struct cache_write_request	*write_request;
313 		write_request = get_cache_write_request(&qstate->request);
315 		result = qstate->read_func(qstate, &write_request->entry_length,
318 	    		&write_request->cache_key_size, sizeof(size_t));
320 	    		&write_request->data_size, sizeof(size_t));
327 		if (BUFSIZE_INVALID(write_request->entry_length) ||
328 			BUFSIZE_INVALID(write_request->cache_key_size) ||
329 			(BUFSIZE_INVALID(write_request->data_size) &&
330 			(write_request->data_size != 0))) {
335 		write_request->entry = calloc(1,
336 			write_request->entry_length + 1);
337 		assert(write_request->entry != NULL);
339 		write_request->cache_key = calloc(1,
340 			write_request->cache_key_size +
342 		assert(write_request->cache_key != NULL);
343 		memcpy(write_request->cache_key, qstate->eid_str,
346 		if (write_request->data_size != 0) {
347 			write_request->data = calloc(1,
348 				write_request->data_size);
349 			assert(write_request->data != NULL);
352 		qstate->kevent_watermark = write_request->entry_length +
353 			write_request->cache_key_size +
354 			write_request->data_size;
365 	struct cache_write_request	*write_request;
369 	write_request = get_cache_write_request(&qstate->request);
371 	result = qstate->read_func(qstate, write_request->entry,
372 		write_request->entry_length);
373 	result += qstate->read_func(qstate, write_request->cache_key +
374 		qstate->eid_str_length, write_request->cache_key_size);
375 	if (write_request->data_size != 0)
376 		result += qstate->read_func(qstate, write_request->data,
377 			write_request->data_size);
383 	write_request->cache_key_size += qstate->eid_str_length;
386 	if (write_request->data_size != 0)
397 	struct cache_write_request	*write_request;
404 	write_request = get_cache_write_request(&qstate->request);
407 		s_configuration, write_request->entry);
412 		LOG_ERR_2("write_request", "can't find configuration"
413 		    " entry '%s'. aborting request", write_request->entry);
420 		LOG_ERR_2("write_request",
422 			write_request->entry);
429 		LOG_ERR_2("write_request",
431 			"can't write to it", write_request->entry);
443 			write_request->cache_key,
444 	    		write_request->cache_key_size,
445 	    		write_request->data,
446 			write_request->data_size);
470 	struct cache_write_request	*write_request;
477 	write_request = get_cache_write_request(&qstate->request);
480 		s_configuration, write_request->entry);
487 		   	" entry '%s'. aborting request", write_request->entry);
496 			write_request->entry);
505 			"can't write to it", write_request->entry);
524 			write_request->cache_key,
525 	    		write_request->cache_key_size,