subscription_mgr.h File Reference

#include "b2c.h"
#include "msg_subscription_create_bs.h"
#include "msg_subscription_delete_bs.h"
#include "msg_subscription_monitored_item.h"
#include "msg_subscription_publish_ack_bs.h"
#include "msg_subscription_set_publishing_mode_bs.h"
#include "subscription_absent_node.h"
#include "subscription_core.h"
#include "subscription_create_monitored_item_it.h"
#include "address_space_itf.h"
#include "channel_mgr.h"
#include "constants.h"
#include "constants_statuscodes_bs.h"
#include "message_in_bs.h"
#include "message_out_bs.h"
#include "request_handle_bs.h"
#include "session_mgr.h"
#include "write_value_pointer_bs.h"

Go to the source code of this file.

Macros
#define	subscription_mgr__is_valid_subscription   subscription_core__is_valid_subscription

Functions
void	subscription_mgr__INITIALISATION (void)
void	subscription_mgr__create_notification_on_monitored_items_if_data_changed (const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue, const constants__t_WriteValuePointer_i subscription_mgr__p_old_wv_pointer, const constants__t_WriteValuePointer_i subscription_mgr__p_new_wv_pointer)
void	subscription_mgr__create_notification_on_monitored_items_if_node_changed (const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue, const t_bool subscription_mgr__p_added)
void	subscription_mgr__fill_delete_subscriptions_response (const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_bool subscription_mgr__p_has_sub, const constants__t_subscription_i subscription_mgr__p_session_sub, const t_entier4 subscription_mgr__p_nb_reqs)
void	subscription_mgr__fill_publish_response_msg (const constants__t_msg_i subscription_mgr__p_resp_msg, const constants__t_subscription_i subscription_mgr__p_subscription, const t_bool subscription_mgr__p_moreNotifs)
void	subscription_mgr__fill_publish_response_msg_ack_results (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_acks)
void	subscription_mgr__fill_publish_response_msg_available_seq_nums (const constants__t_msg_i subscription_mgr__p_resp_msg, const constants__t_notifRepublishQueue_i subscription_mgr__republishQueue, const t_entier4 subscription_mgr__nb_seq_nums)
void	subscription_mgr__fill_response_subscription_delete_monitored_items (const constants__t_subscription_i subscription_mgr__p_subscription, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_monitored_items)
void	subscription_mgr__fill_response_subscription_modify_monitored_items (const constants__t_endpoint_config_idx_i subscription_mgr__p_endpoint_idx, const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_monitored_items)
void	subscription_mgr__fill_response_subscription_set_monit_mode_monitored_items (const constants__t_monitoringMode_i subscription_mgr__p_monitoring_mode, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_monitored_items)
void	subscription_mgr__fill_set_publishing_mode_response (const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_bool subscription_mgr__p_has_sub, const constants__t_subscription_i subscription_mgr__p_session_sub, const t_bool subscription_mgr__p_pub_enabled, const t_entier4 subscription_mgr__p_nb_reqs)
void	subscription_mgr__local_check_filtered_subscription_and_monitored_item (const constants__t_subscription_i subscription_mgr__p_opt_sub_to_filter, const constants__t_monitoredItemId_i subscription_mgr__p_opt_mi_to_fitler, const constants__t_subscription_i subscription_mgr__p_sub, const constants__t_monitoredItemId_i subscription_mgr__p_mi, t_bool *const subscription_mgr__bres)
void	subscription_mgr__local_create_delete_notification_on_set_monit_mode_change (const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer, const constants__t_monitoringMode_i subscription_mgr__p_prevMonitMode, const constants__t_monitoringMode_i subscription_mgr__p_newMonitMode)
void	subscription_mgr__local_create_notification_if_node_changed_or_monitMode_enabling (const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer, const t_bool subscription_mgr__p_added_or_monitMode, const t_bool subscription_mgr__p_monitMode_enabling)
void	subscription_mgr__local_create_notification_on_monitored_item_if_event_selected (const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer, const constants__t_Event_i subscription_mgr__p_event, const constants__t_subscription_i subscription_mgr__p_sub_id, const constants__t_monitoredItemId_i subscription_mgr__p_mi_id)
void	subscription_mgr__local_create_notification_on_monitored_items_if_data_changed (const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer, const constants__t_WriteValuePointer_i subscription_mgr__p_old_wv_pointer, const constants__t_WriteValuePointer_i subscription_mgr__p_new_wv_pointer)
void	subscription_mgr__local_create_notification_on_monitored_items_if_event_selected (const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue, const constants__t_Event_i subscription_mgr__p_event, const constants__t_subscription_i subscription_mgr__p_sub_id, const constants__t_monitoredItemId_i subscription_mgr__p_mi_id)
void	subscription_mgr__local_treat_create_monitored_item_index (const constants__t_session_i subscription_mgr__p_session, const constants__t_subscription_i subscription_mgr__p_subscription, const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn, const constants__t_user_i subscription_mgr__p_user, const constants__t_LocaleIds_i subscription_mgr__p_locales, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_index)
void	subscription_mgr__local_treat_create_monitored_items (const constants__t_session_i subscription_mgr__p_session, const constants__t_subscription_i subscription_mgr__p_subscription, const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn, const constants__t_user_i subscription_mgr__p_user, const constants__t_LocaleIds_i subscription_mgr__p_locales, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_monitored_items)
void	subscription_mgr__server_subscription_data_changed (const constants__t_WriteValuePointer_i subscription_mgr__p_old_write_value_pointer, const constants__t_WriteValuePointer_i subscription_mgr__p_new_write_value_pointer)
void	subscription_mgr__server_subscription_event_triggered (const constants__t_NodeId_i subscription_mgr__p_notifierId, const constants__t_Event_i subscription_mgr__p_event, const constants__t_subscription_i subscription_mgr__p_sub_id, const constants__t_monitoredItemId_i subscription_mgr__p_mi_id, t_bool *const subscription_mgr__bres)
void	subscription_mgr__server_subscription_node_changed (const t_bool subscription_mgr__p_node_added, const constants__t_NodeId_i subscription_mgr__p_nid)
void	subscription_mgr__server_subscription_publish_timeout (const constants__t_subscription_i subscription_mgr__p_subscription)
void	subscription_mgr__server_subscription_session_inactive (const constants__t_session_i subscription_mgr__p_session, const constants__t_sessionState_i subscription_mgr__p_newSessionState)
void	subscription_mgr__subscription_mgr_UNINITIALISATION (void)
void	subscription_mgr__treat_create_subscription_request (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)
void	subscription_mgr__treat_delete_subscriptions_request (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)
void	subscription_mgr__treat_modify_subscription_request (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)
void	subscription_mgr__treat_publishing_mode_request (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)
void	subscription_mgr__treat_subscription_create_monitored_items_req (const constants__t_session_i subscription_mgr__p_session, const constants__t_user_i subscription_mgr__p_user, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)
void	subscription_mgr__treat_subscription_delete_monitored_items_req (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)
void	subscription_mgr__treat_subscription_modify_monitored_items_req (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)
void	subscription_mgr__treat_subscription_publish_request (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_header_i subscription_mgr__p_req_header, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_server_request_handle_i subscription_mgr__p_req_handle, const constants__t_request_context_i subscription_mgr__p_req_ctx, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service, t_bool *const subscription_mgr__async_resp_msg)
void	subscription_mgr__treat_subscription_republish_request (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)
void	subscription_mgr__treat_subscription_set_monit_mode_monitored_items_req (const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service)

