diff options
| author |   Fulup Ar Foll <fulup@iot.bzh> | 2017-05-26 18:45:56 +0200 |
|---|---|---|
| committer | Fulup Ar Foll <fulup@iot.bzh> | 2017-05-26 18:45:56 +0200 |
| commit | d2e42029ec04c3f224580f8007cdfbbfe0fc47a6 (patch) | |
| tree | ad2ccf167cf7997c84191d41e6ba55cb2efd6bed /ucs2-lib/src/ucs_inic_res.c | |
| parent | 18e393e1443fd4c38b34979888fb55d30448cf31 (diff) | |
Initial Commit
Diffstat (limited to 'ucs2-lib/src/ucs_inic_res.c')
| -rw-r--r-- | ucs2-lib/src/ucs_inic_res.c | 3735 |
1 files changed, 3735 insertions, 0 deletions
diff --git a/ucs2-lib/src/ucs_inic_res.c b/ucs2-lib/src/ucs_inic_res.c new file mode 100644 index 0000000..b9ab104 --- /dev/null +++ b/ucs2-lib/src/ucs_inic_res.c @@ -0,0 +1,3735 @@ +/*------------------------------------------------------------------------------------------------*/ +/* UNICENS V2.1.0-3491 */ +/* Copyright (c) 2017 Microchip Technology Germany II GmbH & Co. KG. */ +/* */ +/* This program is free software: you can redistribute it and/or modify */ +/* it under the terms of the GNU General Public License as published by */ +/* the Free Software Foundation, either version 2 of the License, or */ +/* (at your option) any later version. */ +/* */ +/* This program is distributed in the hope that it will be useful, */ +/* but WITHOUT ANY WARRANTY; without even the implied warranty of */ +/* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the */ +/* GNU General Public License for more details. */ +/* */ +/* You should have received a copy of the GNU General Public License */ +/* along with this program. If not, see <http://www.gnu.org/licenses/>. */ +/* */ +/* You may also obtain this software under a propriety license from Microchip. */ +/* Please contact Microchip for further information. */ +/*------------------------------------------------------------------------------------------------*/ + +/*! + * \file + * \brief Implementation of FBlock INIC (resource management parts of INIC management) + * \details Contains the resource management parts of INIC management + * + * \cond UCS_INTERNAL_DOC + * \addtogroup G_INIC + * @{ + */ + +/*------------------------------------------------------------------------------------------------*/ +/* Includes */ +/*------------------------------------------------------------------------------------------------*/ +#include "ucs_misc.h" +#include "ucs_ret_pb.h" +#include "ucs_inic.h" +#include "ucs_base.h" + +/*------------------------------------------------------------------------------------------------*/ +/* Internal macros */ +/*------------------------------------------------------------------------------------------------*/ +/*! \brief API locking Bitmask for all INIC create methods. */ +#define INIC_API_CREATE_CLASS 0x0001U +/*! \brief API locking Bitmask of method Inic_ResourceDestroy(). */ +#define INIC_API_RESOURCE_DESTROY 0x0002U +/*! \brief API locking Bitmask of method Inic_ResourceInvalidList_Get(). */ +#define INIC_API_RESOURCE_INVAL_LIST 0x0004U +/*! \brief API locking Bitmask of method Inic_Notification_Set(). */ +#define INIC_API_NOTIFICATION 0x0008U +/*! \brief API locking Bitmask of method Inic_StreamPortConfig_Get(). */ +#define INIC_API_STREAM_PORT_CONFIG 0x0010U +/*! \brief API locking Bitmask of method Inic_SyncMute(). */ +#define INIC_API_SYNC_MUTE 0x0020U +/*! \brief API locking Bitmask of method Inic_SyncDemute(). */ +#define INIC_API_SYNC_DEMUTE 0x0040U +/*! \brief API locking Bitmask of method Inic_MostPortEnable(). */ +#define INIC_API_MOST_PORT_ENABLE 0x0080U +/*! \brief API locking Bitmask of method Inic_MostPortEnFullStr(). */ +#define INIC_API_MOST_PORT_EN_FULL_STR 0x0100U +/*! \brief API locking Bitmask of method Inic_GpioPortPinMode_SetGet(). */ +#define INIC_API_GPIO_PIN_MODE 0x0200U +/*! \brief API locking Bitmask of method Inic_GpioPortPinState_SetGet(). */ +#define INIC_API_GPIO_PIN_STATE 0x0400U +/*! \brief API locking Bitmask of methods Inic_I2cPortRead_StartResultAck() and Inic_I2cPortWrite_StartResultAck(). */ +#define INIC_API_I2C_PORT_WR 0x0800U +/*! \brief Bitmask for API method Inic_DeviceSync() used by API locking manager */ +#define INIC_API_DEVICE_SYNC 0x1000U + +/*------------------------------------------------------------------------------------------------*/ +/* Internal prototypes */ +/*------------------------------------------------------------------------------------------------*/ +static void Inic_HandleResApiTimeout(void *self, void *method_mask_ptr); +static void Inic_ResMsgTxStatusCb(void *self, Msg_MostTel_t *tel_ptr, Ucs_MsgTxStatus_t status); + +/*------------------------------------------------------------------------------------------------*/ +/* Implementation */ +/*------------------------------------------------------------------------------------------------*/ +/*! \brief Initialization function of the INIC Resource Management part. Called by Inic_Ctor(). + * \param self Instance pointer + */ +void Inic_InitResourceManagement(CInic *self) +{ + Sobs_Ctor(&self->lock.res_observer, self, &Inic_HandleResApiTimeout); + Al_Ctor(&self->lock.res_api, &self->lock.res_observer, self->base_ptr->ucs_user_ptr); + Alm_RegisterApi(&self->base_ptr->alm, &self->lock.res_api); + + /* initializes the gpio report time status */ + self->gpio_rt_status.first_report = true; +} + +/*! \brief Handles an API timeout + * \param self Instance pointer + * \param method_mask_ptr Bitmask to signal which API method has caused the timeout + */ +static void Inic_HandleResApiTimeout(void *self, void *method_mask_ptr) +{ + CInic *self_ = (CInic *)self; + Alm_ModuleMask_t method_mask = *((Alm_ModuleMask_t *)method_mask_ptr); + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result.code = UCS_RES_ERR_TIMEOUT; + res_data.result.info_ptr = NULL; + + switch(method_mask) + { + case INIC_API_CREATE_CLASS: + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for INIC create method.", 0U)); + break; + case INIC_API_RESOURCE_DESTROY: + Ssub_Notify(&self_->ssubs[INIC_SSUB_RESOURCE_DESTROY], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_ResourceDestroy().", 0U)); + break; + case INIC_API_RESOURCE_INVAL_LIST: + Ssub_Notify(&self_->ssubs[INIC_SSUB_RESOURCE_INVAL_LIST], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_ResourceInvalidList_Get().", 0U)); + break; + case INIC_API_NOTIFICATION: + Ssub_Notify(&self_->ssubs[INIC_SSUB_NOTIFICATION], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_Notification_Get().", 0U)); + break; + case INIC_API_STREAM_PORT_CONFIG: + Ssub_Notify(&self_->ssubs[INIC_SSUB_STREAM_PORT_CONFIG], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_StreamPortConfig_Get().", 0U)); + break; + case INIC_API_SYNC_MUTE: + Ssub_Notify(&self_->ssubs[INIC_SSUB_SYNC_MUTE], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_SyncMute().", 0U)); + break; + case INIC_API_SYNC_DEMUTE: + Ssub_Notify(&self_->ssubs[INIC_SSUB_SYNC_DEMUTE], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_SyncDemute().", 0U)); + break; + case INIC_API_MOST_PORT_ENABLE: + Ssub_Notify(&self_->ssubs[INIC_SSUB_MOST_PORT_ENABLE], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_MostPortEnable().", 0U)); + break; + case INIC_API_MOST_PORT_EN_FULL_STR: + Ssub_Notify(&self_->ssubs[INIC_SSUB_MOST_PORT_EN_FULL_STR], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_MostPortEnFullStr().", 0U)); + break; + case INIC_API_GPIO_PIN_MODE: + Ssub_Notify(&self_->ssubs[INIC_SSUB_GPIO_PIN_MODE], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_GpioPortPinMode_SetGet().", 0U)); + break; + case INIC_API_GPIO_PIN_STATE: + Ssub_Notify(&self_->ssubs[INIC_SSUB_GPIO_PIN_STATE], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_GpioPortPinState_SetGet().", 0U)); + break; + case INIC_API_DEVICE_SYNC: + Ssub_Notify(&self_->ssubs[INIC_SSUB_DEVICE_SYNC], &res_data, true); + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "API locking timeout occurred for method Inic_DeviceSync_StartResult().", 0U)); + break; + default: + TR_ERROR((self_->base_ptr->ucs_user_ptr, "[INIC_RES]", "Unknown API locking bitmask detected. Mask: 0x%02X", 1U, method_mask)); + break; + } +} + +/*! \brief Add an observer to the ResourceMonitor subject + * \param self Instance of CInic + * \param obs_ptr Pointer to observer to be informed + */ +void Inic_AddObsrvResMonitor(CInic *self, CObserver *obs_ptr) +{ + (void)Sub_AddObserver(&self->subs[INIC_SUB_RES_MONITOR], obs_ptr); +} + +/*! \brief Delete an observer from the ResourceMonitor subject + * \param self Instance of CInic + * \param obs_ptr Pointer to observer to be informed + */ +void Inic_DelObsrvResMonitor(CInic *self, CObserver *obs_ptr) +{ + (void)Sub_RemoveObserver(&self->subs[INIC_SUB_RES_MONITOR], obs_ptr); +} + +/*! \brief Add an observer to the MOSTPortStatus subject + * \param self Instance of CInic + * \param obs_ptr Pointer to observer to be informed + */ +void Inic_AddObsrvMostPortStatus(CInic *self, CObserver *obs_ptr) +{ + if (Sub_AddObserver(&self->subs[INIC_SUB_MOST_PORT_STATUS], obs_ptr) != SUB_UNKNOWN_OBSERVER) + { + Sub_Notify(&self->subs[INIC_SUB_MOST_PORT_STATUS], &self->most_port_status); + } +} + +/*! \brief Delete an observer from the MOSTPortStatus subject + * \param self Instance of CInic + * \param obs_ptr Pointer to observer to be informed + */ +void Inic_DelObsrvMostPortStatus(CInic *self, CObserver *obs_ptr) +{ + (void)Sub_RemoveObserver(&self->subs[INIC_SUB_MOST_PORT_STATUS], obs_ptr); +} + +/*! \brief Add an observer to the GpioTriggerEvent subject + * \param self Instance of CInic + * \param obs_ptr Pointer to observer to be informed + */ +void Inic_AddObsrvGpioTriggerEvent(CInic *self, CObserver *obs_ptr) +{ + (void)Sub_AddObserver(&self->subs[INIC_SUB_GPIO_TRIGGER_EVENT], obs_ptr); +} + +/*! \brief Removes an observer from the GpioTriggerEvent subject + * \param self Instance of CInic + * \param obs_ptr Pointer to observer to be informed + */ +void Inic_DelObsrvGpioTriggerEvent(CInic *self, CObserver *obs_ptr) +{ + (void)Sub_RemoveObserver(&self->subs[INIC_SUB_GPIO_TRIGGER_EVENT], obs_ptr); +} + +/*! \brief Destroys the resources associated with the given resource handles + * \param self Reference to CInic instance + * \param res_handle_list resource handle list + * \param obs_ptr Reference to an optional observer. The result must be casted into type + * Inic_StdResult_t. + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + * \return UCS_RET_ERR_PARAM Wrong length of resource handle list + */ +Ucs_Return_t Inic_ResourceDestroy(CInic *self, + Inic_ResHandleList_t res_handle_list, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + uint8_t len; + + if(Al_Lock(&self->lock.res_api, INIC_API_RESOURCE_DESTROY) != false) + { + /* sender handle + number of resource handles */ + len = 2U * res_handle_list.num_handles; + + if ((len == 0U) || ((MAX_INVALID_HANDLES_LIST << 1) < len)) + { + Al_Release(&self->lock.res_api, INIC_API_RESOURCE_DESTROY); + result = UCS_RET_ERR_PARAM; + } + else + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, len); + + if (msg_ptr != NULL) + { + uint8_t i; + + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_RESOURCE_DESTROY; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + for (i=0U; i < res_handle_list.num_handles; ++i) + { + msg_ptr->tel.tel_data_ptr[2U*i] = MISC_HB(res_handle_list.res_handles[i]); + msg_ptr->tel.tel_data_ptr[1U + (2U*i)] = MISC_LB(res_handle_list.res_handles[i]); + } + + self->ssubs[INIC_SSUB_RESOURCE_DESTROY].user_mask = INIC_API_RESOURCE_DESTROY; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_RESOURCE_DESTROY]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_RESOURCE_DESTROY], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_RESOURCE_DESTROY); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Retrieves the list of invalid resources + * \param self Reference to CInic instance + * \param obs_ptr Reference to an optional observer. The result must be casted into type + * Inic_StdResult_t. + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_ResourceInvalidList_Get(CInic *self, CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_RESOURCE_INVAL_LIST) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 0U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_RESOURCE_INVALID_LIST; + msg_ptr->id.op_type = UCS_OP_GET; + + self->ssubs[INIC_SSUB_RESOURCE_INVAL_LIST].user_mask = INIC_API_RESOURCE_INVAL_LIST; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_RESOURCE_INVAL_LIST]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_RESOURCE_INVAL_LIST], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_RESOURCE_INVAL_LIST); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Resets the resource monitor back to its default state. + * \param self Reference to CInic instance + * \param control Used to reset the resource monitor + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + */ +Ucs_Return_t Inic_ResourceMonitor_Set(CInic *self, Ucs_Resource_MonitorCtrl_t control) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 1U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_RESOURCE_MONITOR; + msg_ptr->id.op_type = UCS_OP_SET; + msg_ptr->tel.tel_data_ptr[0] = (uint8_t)control; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + } + else + { + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + + return result; +} + +/*! \brief Triggers notification of the given function_id list. + * \param self Reference to CInic instance + * \param control control command used + * \param device_id Id of the sending device (local node address). + * \param fktid_list function ids list. + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_PARAM parameter exceeds its admissible range was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + */ +Ucs_Return_t Inic_Notification_Set(CInic *self, Ucs_Inic_NotificationCtrl_t control, uint16_t device_id, Inic_FktIdList_t fktid_list) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + /* control + device_id + size of the funcids list */ + uint8_t len = 1U + 2U + (2U * fktid_list.num_fktids); + + if (len > MSG_MAX_SIZE_PAYLOAD) + { + result = UCS_RET_ERR_PARAM; + } + else + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, len); + + if (msg_ptr != NULL) + { + uint8_t i; + + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_NOTIFICATION; + msg_ptr->id.op_type = UCS_OP_SET; + + msg_ptr->tel.tel_data_ptr[0] = (uint8_t)control; + msg_ptr->tel.tel_data_ptr[1] = MISC_HB(device_id); + msg_ptr->tel.tel_data_ptr[2] = MISC_LB(device_id); + + if ((len > 3U) && (fktid_list.fktids_ptr != NULL) ) + { + for (i=0U; i < fktid_list.num_fktids; ++i) + { + msg_ptr->tel.tel_data_ptr[3U+(2U*i)] = MISC_HB(fktid_list.fktids_ptr[i]); + msg_ptr->tel.tel_data_ptr[4U+(2U*i)] = MISC_LB(fktid_list.fktids_ptr[i]); + } + } + + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_NOTIFICATION]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + } + else + { + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + + return result; +} + +/*! \brief Gets the device id that has notified the given function_id + * \param self Reference to CInic instance + * \param fktid The function id to be looked for + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_Notification_Get(CInic *self, uint16_t fktid, CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_NOTIFICATION) != false) + { + Msg_MostTel_t * msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 2U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_NOTIFICATION; + msg_ptr->id.op_type = UCS_OP_GET; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(fktid); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(fktid); + + self->ssubs[INIC_SSUB_NOTIFICATION].user_mask = INIC_API_NOTIFICATION; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_NOTIFICATION]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_NOTIFICATION], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_NOTIFICATION); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates a synchronous data connection. The connection can be directly associated with + * an input and output socket. + * \param self Reference to CInic instance + * \param resource_handle_in The ID number of the socket or splitter resource that is the + * starting point of the link. + * \param resource_handle_out The ID number of the socket or splitter resource that is the ending + * point of the link. + * \param default_mute specifies if the connection is muted by default + * \param mute_mode Configures how the resource monitor shall handle events that may + * the streamed data invalid. + * \param offset Denotes the offset from/to where data from/to a socket should be + * routed from/to a splitter/combiner. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_SyncCreate(CInic *self, + uint16_t resource_handle_in, + uint16_t resource_handle_out, + bool default_mute, + Ucs_Sync_MuteMode_t mute_mode, + uint16_t offset, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 8U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_SYNC_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(resource_handle_in); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(resource_handle_in); + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(resource_handle_out); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(resource_handle_out); + msg_ptr->tel.tel_data_ptr[4] = (default_mute != false) ? 1U : 0U; + msg_ptr->tel.tel_data_ptr[5] = (uint8_t)mute_mode; + msg_ptr->tel.tel_data_ptr[6] = MISC_HB(offset); + msg_ptr->tel.tel_data_ptr[7] = MISC_LB(offset); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function manually mutes a synchronous data connection. + * \param self Reference to CInic instance + * \param sync_handle Resource handle of the synchronous connection + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_SyncMute(CInic *self, + uint16_t sync_handle, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_SYNC_MUTE) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 2U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_SYNC_MUTE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(sync_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(sync_handle); + + self->ssubs[INIC_SSUB_SYNC_MUTE].user_mask = INIC_API_SYNC_MUTE; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_SYNC_MUTE]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_SYNC_MUTE], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_SYNC_MUTE); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function manually de-mutes a synchronous data connection. + * \param self Reference to CInic instance + * \param sync_handle Resource handle of the synchronous connection + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_SyncDemute(CInic *self, + uint16_t sync_handle, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_SYNC_DEMUTE) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 2U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_SYNC_DEMUTE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(sync_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(sync_handle); + + self->ssubs[INIC_SSUB_SYNC_DEMUTE].user_mask = INIC_API_SYNC_DEMUTE; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_SYNC_DEMUTE]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_SYNC_DEMUTE], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_SYNC_DEMUTE); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates a DiscreteFrame Isochronous streaming phase connection. The connection can be + * directly associated with an input and output socket. + * \param self Reference to CInic instance + * \param resource_handle_in The ID number of the socket or splitter resource that is the + * starting point of the link. + * \param resource_handle_out The ID number of the socket or splitter resource that is the ending + * point of the link. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_DfiPhaseCreate(CInic *self, + uint16_t resource_handle_in, + uint16_t resource_handle_out, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 4U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_DFIPHASE_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(resource_handle_in); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(resource_handle_in); + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(resource_handle_out); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(resource_handle_out); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates a combiner resource. A Combiner enables grouping of data from multiple network + * sockets into the same port socket. + * \param self Reference to CInic instance + * \param port_socket_handle Only supported sockets are Streaming Port, MLB, USB (OS81118) or PCI + * (OS81160) sockets of data type Synchronous. Direction must be OUT. + * \param most_port_handle When the splitter is created with a MOST socket, the socket must be + * created on the same port indicated by this handle. + * \param bytes_per_frame Specifies the total number of data bytes that are to be transferred + * each MOST frame. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_CombinerCreate(CInic *self, + uint16_t port_socket_handle, + uint16_t most_port_handle, + uint16_t bytes_per_frame, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 6U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_COMBINER_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(port_socket_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(port_socket_handle); + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(most_port_handle); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(most_port_handle); + msg_ptr->tel.tel_data_ptr[4] = MISC_HB(bytes_per_frame); + msg_ptr->tel.tel_data_ptr[5] = MISC_LB(bytes_per_frame); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates a splitter resource. A Splitter enables splitting up the data from a single + * channel into multiple channels. + * \param self Reference to CInic instance + * \param socket_handle_in All sockets of data type Synchronous are supported, regardless of + * the port the socket is created on. The direction must be IN. + * \param most_port_handle When the splitter is created with a MOST socket, the socket must be + * created on the same port indicated by this handle. + * \param bytes_per_frame Specifies the total number of data bytes that are to be transferred + * each MOST frame. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_SplitterCreate(CInic *self, + uint16_t socket_handle_in, + uint16_t most_port_handle, + uint16_t bytes_per_frame, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 6U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_SPLITTER_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(socket_handle_in); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(socket_handle_in); + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(most_port_handle); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(most_port_handle); + msg_ptr->tel.tel_data_ptr[4] = MISC_HB(bytes_per_frame); + msg_ptr->tel.tel_data_ptr[5] = MISC_LB(bytes_per_frame); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates an Quality of Service IP Streaming data connection. + * \param self Reference to CInic instance + * \param socket_in_handle The ID number of the created socket that is the starting point of + * the link. Must be a socket of type Input. + * \param socket_out_handle The ID number of the created socket that is the ending point of + * the link. Must be a socket of type Output. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_QoSCreate(CInic *self, + uint16_t socket_in_handle, + uint16_t socket_out_handle, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 4U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_QOS_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(socket_in_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(socket_in_handle); + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(socket_out_handle); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(socket_out_handle); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates an IPC (Inter-Processor Communication) packet connection. + * \param self Reference to CInic instance + * \param socket_in_handle The ID number of the created socket that is the starting point of + * the link. Must be a socket of type Input. + * \param socket_out_handle The ID number of the created socket that is the ending point of + * the link. Must be a socket of type Output. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_IpcCreate(CInic *self, + uint16_t socket_in_handle, + uint16_t socket_out_handle, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 4U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_IPC_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(socket_in_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(socket_in_handle); + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(socket_out_handle); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(socket_out_handle); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates an A/V Packetized Isochronous Streaming data connection. + * \param self Reference to CInic instance + * \param socket_in_handle The ID number of the created socket that is the starting point of + * the link. Must be a socket of type Input. + * \param socket_out_handle The ID number of the created socket that is the ending point of + * the link. Must be a socket of type Output. + * \param isoc_packet_size Specifies the size of data packets that are to be transported over + * the isochronous channel. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_AvpCreate(CInic *self, + uint16_t socket_in_handle, + uint16_t socket_out_handle, + Ucs_Avp_IsocPacketSize_t isoc_packet_size, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 6U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_AVP_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(socket_in_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(socket_in_handle); + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(socket_out_handle); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(socket_out_handle); + msg_ptr->tel.tel_data_ptr[4] = MISC_HB((uint16_t)isoc_packet_size); + msg_ptr->tel.tel_data_ptr[5] = MISC_LB((uint16_t)isoc_packet_size); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function creates a MOST socket bound to the MOST Network Port. + * \param self Reference to CInic instance + * \param most_port_handle MOST Network Port resource handle + * \param direction indicates the direction of the data stream from the perspective of + * the INIC + * \param data_type Specifies the data type + * \param bandwidth Required socket bandwidth in bytes. Maximum value depends on current + * free network resources. + * \param connection_label MOST network connection label. When used as parameter with direction + * Input, the connection label is used to connect to the appropriate MOST + * frame bytes. When used as parameter with direction Output, the + * connection label is not used and must be set to 0xFFFF. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_MostSocketCreate(CInic *self, + uint16_t most_port_handle, + Ucs_SocketDirection_t direction, + Ucs_Most_SocketDataType_t data_type, + uint16_t bandwidth, + uint16_t connection_label, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 8U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_MOST_SOCKET_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(most_port_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(most_port_handle); + msg_ptr->tel.tel_data_ptr[2] = (uint8_t)direction; + msg_ptr->tel.tel_data_ptr[3] = (uint8_t)data_type; + msg_ptr->tel.tel_data_ptr[4] = MISC_HB(bandwidth); + msg_ptr->tel.tel_data_ptr[5] = MISC_LB(bandwidth); + msg_ptr->tel.tel_data_ptr[6] = MISC_HB(connection_label); + msg_ptr->tel.tel_data_ptr[7] = MISC_LB(connection_label); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates the MediaLB Port with its associated port instance identifier. + * \param self Reference to CInic instance + * \param index MediaLB Port instance + * \param clock_config Stores the clock speed configuration. The value is a multiple + * of the MOST network frame rate Fs; this means the MediaLB Port + * can only be frequency locked to the network's system clock. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_MlbPortCreate(CInic *self, + uint8_t index, + Ucs_Mlb_ClockConfig_t clock_config, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 2U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_MLB_PORT_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = index; + msg_ptr->tel.tel_data_ptr[1] = (uint8_t)clock_config; + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates a MediaLB socket bound to the MediaLB Port with the associated port instance + * identifier. If INIC enters Protected Mode, the MediaLB socket will be automatically + * destroyed. + * \param self Reference to CInic instance + * \param mlb_port_handle MediaLB Port resource handle + * \param direction Indicates the direction of the data stream from the perspective of + * the INIC + * \param data_type Specifies the data type + * \param bandwidth Required socket bandwidth in bytes + * \param channel_address Indicates the MediaLB ChannelAddress where the socket is mapped to. + * If the MediaLB Port is created by default, ChannelAddresses 0x0002 + * and 0x0004 are reserved and cannot be used. + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_MlbSocketCreate(CInic *self, + uint16_t mlb_port_handle, + Ucs_SocketDirection_t direction, + Ucs_Mlb_SocketDataType_t data_type, + uint16_t bandwidth, + uint16_t channel_address, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 8U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_MLB_SOCKET_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(mlb_port_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(mlb_port_handle); + msg_ptr->tel.tel_data_ptr[2] = (uint8_t)direction; + msg_ptr->tel.tel_data_ptr[3] = (uint8_t)data_type; + msg_ptr->tel.tel_data_ptr[4] = MISC_HB(bandwidth); + msg_ptr->tel.tel_data_ptr[5] = MISC_LB(bandwidth); + msg_ptr->tel.tel_data_ptr[6] = MISC_HB(channel_address); + msg_ptr->tel.tel_data_ptr[7] = MISC_LB(channel_address); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates the USB Port with its associated port instance identifier. The instance + * identifier of an USB Port is always directly bound to a specific hardware port. + * \param self Reference to CInic instance + * \param index USB Port instance + * \param physical_layer USB Port physical layer + * \param devices_interfaces USB Interfaces supported by the device + * \param streaming_if_ep_out_count number of USB OUT Endpoints being provided through the USB streaming interface + * \param streaming_if_ep_in_count number of USB IN Endpoints being provided through the USB Streaming interface + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_UsbPortCreate(CInic *self, + uint8_t index, + Ucs_Usb_PhysicalLayer_t physical_layer, + uint16_t devices_interfaces, + uint8_t streaming_if_ep_out_count, + uint8_t streaming_if_ep_in_count, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 6U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_USB_PORT_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = index; + msg_ptr->tel.tel_data_ptr[1] = (uint8_t)physical_layer; + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(devices_interfaces); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(devices_interfaces); + msg_ptr->tel.tel_data_ptr[4] = streaming_if_ep_out_count; + msg_ptr->tel.tel_data_ptr[5] = streaming_if_ep_in_count; + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Creates a USB socket bound to the USB port with its associated port instance identifier. + * If INIC enters Protected Mode, the USB socket will be automatically destroyed. + * \param self Reference to CInic instance + * \param usb_port_handle USB Port resource handle + * \param direction Indicates the direction of the data stream from the perspective of + * the INIC + * \param data_type Specifies the data type + * \param end_point_addr Denotes the address of a USB endpoint as per its description in the + * USB 2.0 Specification + * \param frames_per_transfer Indicates the number of MOST frames per transfer per one USB + * transaction + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_UsbSocketCreate(CInic *self, + uint16_t usb_port_handle, + Ucs_SocketDirection_t direction, + Ucs_Usb_SocketDataType_t data_type, + uint8_t end_point_addr, + uint16_t frames_per_transfer, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 7U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_USB_SOCKET_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(usb_port_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(usb_port_handle); + msg_ptr->tel.tel_data_ptr[2] = (uint8_t)direction; + msg_ptr->tel.tel_data_ptr[3] = (uint8_t)data_type; + msg_ptr->tel.tel_data_ptr[4] = end_point_addr; + msg_ptr->tel.tel_data_ptr[5] = MISC_HB(frames_per_transfer); + msg_ptr->tel.tel_data_ptr[6] = MISC_LB(frames_per_transfer); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function is used to configure the Streaming Ports. + * \param self Reference to CInic instance + * \param index Streaming Port instance + * \param op_mode Streaming Port Operation mode + * \param port_option Streaming Port Options + * \param clock_mode Stream Port Clock Mode + * \param clock_data_delay Stream Port Clock Data Delay + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + */ +Ucs_Return_t Inic_StreamPortConfig_SetGet(CInic *self, + uint8_t index, + Ucs_Stream_PortOpMode_t op_mode, + Ucs_Stream_PortOption_t port_option, + Ucs_Stream_PortClockMode_t clock_mode, + Ucs_Stream_PortClockDataDelay_t clock_data_delay, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_STREAM_PORT_CONFIG) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 5U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_STREAM_PORT_CONFIG; + msg_ptr->id.op_type = UCS_OP_SETGET; + + msg_ptr->tel.tel_data_ptr[0] = (uint8_t)index; + msg_ptr->tel.tel_data_ptr[1] = (uint8_t)op_mode; + msg_ptr->tel.tel_data_ptr[2] = (uint8_t)port_option; + msg_ptr->tel.tel_data_ptr[3] = (uint8_t)clock_mode; + msg_ptr->tel.tel_data_ptr[4] = (uint8_t)clock_data_delay; + + self->ssubs[INIC_SSUB_STREAM_PORT_CONFIG].user_mask = INIC_API_STREAM_PORT_CONFIG; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_STREAM_PORT_CONFIG]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_STREAM_PORT_CONFIG], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_STREAM_PORT_CONFIG); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function is used to request the configurations of the Streaming Ports. + * \param self Reference to CInic instance + * \param index Streaming Port Instance ID + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_StreamPortConfig_Get(CInic *self, + uint8_t index, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_STREAM_PORT_CONFIG) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 1U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_STREAM_PORT_CONFIG; + msg_ptr->id.op_type = UCS_OP_GET; + + msg_ptr->tel.tel_data_ptr[0] = (uint8_t)index; + + self->ssubs[INIC_SSUB_STREAM_PORT_CONFIG].user_mask = INIC_API_STREAM_PORT_CONFIG; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_STREAM_PORT_CONFIG]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_STREAM_PORT_CONFIG], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_STREAM_PORT_CONFIG); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function creates the Streaming Port with its associated port instance identifier. + * \param self Reference to CInic instance + * \param index Streaming Port instance + * \param clock_config Clock speed configuration of the SCK signal + * \param data_alignment Defines the alignment of the data bytes within the streaming port frame + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_StreamPortCreate(CInic *self, + uint8_t index, + Ucs_Stream_PortClockConfig_t clock_config, + Ucs_Stream_PortDataAlign_t data_alignment, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 3U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_STREAM_PORT_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = index; + msg_ptr->tel.tel_data_ptr[1] = (uint8_t)clock_config; + msg_ptr->tel.tel_data_ptr[2] = (uint8_t)data_alignment; + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function creates a Synchronous or DiscreteFrame Isochronous Streaming data socket + * bound to the Streaming Port with the denoted port instance identifier. + * \param self Reference to CInic instance + * \param stream_port_handle Streaming Port resource handle + * \param direction Indicates the direction of the data stream, from the INIC's + * perspective + * \param data_type Specifies the data type + * \param bandwidth Required socket bandwidth in bytes + * \param stream_pin_id ID of the serial interface pin of the addressed Streaming Port + * instance + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_StreamSocketCreate(CInic *self, + uint16_t stream_port_handle, + Ucs_SocketDirection_t direction, + Ucs_Stream_SocketDataType_t data_type, + uint16_t bandwidth, + Ucs_Stream_PortPinId_t stream_pin_id, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 7U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_STREAM_SOCKET_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(stream_port_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(stream_port_handle); + msg_ptr->tel.tel_data_ptr[2] = (uint8_t)direction; + msg_ptr->tel.tel_data_ptr[3] = (uint8_t)data_type; + msg_ptr->tel.tel_data_ptr[4] = MISC_HB(bandwidth); + msg_ptr->tel.tel_data_ptr[5] = MISC_LB(bandwidth); + msg_ptr->tel.tel_data_ptr[6] = (uint8_t)stream_pin_id; + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function creates an RMCK Port with its associated port instance identifier. + * \param self Reference to CInic instance + * \param index RMCK Port instance + * \param clock_source Indicates the source of the RMCK clock + * \param divisor Divisor of the clock source + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_RmckPortCreate(CInic *self, + uint8_t index, + Ucs_Rmck_PortClockSource_t clock_source, + uint16_t divisor, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 4U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_RMCK_PORT_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = index; + msg_ptr->tel.tel_data_ptr[1] = (uint8_t)clock_source; + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(divisor); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(divisor); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function creates an I2C Port with its associated port instance identifier. + * \param self Reference to CInic instance + * \param index I2C Port instance + * \param address The 7-bit I2C slave address of the peripheral to be read. + * \param mode The operation mode of the I2C Port + * \param speed The speed grade of the I2C Port + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_I2cPortCreate(CInic *self, + uint8_t index, + uint8_t address, + uint8_t mode, + Ucs_I2c_Speed_t speed, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 4U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_I2C_PORT_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = index; + msg_ptr->tel.tel_data_ptr[1] = address; + msg_ptr->tel.tel_data_ptr[2] = mode; + msg_ptr->tel.tel_data_ptr[3] = (uint8_t)speed; + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function reads a block of bytes from an I2C device at a specified I2C address. + * \param self Reference to CInic instance + * \param port_handle Port resource handle + * \param slave_address The 7-bit I2C slave address of the peripheral to be read + * \param data_len Number of bytes to be read from the address + * \param timeout The timeout for the I2C Port read + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_I2cPortRead(CInic *self, + uint16_t port_handle, + uint8_t slave_address, + uint8_t data_len, + uint16_t timeout, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_I2C_PORT_WR) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 6U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_I2C_PORT_READ; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(port_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(port_handle); + msg_ptr->tel.tel_data_ptr[2] = slave_address; + msg_ptr->tel.tel_data_ptr[3] = data_len; + msg_ptr->tel.tel_data_ptr[4] = MISC_HB(timeout); + msg_ptr->tel.tel_data_ptr[5] = MISC_LB(timeout); + + self->ssubs[INIC_SSUB_I2C_PORT_WR].user_mask = INIC_API_I2C_PORT_WR; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_I2C_PORT_WR]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_I2C_PORT_WR], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_I2C_PORT_WR); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function writes a block of bytes to an I2C device at a specified I2C address. + * \param self Reference to CInic instance + * \param port_handle Port resource handle + * \param mode The write transfer mode + * \param block_count The number of blocks to be written to the I2C address. + * \param slave_address The 7-bit I2C slave address of the peripheral to be read + * \param timeout The timeout for the I2C Port write + * \param data_len Number of bytes to be written to the addressed I2C peripheral + * \param data_list Reference to the data list to be written + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_I2cPortWrite(CInic *self, + uint16_t port_handle, + Ucs_I2c_TrMode_t mode, + uint8_t block_count, + uint8_t slave_address, + uint16_t timeout, + uint8_t data_len, + uint8_t data_list[], + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_I2C_PORT_WR) != false) + { + uint8_t i; + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, (8U + data_len)); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_I2C_PORT_WRITE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(port_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(port_handle); + msg_ptr->tel.tel_data_ptr[2] = (uint8_t)mode; + msg_ptr->tel.tel_data_ptr[3] = block_count; + msg_ptr->tel.tel_data_ptr[4] = slave_address; + msg_ptr->tel.tel_data_ptr[5] = (mode == UCS_I2C_BURST_MODE) ? (data_len/block_count):data_len; + msg_ptr->tel.tel_data_ptr[6] = MISC_HB(timeout); + msg_ptr->tel.tel_data_ptr[7] = MISC_LB(timeout); + + if (data_list != NULL) + { + for (i = 0U; i < data_len; i++) + { + msg_ptr->tel.tel_data_ptr[8U + i] = data_list[i]; + } + } + + self->ssubs[INIC_SSUB_I2C_PORT_WR].user_mask = INIC_API_I2C_PORT_WR; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_I2C_PORT_WR]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_I2C_PORT_WR], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_I2C_PORT_WR); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function creates an PCIe Port with its associated port instance identifier. + * \param self Reference to CInic instance + * \param index PCIe Port instance + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_PciPortCreate(CInic *self, + uint8_t index, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 1U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_PCI_PORT_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = index; + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function creates a PCIe socket bound to the PCIe Port with the associated port + * instance identifier. If the EHC detaches, the PCIe socket will be automatically + * destroyed. + * \param self Reference to CInic instance + * \param pci_port_handle PCIe Port resource handle + * \param direction Indicates the direction of the data stream from the perspective of + * the INIC + * \param data_type Specifies the data type + * \param dma_channel Specifies the DMA channel + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_PciSocketCreate(CInic *self, + uint16_t pci_port_handle, + Ucs_SocketDirection_t direction, + Ucs_Pci_SocketDataType_t data_type, + uint8_t dma_channel, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 5U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_PCI_SOCKET_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(pci_port_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(pci_port_handle); + msg_ptr->tel.tel_data_ptr[2] = (uint8_t)direction; + msg_ptr->tel.tel_data_ptr[3] = (uint8_t)data_type; + msg_ptr->tel.tel_data_ptr[4] = dma_channel; + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function creates a GPIO Port with its associated port instance identifier. + * \param self Reference to CInic instance + * \param gpio_port_index GPIO Port instance + * \param debounce_time Timeout for the GPIO debounce timer + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_GpioPortCreate(CInic *self, + uint8_t gpio_port_index, + uint16_t debounce_time, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_CREATE_CLASS) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 3U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_GPIO_PORT_CREATE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = gpio_port_index; + msg_ptr->tel.tel_data_ptr[1] = MISC_HB(debounce_time); + msg_ptr->tel.tel_data_ptr[2] = MISC_LB(debounce_time); + + self->ssubs[INIC_SSUB_CREATE_CLASS].user_mask = INIC_API_CREATE_CLASS; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_CREATE_CLASS]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_CREATE_CLASS], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_CREATE_CLASS); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function enables or disables a specific MOST Network Port. + * \param self Reference to CInic instance + * \param most_port_handle Port resource handle + * \param enabled Indicates whether a MOST Network Port should be enabled or disabled + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_MostPortEnable(CInic *self, + uint16_t most_port_handle, + bool enabled, + CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_MOST_PORT_ENABLE) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 3U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_MOST_PORT_ENABLE; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(most_port_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(most_port_handle); + msg_ptr->tel.tel_data_ptr[2] = (enabled != false) ? 1U : 0U; + + self->ssubs[INIC_SSUB_MOST_PORT_ENABLE].user_mask = INIC_API_MOST_PORT_ENABLE; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_MOST_PORT_ENABLE]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_MOST_PORT_ENABLE], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_MOST_PORT_ENABLE); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function retrieves the current pin mode of the given GPIO Port. + * \param self Reference to CInic instance + * \param gpio_handle GPIO Port instance + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_GpioPortPinMode_Get(CInic *self, uint16_t gpio_handle, CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_GPIO_PIN_MODE) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 2U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_GPIO_PORT_PIN_MODE; + msg_ptr->id.op_type = UCS_OP_GET; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(gpio_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(gpio_handle); + + self->ssubs[INIC_SSUB_GPIO_PIN_MODE].user_mask = INIC_API_GPIO_PIN_MODE; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_GPIO_PIN_MODE]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_GPIO_PIN_MODE], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_GPIO_PIN_MODE); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function sets and retrieves the mode of a pin on the GPIO Port + * \param self Reference to CInic instance + * \param gpio_handle GPIO Port instance + * \param pin The GPIO pin that is to be configured + * \param mode The mode of the GPIO pin + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_GpioPortPinMode_SetGet(CInic *self, uint16_t gpio_handle, uint8_t pin, Ucs_Gpio_PinMode_t mode, CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_GPIO_PIN_MODE) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 4U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_GPIO_PORT_PIN_MODE; + msg_ptr->id.op_type = UCS_OP_SETGET; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(gpio_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(gpio_handle); + msg_ptr->tel.tel_data_ptr[2] = pin; + msg_ptr->tel.tel_data_ptr[3] = (uint8_t)mode; + + self->ssubs[INIC_SSUB_GPIO_PIN_MODE].user_mask = INIC_API_GPIO_PIN_MODE; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_GPIO_PIN_MODE]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_GPIO_PIN_MODE], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_GPIO_PIN_MODE); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function retrieves the pin state of the given GPIO Port. + * \param self Reference to CInic instance + * \param gpio_handle GPIO Port instance + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_GpioPortPinState_Get(CInic *self, uint16_t gpio_handle, CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_GPIO_PIN_STATE) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 2U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_GPIO_PORT_PIN_STATE; + msg_ptr->id.op_type = UCS_OP_GET; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(gpio_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(gpio_handle); + + self->ssubs[INIC_SSUB_GPIO_PIN_STATE].user_mask = INIC_API_GPIO_PIN_STATE; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_GPIO_PIN_STATE]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_GPIO_PIN_STATE], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_GPIO_PIN_STATE); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function sets and retrieves the state of a pin on the GPIO Port + * \param self Reference to CInic instance + * \param gpio_handle GPIO Port instance + * \param mask The GPIO pins to be written + * \param data The state of the GPIO pins to be written + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_GpioPortPinState_SetGet(CInic *self, uint16_t gpio_handle, uint16_t mask, uint16_t data, CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_GPIO_PIN_STATE) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 6U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_GPIO_PORT_PIN_STATE; + msg_ptr->id.op_type = UCS_OP_SETGET; + + msg_ptr->tel.tel_data_ptr[0] = MISC_HB(gpio_handle); + msg_ptr->tel.tel_data_ptr[1] = MISC_LB(gpio_handle); + msg_ptr->tel.tel_data_ptr[2] = MISC_HB(mask); + msg_ptr->tel.tel_data_ptr[3] = MISC_LB(mask); + msg_ptr->tel.tel_data_ptr[4] = MISC_HB(data); + msg_ptr->tel.tel_data_ptr[5] = MISC_LB(data); + + self->ssubs[INIC_SSUB_GPIO_PIN_STATE].user_mask = INIC_API_GPIO_PIN_STATE; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_GPIO_PIN_STATE]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_GPIO_PIN_STATE], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_GPIO_PIN_STATE); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief This function enables full streaming for a specific MOST Network Port. + * \param self Reference to CInic instance + * \param most_port_handle Port resource handle + * \param enabled Indicates whether full streaming is enabled or disabled + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + * \return UCS_RET_ERR_API_LOCKED Resource API is already used by another command + */ +Ucs_Return_t Inic_MostPortEnFullStr(CInic *self, + uint16_t most_port_handle, + bool enabled, + CSingleObserver *obs_ptr) +{ + MISC_UNUSED(self); + MISC_UNUSED(most_port_handle); + MISC_UNUSED(enabled); + MISC_UNUSED(obs_ptr); + + return UCS_RET_ERR_NOT_SUPPORTED; +} + +/*! \brief Allows remote synchronization of the given device + * \param self Reference to CInic instance + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + */ +Ucs_Return_t Inic_DeviceSync(CInic *self, CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + + if(Al_Lock(&self->lock.res_api, INIC_API_DEVICE_SYNC) != false) + { + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 1U); + + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_DEVICE_SYNC; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = 0x01U; + + self->ssubs[INIC_SSUB_DEVICE_SYNC].user_mask = INIC_API_DEVICE_SYNC; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_DEVICE_SYNC]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_DEVICE_SYNC], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_DEVICE_SYNC); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*! \brief Un-synchronizes to the given remote device + * \param self Reference to CInic instance + * \param obs_ptr Reference to an optional observer + * \return UCS_RET_SUCCESS message was created + * \return UCS_RET_ERR_BUFFER_OVERFLOW no message buffer available + */ +Ucs_Return_t Inic_DeviceUnsync(CInic *self, CSingleObserver *obs_ptr) +{ + Ucs_Return_t result = UCS_RET_SUCCESS; + Msg_MostTel_t *msg_ptr = Trcv_TxAllocateMsg(self->xcvr_ptr, 1U); + + if(Al_Lock(&self->lock.res_api, INIC_API_DEVICE_SYNC) != false) + { + if (msg_ptr != NULL) + { + msg_ptr->destination_addr = self->target_address; + + msg_ptr->id.fblock_id = FB_INIC; + msg_ptr->id.instance_id = 0U; + msg_ptr->id.function_id = INIC_FID_DEVICE_SYNC; + msg_ptr->id.op_type = UCS_OP_STARTRESULT; + + msg_ptr->tel.tel_data_ptr[0] = 0U; + + self->ssubs[INIC_SSUB_DEVICE_SYNC].user_mask = INIC_API_DEVICE_SYNC; + msg_ptr->info_ptr = &self->ssubs[INIC_SSUB_DEVICE_SYNC]; + Trcv_TxSendMsgExt(self->xcvr_ptr, msg_ptr, &Inic_ResMsgTxStatusCb, self); + + (void)Ssub_AddObserver(&self->ssubs[INIC_SSUB_DEVICE_SYNC], obs_ptr); + } + else + { + Al_Release(&self->lock.res_api, INIC_API_DEVICE_SYNC); + result = UCS_RET_ERR_BUFFER_OVERFLOW; + } + } + else + { + result = UCS_RET_ERR_API_LOCKED; + } + + return result; +} + +/*------------------------------------------------------------------------------------------------*/ +/* Handler functions */ +/*------------------------------------------------------------------------------------------------*/ +/*! \brief Handle message Tx status, Unlock the API and free the message objects + * \param self The instance + * \param tel_ptr Reference to transmitted message + * \param status Status of the transmitted message + */ +static void Inic_ResMsgTxStatusCb(void *self, Msg_MostTel_t *tel_ptr, Ucs_MsgTxStatus_t status) +{ + CInic *self_ = (CInic *)self; + CSingleSubject *ssub_ptr = (CSingleSubject *)tel_ptr->info_ptr; + + if ((status != UCS_MSG_STAT_OK) && (tel_ptr->info_ptr != NULL)) + { + Inic_StdResult_t res_data; + + res_data.data_info = &status; + res_data.result.code = UCS_RES_ERR_TRANSMISSION; + res_data.result.info_ptr = NULL; + res_data.result.info_size = 0U; + Ssub_Notify(ssub_ptr, &res_data, true); + + if ((ssub_ptr != NULL) && (ssub_ptr->user_mask != 0U)) + { + Al_Release(&self_->lock.res_api, (Alm_ModuleMask_t)ssub_ptr->user_mask); + } + } + Trcv_TxReleaseMsg(tel_ptr); + /* Reset user mask of the single subject if available */ + if (ssub_ptr != NULL) + { + ssub_ptr->user_mask = 0U; + } + + /* ICM messages pending? */ + if (Sub_GetNumObservers(&self_->subs[INIC_SUB_TX_MSG_OBJ_AVAIL]) > 0U) + { + Sub_Notify(&self_->subs[INIC_SUB_TX_MSG_OBJ_AVAIL], NULL); + } +} + +/*! \brief Handler function for INIC.ResourceDestroy.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_ResourceDestroy_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_RESOURCE_DESTROY], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_RESOURCE_DESTROY); +} + +/*! \brief Handler function for INIC.ResourceDestroy.ResultAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_ResourceDestroy_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + MISC_UNUSED(msg_ptr); + + res_data.data_info = NULL; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_RESOURCE_DESTROY], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_RESOURCE_DESTROY); +} + +/*! \brief Handler function for INIC.ResourceInvalidList.Status + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_ResourceInvalidList_Status(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + Inic_ResHandleList_t result; + uint8_t i; + uint16_t inv_res_handles[22]; /* Max. ICM message size is 45 -> max. 22 16-bit values */ + + res_data.data_info = &result; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + /* Length of message must be even, since 16-Bit values are transmitted via two 8-bit fields. */ + TR_ASSERT(self_->base_ptr->ucs_user_ptr, "[INIC_RES]", ((msg_ptr->tel.tel_len % 2U) == 0U)); + + for(i=0U; (i < (uint8_t)(msg_ptr->tel.tel_len >> 1)); i++) + { + MISC_DECODE_WORD(&inv_res_handles[i], + &(msg_ptr->tel.tel_data_ptr[(uint8_t)((uint8_t)i << 1)])); + } + result.res_handles = &inv_res_handles[0]; + result.num_handles = (uint8_t)((uint8_t)msg_ptr->tel.tel_len >> 1); + Ssub_Notify(&self_->ssubs[INIC_SSUB_RESOURCE_INVAL_LIST], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_RESOURCE_INVAL_LIST); +} + +/*! \brief Handler function for INIC.ResourceInvalidList.Error + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_ResourceInvalidList_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + msg_ptr->tel.tel_len); + Ssub_Notify(&self_->ssubs[INIC_SSUB_RESOURCE_INVAL_LIST], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_RESOURCE_INVAL_LIST); +} + +/*! \brief Handler function for INIC.ResourceMonitor.Status + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_ResourceMonitor_Status(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + Ucs_Resource_MonitorState_t state; + + res_data.data_info = &state; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + state = (Ucs_Resource_MonitorState_t)msg_ptr->tel.tel_data_ptr[0]; + Sub_Notify(&self_->subs[INIC_SUB_RES_MONITOR], &res_data); +} + +/*! \brief Handler function for INIC.ResourceMonitor.Error + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_ResourceMonitor_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + msg_ptr->tel.tel_len); + Sub_Notify(&self_->subs[INIC_SUB_RES_MONITOR], &res_data); +} + +/*! \brief Handler function for INIC.SyncCreate.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_SyncCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.SyncCreate.ResultAck. res_data.data_info points to the + * resource handle of the synchronous connection which was created. + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_SyncCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + + +/*! \brief Handler function for INIC.SyncMute.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_SyncMute_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_SYNC_MUTE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_SYNC_MUTE); +} + +/*! \brief Handler function for INIC.SyncMute.ResultAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_SyncMute_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + MISC_UNUSED(msg_ptr); + + res_data.data_info = NULL; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_SYNC_MUTE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_SYNC_MUTE); +} + +/*! \brief Handler function for INIC.SyncDemute.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_SyncDemute_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_SYNC_DEMUTE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_SYNC_DEMUTE); +} + +/*! \brief Handler function for INIC.SyncDemute.ResultAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_SyncDemute_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + MISC_UNUSED(msg_ptr); + + res_data.data_info = NULL; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_SYNC_DEMUTE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_SYNC_DEMUTE); +} + +/*! \brief Handler function for INIC.DFIPhaseCreate.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_DfiPhaseCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.DFIPhaseCreate.ResultAck. res_data.data_info points to the + * resource handle of the DFIPhase streaming phase connection which was created. + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_DfiPhaseCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.CombinerCreate.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_CombinerCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.CombinerCreate.ResultAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_CombinerCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.SplitterCreate.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_SplitterCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.SplitterCreate.ResultAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_SplitterCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.QoSCreate.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_QoSCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.QoSCreate.ResultAck.res_data.data_info points to the Resource + * handle of the Quality of Service IP Streaming data connection which was created. + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_QoSCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.IPCPacketCreate.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_IpcCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.IPCPacketCreate.ResultAck.res_data.data_info points to the resource + * handle of the Inter-Processor Communication packet connection which was created. + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_IpcCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.AVPCreate.ErrorAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_AvpCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.AVPCreate.ResultAck. res_data.data_info points to the Resource + * handle of the A/V Packetized Isochronous Streaming connection which was created. + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_AvpCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.MOSTPortStatus.Status + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MostPortStatus_Status(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_MostPortStatus_t result; + + MISC_DECODE_WORD(&(result.most_port_handle), &(msg_ptr->tel.tel_data_ptr[0])); + result.availability = (Ucs_Most_PortAvail_t)msg_ptr->tel.tel_data_ptr[2]; + result.avail_info = (Ucs_Most_PortAvailInfo_t)msg_ptr->tel.tel_data_ptr[3]; + result.fullstreaming_enabled = (msg_ptr->tel.tel_data_ptr[4] != 0U) ? true : false; + MISC_DECODE_WORD(&(result.freestreaming_bw), &(msg_ptr->tel.tel_data_ptr[5])); + + self_->most_port_status = result; + + Sub_Notify(&self_->subs[INIC_SUB_MOST_PORT_STATUS], &result); +} + +/*! \brief Handler function for INIC.MOSTPortStatus.Error + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MostPortStatus_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + msg_ptr->tel.tel_len); + + Sub_Notify(&self_->subs[INIC_SUB_MOST_PORT_STATUS], &res_data); +} + +/*! \brief Handler function for INIC.MOSTSocketCreate.ErrorAck. Result is delivered via the + * SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MostSocketCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.MOSTSocketCreate.ResultAck + * \details Result is delivered via the SingleObserver element ssubs[INIC_SSUB_CREATE_CLASS]. Element + * res_data.data_info points to a variable of type Inic_MostSocketCreate_Result_t + * which holds the results of the MOSTSocketCreate command. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MostSocketCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + Inic_MostSocketCreate_Result_t res; + + MISC_DECODE_WORD(&(res.most_socket_handle), &(msg_ptr->tel.tel_data_ptr[0])); + MISC_DECODE_WORD(&(res.conn_label), &(msg_ptr->tel.tel_data_ptr[2])); + res_data.data_info = &res; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + + +/*! \brief Handler function for INIC.MLBPortCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MlbPortCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.MLBPortCreate.ResultAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * Element res_data.data_info points to the variable mlb_port_handle which holds the + * MediaLB Port resource handle. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MlbPortCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t mlb_port_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&mlb_port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &mlb_port_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.MLBSocketCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MlbSocketCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.MLBSocketCreate.ResultAck + * \details Element res_data.data_info points to the variable mlb_socket_handle which holds the + * MediaLB Socket resource handle of the created socket. Result is delivered via the + * SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MlbSocketCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t mlb_socket_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&mlb_socket_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &mlb_socket_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.USBPortCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_UsbPortCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.USBPortCreate.ResultAck + * \details Element res_data.data_info points to the variable usb_port_handle which holds the USB + * Port resource handle. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_UsbPortCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t usb_port_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&usb_port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &usb_port_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.USBSocketCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_UsbSocketCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.USBSocketCreate.ResultAck + * \details Element res_data.data_info points to the variable usb_socket_handle which holds the + * Socket resource handle of the created socket. Result is delivered via the + * SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_UsbSocketCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t usb_socket_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&usb_socket_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &usb_socket_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.StreamPortConfiguration.Status + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_STREAM_PORT_CONFIG]. + * Element res_data.data_info points to a variable of type Inic_StreamPortConfigStatus_t + * which holds the results of the INIC.StreamPortConfiguration.Get command. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_StreamPortConfig_Status(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StreamPortConfigStatus_t res; + Inic_StdResult_t res_data; + + res_data.data_info = &res; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + res.index = msg_ptr->tel.tel_data_ptr[0]; + res.op_mode = (Ucs_Stream_PortOpMode_t)msg_ptr->tel.tel_data_ptr[1]; + res.port_option = (Ucs_Stream_PortOption_t)msg_ptr->tel.tel_data_ptr[2]; + res.clock_mode = (Ucs_Stream_PortClockMode_t)msg_ptr->tel.tel_data_ptr[3]; + res.clock_data_delay = (Ucs_Stream_PortClockDataDelay_t)msg_ptr->tel.tel_data_ptr[4]; + + Ssub_Notify(&self_->ssubs[INIC_SSUB_STREAM_PORT_CONFIG], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_STREAM_PORT_CONFIG); +} + +/*! \brief Handler function for INIC.StreamPortConfiguration.Error + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_STREAM_PORT_CONFIG]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_StreamPortConfig_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + msg_ptr->tel.tel_len); + Ssub_Notify(&self_->ssubs[INIC_SSUB_STREAM_PORT_CONFIG], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_STREAM_PORT_CONFIG); +} + +/*! \brief Handler function for INIC.StreamPortCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_StreamPortCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.StreamPortCreate.ResultAck + * \details Element res_data.data_info points to the variable stream_port_handle which holds the + * Streaming Port resource handle. Result is delivered via the SingleObserver object + * ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_StreamPortCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t stream_port_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&stream_port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &stream_port_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.StreamSocketCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_StreamSocketCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.StreamSocketCreate.ResultAck + * \details Element res_data.data_info points to the variable stream_socket_handle which holds + * the Socket resource handle of the created socket. Result is delivered via the + * SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_StreamSocketCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t stream_socket_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&stream_socket_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &stream_socket_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.RMCKOutPortCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_RmckPortCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.RMCKOutPortCreate.ResultAck + * \details Element res_data.data_info points to the variable rmck_port_handle which holds the + * RMCK Port resource handle. Result is delivered via the SingleObserver object + * ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_RmckPortCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t rmck_port_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&rmck_port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &rmck_port_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.I2CPortCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_I2cPortCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.I2CPortCreate.ResultAck + * \details Element res_data.data_info points to the variable i2c_port_handle which holds the + * I2C Port resource handle. Result is delivered via the SingleObserver object + * ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_I2cPortCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t i2c_port_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&i2c_port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &i2c_port_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.I2CPortRead.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_I2C_PORT_WR]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_I2cPortRead_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_I2C_PORT_WR], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_I2C_PORT_WR); +} + +/*! \brief Handler function for INIC.I2CPortRead.ResultAck + * \details Element res_data.data_info points to a variable of type Inic_I2cReadResStatus_t which holds the + * the results of the INIC.I2CPortRead.StartResultAck command. + * Result is delivered via the SingleObserver object ssubs[INIC_SSUB_I2C_PORT_WR]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_I2cPortRead_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_I2cReadResStatus_t i2c_read_res; + Inic_StdResult_t res_data; + + res_data.data_info = &i2c_read_res; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + MISC_DECODE_WORD(&i2c_read_res.port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + i2c_read_res.slave_address = msg_ptr->tel.tel_data_ptr[2]; + i2c_read_res.data_len = msg_ptr->tel.tel_data_ptr[3]; + i2c_read_res.data_ptr = &msg_ptr->tel.tel_data_ptr[4]; + + Ssub_Notify(&self_->ssubs[INIC_SSUB_I2C_PORT_WR], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_I2C_PORT_WR); +} + +/*! \brief Handler function for INIC.I2CPortWrite.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_I2C_PORT_WR]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_I2cPortWrite_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_I2C_PORT_WR], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_I2C_PORT_WR); +} + +/*! \brief Handler function for INIC.I2CPortWrite.ResultAck + * \details Element res_data.data_info points to a variable of type Inic_I2cWriteResStatus_t which holds the + * the results of the INIC.I2CPortWrite.StartResultAck command. + * Result is delivered via the SingleObserver object ssubs[INIC_SSUB_I2C_PORT_WR]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_I2cPortWrite_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_I2cWriteResStatus_t i2c_write_res; + Inic_StdResult_t res_data; + + res_data.data_info = &i2c_write_res; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + MISC_DECODE_WORD(&i2c_write_res.port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + i2c_write_res.slave_address = msg_ptr->tel.tel_data_ptr[2]; + i2c_write_res.data_len = msg_ptr->tel.tel_data_ptr[3]; + + Ssub_Notify(&self_->ssubs[INIC_SSUB_I2C_PORT_WR], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_I2C_PORT_WR); +} + +/*! \brief Handler function for INIC.PCIPortCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_PciPortCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.PCIPortCreate.ResultAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_PciPortCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t pci_port_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&pci_port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &pci_port_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.PCISocketCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_PciSocketCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.PCISocketCreate.ResultAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_PciSocketCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t pci_socket_port_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&pci_socket_port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &pci_socket_port_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.GPIOPortCreate.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_GpioPortCreate_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.GPIOPortCreate.ResultAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_CREATE_CLASS]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_GpioPortCreate_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + uint16_t gpio_port_handle; + Inic_StdResult_t res_data; + + MISC_DECODE_WORD(&gpio_port_handle, &(msg_ptr->tel.tel_data_ptr[0])); + res_data.data_info = &gpio_port_handle; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_CREATE_CLASS], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_CREATE_CLASS); +} + +/*! \brief Handler function for INIC.MOSTPortEnable.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_MOST_PORT_ENABLE]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MostPortEnable_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_MOST_PORT_ENABLE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_MOST_PORT_ENABLE); +} + +/*! \brief Handler function for INIC.MOSTPortEnable.ResultAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_MOST_PORT_ENABLE]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MostPortEnable_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + MISC_UNUSED(msg_ptr); + + res_data.data_info = NULL; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_MOST_PORT_ENABLE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_MOST_PORT_ENABLE); +} + +/*! \brief Handler function for INIC.GPIOPortPinMode.Status + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_GPIO_PIN_MODE]. + * Element res_data.data_info points to a variable of type Inic_GpioPortPinModeStatus_t + * which holds the results of the INIC.GPIOPortPinMode.Get command. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_GpioPortPinMode_Status(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_GpioPortPinModeStatus_t res; + Inic_StdResult_t res_data; + uint8_t i = 2U, j = 0U; + Ucs_Gpio_PinConfiguration_t pin_ls[16U]; + + res.cfg_list = &pin_ls[0]; + res.len = (msg_ptr->tel.tel_len - 2U) >> 1U; + res_data.data_info = &res; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + MISC_DECODE_WORD(&res.gpio_handle, &(msg_ptr->tel.tel_data_ptr[0])); + for (; (i < msg_ptr->tel.tel_len) && (j < 16U); i=i+2U) + { + pin_ls[j].pin = msg_ptr->tel.tel_data_ptr[i]; + pin_ls[j].mode = (Ucs_Gpio_PinMode_t)msg_ptr->tel.tel_data_ptr[i+1U]; + j++; + } + + Ssub_Notify(&self_->ssubs[INIC_SSUB_GPIO_PIN_MODE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_GPIO_PIN_MODE); +} + +/*! \brief Handler function for INIC.GPIOPortPinMode.Error + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_GPIO_PIN_MODE]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_GpioPortPinMode_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + msg_ptr->tel.tel_len); + Ssub_Notify(&self_->ssubs[INIC_SSUB_GPIO_PIN_MODE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_GPIO_PIN_MODE); +} + +/*! \brief Handler function for INIC.GPIOPortPinState.Status + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_GPIO_PIN_STATE]. + * Element res_data.data_info points to a variable of type Inic_GpioPortPinStateStatus_t + * which holds the results of the INIC.GPIOPortPinState.Get command. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_GpioPortPinState_Status(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_GpioPortPinStateStatus_t res; + Inic_StdResult_t res_data; + + res_data.data_info = &res; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + MISC_DECODE_WORD(&res.gpio_handle, &(msg_ptr->tel.tel_data_ptr[0])); + MISC_DECODE_WORD(&res.current_state, &(msg_ptr->tel.tel_data_ptr[2])); + MISC_DECODE_WORD(&res.sticky_state, &(msg_ptr->tel.tel_data_ptr[4])); + + Ssub_Notify(&self_->ssubs[INIC_SSUB_GPIO_PIN_STATE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_GPIO_PIN_STATE); +} + +/*! \brief Handler function for INIC.GPIOPortPinState.Error + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_GPIO_PIN_STATE]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_GpioPortPinState_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + msg_ptr->tel.tel_len); + Ssub_Notify(&self_->ssubs[INIC_SSUB_GPIO_PIN_STATE], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_GPIO_PIN_STATE); +} + +/*! \brief Handler function for INIC.GPIOPortTriggerEvent.Status + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_GPIO_TRIGGER_EVENT]. + * Element res_data.data_info points to a variable of type Inic_GpioTriggerEventStatus_t + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_GpioPortTrigger_Status(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_GpioTriggerEventStatus_t res; + Inic_StdResult_t res_data; + + res_data.data_info = &res; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + MISC_DECODE_WORD(&res.gpio_handle, &(msg_ptr->tel.tel_data_ptr[0])); + MISC_DECODE_WORD(&res.rising_edges, &(msg_ptr->tel.tel_data_ptr[2])); + MISC_DECODE_WORD(&res.falling_edges, &(msg_ptr->tel.tel_data_ptr[4])); + MISC_DECODE_WORD(&res.levels, &(msg_ptr->tel.tel_data_ptr[6])); + res.is_first_report = self_->gpio_rt_status.first_report; + if (self_->gpio_rt_status.first_report) + { + self_->gpio_rt_status.first_report = false; + } + + Sub_Notify(&self_->subs[INIC_SUB_GPIO_TRIGGER_EVENT], &res_data); +} + +/*! \brief Handler function for INIC.GPIOPortTriggerEvent.Error + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_GPIO_TRIGGER_EVENT]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_GpioPortTrigger_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + msg_ptr->tel.tel_len); + Sub_Notify(&self_->subs[INIC_SUB_GPIO_TRIGGER_EVENT], &res_data); +} + +/*! \brief Handler function for INIC.MOSTPortEnableFullStreaming.ErrorAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_MOST_PORT_EN_FULL_STR]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MostPortEnFullStr_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + Ssub_Notify(&self_->ssubs[INIC_SSUB_MOST_PORT_EN_FULL_STR], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_MOST_PORT_EN_FULL_STR); +} + +/*! \brief Handler function for INIC.MOSTPortEnableFullStreaming.ResultAck + * \details Result is delivered via the SingleObserver object ssubs[INIC_SSUB_MOST_PORT_EN_FULL_STR]. + * \param self Reference to CInic instance + * \param msg_ptr Pointer to received message + */ +void Inic_MostPortEnFullStr_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + MISC_UNUSED(msg_ptr); + + res_data.data_info = NULL; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + Ssub_Notify(&self_->ssubs[INIC_SSUB_MOST_PORT_EN_FULL_STR], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_MOST_PORT_EN_FULL_STR); +} + +/*! \brief Handler function for INIC.Notification.Error + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_Notification_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + + Ssub_Notify(&self_->ssubs[INIC_SSUB_NOTIFICATION], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_NOTIFICATION); +} + +/*! \brief Handler function for INIC.Notification.ResultAck + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_Notification_Status(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + Inic_NotificationResult_t notif_res; + + res_data.data_info = ¬if_res; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + MISC_DECODE_WORD(¬if_res.func_id, &(msg_ptr->tel.tel_data_ptr[0])); + if (msg_ptr->tel.tel_len == 4U) + { + MISC_DECODE_WORD(¬if_res.device_id, &(msg_ptr->tel.tel_data_ptr[2])); + } + else + { + notif_res.device_id = 0U; + } + + Ssub_Notify(&self_->ssubs[INIC_SSUB_NOTIFICATION], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_NOTIFICATION); +} + +/*! \brief Handler function for INIC.DeviceSync.Error + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_DeviceSync_Error(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + res_data.data_info = NULL; + res_data.result = Inic_TranslateError(self_, + &msg_ptr->tel.tel_data_ptr[0], + (msg_ptr->tel.tel_len)); + + Ssub_Notify(&self_->ssubs[INIC_SSUB_DEVICE_SYNC], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_DEVICE_SYNC); +} + +/*! \brief Handler function for INIC.DeviceSync.Result + * \param self reference to INIC object + * \param msg_ptr received message + */ +void Inic_DeviceSync_Result(void *self, Msg_MostTel_t *msg_ptr) +{ + CInic *self_ = (CInic *)self; + Inic_StdResult_t res_data; + + MISC_UNUSED(msg_ptr); + + res_data.data_info = NULL; + res_data.result.code = UCS_RES_SUCCESS; + res_data.result.info_ptr = NULL; + + Ssub_Notify(&self_->ssubs[INIC_SSUB_DEVICE_SYNC], &res_data, true); + Al_Release(&self_->lock.res_api, INIC_API_DEVICE_SYNC); +} + +/*! + * @} + * \endcond + */ + +/*------------------------------------------------------------------------------------------------*/ +/* End of file */ +/*------------------------------------------------------------------------------------------------*/ + |