S2OPC OPCUA Toolkit: /builds/systerel/test-for-analyses-s2opc/src/ClientServer/services/bgenc/subscription_core

#include "b2c.h"
#include "channel_mgr.h"
#include "constants.h"
#include "message_in_bs.h"
#include "message_out_bs.h"
#include "request_handle_bs.h"

Go to the source code of this file.

Functions
void	subscription_core_1__INITIALISATION (void)

void	subscription_core_1__add_subscription (const constants__t_subscription_i subscription_core_1__p_subscription, const constants__t_session_i subscription_core_1__p_session, const constants__t_opcua_duration_i subscription_core_1__p_revPublishInterval, const t_entier4 subscription_core_1__p_revLifetimeCount, const t_entier4 subscription_core_1__p_revMaxKeepAlive, const t_entier4 subscription_core_1__p_maxNotificationsPerPublish, const t_bool subscription_core_1__p_publishEnabled, const constants__t_publishReqQueue_i subscription_core_1__p_publishQueue, const constants__t_notifRepublishQueue_i subscription_core_1__p_republishQueue, const constants__t_monitoredItemQueue_i subscription_core_1__p_monitoredItemQueue, const constants__t_timer_id_i subscription_core_1__p_timerId)

void	subscription_core_1__decrement_subscription_KeepAliveCounter (const constants__t_subscription_i subscription_core_1__p_subscription)

void	subscription_core_1__decrement_subscription_LifetimeCounter (const constants__t_subscription_i subscription_core_1__p_subscription)

void	subscription_core_1__delete_subscription (const constants__t_subscription_i subscription_core_1__p_subscription)

void	subscription_core_1__get_subscription_KeepAliveCounter (const constants__t_subscription_i subscription_core_1__p_subscription, t_entier4 *const subscription_core_1__p_keepAliveCounter)

void	subscription_core_1__get_subscription_LifetimeCounter (const constants__t_subscription_i subscription_core_1__p_subscription, t_entier4 *const subscription_core_1__p_lifetimeCounter)

void	subscription_core_1__get_subscription_MaxNotifsPerPublish (const constants__t_subscription_i subscription_core_1__p_subscription, t_entier4 *const subscription_core_1__p_maxNotificationsPerPublish)

void	subscription_core_1__get_subscription_MessageSent (const constants__t_subscription_i subscription_core_1__p_subscription, t_bool *const subscription_core_1__p_firstMsgSent)

void	subscription_core_1__get_subscription_MoreNotifications (const constants__t_subscription_i subscription_core_1__p_subscription, t_bool *const subscription_core_1__p_moreNotifs)

void	subscription_core_1__get_subscription_PublishingEnabled (const constants__t_subscription_i subscription_core_1__p_subscription, t_bool *const subscription_core_1__p_pubEnabled)

void	subscription_core_1__get_subscription_SeqNum (const constants__t_subscription_i subscription_core_1__p_subscription, constants__t_sub_seq_num_i *const subscription_core_1__p_seqNumToSend)

void	subscription_core_1__get_subscription_monitoredItemQueue (const constants__t_subscription_i subscription_core_1__p_subscription, constants__t_monitoredItemQueue_i *const subscription_core_1__p_monitoredItemQueue)

void	subscription_core_1__get_subscription_notifRepublishQueue (const constants__t_subscription_i subscription_core_1__p_subscription, constants__t_notifRepublishQueue_i *const subscription_core_1__p_republishQueue)

void	subscription_core_1__get_subscription_publishInterval (const constants__t_subscription_i subscription_core_1__p_subscription, constants__t_opcua_duration_i *const subscription_core_1__p_publishInterval)

void	subscription_core_1__get_subscription_publishRequestQueue (const constants__t_subscription_i subscription_core_1__p_subscription, constants__t_publishReqQueue_i *const subscription_core_1__p_publishReqQueue)

void	subscription_core_1__get_subscription_state (const constants__t_subscription_i subscription_core_1__p_subscription, constants__t_subscriptionState_i *const subscription_core_1__p_state)

void	subscription_core_1__get_subscription_timer_id (const constants__t_subscription_i subscription_core_1__p_subscription, constants__t_timer_id_i *const subscription_core_1__p_timer_id)

