Tani OpcPipe protocol  1.0.5
Tani OpcPipe protocol
Macros | Functions | Variables
PlcOpcPipeMQTTLoader.c File Reference

PlcOpcPipeMQTTLoader.Dia. More...

Functions

 DLL_OS_SPECIFIC_NAME ("MQTTAccess2")
 
DLL_DYNAMIC_FUNCTION_LIST_START DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttQueryVersion,(W_UINT32 *version))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttQueryLoadPath,(char *path, int len))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttDebugSetShareHandle,(void *givenShare))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttSetLoggingBits,(LOGGINGBITS *inData))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttInternalCallbacks,(OPCPIPE_INTERNAL_CALLBACKS *cb, struct _OPCPIPE_GROUP_CALLBACKS *cb2))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttInternalCallbacksEx,(OPCPIPE_INTERNAL_CALLBACKS *cb, struct _OPCPIPE_GROUP_CALLBACKS_EX *cb2))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttClientInitEx,(W_UINT32 compatVersion, W_UINT32 *retCompatVersion))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttClientTerminate,(void))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttBrowse,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE browseHandle, W_UINT32 browseOpcode, W_UINT32 startOffset, const char *path, OPCPIPE_BROWSE_REQUEST_PARAMS *browseParams, W_UINT16 typ, W_UINT8 browseFlags))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttStopBrowse,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE browseHandle, W_UINT32 browseOpcode))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttClientConnection,(OPCPIPE_INTERNALS *t, PLC_MQTT_CONNECTION_PARAMS *cr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttStopConnection,(OPCPIPE_INTERNALS *t))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttFreeConnection,(OPCPIPE_INTERNALS *t))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttBrokerConnection,(OPCPIPE_INTERNALS *t, PLC_MQTT_CONNECTION_PARAMS *cr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttDiagnostics,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE diagHandle, WMK_OPCPIPE_HANDLE *topicHandle, WMK_PTR_CONFIRM confirm, W_UINT32 no))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttCreateItem,(OPCPIPE_INTERNALS *t, W_UINT32 itemCount, INTERNAL_CREATE_ITEM_DATA *data))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttActivateItem,(OPCPIPE_INTERNALS *t, W_UINT32 count, INTERNAL_HANDLE_ITEM_DATA *ptr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttDeactivateItem,(OPCPIPE_INTERNALS *t, W_UINT32 count, INTERNAL_HANDLE_ITEM_DATA *ptr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttRefreshItem,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE readHandle, W_UINT32 itemsCount, INTERNAL_RW_ITEM_DATA *ptr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttDeleteItem,(OPCPIPE_INTERNALS *t, W_UINT32 count, INTERNAL_HANDLE_ITEM_DATA *ptr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttWriteItem,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE writeHandle, W_UINT32 itemsCount, INTERNAL_RW_ITEM_DATA *ptr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttSyncReadItem,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE readHandle, W_UINT32 itemsCount, INTERNAL_RW_ITEM_DATA *ptr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttBrowseItemData,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE browseHandle, W_UINT32 dataLen, PLC_OPCPIPE_BROWSEITEMDATA *data, WMK_PTR_CONFIRM confirm))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttCyclicReadData,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE ackHandle, W_UINT32 itemCount, INTERNAL_RW_ITEM_DATA *data))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttSyncReadData,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE readHandle, WMK_OPCPIPE_HANDLE ackHandle, W_UINT32 itemCount, INTERNAL_RW_ITEM_DATA *data))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttWriteComplete,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE writeHandle, W_UINT32 itemCount, INTERNAL_RW_ITEM_DATA *data))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttCreateItemData,(OPCPIPE_INTERNALS *t, W_UINT32 count, INTERNAL_CREATE_ITEM_DATA *data, int createErr))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttCleanupItem,(OPCPIPE_INTERNALS *t, OPCPIPE_ITEM *item, HANDLE_PAIR *netrefItem))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttTimecount,(OPCPIPE_INTERNALS *t))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttDiagClientName,(OPCPIPE_INTERNALS *t, char *mem, W_UINT32 memlen))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttReadDebugBuffer,(char *buffer, W_UINT32 buflen))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttQueryItemInformation,(OPCPIPE_INTERNALS *t, OPCPIPE_ITEM *item, WMK_OPCPIPE_ITEM_INFO *itemInfo, W_UINT32 maxMem))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttStopWriteItems,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE writeHandle))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttStopSyncReadItems,(OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE readHandle))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttConnStatus,(OPCPIPE_INTERNALS *t, OPCPIPE_STATUS *status))
 
 DLL_DYNAMIC_FUNCTION_LIST_ENTRY (MqttItemSyntaxParse,(OPCPIPE_INTERNALS *t, const char *itemSyntax, PLC_BROWSE_RESPONSE *address, W_UINT32 addressMemlen))
 
EXTERN_C int WENTRY_C MqttQueryVersion (W_UINT32 *version)
 
EXTERN_C int WENTRY_C MqttQueryLoadPath (char *path, int len)
 
EXTERN_C int WENTRY_C MqttDebugSetShareHandle (void *givenShare)
 
EXTERN_C int WENTRY_C MqttInternalCallbacks (OPCPIPE_INTERNAL_CALLBACKS *cb, struct _OPCPIPE_GROUP_CALLBACKS *cb2)
 
EXTERN_C int WENTRY_C MqttInternalCallbacksEx (OPCPIPE_INTERNAL_CALLBACKS *cb, struct _OPCPIPE_GROUP_CALLBACKS_EX *cb2)
 