Macro Definition Documentation

subscription_mgr__is_valid_subscription

#define subscription_mgr__is_valid_subscription   subscription_core__is_valid_subscription

Function Documentation

subscription_mgr__INITIALISATION()

void subscription_mgr__INITIALISATION ( void )

extern

subscription_mgr__create_notification_on_monitored_items_if_data_changed()

void subscription_mgr__create_notification_on_monitored_items_if_data_changed ( const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue, const constants__t_WriteValuePointer_i subscription_mgr__p_old_wv_pointer, const constants__t_WriteValuePointer_i subscription_mgr__p_new_wv_pointer )

extern

subscription_mgr__create_notification_on_monitored_items_if_node_changed()

void subscription_mgr__create_notification_on_monitored_items_if_node_changed ( const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue, const t_bool subscription_mgr__p_added )

extern

subscription_mgr__fill_delete_subscriptions_response()

void subscription_mgr__fill_delete_subscriptions_response ( const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_bool subscription_mgr__p_has_sub, const constants__t_subscription_i subscription_mgr__p_session_sub, const t_entier4 subscription_mgr__p_nb_reqs )

extern

subscription_mgr__fill_publish_response_msg()

void subscription_mgr__fill_publish_response_msg ( const constants__t_msg_i subscription_mgr__p_resp_msg, const constants__t_subscription_i subscription_mgr__p_subscription, const t_bool subscription_mgr__p_moreNotifs )

