Lines Matching refs:element

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