void	subscription_core_1__getall_session (const constants__t_subscription_i subscription_core_1__p_subscription, constants__t_session_i *const subscription_core_1__p_session)

void	subscription_core_1__getall_subscription (const constants__t_session_i subscription_core_1__p_session, t_bool const subscription_core_1__p_dom, constants__t_subscription_i const subscription_core_1__p_subscription)

void	subscription_core_1__is_valid_subscription (const constants__t_subscription_i subscription_core_1__p_subscription, t_bool *const subscription_core_1__is_valid)

void	subscription_core_1__reset_subscription_KeepAliveCounter (const constants__t_subscription_i subscription_core_1__p_subscription)

void	subscription_core_1__reset_subscription_LifetimeCounter (const constants__t_subscription_i subscription_core_1__p_subscription)

void	subscription_core_1__set_subscription_MaxLifetimeAndKeepAliveCount (const constants__t_subscription_i subscription_core_1__p_subscription, const t_entier4 subscription_core_1__p_revLifetimeCount, const t_entier4 subscription_core_1__p_revMaxKeepAlive)

void	subscription_core_1__set_subscription_MaxNotifsPerPublish (const constants__t_subscription_i subscription_core_1__p_subscription, const t_entier4 subscription_core_1__p_maxNotificationsPerPublish)

void	subscription_core_1__set_subscription_MessageSent (const constants__t_subscription_i subscription_core_1__p_subscription)

void	subscription_core_1__set_subscription_MoreNotifications (const constants__t_subscription_i subscription_core_1__p_subscription, const t_bool subscription_core_1__p_moreNotifs)

void	subscription_core_1__set_subscription_PublishingEnabled (const constants__t_subscription_i subscription_core_1__p_subscription, const t_bool subscription_core_1__p_pubEnabled)

void	subscription_core_1__set_subscription_SeqNum (const constants__t_subscription_i subscription_core_1__p_subscription, const constants__t_sub_seq_num_i subscription_core_1__p_nextSeqNum)

void	subscription_core_1__set_subscription_publishInterval (const constants__t_subscription_i subscription_core_1__p_subscription, const constants__t_opcua_duration_i subscription_core_1__p_revPublishInterval)

void	subscription_core_1__set_subscription_state (const constants__t_subscription_i subscription_core_1__p_subscription, const constants__t_subscriptionState_i subscription_core_1__p_state)

void	subscription_core_1__set_subscription_timer_id (const constants__t_subscription_i subscription_core_1__p_subscription, const constants__t_timer_id_i subscription_core_1__p_timer_id)

Variables
t_entier4	subscription_core_1__a_KeepAliveCounter_i [constants__t_subscription_i_max+1]

t_entier4	subscription_core_1__a_LifetimeCounter_i [constants__t_subscription_i_max+1]

t_bool	subscription_core_1__a_MessageSent_i [constants__t_subscription_i_max+1]

t_bool	subscription_core_1__a_MoreNotifications_i [constants__t_subscription_i_max+1]

t_bool	subscription_core_1__a_PublishingEnabled_i [constants__t_subscription_i_max+1]

constants__t_sub_seq_num_i	subscription_core_1__a_SeqNum_i [constants__t_subscription_i_max+1]

t_entier4	subscription_core_1__a_keepAliveExpCount_i [constants__t_subscription_i_max+1]

t_entier4	subscription_core_1__a_lifetimeExpCount_i [constants__t_subscription_i_max+1]

t_entier4	subscription_core_1__a_maxNotifsPerPublish_i [constants__t_subscription_i_max+1]

constants__t_monitoredItemQueue_i	subscription_core_1__a_monitoredItemQueue_i [constants__t_subscription_i_max+1]

constants__t_notifRepublishQueue_i	subscription_core_1__a_notifRepublishQueue_i [constants__t_subscription_i_max+1]

constants__t_opcua_duration_i	subscription_core_1__a_publishInterval_i [constants__t_subscription_i_max+1]

constants__t_publishReqQueue_i	subscription_core_1__a_publishRequestQueue_i [constants__t_subscription_i_max+1]

constants__t_timer_id_i	subscription_core_1__a_publishTimer_i [constants__t_subscription_i_max+1]

constants__t_subscription_i	subscription_core_1__a_session_subscription_i [constants__t_session_i_max+1]

