123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661 |
- /* This Source Code Form is subject to the terms of the Mozilla Public
- * License, v. 2.0. If a copy of the MPL was not distributed with this
- * file, You can obtain one at http://mozilla.org/MPL/2.0/.
- *
- * Copyright 2015-2017 (c) Fraunhofer IOSB (Author: Julius Pfrommer)
- * Copyright 2015 (c) Oleksiy Vasylyev
- * Copyright 2017 (c) Florian Palm
- * Copyright 2016 (c) Chris Iatrou
- * Copyright 2017 (c) Stefan Profanter, fortiss GmbH
- */
- #include "ua_client.h"
- #include "ua_client_internal.h"
- #include "ua_client_highlevel.h"
- #include "ua_client_highlevel_async.h"
- #include "ua_util.h"
- UA_StatusCode
- UA_Client_NamespaceGetIndex(UA_Client *client, UA_String *namespaceUri,
- UA_UInt16 *namespaceIndex) {
- UA_ReadRequest request;
- UA_ReadRequest_init(&request);
- UA_ReadValueId id;
- UA_ReadValueId_init(&id);
- id.attributeId = UA_ATTRIBUTEID_VALUE;
- id.nodeId = UA_NODEID_NUMERIC(0, UA_NS0ID_SERVER_NAMESPACEARRAY);
- request.nodesToRead = &id;
- request.nodesToReadSize = 1;
- UA_ReadResponse response = UA_Client_Service_read(client, request);
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- if(response.responseHeader.serviceResult != UA_STATUSCODE_GOOD)
- retval = response.responseHeader.serviceResult;
- else if(response.resultsSize != 1 || !response.results[0].hasValue)
- retval = UA_STATUSCODE_BADNODEATTRIBUTESINVALID;
- else if(response.results[0].value.type != &UA_TYPES[UA_TYPES_STRING])
- retval = UA_STATUSCODE_BADTYPEMISMATCH;
- if(retval != UA_STATUSCODE_GOOD) {
- UA_ReadResponse_deleteMembers(&response);
- return retval;
- }
- retval = UA_STATUSCODE_BADNOTFOUND;
- UA_String *ns = (UA_String *)response.results[0].value.data;
- for(size_t i = 0; i < response.results[0].value.arrayLength; ++i) {
- if(UA_String_equal(namespaceUri, &ns[i])) {
- *namespaceIndex = (UA_UInt16)i;
- retval = UA_STATUSCODE_GOOD;
- break;
- }
- }
- UA_ReadResponse_deleteMembers(&response);
- return retval;
- }
- UA_StatusCode
- UA_Client_forEachChildNodeCall(UA_Client *client, UA_NodeId parentNodeId,
- UA_NodeIteratorCallback callback, void *handle) {
- UA_BrowseRequest bReq;
- UA_BrowseRequest_init(&bReq);
- bReq.requestedMaxReferencesPerNode = 0;
- bReq.nodesToBrowse = UA_BrowseDescription_new();
- bReq.nodesToBrowseSize = 1;
- UA_NodeId_copy(&parentNodeId, &bReq.nodesToBrowse[0].nodeId);
- bReq.nodesToBrowse[0].resultMask = UA_BROWSERESULTMASK_ALL; //return everything
- bReq.nodesToBrowse[0].browseDirection = UA_BROWSEDIRECTION_BOTH;
- UA_BrowseResponse bResp = UA_Client_Service_browse(client, bReq);
- UA_StatusCode retval = bResp.responseHeader.serviceResult;
- if(retval == UA_STATUSCODE_GOOD) {
- for(size_t i = 0; i < bResp.resultsSize; ++i) {
- for(size_t j = 0; j < bResp.results[i].referencesSize; ++j) {
- UA_ReferenceDescription *ref = &bResp.results[i].references[j];
- retval |= callback(ref->nodeId.nodeId, !ref->isForward,
- ref->referenceTypeId, handle);
- }
- }
- }
- UA_BrowseRequest_deleteMembers(&bReq);
- UA_BrowseResponse_deleteMembers(&bResp);
- return retval;
- }
- /*******************/
- /* Node Management */
- /*******************/
- UA_StatusCode
- UA_Client_addReference(UA_Client *client, const UA_NodeId sourceNodeId,
- const UA_NodeId referenceTypeId, UA_Boolean isForward,
- const UA_String targetServerUri,
- const UA_ExpandedNodeId targetNodeId,
- UA_NodeClass targetNodeClass) {
- UA_AddReferencesItem item;
- UA_AddReferencesItem_init(&item);
- item.sourceNodeId = sourceNodeId;
- item.referenceTypeId = referenceTypeId;
- item.isForward = isForward;
- item.targetServerUri = targetServerUri;
- item.targetNodeId = targetNodeId;
- item.targetNodeClass = targetNodeClass;
- UA_AddReferencesRequest request;
- UA_AddReferencesRequest_init(&request);
- request.referencesToAdd = &item;
- request.referencesToAddSize = 1;
- UA_AddReferencesResponse response = UA_Client_Service_addReferences(client, request);
- UA_StatusCode retval = response.responseHeader.serviceResult;
- if(retval != UA_STATUSCODE_GOOD) {
- UA_AddReferencesResponse_deleteMembers(&response);
- return retval;
- }
- if(response.resultsSize != 1) {
- UA_AddReferencesResponse_deleteMembers(&response);
- return UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- retval = response.results[0];
- UA_AddReferencesResponse_deleteMembers(&response);
- return retval;
- }
- UA_StatusCode
- UA_Client_deleteReference(UA_Client *client, const UA_NodeId sourceNodeId,
- const UA_NodeId referenceTypeId, UA_Boolean isForward,
- const UA_ExpandedNodeId targetNodeId,
- UA_Boolean deleteBidirectional) {
- UA_DeleteReferencesItem item;
- UA_DeleteReferencesItem_init(&item);
- item.sourceNodeId = sourceNodeId;
- item.referenceTypeId = referenceTypeId;
- item.isForward = isForward;
- item.targetNodeId = targetNodeId;
- item.deleteBidirectional = deleteBidirectional;
- UA_DeleteReferencesRequest request;
- UA_DeleteReferencesRequest_init(&request);
- request.referencesToDelete = &item;
- request.referencesToDeleteSize = 1;
- UA_DeleteReferencesResponse response = UA_Client_Service_deleteReferences(client, request);
- UA_StatusCode retval = response.responseHeader.serviceResult;
- if(retval != UA_STATUSCODE_GOOD) {
- UA_DeleteReferencesResponse_deleteMembers(&response);
- return retval;
- }
- if(response.resultsSize != 1) {
- UA_DeleteReferencesResponse_deleteMembers(&response);
- return UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- retval = response.results[0];
- UA_DeleteReferencesResponse_deleteMembers(&response);
- return retval;
- }
- UA_StatusCode
- UA_Client_deleteNode(UA_Client *client, const UA_NodeId nodeId,
- UA_Boolean deleteTargetReferences) {
- UA_DeleteNodesItem item;
- UA_DeleteNodesItem_init(&item);
- item.nodeId = nodeId;
- item.deleteTargetReferences = deleteTargetReferences;
- UA_DeleteNodesRequest request;
- UA_DeleteNodesRequest_init(&request);
- request.nodesToDelete = &item;
- request.nodesToDeleteSize = 1;
- UA_DeleteNodesResponse response = UA_Client_Service_deleteNodes(client, request);
- UA_StatusCode retval = response.responseHeader.serviceResult;
- if(retval != UA_STATUSCODE_GOOD) {
- UA_DeleteNodesResponse_deleteMembers(&response);
- return retval;
- }
- if(response.resultsSize != 1) {
- UA_DeleteNodesResponse_deleteMembers(&response);
- return UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- retval = response.results[0];
- UA_DeleteNodesResponse_deleteMembers(&response);
- return retval;
- }
- UA_StatusCode
- __UA_Client_addNode(UA_Client *client, const UA_NodeClass nodeClass,
- const UA_NodeId requestedNewNodeId, const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId, const UA_QualifiedName browseName,
- const UA_NodeId typeDefinition, const UA_NodeAttributes *attr,
- const UA_DataType *attributeType, UA_NodeId *outNewNodeId) {
- UA_AddNodesRequest request;
- UA_AddNodesRequest_init(&request);
- UA_AddNodesItem item;
- UA_AddNodesItem_init(&item);
- item.parentNodeId.nodeId = parentNodeId;
- item.referenceTypeId = referenceTypeId;
- item.requestedNewNodeId.nodeId = requestedNewNodeId;
- item.browseName = browseName;
- item.nodeClass = nodeClass;
- item.typeDefinition.nodeId = typeDefinition;
- item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
- item.nodeAttributes.content.decoded.type = attributeType;
- item.nodeAttributes.content.decoded.data = (void*)(uintptr_t)attr; // hack. is not written into.
- request.nodesToAdd = &item;
- request.nodesToAddSize = 1;
- UA_AddNodesResponse response = UA_Client_Service_addNodes(client, request);
- UA_StatusCode retval = response.responseHeader.serviceResult;
- if(retval != UA_STATUSCODE_GOOD) {
- UA_AddNodesResponse_deleteMembers(&response);
- return retval;
- }
- if(response.resultsSize != 1) {
- UA_AddNodesResponse_deleteMembers(&response);
- return UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- /* Move the id of the created node */
- retval = response.results[0].statusCode;
- if(retval == UA_STATUSCODE_GOOD && outNewNodeId) {
- *outNewNodeId = response.results[0].addedNodeId;
- UA_NodeId_init(&response.results[0].addedNodeId);
- }
- UA_AddNodesResponse_deleteMembers(&response);
- return retval;
- }
- /********/
- /* Call */
- /********/
- #ifdef UA_ENABLE_METHODCALLS
- UA_StatusCode
- UA_Client_call(UA_Client *client, const UA_NodeId objectId,
- const UA_NodeId methodId, size_t inputSize,
- const UA_Variant *input, size_t *outputSize,
- UA_Variant **output) {
- /* Set up the request */
- UA_CallRequest request;
- UA_CallRequest_init(&request);
- UA_CallMethodRequest item;
- UA_CallMethodRequest_init(&item);
- item.methodId = methodId;
- item.objectId = objectId;
- item.inputArguments = (UA_Variant *)(void*)(uintptr_t)input; // cast const...
- item.inputArgumentsSize = inputSize;
- request.methodsToCall = &item;
- request.methodsToCallSize = 1;
- /* Call the service */
- UA_CallResponse response = UA_Client_Service_call(client, request);
- UA_StatusCode retval = response.responseHeader.serviceResult;
- if(retval == UA_STATUSCODE_GOOD) {
- if(response.resultsSize == 1)
- retval = response.results[0].statusCode;
- else
- retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- if(retval != UA_STATUSCODE_GOOD) {
- UA_CallResponse_deleteMembers(&response);
- return retval;
- }
- /* Move the output arguments */
- if(output != NULL && outputSize != NULL) {
- *output = response.results[0].outputArguments;
- *outputSize = response.results[0].outputArgumentsSize;
- response.results[0].outputArguments = NULL;
- response.results[0].outputArgumentsSize = 0;
- }
- UA_CallResponse_deleteMembers(&response);
- return retval;
- }
- #endif
- /********************/
- /* Write Attributes */
- /********************/
- UA_StatusCode
- __UA_Client_writeAttribute(UA_Client *client, const UA_NodeId *nodeId,
- UA_AttributeId attributeId, const void *in,
- const UA_DataType *inDataType) {
- if(!in)
- return UA_STATUSCODE_BADTYPEMISMATCH;
- UA_WriteValue wValue;
- UA_WriteValue_init(&wValue);
- wValue.nodeId = *nodeId;
- wValue.attributeId = attributeId;
- if(attributeId == UA_ATTRIBUTEID_VALUE)
- wValue.value.value = *(const UA_Variant*)in;
- else
- /* hack. is never written into. */
- UA_Variant_setScalar(&wValue.value.value, (void*)(uintptr_t)in, inDataType);
- wValue.value.hasValue = true;
- UA_WriteRequest wReq;
- UA_WriteRequest_init(&wReq);
- wReq.nodesToWrite = &wValue;
- wReq.nodesToWriteSize = 1;
- UA_WriteResponse wResp = UA_Client_Service_write(client, wReq);
- UA_StatusCode retval = wResp.responseHeader.serviceResult;
- if(retval == UA_STATUSCODE_GOOD) {
- if(wResp.resultsSize == 1)
- retval = wResp.results[0];
- else
- retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- UA_WriteResponse_deleteMembers(&wResp);
- return retval;
- }
- UA_StatusCode
- UA_Client_writeArrayDimensionsAttribute(UA_Client *client, const UA_NodeId nodeId,
- size_t newArrayDimensionsSize,
- const UA_UInt32 *newArrayDimensions) {
- if(!newArrayDimensions)
- return UA_STATUSCODE_BADTYPEMISMATCH;
- UA_WriteValue wValue;
- UA_WriteValue_init(&wValue);
- wValue.nodeId = nodeId;
- wValue.attributeId = UA_ATTRIBUTEID_ARRAYDIMENSIONS;
- UA_Variant_setArray(&wValue.value.value, (void*)(uintptr_t)newArrayDimensions,
- newArrayDimensionsSize, &UA_TYPES[UA_TYPES_UINT32]);
- wValue.value.hasValue = true;
- UA_WriteRequest wReq;
- UA_WriteRequest_init(&wReq);
- wReq.nodesToWrite = &wValue;
- wReq.nodesToWriteSize = 1;
- UA_WriteResponse wResp = UA_Client_Service_write(client, wReq);
- UA_StatusCode retval = wResp.responseHeader.serviceResult;
- if(retval == UA_STATUSCODE_GOOD) {
- if(wResp.resultsSize == 1)
- retval = wResp.results[0];
- else
- retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- UA_WriteResponse_deleteMembers(&wResp);
- return retval;
- }
- /*******************/
- /* Read Attributes */
- /*******************/
- UA_StatusCode
- __UA_Client_readAttribute(UA_Client *client, const UA_NodeId *nodeId,
- UA_AttributeId attributeId, void *out,
- const UA_DataType *outDataType) {
- UA_ReadValueId item;
- UA_ReadValueId_init(&item);
- item.nodeId = *nodeId;
- item.attributeId = attributeId;
- UA_ReadRequest request;
- UA_ReadRequest_init(&request);
- request.nodesToRead = &item;
- request.nodesToReadSize = 1;
- UA_ReadResponse response = UA_Client_Service_read(client, request);
- UA_StatusCode retval = response.responseHeader.serviceResult;
- if(retval == UA_STATUSCODE_GOOD) {
- if(response.resultsSize == 1)
- retval = response.results[0].status;
- else
- retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- if(retval != UA_STATUSCODE_GOOD) {
- UA_ReadResponse_deleteMembers(&response);
- return retval;
- }
- /* Set the StatusCode */
- UA_DataValue *res = response.results;
- if(res->hasStatus)
- retval = res->status;
- /* Return early of no value is given */
- if(!res->hasValue) {
- if(retval == UA_STATUSCODE_GOOD)
- retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
- UA_ReadResponse_deleteMembers(&response);
- return retval;
- }
- /* Copy value into out */
- if(attributeId == UA_ATTRIBUTEID_VALUE) {
- memcpy(out, &res->value, sizeof(UA_Variant));
- UA_Variant_init(&res->value);
- } else if(attributeId == UA_ATTRIBUTEID_NODECLASS) {
- memcpy(out, (UA_NodeClass*)res->value.data, sizeof(UA_NodeClass));
- } else if(UA_Variant_isScalar(&res->value) &&
- res->value.type == outDataType) {
- memcpy(out, res->value.data, res->value.type->memSize);
- UA_free(res->value.data);
- res->value.data = NULL;
- } else {
- retval = UA_STATUSCODE_BADUNEXPECTEDERROR;
- }
- UA_ReadResponse_deleteMembers(&response);
- return retval;
- }
- static UA_StatusCode
- processReadArrayDimensionsResult(UA_ReadResponse *response,
- UA_UInt32 **outArrayDimensions,
- size_t *outArrayDimensionsSize) {
- UA_StatusCode retval = response->responseHeader.serviceResult;
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- if(response->resultsSize != 1)
- return UA_STATUSCODE_BADUNEXPECTEDERROR;
- retval = response->results[0].status;
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- UA_DataValue *res = &response->results[0];
- if(!res->hasValue ||
- UA_Variant_isScalar(&res->value) ||
- res->value.type != &UA_TYPES[UA_TYPES_UINT32])
- return UA_STATUSCODE_BADUNEXPECTEDERROR;
- /* Move results */
- *outArrayDimensions = (UA_UInt32*)res->value.data;
- *outArrayDimensionsSize = res->value.arrayLength;
- res->value.data = NULL;
- res->value.arrayLength = 0;
- return UA_STATUSCODE_GOOD;
- }
- UA_StatusCode
- UA_Client_readArrayDimensionsAttribute(UA_Client *client, const UA_NodeId nodeId,
- size_t *outArrayDimensionsSize,
- UA_UInt32 **outArrayDimensions) {
- UA_ReadValueId item;
- UA_ReadValueId_init(&item);
- item.nodeId = nodeId;
- item.attributeId = UA_ATTRIBUTEID_ARRAYDIMENSIONS;
- UA_ReadRequest request;
- UA_ReadRequest_init(&request);
- request.nodesToRead = &item;
- request.nodesToReadSize = 1;
- UA_ReadResponse response = UA_Client_Service_read(client, request);
- UA_StatusCode retval = processReadArrayDimensionsResult(&response, outArrayDimensions,
- outArrayDimensionsSize);
- UA_ReadResponse_deleteMembers(&response);
- return retval;
- }
- /*Async Functions*/
- /*highlevel callbacks
- * used to hide response handling details*/
- static
- void ValueAttributeRead(UA_Client *client, void *userdata, UA_UInt32 requestId,
- void *response) {
- if (response == NULL) {
- return;
- }
- CustomCallback *cc;
- LIST_FOREACH(cc, &client->customCallbacks, pointers)
- {
- if (cc->callbackId == requestId)
- break;
- }
- if (!cc)
- return;
- UA_ReadResponse rr = *(UA_ReadResponse *) response;
- if (rr.results[0].status != UA_STATUSCODE_GOOD)
- UA_ReadResponse_deleteMembers((UA_ReadResponse*) response);
- UA_Variant out;
- UA_Variant_init(&out);
- UA_DataValue *res = rr.results;
- if (!res->hasValue) {
- return;
- }
- /*__UA_Client_readAttribute*/
- memcpy(&out, &res->value, sizeof(UA_Variant));
- /* Copy value into out */
- if (cc->attributeId == UA_ATTRIBUTEID_VALUE) {
- memcpy(&out, &res->value, sizeof(UA_Variant));
- UA_Variant_init(&res->value);
- } else if (cc->attributeId == UA_ATTRIBUTEID_NODECLASS) {
- memcpy(&out, (UA_NodeClass*) res->value.data, sizeof(UA_NodeClass));
- } else if (UA_Variant_isScalar(&res->value)
- && res->value.type == cc->outDataType) {
- memcpy(&out, res->value.data, res->value.type->memSize);
- UA_free(res->value.data);
- res->value.data = NULL;
- }
- //use callbackId to find the right custom callback
- cc->callback(client, userdata, requestId, &out);
- LIST_REMOVE(cc, pointers);
- UA_free(cc);
- UA_ReadResponse_deleteMembers((UA_ReadResponse*) response);
- UA_Variant_deleteMembers(&out);
- }
- /*Read Attributes*/
- UA_StatusCode __UA_Client_readAttribute_async(UA_Client *client,
- const UA_NodeId *nodeId, UA_AttributeId attributeId,
- const UA_DataType *outDataType, UA_ClientAsyncServiceCallback callback,
- void *userdata, UA_UInt32 *reqId) {
- UA_ReadValueId item;
- UA_ReadValueId_init(&item);
- item.nodeId = *nodeId;
- item.attributeId = attributeId;
- UA_ReadRequest request;
- UA_ReadRequest_init(&request);
- request.nodesToRead = &item;
- request.nodesToReadSize = 1;
- __UA_Client_AsyncService(client, &request, &UA_TYPES[UA_TYPES_READREQUEST],
- ValueAttributeRead, &UA_TYPES[UA_TYPES_READRESPONSE], userdata,
- reqId);
- CustomCallback *cc = (CustomCallback*) UA_malloc(sizeof(CustomCallback));
- if (!cc)
- return UA_STATUSCODE_BADOUTOFMEMORY;
- cc->callback = callback;
- cc->callbackId = *reqId;
- cc->attributeId = attributeId;
- cc->outDataType = outDataType;
- LIST_INSERT_HEAD(&client->customCallbacks, cc, pointers);
- return UA_STATUSCODE_GOOD;
- }
- /*Write Attributes*/
- UA_StatusCode __UA_Client_writeAttribute_async(UA_Client *client,
- const UA_NodeId *nodeId, UA_AttributeId attributeId, const void *in,
- const UA_DataType *inDataType, UA_ClientAsyncServiceCallback callback,
- void *userdata, UA_UInt32 *reqId) {
- if (!in)
- return UA_STATUSCODE_BADTYPEMISMATCH;
- UA_WriteValue wValue;
- UA_WriteValue_init(&wValue);
- wValue.nodeId = *nodeId;
- wValue.attributeId = attributeId;
- if (attributeId == UA_ATTRIBUTEID_VALUE)
- wValue.value.value = *(const UA_Variant*) in;
- else
- /* hack. is never written into. */
- UA_Variant_setScalar(&wValue.value.value, (void*) (uintptr_t) in,
- inDataType);
- wValue.value.hasValue = true;
- UA_WriteRequest wReq;
- UA_WriteRequest_init(&wReq);
- wReq.nodesToWrite = &wValue;
- wReq.nodesToWriteSize = 1;
- return __UA_Client_AsyncService(client, &wReq,
- &UA_TYPES[UA_TYPES_WRITEREQUEST], callback,
- &UA_TYPES[UA_TYPES_WRITERESPONSE], userdata, reqId);
- }
- /*Node Management*/
- UA_StatusCode UA_EXPORT
- __UA_Client_addNode_async(UA_Client *client, const UA_NodeClass nodeClass,
- const UA_NodeId requestedNewNodeId, const UA_NodeId parentNodeId,
- const UA_NodeId referenceTypeId, const UA_QualifiedName browseName,
- const UA_NodeId typeDefinition, const UA_NodeAttributes *attr,
- const UA_DataType *attributeType, UA_NodeId *outNewNodeId,
- UA_ClientAsyncServiceCallback callback, void *userdata,
- UA_UInt32 *reqId) {
- UA_AddNodesRequest request;
- UA_AddNodesRequest_init(&request);
- UA_AddNodesItem item;
- UA_AddNodesItem_init(&item);
- item.parentNodeId.nodeId = parentNodeId;
- item.referenceTypeId = referenceTypeId;
- item.requestedNewNodeId.nodeId = requestedNewNodeId;
- item.browseName = browseName;
- item.nodeClass = nodeClass;
- item.typeDefinition.nodeId = typeDefinition;
- item.nodeAttributes.encoding = UA_EXTENSIONOBJECT_DECODED_NODELETE;
- item.nodeAttributes.content.decoded.type = attributeType;
- item.nodeAttributes.content.decoded.data = (void*) (uintptr_t) attr; // hack. is not written into.
- request.nodesToAdd = &item;
- request.nodesToAddSize = 1;
- return __UA_Client_AsyncService(client, &request,
- &UA_TYPES[UA_TYPES_ADDNODESREQUEST], callback,
- &UA_TYPES[UA_TYPES_ADDNODESRESPONSE], userdata, reqId);
- }
- /*Misc Highlevel Functions*/
- UA_StatusCode __UA_Client_call_async(UA_Client *client,
- const UA_NodeId objectId, const UA_NodeId methodId, size_t inputSize,
- const UA_Variant *input, UA_ClientAsyncServiceCallback callback,
- void *userdata, UA_UInt32 *reqId) {
- UA_CallRequest request;
- UA_CallRequest_init(&request);
- UA_CallMethodRequest item;
- UA_CallMethodRequest_init(&item);
- item.methodId = methodId;
- item.objectId = objectId;
- item.inputArguments = (UA_Variant *) (void*) (uintptr_t) input; // cast const...
- item.inputArgumentsSize = inputSize;
- request.methodsToCall = &item;
- request.methodsToCallSize = 1;
- return __UA_Client_AsyncService(client, &request,
- &UA_TYPES[UA_TYPES_CALLREQUEST], callback,
- &UA_TYPES[UA_TYPES_CALLRESPONSE], userdata, reqId);
- }
- UA_StatusCode __UA_Client_translateBrowsePathsToNodeIds_async(UA_Client *client,
- char *paths[], UA_UInt32 ids[], size_t pathSize,
- UA_ClientAsyncServiceCallback callback, void *userdata,
- UA_UInt32 *reqId) {
- UA_BrowsePath browsePath;
- UA_BrowsePath_init(&browsePath);
- browsePath.startingNode = UA_NODEID_NUMERIC(0, UA_NS0ID_OBJECTSFOLDER);
- browsePath.relativePath.elements = (UA_RelativePathElement*) UA_Array_new(
- pathSize, &UA_TYPES[UA_TYPES_RELATIVEPATHELEMENT]);
- if (!browsePath.relativePath.elements)
- return UA_STATUSCODE_BADOUTOFMEMORY;
- browsePath.relativePath.elementsSize = pathSize;
- UA_TranslateBrowsePathsToNodeIdsRequest request;
- UA_TranslateBrowsePathsToNodeIdsRequest_init(&request);
- request.browsePaths = &browsePath;
- request.browsePathsSize = 1;
- UA_StatusCode retval = __UA_Client_AsyncService(client, &request,
- &UA_TYPES[UA_TYPES_TRANSLATEBROWSEPATHSTONODEIDSREQUEST], callback,
- &UA_TYPES[UA_TYPES_TRANSLATEBROWSEPATHSTONODEIDSRESPONSE], userdata,
- reqId);
- if (retval != UA_STATUSCODE_GOOD) {
- UA_Array_delete(browsePath.relativePath.elements,
- browsePath.relativePath.elementsSize,
- &UA_TYPES[UA_TYPES_RELATIVEPATHELEMENT]);
- return retval;
- }
- UA_BrowsePath_deleteMembers(&browsePath);
- return retval;
- }
|