43 init_comm_element(struct comm_element *element, enum comm_element_t type)  in init_comm_element()  argument
47 	memset(element, 0, sizeof(struct comm_element));  in init_comm_element()
51 		init_cache_write_request(&element->c_write_request);  in init_comm_element()
54 		init_cache_write_response(&element->c_write_response);  in init_comm_element()
57 		init_cache_read_request(&element->c_read_request);  in init_comm_element()
60 		init_cache_read_response(&element->c_read_response);  in init_comm_element()
63 		init_cache_transform_request(&element->c_transform_request);  in init_comm_element()
66 		init_cache_transform_response(&element->c_transform_response);  in init_comm_element()
69 		init_cache_mp_write_session_request(&element->c_mp_ws_request);  in init_comm_element()
72 		init_cache_mp_write_session_response(&element->c_mp_ws_response);  in init_comm_element()
76 			&element->c_mp_ws_write_request);  in init_comm_element()
80 			&element->c_mp_ws_write_response);  in init_comm_element()
83 		init_cache_mp_read_session_request(&element->c_mp_rs_request);  in init_comm_element()
86 		init_cache_mp_read_session_response(&element->c_mp_rs_response);  in init_comm_element()
90 			&element->c_mp_rs_read_response);  in init_comm_element()
100 	element->type = type;  in init_comm_element()
105 finalize_comm_element(struct comm_element *element)  in finalize_comm_element()  argument
109 	switch (element->type) {  in finalize_comm_element()
111 		finalize_cache_write_request(&element->c_write_request);  in finalize_comm_element()
114 		finalize_cache_write_response(&element->c_write_response);  in finalize_comm_element()
117 		finalize_cache_read_request(&element->c_read_request);  in finalize_comm_element()
120 		finalize_cache_read_response(&element->c_read_response);  in finalize_comm_element()
123 		finalize_cache_transform_request(&element->c_transform_request);  in finalize_comm_element()
127 			&element->c_transform_response);  in finalize_comm_element()
131 			&element->c_mp_ws_request);  in finalize_comm_element()
135 			&element->c_mp_ws_response);  in finalize_comm_element()
139 			&element->c_mp_ws_write_request);  in finalize_comm_element()
143 			&element->c_mp_ws_write_response);  in finalize_comm_element()
147 			&element->c_mp_rs_request);  in finalize_comm_element()
151 			&element->c_mp_rs_response);  in finalize_comm_element()
155 			&element->c_mp_rs_read_response);  in finalize_comm_element()
163 	element->type = CET_UNDEFINED;  in finalize_comm_element()
188 get_cache_write_request(struct comm_element *element)  in get_cache_write_request()  argument
192 	assert(element->type == CET_WRITE_REQUEST);  in get_cache_write_request()
194 	return (&element->c_write_request);  in get_cache_write_request()
215 get_cache_write_response(struct comm_element *element)  in get_cache_write_response()  argument
219 	assert(element->type == CET_WRITE_RESPONSE);  in get_cache_write_response()
221 	return (&element->c_write_response);  in get_cache_write_response()
244 get_cache_read_request(struct comm_element *element)  in get_cache_read_request()  argument
248 	assert(element->type == CET_READ_REQUEST);  in get_cache_read_request()
250 	return (&element->c_read_request);  in get_cache_read_request()
272 get_cache_read_response(struct comm_element *element)  in get_cache_read_response()  argument
276 	assert(element->type == CET_READ_RESPONSE);  in get_cache_read_response()
278 	return (&element->c_read_response);  in get_cache_read_response()
301 get_cache_transform_request(struct comm_element *element)  in get_cache_transform_request()  argument
305 	assert(element->type == CET_TRANSFORM_REQUEST);  in get_cache_transform_request()
307 	return (&element->c_transform_request);  in get_cache_transform_request()
330 get_cache_transform_response(struct comm_element *element)  in get_cache_transform_response()  argument
334 	assert(element->type == CET_TRANSFORM_RESPONSE);  in get_cache_transform_response()
336 	return (&element->c_transform_response);  in get_cache_transform_response()
362 get_cache_mp_write_session_request(struct comm_element *element)  in get_cache_mp_write_session_request()  argument
366 	assert(element->type == CET_MP_WRITE_SESSION_REQUEST);  in get_cache_mp_write_session_request()
368 	return (&element->c_mp_ws_request);  in get_cache_mp_write_session_request()
392 get_cache_mp_write_session_response(struct comm_element *element)  in get_cache_mp_write_session_response()  argument
396 	assert(element->type == CET_MP_WRITE_SESSION_RESPONSE);  in get_cache_mp_write_session_response()
398 	return (&element->c_mp_ws_response);  in get_cache_mp_write_session_response()
423 get_cache_mp_write_session_write_request(struct comm_element *element)  in get_cache_mp_write_session_write_request()  argument
427 	assert(element->type == CET_MP_WRITE_SESSION_WRITE_REQUEST);  in get_cache_mp_write_session_write_request()
429 	return (&element->c_mp_ws_write_request);  in get_cache_mp_write_session_write_request()
453 get_cache_mp_write_session_write_response(struct comm_element *element)  in get_cache_mp_write_session_write_response()  argument
457 	assert(element->type == CET_MP_WRITE_SESSION_WRITE_RESPONSE);  in get_cache_mp_write_session_write_response()
459 	return (&element->c_mp_ws_write_response);  in get_cache_mp_write_session_write_response()
483 get_cache_mp_read_session_request(struct comm_element *element)  in get_cache_mp_read_session_request()  argument
487 	assert(element->type == CET_MP_READ_SESSION_REQUEST);  in get_cache_mp_read_session_request()
489 	return (&element->c_mp_rs_request);  in get_cache_mp_read_session_request()
513 get_cache_mp_read_session_response(struct comm_element *element)  in get_cache_mp_read_session_response()  argument
517 	assert(element->type == CET_MP_READ_SESSION_RESPONSE);  in get_cache_mp_read_session_response()
519 	return (&element->c_mp_rs_response);  in get_cache_mp_read_session_response()
544 get_cache_mp_read_session_read_response(struct comm_element *element)  in get_cache_mp_read_session_read_response()  argument
548 	assert(element->type == CET_MP_READ_SESSION_READ_RESPONSE);  in get_cache_mp_read_session_read_response()
550 	return (&element->c_mp_rs_read_response);  in get_cache_mp_read_session_read_response()