constants__t_session_i	subscription_core_1__a_subscription_session_i [constants__t_subscription_i_max+1]

constants__t_subscriptionState_i	subscription_core_1__a_subscription_state_i [constants__t_subscription_i_max+1]

t_bool	subscription_core_1__s_subscription_i [constants__t_subscription_i_max+1]

Function Documentation

◆ subscription_core_1__INITIALISATION()

void subscription_core_1__INITIALISATION ( void )

extern

◆ subscription_core_1__add_subscription()

void subscription_core_1__add_subscription	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const constants__t_session_i	subscription_core_1__p_session,
		const constants__t_opcua_duration_i	subscription_core_1__p_revPublishInterval,
		const t_entier4	subscription_core_1__p_revLifetimeCount,
		const t_entier4	subscription_core_1__p_revMaxKeepAlive,
		const t_entier4	subscription_core_1__p_maxNotificationsPerPublish,
		const t_bool	subscription_core_1__p_publishEnabled,
		const constants__t_publishReqQueue_i	subscription_core_1__p_publishQueue,
		const constants__t_notifRepublishQueue_i	subscription_core_1__p_republishQueue,
		const constants__t_monitoredItemQueue_i	subscription_core_1__p_monitoredItemQueue,
		const constants__t_timer_id_i	subscription_core_1__p_timerId )

extern

◆ subscription_core_1__decrement_subscription_KeepAliveCounter()

void subscription_core_1__decrement_subscription_KeepAliveCounter ( const constants__t_subscription_i subscription_core_1__p_subscription )

extern

◆ subscription_core_1__decrement_subscription_LifetimeCounter()

void subscription_core_1__decrement_subscription_LifetimeCounter ( const constants__t_subscription_i subscription_core_1__p_subscription )

extern

◆ subscription_core_1__delete_subscription()

void subscription_core_1__delete_subscription ( const constants__t_subscription_i subscription_core_1__p_subscription )

extern

◆ subscription_core_1__get_subscription_KeepAliveCounter()

void subscription_core_1__get_subscription_KeepAliveCounter	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		t_entier4 *const	subscription_core_1__p_keepAliveCounter )

extern

◆ subscription_core_1__get_subscription_LifetimeCounter()

void subscription_core_1__get_subscription_LifetimeCounter	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		t_entier4 *const	subscription_core_1__p_lifetimeCounter )

extern

◆ subscription_core_1__get_subscription_MaxNotifsPerPublish()

void subscription_core_1__get_subscription_MaxNotifsPerPublish	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		t_entier4 *const	subscription_core_1__p_maxNotificationsPerPublish )

extern

◆ subscription_core_1__get_subscription_MessageSent()

void subscription_core_1__get_subscription_MessageSent	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		t_bool *const	subscription_core_1__p_firstMsgSent )

extern

◆ subscription_core_1__get_subscription_MoreNotifications()

void subscription_core_1__get_subscription_MoreNotifications	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		t_bool *const	subscription_core_1__p_moreNotifs )

extern

◆ subscription_core_1__get_subscription_PublishingEnabled()

void subscription_core_1__get_subscription_PublishingEnabled	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		t_bool *const	subscription_core_1__p_pubEnabled )

extern

◆ subscription_core_1__get_subscription_SeqNum()

void subscription_core_1__get_subscription_SeqNum	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		constants__t_sub_seq_num_i *const	subscription_core_1__p_seqNumToSend )

extern

◆ subscription_core_1__get_subscription_monitoredItemQueue()

void subscription_core_1__get_subscription_monitoredItemQueue	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		constants__t_monitoredItemQueue_i *const	subscription_core_1__p_monitoredItemQueue )

extern

◆ subscription_core_1__get_subscription_notifRepublishQueue()

void subscription_core_1__get_subscription_notifRepublishQueue	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		constants__t_notifRepublishQueue_i *const	subscription_core_1__p_republishQueue )

extern

◆ subscription_core_1__get_subscription_publishInterval()

void subscription_core_1__get_subscription_publishInterval	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		constants__t_opcua_duration_i *const	subscription_core_1__p_publishInterval )

extern

◆ subscription_core_1__get_subscription_publishRequestQueue()

void subscription_core_1__get_subscription_publishRequestQueue	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		constants__t_publishReqQueue_i *const	subscription_core_1__p_publishReqQueue )

