UA ANSI C Server Professional  1.4.2.297
 All Data Structures Functions Variables Typedefs Enumerations Enumerator Modules Pages
custom_provider_write.c
/******************************************************************************
**
** Copyright (C) 2011-2014 Unified Automation GmbH. All Rights Reserved.
** Web: http://www.unifiedautomation.com
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** Project: OPC Ansi C OPC Server Examples
**
******************************************************************************/
#include <uaserver_config.h>
#include <opcua_statuscodes.h>
#include <uaserver_write.h>
#include <uaserver_basenode.h>
#include <uaserver_utilities.h>
#include <uaserver_p_atomic.h>
#include "custom_provider_helper.h"
OPCUA_BEGIN_EXTERN_C
IFMETHODIMP(CustomProvider_WriteAsync)(UaServer_ProviderWriteContext* a_pWriteCtx)
{
OpcUa_WriteRequest *pReq;
OpcUa_WriteResponse *pRes;
OpcUa_Int32 i;
OpcUa_BaseNode *pNode;
UaServer_AddressSpace *pAddressSpace = &(g_pCustomProvider->AddressSpace);
OpcUa_InitializeStatus(OpcUa_Module_Server, "CustomProvider_WriteAsync");
OpcUa_ReturnErrorIfArgumentNull(a_pWriteCtx);
pReq = a_pWriteCtx->pRequest;
pRes = a_pWriteCtx->pResponse;
/* We will send exactly one callback */
UaServer_Atomic_Increment(&a_pWriteCtx->nOutstandingCbs);
/* Iterate over nodes and check if the provider is responsible for processing them */
for (i = 0; i < pReq->NoOfNodesToWrite; i++)
{
if (pReq->NodesToWrite[i].NodeId.NamespaceIndex == g_uCustomProvider_NamespaceIndex)
{
UaServer_GetNode(pAddressSpace, &pReq->NodesToWrite[i].NodeId, &pNode);
if (pNode)
{
if ( (a_pWriteCtx->pRequest->NodesToWrite[i].AttributeId == OpcUa_Attributes_Value &&
OpcUa_BaseNode_GetType(pNode) == eVariable &&
(OpcUa_Variable_GetAccessLevel(pNode) & OpcUa_AccessLevels_CurrentWrite) == 0) )
{
pRes->Results[i] = OpcUa_BadNotWritable;
continue;
}
if ( (a_pWriteCtx->pRequest->NodesToWrite[i].AttributeId == OpcUa_Attributes_Value &&
a_pWriteCtx->pSession->UserIdentityData)) ||
(a_pWriteCtx->pRequest->NodesToWrite[i].AttributeId != OpcUa_Attributes_Value &&
a_pWriteCtx->pSession->UserIdentityData)))
{
pRes->Results[i] = OpcUa_BadNotWritable;
continue;
}
/* Use the SDK's helper function to process the request */
UaServer_WriteInternal(pNode, a_pWriteCtx, i);
}
else
{
pRes->Results[i] = OpcUa_BadNodeIdUnknown;
}
}
}
/* Send callback */
UaServer_WriteComplete(a_pWriteCtx);
OpcUa_ReturnStatusCode;
OpcUa_BeginErrorHandling;
OpcUa_FinishErrorHandling;
}
OPCUA_END_EXTERN_C