uaprovider_demo.c

/******************************************************************************
**
**   **************************** auto-generated ****************************
**     This code was generated by a tool: UaModeler
**     Runtime Version: 1.2.0, using ANSI C SDK 1.4.0 provider template (version 1)
**
**     Changes to this file may cause incorrect behavior and will be lost if
**     the code is regenerated.
**   **************************** auto-generated ****************************

** Copyright (c) 2006-2014 Unified Automation GmbH All rights reserved.
** Web: http://www.unifiedautomation.com
**
** Software License Agreement ("SLA") Version 2.3
**
** Unless explicitly acquired and licensed from Licensor under another
** license, the contents of this file are subject to the Software License
** Agreement ("SLA") Version 2.3, or subsequent versions
** as allowed by the SLA, and You may not copy or use this file in either
** source code or executable form, except in compliance with the terms and
** conditions of the SLA.
**
** All software distributed under the SLA is provided strictly on an
** "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESS OR IMPLIED,
** AND LICENSOR HEREBY DISCLAIMS ALL SUCH WARRANTIES, INCLUDING WITHOUT
** LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
** PURPOSE, QUIET ENJOYMENT, OR NON-INFRINGEMENT. See the SLA for specific
** language governing rights and limitations under the SLA.
**
** Project: OPC Ansi C DemoProvider for namespace http://www.unifiedautomation.com/DemoServer/
**
** Description: OPC Unified Architecture Software Development Kit.
**
** The complete license agreement can be found here:
** http://unifiedautomation/License/SLA/2.3/
**
** Created: 15.07.2014
**
******************************************************************************/

#include "uaprovider_demo.h"

#include <opcua_proxystub.h>
#include <opcua_errorhandling.h>
#include <opcua_identifiers.h>
#include <opcua_string.h>
#include <opcua_pki.h>
#include <opcua_trace.h>

#include <uaserver_p_utilities.h>

#include "uaprovider_demo_helper.h"
#include "uaprovider_demo_nodes_1.h"
#include "uaprovider_demo_types_1.h"

#if UASERVER_SUPPORT_EVENTS
#include "uaprovider_demo_events_1.h"
#endif /* UASERVER_SUPPORT_EVENTS */
#include "uaprovider_demo_simulation.h"

/* Global Provider data */
UaServer_Provider*              g_pDemoProvider;
UaServer_pProviderInterface*    g_pDemoProviderInterface;

/* These are the basenodes managed by the server. */
OpcUa_UInt16                    g_UaProviderDemo_uNamespaceIndex1 = OpcUa_UInt16_Max;

/* The number of nodes managed by the server. */
#if HAVE_ENCODING_BINARY
#define UAPROVIDER_DEMO_NUMBEROFNODES1 428
#define UAPROVIDER_DEMO_NUMBEROFREFERENCES1 902
#else
#define UAPROVIDER_DEMO_NUMBEROFNODES1 424
#define UAPROVIDER_DEMO_NUMBEROFREFERENCES1 893
#endif
#define UAPROVIDER_DEMO_NUMBEROFMETHODS1 18
#define UAPROVIDER_DEMO_HASHTABLESIZE 1009


IFMETHODIMP(UaProvider_Demo_ReadAsync)(UaServer_ProviderReadContext* a_pReadCtx);
IFMETHODIMP(UaProvider_Demo_WriteAsync)(UaServer_ProviderWriteContext* a_pWriteCtx);
#if UASERVER_SERVICES_HISTORYREAD
IFMETHODIMP(UaProvider_Demo_HistoryReadRawModifiedAsync)(UaServer_ProviderHistoryReadRawModifiedContext* a_pReadCtx);
#endif
IFMETHODIMP(UaProvider_Demo_BrowseAsync)(UaServer_ProviderBrowseContext* a_pBrowseCtx);
IFMETHODIMP(UaProvider_Demo_TranslateAsync)(UaServer_ProviderTranslateContext* a_pTranslateCtx);
IFMETHODIMP(UaProvider_Demo_RegisterNodesAsync)(UaServer_ProviderRegisterNodesContext* a_pRegisterNodesCtx);
IFMETHODIMP(UaProvider_Demo_UnregisterNodesAsync)(UaServer_ProviderUnregisterNodesContext* a_pUnregisterNodesCtx);
#if UASERVER_SERVICES_CALL
IFMETHODIMP(UaProvider_Demo_CallAsync)(UaServer_ProviderCallContext* a_pCallContext);
#endif
IFMETHODIMP(UaProvider_Demo_AddItem)(UaServer_MonitoredItem* a_pItem);
IFMETHODIMP(UaProvider_Demo_RemoveItem)(UaServer_MonitoredItem* a_pItem);
IFMETHODIMP(UaProvider_Demo_Subscribe)(UaServer_ProviderSubscribeContext *a_pCtx);

OpcUa_StatusCode UaProvider_Demo_Subscription_Initialize();
OpcUa_StatusCode UaProvider_Demo_Subscription_Cleanup();

IFMETHODIMP(UaProvider_Demo_Cleanup)()
{
    printf("Cleanup Demo Provider ...\n");

    UaProvider_Demo_StopSimulation();
    UaProvider_Demo_CleanupSimulation();

    UaProvider_Demo_Subscription_Cleanup();
#if UASERVER_SUPPORT_EVENTS
    UaProvider_Demo_UnregisterEventTypes1();
#endif

    printf("Cleanup Demo Provider DONE!\n");

    return OpcUa_Good;
}