extern

subscription_mgr__fill_publish_response_msg_ack_results()

void subscription_mgr__fill_publish_response_msg_ack_results ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_acks )

extern

subscription_mgr__fill_publish_response_msg_available_seq_nums()

void subscription_mgr__fill_publish_response_msg_available_seq_nums ( const constants__t_msg_i subscription_mgr__p_resp_msg, const constants__t_notifRepublishQueue_i subscription_mgr__republishQueue, const t_entier4 subscription_mgr__nb_seq_nums )

extern

subscription_mgr__fill_response_subscription_delete_monitored_items()

void subscription_mgr__fill_response_subscription_delete_monitored_items ( const constants__t_subscription_i subscription_mgr__p_subscription, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_monitored_items )

extern

subscription_mgr__fill_response_subscription_modify_monitored_items()

void subscription_mgr__fill_response_subscription_modify_monitored_items ( const constants__t_endpoint_config_idx_i subscription_mgr__p_endpoint_idx, const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_monitored_items )

extern

subscription_mgr__fill_response_subscription_set_monit_mode_monitored_items()

void subscription_mgr__fill_response_subscription_set_monit_mode_monitored_items ( const constants__t_monitoringMode_i subscription_mgr__p_monitoring_mode, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_monitored_items )

extern

subscription_mgr__fill_set_publishing_mode_response()

void subscription_mgr__fill_set_publishing_mode_response ( const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_bool subscription_mgr__p_has_sub, const constants__t_subscription_i subscription_mgr__p_session_sub, const t_bool subscription_mgr__p_pub_enabled, const t_entier4 subscription_mgr__p_nb_reqs )

extern

subscription_mgr__local_check_filtered_subscription_and_monitored_item()

void subscription_mgr__local_check_filtered_subscription_and_monitored_item ( const constants__t_subscription_i subscription_mgr__p_opt_sub_to_filter, const constants__t_monitoredItemId_i subscription_mgr__p_opt_mi_to_fitler, const constants__t_subscription_i subscription_mgr__p_sub, const constants__t_monitoredItemId_i subscription_mgr__p_mi, t_bool *const subscription_mgr__bres )

extern

subscription_mgr__local_create_delete_notification_on_set_monit_mode_change()

void subscription_mgr__local_create_delete_notification_on_set_monit_mode_change ( const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer, const constants__t_monitoringMode_i subscription_mgr__p_prevMonitMode, const constants__t_monitoringMode_i subscription_mgr__p_newMonitMode )

extern

subscription_mgr__local_create_notification_if_node_changed_or_monitMode_enabling()

void subscription_mgr__local_create_notification_if_node_changed_or_monitMode_enabling ( const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer, const t_bool subscription_mgr__p_added_or_monitMode, const t_bool subscription_mgr__p_monitMode_enabling )

extern

subscription_mgr__local_create_notification_on_monitored_item_if_event_selected()

void subscription_mgr__local_create_notification_on_monitored_item_if_event_selected ( const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer, const constants__t_Event_i subscription_mgr__p_event, const constants__t_subscription_i subscription_mgr__p_sub_id, const constants__t_monitoredItemId_i subscription_mgr__p_mi_id )

extern

subscription_mgr__local_create_notification_on_monitored_items_if_data_changed()

void subscription_mgr__local_create_notification_on_monitored_items_if_data_changed ( const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer, const constants__t_WriteValuePointer_i subscription_mgr__p_old_wv_pointer, const constants__t_WriteValuePointer_i subscription_mgr__p_new_wv_pointer )

extern

subscription_mgr__local_create_notification_on_monitored_items_if_event_selected()

void subscription_mgr__local_create_notification_on_monitored_items_if_event_selected ( const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue, const constants__t_Event_i subscription_mgr__p_event, const constants__t_subscription_i subscription_mgr__p_sub_id, const constants__t_monitoredItemId_i subscription_mgr__p_mi_id )

