41 init_comm_element(struct comm_element *element, enum comm_element_t type)  in init_comm_element()  argument
45 	memset(element, 0, sizeof(struct comm_element));  in init_comm_element()
49 		init_cache_write_request(&element->c_write_request);  in init_comm_element()
52 		init_cache_write_response(&element->c_write_response);  in init_comm_element()
55 		init_cache_read_request(&element->c_read_request);  in init_comm_element()
58 		init_cache_read_response(&element->c_read_response);  in init_comm_element()
61 		init_cache_transform_request(&element->c_transform_request);  in init_comm_element()
64 		init_cache_transform_response(&element->c_transform_response);  in init_comm_element()
67 		init_cache_mp_write_session_request(&element->c_mp_ws_request);  in init_comm_element()
70 		init_cache_mp_write_session_response(&element->c_mp_ws_response);  in init_comm_element()
74 			&element->c_mp_ws_write_request);  in init_comm_element()
78 			&element->c_mp_ws_write_response);  in init_comm_element()
81 		init_cache_mp_read_session_request(&element->c_mp_rs_request);  in init_comm_element()
84 		init_cache_mp_read_session_response(&element->c_mp_rs_response);  in init_comm_element()
88 			&element->c_mp_rs_read_response);  in init_comm_element()
93 		LOG_ERR_2("init_comm_element", "invalid communication element");  in init_comm_element()
98 	element->type = type;  in init_comm_element()
103 finalize_comm_element(struct comm_element *element)  in finalize_comm_element()  argument
107 	switch (element->type) {  in finalize_comm_element()
109 		finalize_cache_write_request(&element->c_write_request);  in finalize_comm_element()
112 		finalize_cache_write_response(&element->c_write_response);  in finalize_comm_element()
115 		finalize_cache_read_request(&element->c_read_request);  in finalize_comm_element()
118 		finalize_cache_read_response(&element->c_read_response);  in finalize_comm_element()
121 		finalize_cache_transform_request(&element->c_transform_request);  in finalize_comm_element()
125 			&element->c_transform_response);  in finalize_comm_element()
129 			&element->c_mp_ws_request);  in finalize_comm_element()
133 			&element->c_mp_ws_response);  in finalize_comm_element()
137 			&element->c_mp_ws_write_request);  in finalize_comm_element()
141 			&element->c_mp_ws_write_response);  in finalize_comm_element()
145 			&element->c_mp_rs_request);  in finalize_comm_element()
149 			&element->c_mp_rs_response);  in finalize_comm_element()
153 			&element->c_mp_rs_read_response);  in finalize_comm_element()
161 	element->type = CET_UNDEFINED;  in finalize_comm_element()
186 get_cache_write_request(struct comm_element *element)  in get_cache_write_request()  argument
190 	assert(element->type == CET_WRITE_REQUEST);  in get_cache_write_request()
192 	return (&element->c_write_request);  in get_cache_write_request()
213 get_cache_write_response(struct comm_element *element)  in get_cache_write_response()  argument
217 	assert(element->type == CET_WRITE_RESPONSE);  in get_cache_write_response()
219 	return (&element->c_write_response);  in get_cache_write_response()
242 get_cache_read_request(struct comm_element *element)  in get_cache_read_request()  argument
246 	assert(element->type == CET_READ_REQUEST);  in get_cache_read_request()
248 	return (&element->c_read_request);  in get_cache_read_request()
270 get_cache_read_response(struct comm_element *element)  in get_cache_read_response()  argument
274 	assert(element->type == CET_READ_RESPONSE);  in get_cache_read_response()
276 	return (&element->c_read_response);  in get_cache_read_response()
299 get_cache_transform_request(struct comm_element *element)  in get_cache_transform_request()  argument
303 	assert(element->type == CET_TRANSFORM_REQUEST);  in get_cache_transform_request()
305 	return (&element->c_transform_request);  in get_cache_transform_request()
328 get_cache_transform_response(struct comm_element *element)  in get_cache_transform_response()  argument
332 	assert(element->type == CET_TRANSFORM_RESPONSE);  in get_cache_transform_response()
334 	return (&element->c_transform_response);  in get_cache_transform_response()
360 get_cache_mp_write_session_request(struct comm_element *element)  in get_cache_mp_write_session_request()  argument
364 	assert(element->type == CET_MP_WRITE_SESSION_REQUEST);  in get_cache_mp_write_session_request()
366 	return (&element->c_mp_ws_request);  in get_cache_mp_write_session_request()
390 get_cache_mp_write_session_response(struct comm_element *element)  in get_cache_mp_write_session_response()  argument
394 	assert(element->type == CET_MP_WRITE_SESSION_RESPONSE);  in get_cache_mp_write_session_response()
396 	return (&element->c_mp_ws_response);  in get_cache_mp_write_session_response()
421 get_cache_mp_write_session_write_request(struct comm_element *element)  in get_cache_mp_write_session_write_request()  argument
425 	assert(element->type == CET_MP_WRITE_SESSION_WRITE_REQUEST);  in get_cache_mp_write_session_write_request()
427 	return (&element->c_mp_ws_write_request);  in get_cache_mp_write_session_write_request()
451 get_cache_mp_write_session_write_response(struct comm_element *element)  in get_cache_mp_write_session_write_response()  argument
455 	assert(element->type == CET_MP_WRITE_SESSION_WRITE_RESPONSE);  in get_cache_mp_write_session_write_response()
457 	return (&element->c_mp_ws_write_response);  in get_cache_mp_write_session_write_response()
481 get_cache_mp_read_session_request(struct comm_element *element)  in get_cache_mp_read_session_request()  argument
485 	assert(element->type == CET_MP_READ_SESSION_REQUEST);  in get_cache_mp_read_session_request()
487 	return (&element->c_mp_rs_request);  in get_cache_mp_read_session_request()
511 get_cache_mp_read_session_response(struct comm_element *element)  in get_cache_mp_read_session_response()  argument
515 	assert(element->type == CET_MP_READ_SESSION_RESPONSE);  in get_cache_mp_read_session_response()
517 	return (&element->c_mp_rs_response);  in get_cache_mp_read_session_response()
542 get_cache_mp_read_session_read_response(struct comm_element *element)  in get_cache_mp_read_session_read_response()  argument
546 	assert(element->type == CET_MP_READ_SESSION_READ_RESPONSE);  in get_cache_mp_read_session_read_response()
548 	return (&element->c_mp_rs_read_response);  in get_cache_mp_read_session_read_response()