EXTERN_C int WENTRY_C MqttSetLoggingBits (LOGGINGBITS *inData)
 
EXTERN_C int WENTRY_C MqttClientInitEx (W_UINT32 compatVersion, W_UINT32 *retCompatVersion)
 
EXTERN_C int WENTRY_C MqttClientTerminate (void)
 
EXTERN_C int WENTRY_C MqttBrowse (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE browseHandle, W_UINT32 browseOpcode, W_UINT32 startOffset, const char *path, OPCPIPE_BROWSE_REQUEST_PARAMS *browseParams, W_UINT16 typ, W_UINT8 browseFlags)
 
EXTERN_C int WENTRY_C MqttStopBrowse (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE browseHandle, W_UINT32 browseOpcode)
 
EXTERN_C int WENTRY_C MqttDiagnostics (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE diagHandle, WMK_OPCPIPE_HANDLE *topicHandle, WMK_PTR_CONFIRM confirm, W_UINT32 no)
 
EXTERN_C int WENTRY_C MqttClientConnection (OPCPIPE_INTERNALS *t, PLC_MQTT_CONNECTION_PARAMS *cr)
 
EXTERN_C int WENTRY_C MqttStopConnection (OPCPIPE_INTERNALS *t)
 
EXTERN_C int WENTRY_C MqttFreeConnection (OPCPIPE_INTERNALS *t)
 
EXTERN_C int WENTRY_C MqttBrokerConnection (OPCPIPE_INTERNALS *t, PLC_MQTT_CONNECTION_PARAMS *cr)
 
EXTERN_C int WENTRY_C MqttCreateItem (OPCPIPE_INTERNALS *t, W_UINT32 itemCount, INTERNAL_CREATE_ITEM_DATA *data)
 
EXTERN_C int WENTRY_C MqttActivateItem (OPCPIPE_INTERNALS *t, W_UINT32 count, INTERNAL_HANDLE_ITEM_DATA *ptr)
 
EXTERN_C int WENTRY_C MqttDeactivateItem (OPCPIPE_INTERNALS *t, W_UINT32 count, INTERNAL_HANDLE_ITEM_DATA *ptr)
 
EXTERN_C int WENTRY_C MqttRefreshItem (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE readHandle, W_UINT32 itemsCount, INTERNAL_RW_ITEM_DATA *ptr)
 
EXTERN_C int WENTRY_C MqttDeleteItem (OPCPIPE_INTERNALS *t, W_UINT32 count, INTERNAL_HANDLE_ITEM_DATA *ptr)
 
EXTERN_C int WENTRY_C MqttWriteItem (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE writeHandle, W_UINT32 itemsCount, INTERNAL_RW_ITEM_DATA *ptr)
 
EXTERN_C int WENTRY_C MqttSyncReadItem (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE readHandle, W_UINT32 itemsCount, INTERNAL_RW_ITEM_DATA *ptr)
 
EXTERN_C int WENTRY_C MqttBrowseItemData (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE browseHandle, W_UINT32 dataLen, PLC_OPCPIPE_BROWSEITEMDATA *data, WMK_PTR_CONFIRM confirm)
 
EXTERN_C int WENTRY_C MqttCyclicReadData (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE ackHandle, W_UINT32 itemCount, INTERNAL_RW_ITEM_DATA *data)
 
EXTERN_C int WENTRY_C MqttSyncReadData (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE readHandle, WMK_OPCPIPE_HANDLE ackHandle, W_UINT32 itemCount, INTERNAL_RW_ITEM_DATA *data)
 
EXTERN_C int WENTRY_C MqttWriteComplete (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE writeHandle, W_UINT32 itemCount, INTERNAL_RW_ITEM_DATA *data)
 
EXTERN_C int WENTRY_C MqttCreateItemData (OPCPIPE_INTERNALS *t, W_UINT32 count, INTERNAL_CREATE_ITEM_DATA *data, int createErr)
 
EXTERN_C int WENTRY_C MqttCleanupItem (OPCPIPE_INTERNALS *t, OPCPIPE_ITEM *item, HANDLE_PAIR *netrefItem)
 
EXTERN_C int WENTRY_C MqttReadDebugBuffer (char *buffer, W_UINT32 buflen)
 
EXTERN_C int WENTRY_C MqttTimecount (OPCPIPE_INTERNALS *t)
 
EXTERN_C int WENTRY_C MqttDiagClientName (OPCPIPE_INTERNALS *t, char *mem, W_UINT32 memlen)
 
EXTERN_C int WENTRY_C MqttQueryItemInformation (OPCPIPE_INTERNALS *t, OPCPIPE_ITEM *item, WMK_OPCPIPE_ITEM_INFO *itemInfo, W_UINT32 maxMem)
 
EXTERN_C int WENTRY_C MqttStopWriteItems (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE writeHandle)
 
EXTERN_C int WENTRY_C MqttStopSyncReadItems (OPCPIPE_INTERNALS *t, WMK_OPCPIPE_HANDLE readHandle)
 
EXTERN_C int WENTRY_C MqttConnStatus (OPCPIPE_INTERNALS *t, OPCPIPE_STATUS *status)
 
EXTERN_C int WENTRY_C MqttItemSyntaxParse (OPCPIPE_INTERNALS *t, const char *itemSyntax, PLC_BROWSE_RESPONSE *address, W_UINT32 addressMemlen)
 

Variables

 DLL_DYNAMIC_FUNCTION_LIST_END
 

Detailed Description

PlcOpcPipeMQTTLoader.Dia.

PlcOpcPipeMQTTLoader.Dia

Author
MN
Version
3370
Date
Fri Jan 5 15:17:23 2024 !