/*============================================================================
* Internal Helper For Creating The AddressSpace In The Server
*===========================================================================*/
static OpcUa_StatusCode UaProvider_Demo_CreateAddressSpace()
{
OpcUa_InitializeStatus(OpcUa_Module_Server, "UaProvider_Demo_CreateAddressSpace");
    uStatus = UaProvider_Demo_CreateAddressSpace1();
    OpcUa_GotoErrorIfBad(uStatus);

OpcUa_ReturnStatusCode;
OpcUa_BeginErrorHandling;
OpcUa_FinishErrorHandling;
}

#if UASERVER_SUPPORT_EVENTS

static OpcUa_StatusCode UaProvider_Demo_BuildEventHierarchy()
{
OpcUa_InitializeStatus(OpcUa_Module_Server, "UaProvider_Demo_BuildEventHierarchy");
    uStatus = UaProvider_Demo_BuildEventHierarchy_1();
    OpcUa_GotoErrorIfBad(uStatus);

OpcUa_ReturnStatusCode;
OpcUa_BeginErrorHandling;
OpcUa_FinishErrorHandling;
}
#endif

IFMETHODIMP(UaProvider_Demo_Initialize)(
    UaServer_Provider*             a_pProvider,
    UaServer_pProviderInterface*   a_pProviderInterface)
{
    OpcUa_StatusCode uStatus = OpcUa_Good;

    printf("Initialize Demo Provider ...\n");

    /* store values */
    g_pDemoProvider            = a_pProvider;
    g_pDemoProviderInterface   = a_pProviderInterface;
    OpcUa_MemSet(g_pDemoProviderInterface, 0, sizeof(UaServer_pProviderInterface));

    /* Register Handlers */
    a_pProviderInterface->Cleanup               = UaProvider_Demo_Cleanup;
    a_pProviderInterface->ReadAsync             = UaProvider_Demo_ReadAsync;
    a_pProviderInterface->WriteAsync            = UaProvider_Demo_WriteAsync;
#if UASERVER_SERVICES_HISTORYREAD
    a_pProviderInterface->HistoryReadRawModifiedAsync   = UaProvider_Demo_HistoryReadRawModifiedAsync;
#endif
    a_pProviderInterface->BrowseAsync           = UaProvider_Demo_BrowseAsync;
    a_pProviderInterface->TranslateAsync        = UaProvider_Demo_TranslateAsync;
    a_pProviderInterface->RegisterNodesAsync    = UaProvider_Demo_RegisterNodesAsync;
    a_pProviderInterface->UnregisterNodesAsync  = UaProvider_Demo_UnregisterNodesAsync;
#if UASERVER_SERVICES_CALL
    a_pProviderInterface->CallAsync             = UaProvider_Demo_CallAsync;
#endif
    a_pProviderInterface->AddItem               = UaProvider_Demo_AddItem;
    a_pProviderInterface->RemoveItem            = UaProvider_Demo_RemoveItem;
    a_pProviderInterface->Subscribe             = UaProvider_Demo_Subscribe;

    uStatus = UaServer_RegisterAddressSpace((OpcUa_Handle *)a_pProvider,
              &g_UaProviderDemo_uNamespaceIndex1,
              "http://www.unifiedautomation.com/DemoServer/",
              UAPROVIDER_DEMO_HASHTABLESIZE);
    OpcUa_ReturnErrorIfBad(uStatus);


    /* add types */
    uStatus = OpcUa_ProxyStub_AddTypes(Demo_KnownEncodeableTypes1);
    OpcUa_ReturnErrorIfBad(uStatus);
    /* Create Server Managed AddressSpace */
    uStatus = UaProvider_Demo_CreateAddressSpace();
    OpcUa_ReturnErrorIfBad(uStatus);

    /* initialize subscriptions */
    uStatus = UaProvider_Demo_Subscription_Initialize();
    OpcUa_ReturnErrorIfBad(uStatus);
#if UASERVER_SUPPORT_EVENTS
    /* register event types */
    UaProvider_Demo_RegisterEventTypes1();
    uStatus = UaProvider_Demo_BuildEventHierarchy();
    OpcUa_ReturnErrorIfBad(uStatus);
#endif

    /* initialize simulation */
    uStatus = UaProvider_Demo_InitializeSimulation();
    OpcUa_ReturnErrorIfBad(uStatus);
    uStatus = UaProvider_Demo_StartSimulation();
    OpcUa_ReturnErrorIfBad(uStatus);

    printf("Demo Provider initialized!\n");
    printf("   %d Nodes created\n", a_pProvider->AddressSpace.uNumNodes);
    printf("   NS%d:\n", g_UaProviderDemo_uNamespaceIndex1);
    printf("   %d static nodes created\n", UAPROVIDER_DEMO_NUMBEROFNODES1);
    printf("   %d static references created\n", UAPROVIDER_DEMO_NUMBEROFREFERENCES1);
    printf("   %d static methods created\n", UAPROVIDER_DEMO_NUMBEROFMETHODS1);

    return uStatus;
}

#if BUILD_SHARED_LIBS
DEMOPROVIDER_API(OpcUa_StatusCode) InitializeProvider(
    UaServer_Provider*             pProvider,
    UaServer_pProviderInterface*   pProviderInterface)
{
    return UaProvider_Demo_Initialize(pProvider, pProviderInterface);
}
#endif