Lines Matching refs:element

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