extern

◆ subscription_core_1__get_subscription_state()

void subscription_core_1__get_subscription_state	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		constants__t_subscriptionState_i *const	subscription_core_1__p_state )

extern

◆ subscription_core_1__get_subscription_timer_id()

void subscription_core_1__get_subscription_timer_id	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		constants__t_timer_id_i *const	subscription_core_1__p_timer_id )

extern

◆ subscription_core_1__getall_session()

void subscription_core_1__getall_session	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		constants__t_session_i *const	subscription_core_1__p_session )

extern

◆ subscription_core_1__getall_subscription()

void subscription_core_1__getall_subscription	(	const constants__t_session_i	subscription_core_1__p_session,
		t_bool *const	subscription_core_1__p_dom,
		constants__t_subscription_i *const	subscription_core_1__p_subscription )

extern

◆ subscription_core_1__is_valid_subscription()

void subscription_core_1__is_valid_subscription	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		t_bool *const	subscription_core_1__is_valid )

extern

◆ subscription_core_1__reset_subscription_KeepAliveCounter()

void subscription_core_1__reset_subscription_KeepAliveCounter ( const constants__t_subscription_i subscription_core_1__p_subscription )

extern

◆ subscription_core_1__reset_subscription_LifetimeCounter()

void subscription_core_1__reset_subscription_LifetimeCounter ( const constants__t_subscription_i subscription_core_1__p_subscription )

extern

◆ subscription_core_1__set_subscription_MaxLifetimeAndKeepAliveCount()

void subscription_core_1__set_subscription_MaxLifetimeAndKeepAliveCount	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const t_entier4	subscription_core_1__p_revLifetimeCount,
		const t_entier4	subscription_core_1__p_revMaxKeepAlive )

extern

◆ subscription_core_1__set_subscription_MaxNotifsPerPublish()

void subscription_core_1__set_subscription_MaxNotifsPerPublish	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const t_entier4	subscription_core_1__p_maxNotificationsPerPublish )

extern

◆ subscription_core_1__set_subscription_MessageSent()

void subscription_core_1__set_subscription_MessageSent ( const constants__t_subscription_i subscription_core_1__p_subscription )

extern

◆ subscription_core_1__set_subscription_MoreNotifications()

void subscription_core_1__set_subscription_MoreNotifications	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const t_bool	subscription_core_1__p_moreNotifs )

extern

◆ subscription_core_1__set_subscription_PublishingEnabled()

void subscription_core_1__set_subscription_PublishingEnabled	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const t_bool	subscription_core_1__p_pubEnabled )

extern

◆ subscription_core_1__set_subscription_SeqNum()

void subscription_core_1__set_subscription_SeqNum	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const constants__t_sub_seq_num_i	subscription_core_1__p_nextSeqNum )

extern

◆ subscription_core_1__set_subscription_publishInterval()

void subscription_core_1__set_subscription_publishInterval	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const constants__t_opcua_duration_i	subscription_core_1__p_revPublishInterval )

extern

◆ subscription_core_1__set_subscription_state()

void subscription_core_1__set_subscription_state	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const constants__t_subscriptionState_i	subscription_core_1__p_state )

extern

◆ subscription_core_1__set_subscription_timer_id()

void subscription_core_1__set_subscription_timer_id	(	const constants__t_subscription_i	subscription_core_1__p_subscription,
		const constants__t_timer_id_i	subscription_core_1__p_timer_id )

extern

Variable Documentation

◆ subscription_core_1__a_KeepAliveCounter_i

t_entier4 subscription_core_1__a_KeepAliveCounter_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_LifetimeCounter_i

t_entier4 subscription_core_1__a_LifetimeCounter_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_MessageSent_i

t_bool subscription_core_1__a_MessageSent_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_MoreNotifications_i

t_bool subscription_core_1__a_MoreNotifications_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_PublishingEnabled_i

t_bool subscription_core_1__a_PublishingEnabled_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_SeqNum_i

constants__t_sub_seq_num_i subscription_core_1__a_SeqNum_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_keepAliveExpCount_i

t_entier4 subscription_core_1__a_keepAliveExpCount_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_lifetimeExpCount_i

t_entier4 subscription_core_1__a_lifetimeExpCount_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_maxNotifsPerPublish_i