extern

subscription_mgr__local_treat_create_monitored_item_index()

void subscription_mgr__local_treat_create_monitored_item_index ( const constants__t_session_i subscription_mgr__p_session, const constants__t_subscription_i subscription_mgr__p_subscription, const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn, const constants__t_user_i subscription_mgr__p_user, const constants__t_LocaleIds_i subscription_mgr__p_locales, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_index )

extern

subscription_mgr__local_treat_create_monitored_items()

void subscription_mgr__local_treat_create_monitored_items ( const constants__t_session_i subscription_mgr__p_session, const constants__t_subscription_i subscription_mgr__p_subscription, const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn, const constants__t_user_i subscription_mgr__p_user, const constants__t_LocaleIds_i subscription_mgr__p_locales, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, const t_entier4 subscription_mgr__p_nb_monitored_items )

extern

subscription_mgr__server_subscription_data_changed()

void subscription_mgr__server_subscription_data_changed ( const constants__t_WriteValuePointer_i subscription_mgr__p_old_write_value_pointer, const constants__t_WriteValuePointer_i subscription_mgr__p_new_write_value_pointer )

extern

subscription_mgr__server_subscription_event_triggered()

void subscription_mgr__server_subscription_event_triggered ( const constants__t_NodeId_i subscription_mgr__p_notifierId, const constants__t_Event_i subscription_mgr__p_event, const constants__t_subscription_i subscription_mgr__p_sub_id, const constants__t_monitoredItemId_i subscription_mgr__p_mi_id, t_bool *const subscription_mgr__bres )

extern

subscription_mgr__server_subscription_node_changed()

void subscription_mgr__server_subscription_node_changed ( const t_bool subscription_mgr__p_node_added, const constants__t_NodeId_i subscription_mgr__p_nid )

extern

subscription_mgr__server_subscription_publish_timeout()

void subscription_mgr__server_subscription_publish_timeout ( const constants__t_subscription_i subscription_mgr__p_subscription )

extern

subscription_mgr__server_subscription_session_inactive()

void subscription_mgr__server_subscription_session_inactive ( const constants__t_session_i subscription_mgr__p_session, const constants__t_sessionState_i subscription_mgr__p_newSessionState )

extern

subscription_mgr__subscription_mgr_UNINITIALISATION()

void subscription_mgr__subscription_mgr_UNINITIALISATION ( void )

extern

subscription_mgr__treat_create_subscription_request()

void subscription_mgr__treat_create_subscription_request ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern

subscription_mgr__treat_delete_subscriptions_request()

void subscription_mgr__treat_delete_subscriptions_request ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern

subscription_mgr__treat_modify_subscription_request()

void subscription_mgr__treat_modify_subscription_request ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern

subscription_mgr__treat_publishing_mode_request()

void subscription_mgr__treat_publishing_mode_request ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern

subscription_mgr__treat_subscription_create_monitored_items_req()

void subscription_mgr__treat_subscription_create_monitored_items_req ( const constants__t_session_i subscription_mgr__p_session, const constants__t_user_i subscription_mgr__p_user, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern

subscription_mgr__treat_subscription_delete_monitored_items_req()

void subscription_mgr__treat_subscription_delete_monitored_items_req ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern

subscription_mgr__treat_subscription_modify_monitored_items_req()

void subscription_mgr__treat_subscription_modify_monitored_items_req ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern

subscription_mgr__treat_subscription_publish_request()

void subscription_mgr__treat_subscription_publish_request ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_header_i subscription_mgr__p_req_header, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_server_request_handle_i subscription_mgr__p_req_handle, const constants__t_request_context_i subscription_mgr__p_req_ctx, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service, t_bool *const subscription_mgr__async_resp_msg )

extern

subscription_mgr__treat_subscription_republish_request()

void subscription_mgr__treat_subscription_republish_request ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern

subscription_mgr__treat_subscription_set_monit_mode_monitored_items_req()

void subscription_mgr__treat_subscription_set_monit_mode_monitored_items_req ( const constants__t_session_i subscription_mgr__p_session, const constants__t_msg_i subscription_mgr__p_req_msg, const constants__t_msg_i subscription_mgr__p_resp_msg, constants_statuscodes_bs__t_StatusCode_i *const subscription_mgr__StatusCode_service )

extern