t_entier4 subscription_core_1__a_maxNotifsPerPublish_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_monitoredItemQueue_i

constants__t_monitoredItemQueue_i subscription_core_1__a_monitoredItemQueue_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_notifRepublishQueue_i

constants__t_notifRepublishQueue_i subscription_core_1__a_notifRepublishQueue_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_publishInterval_i

constants__t_opcua_duration_i subscription_core_1__a_publishInterval_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_publishRequestQueue_i

constants__t_publishReqQueue_i subscription_core_1__a_publishRequestQueue_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_publishTimer_i

constants__t_timer_id_i subscription_core_1__a_publishTimer_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_session_subscription_i

constants__t_subscription_i subscription_core_1__a_session_subscription_i[constants__t_session_i_max+1]

extern

◆ subscription_core_1__a_subscription_session_i

constants__t_session_i subscription_core_1__a_subscription_session_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__a_subscription_state_i

constants__t_subscriptionState_i subscription_core_1__a_subscription_state_i[constants__t_subscription_i_max+1]

extern

◆ subscription_core_1__s_subscription_i

t_bool subscription_core_1__s_subscription_i[constants__t_subscription_i_max+1]

extern

Functions

Variables

Function Documentation

◆ subscription_core_1__INITIALISATION()

◆ subscription_core_1__add_subscription()

◆ subscription_core_1__decrement_subscription_KeepAliveCounter()

◆ subscription_core_1__decrement_subscription_LifetimeCounter()

◆ subscription_core_1__delete_subscription()

◆ subscription_core_1__get_subscription_KeepAliveCounter()

◆ subscription_core_1__get_subscription_LifetimeCounter()

◆ subscription_core_1__get_subscription_MaxNotifsPerPublish()

◆ subscription_core_1__get_subscription_MessageSent()

◆ subscription_core_1__get_subscription_MoreNotifications()

◆ subscription_core_1__get_subscription_PublishingEnabled()

◆ subscription_core_1__get_subscription_SeqNum()

◆ subscription_core_1__get_subscription_monitoredItemQueue()

◆ subscription_core_1__get_subscription_notifRepublishQueue()

◆ subscription_core_1__get_subscription_publishInterval()

◆ subscription_core_1__get_subscription_publishRequestQueue()

◆ subscription_core_1__get_subscription_state()

◆ subscription_core_1__get_subscription_timer_id()

◆ subscription_core_1__getall_session()

◆ subscription_core_1__getall_subscription()

◆ subscription_core_1__is_valid_subscription()

◆ subscription_core_1__reset_subscription_KeepAliveCounter()

◆ subscription_core_1__reset_subscription_LifetimeCounter()

◆ subscription_core_1__set_subscription_MaxLifetimeAndKeepAliveCount()

◆ subscription_core_1__set_subscription_MaxNotifsPerPublish()

◆ subscription_core_1__set_subscription_MessageSent()

◆ subscription_core_1__set_subscription_MoreNotifications()

◆ subscription_core_1__set_subscription_PublishingEnabled()

◆ subscription_core_1__set_subscription_SeqNum()

◆ subscription_core_1__set_subscription_publishInterval()

◆ subscription_core_1__set_subscription_state()

◆ subscription_core_1__set_subscription_timer_id()

Variable Documentation

◆ subscription_core_1__a_KeepAliveCounter_i

◆ subscription_core_1__a_LifetimeCounter_i

◆ subscription_core_1__a_MessageSent_i

◆ subscription_core_1__a_MoreNotifications_i

◆ subscription_core_1__a_PublishingEnabled_i

◆ subscription_core_1__a_SeqNum_i

◆ subscription_core_1__a_keepAliveExpCount_i

◆ subscription_core_1__a_lifetimeExpCount_i

◆ subscription_core_1__a_maxNotifsPerPublish_i

◆ subscription_core_1__a_monitoredItemQueue_i

◆ subscription_core_1__a_notifRepublishQueue_i

◆ subscription_core_1__a_publishInterval_i

◆ subscription_core_1__a_publishRequestQueue_i

◆ subscription_core_1__a_publishTimer_i

◆ subscription_core_1__a_session_subscription_i

◆ subscription_core_1__a_subscription_session_i

◆ subscription_core_1__a_subscription_state_i

◆ subscription_core_1__s_subscription_i