123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734 |
- #include "ua_server_internal.h"
- #include "ua_types_generated.h"
- #include "ua_services.h"
- #include "ua_statuscodes.h"
- #include "ua_nodestore.h"
- #include "ua_util.h"
- /******************/
- /* Read Attribute */
- /******************/
- static size_t readNumber(UA_Byte *buf, UA_Int32 buflen, UA_UInt32 *number) {
- UA_UInt32 n = 0;
- size_t progress = 0;
- /* read numbers until the end or a non-number character appears */
- UA_Byte c;
- while((UA_Int32)progress < buflen) {
- c = buf[progress];
- if('0' > c || '9' < c)
- break;
- n = (n*10) + (c-'0');
- progress++;
- }
- *number = n;
- return progress;
- }
- static size_t readDimension(UA_Byte *buf, UA_Int32 buflen, struct UA_NumericRangeDimension *dim) {
- size_t progress = readNumber(buf, buflen, &dim->min);
- if(progress == 0)
- return 0;
- if(buflen <= (UA_Int32)progress || buf[progress] != ':') {
- dim->max = dim->min;
- return progress;
- }
- size_t progress2 = readNumber(&buf[progress+1], buflen - (progress + 1), &dim->max);
- if(progress2 == 0)
- return 0;
- return progress + progress2 + 1;
- }
- #ifndef BUILD_UNIT_TESTS
- static
- #endif
- UA_StatusCode parse_numericrange(const UA_String *str, UA_NumericRange *range) {
- UA_Int32 index = 0;
- size_t dimensionsMax = 0;
- struct UA_NumericRangeDimension *dimensions = NULL;
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- size_t pos = 0;
- do {
- /* alloc dimensions */
- if(index >= (UA_Int32)dimensionsMax) {
- struct UA_NumericRangeDimension *newds = UA_realloc(dimensions, dimensionsMax + 2);
- if(!newds) {
- retval = UA_STATUSCODE_BADOUTOFMEMORY;
- break;
- }
- dimensions = newds;
- dimensionsMax = dimensionsMax + 2;
- }
- /* read the dimension */
- size_t progress = readDimension(&str->data[pos], str->length - pos, &dimensions[index]);
- if(progress == 0) {
- retval = UA_STATUSCODE_BADINDEXRANGEINVALID;
- break;
- }
- pos += progress;
- index++;
- /* loop into the next dimension */
- if(pos >= str->length)
- break;
- } while(str->data[pos] == ',' && pos++);
- if(retval == UA_STATUSCODE_GOOD && index > 0) {
- range->dimensions = dimensions;
- range->dimensionsSize = index;
- } else
- UA_free(dimensions);
- return retval;
- }
- #define CHECK_NODECLASS(CLASS) \
- if(!(node->nodeClass & (CLASS))) { \
- retval = UA_STATUSCODE_BADATTRIBUTEIDINVALID; \
- break; \
- }
- static void handleServerTimestamps(UA_TimestampsToReturn timestamps, UA_DataValue* v) {
- if(v && (timestamps == UA_TIMESTAMPSTORETURN_SERVER || timestamps == UA_TIMESTAMPSTORETURN_BOTH)) {
- v->hasServerTimestamp = UA_TRUE;
- v->serverTimestamp = UA_DateTime_now();
- }
- }
- static void handleSourceTimestamps(UA_TimestampsToReturn timestamps, UA_DataValue* v) {
- if(timestamps == UA_TIMESTAMPSTORETURN_SOURCE || timestamps == UA_TIMESTAMPSTORETURN_BOTH) {
- v->hasSourceTimestamp = UA_TRUE;
- v->sourceTimestamp = UA_DateTime_now();
- }
- }
- static UA_StatusCode getVariableNodeValue(const UA_VariableNode *vn, const UA_TimestampsToReturn timestamps,
- const UA_ReadValueId *id, UA_DataValue *v) {
- UA_NumericRange range;
- UA_NumericRange *rangeptr = NULL;
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- if(id->indexRange.length > 0) {
- retval = parse_numericrange(&id->indexRange, &range);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- rangeptr = ⦥
- }
- if(vn->valueSource == UA_VALUESOURCE_VARIANT) {
- if(vn->value.variant.callback.onRead)
- vn->value.variant.callback.onRead(vn->value.variant.callback.handle, vn->nodeId,
- &v->value, rangeptr);
- if(rangeptr)
- retval = UA_Variant_copyRange(&vn->value.variant.value, &v->value, range);
- else
- retval = UA_Variant_copy(&vn->value.variant.value, &v->value);
- if(retval == UA_STATUSCODE_GOOD)
- handleSourceTimestamps(timestamps, v);
- } else {
- UA_Boolean sourceTimeStamp = (timestamps == UA_TIMESTAMPSTORETURN_SOURCE ||
- timestamps == UA_TIMESTAMPSTORETURN_BOTH);
- retval = vn->value.dataSource.read(vn->value.dataSource.handle, vn->nodeId,
- sourceTimeStamp, rangeptr, v);
- }
- if(rangeptr)
- UA_free(range.dimensions);
- return retval;
- }
- static UA_StatusCode getVariableNodeDataType(const UA_VariableNode *vn, UA_DataValue *v) {
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- if(vn->valueSource == UA_VALUESOURCE_VARIANT) {
- retval = UA_Variant_setScalarCopy(&v->value, &vn->value.variant.value.type->typeId,
- &UA_TYPES[UA_TYPES_NODEID]);
- } else {
- /* Read from the datasource to see the data type */
- UA_DataValue val;
- UA_DataValue_init(&val);
- retval = vn->value.dataSource.read(vn->value.dataSource.handle, vn->nodeId, UA_FALSE, NULL, &val);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- retval = UA_Variant_setScalarCopy(&v->value, &val.value.type->typeId, &UA_TYPES[UA_TYPES_NODEID]);
- UA_DataValue_deleteMembers(&val);
- }
- return retval;
- }
- static UA_StatusCode getVariableNodeArrayDimensions(const UA_VariableNode *vn, UA_DataValue *v) {
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- if(vn->valueSource == UA_VALUESOURCE_VARIANT) {
- retval = UA_Variant_setArrayCopy(&v->value, vn->value.variant.value.arrayDimensions,
- vn->value.variant.value.arrayDimensionsSize, &UA_TYPES[UA_TYPES_INT32]);
- } else {
- /* Read the datasource to see the array dimensions */
- UA_DataValue val;
- UA_DataValue_init(&val);
- retval = vn->value.dataSource.read(vn->value.dataSource.handle, vn->nodeId, UA_FALSE, NULL, &val);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- retval = UA_Variant_setArrayCopy(&v->value, val.value.arrayDimensions,
- val.value.arrayDimensionsSize, &UA_TYPES[UA_TYPES_INT32]);
- UA_DataValue_deleteMembers(&val);
- }
- return retval;
- }
- static const UA_String binEncoding = {sizeof("DefaultBinary")-1, (UA_Byte*)"DefaultBinary"};
- /* clang complains about unused variables */
- // static const UA_String xmlEncoding = {sizeof("DefaultXml")-1, (UA_Byte*)"DefaultXml"};
- /** Reads a single attribute from a node in the nodestore. */
- void Service_Read_single(UA_Server *server, UA_Session *session, const UA_TimestampsToReturn timestamps,
- const UA_ReadValueId *id, UA_DataValue *v) {
- if(id->dataEncoding.name.length > 0 && !UA_String_equal(&binEncoding, &id->dataEncoding.name)) {
- v->hasStatus = UA_TRUE;
- v->status = UA_STATUSCODE_BADDATAENCODINGINVALID;
- return;
- }
- //index range for a non-value
- if(id->indexRange.length > 0 && id->attributeId != UA_ATTRIBUTEID_VALUE){
- v->hasStatus = UA_TRUE;
- v->status = UA_STATUSCODE_BADINDEXRANGENODATA;
- return;
- }
- UA_Node const *node = UA_NodeStore_get(server->nodestore, &id->nodeId);
- if(!node) {
- v->hasStatus = UA_TRUE;
- v->status = UA_STATUSCODE_BADNODEIDUNKNOWN;
- return;
- }
- /* When setting the value fails in the switch, we get an error code and set hasValue to false */
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- v->hasValue = UA_TRUE;
- switch(id->attributeId) {
- case UA_ATTRIBUTEID_NODEID:
- retval = UA_Variant_setScalarCopy(&v->value, &node->nodeId, &UA_TYPES[UA_TYPES_NODEID]);
- break;
- case UA_ATTRIBUTEID_NODECLASS:
- retval = UA_Variant_setScalarCopy(&v->value, &node->nodeClass, &UA_TYPES[UA_TYPES_INT32]);
- break;
- case UA_ATTRIBUTEID_BROWSENAME:
- retval = UA_Variant_setScalarCopy(&v->value, &node->browseName, &UA_TYPES[UA_TYPES_QUALIFIEDNAME]);
- break;
- case UA_ATTRIBUTEID_DISPLAYNAME:
- retval = UA_Variant_setScalarCopy(&v->value, &node->displayName, &UA_TYPES[UA_TYPES_LOCALIZEDTEXT]);
- break;
- case UA_ATTRIBUTEID_DESCRIPTION:
- retval = UA_Variant_setScalarCopy(&v->value, &node->description, &UA_TYPES[UA_TYPES_LOCALIZEDTEXT]);
- break;
- case UA_ATTRIBUTEID_WRITEMASK:
- retval = UA_Variant_setScalarCopy(&v->value, &node->writeMask, &UA_TYPES[UA_TYPES_UINT32]);
- break;
- case UA_ATTRIBUTEID_USERWRITEMASK:
- retval = UA_Variant_setScalarCopy(&v->value, &node->userWriteMask, &UA_TYPES[UA_TYPES_UINT32]);
- break;
- case UA_ATTRIBUTEID_ISABSTRACT:
- CHECK_NODECLASS(UA_NODECLASS_REFERENCETYPE | UA_NODECLASS_OBJECTTYPE |
- UA_NODECLASS_VARIABLETYPE | UA_NODECLASS_DATATYPE);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_ReferenceTypeNode*)node)->isAbstract,
- &UA_TYPES[UA_TYPES_BOOLEAN]);
- break;
- case UA_ATTRIBUTEID_SYMMETRIC:
- CHECK_NODECLASS(UA_NODECLASS_REFERENCETYPE);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_ReferenceTypeNode*)node)->symmetric,
- &UA_TYPES[UA_TYPES_BOOLEAN]);
- break;
- case UA_ATTRIBUTEID_INVERSENAME:
- CHECK_NODECLASS(UA_NODECLASS_REFERENCETYPE);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_ReferenceTypeNode*)node)->inverseName,
- &UA_TYPES[UA_TYPES_LOCALIZEDTEXT]);
- break;
- case UA_ATTRIBUTEID_CONTAINSNOLOOPS:
- CHECK_NODECLASS(UA_NODECLASS_VIEW);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_ViewNode*)node)->containsNoLoops,
- &UA_TYPES[UA_TYPES_BOOLEAN]);
- break;
- case UA_ATTRIBUTEID_EVENTNOTIFIER:
- CHECK_NODECLASS(UA_NODECLASS_VIEW | UA_NODECLASS_OBJECT);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_ViewNode*)node)->eventNotifier,
- &UA_TYPES[UA_TYPES_BYTE]);
- break;
- case UA_ATTRIBUTEID_VALUE:
- CHECK_NODECLASS(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE);
- retval = getVariableNodeValue((const UA_VariableNode*)node, timestamps, id, v);
- break;
- case UA_ATTRIBUTEID_DATATYPE:
- CHECK_NODECLASS(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE);
- retval = getVariableNodeDataType((const UA_VariableNode*)node, v);
- break;
- case UA_ATTRIBUTEID_VALUERANK:
- CHECK_NODECLASS(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_VariableTypeNode*)node)->valueRank,
- &UA_TYPES[UA_TYPES_INT32]);
- break;
- case UA_ATTRIBUTEID_ARRAYDIMENSIONS:
- CHECK_NODECLASS(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE);
- retval = getVariableNodeArrayDimensions((const UA_VariableNode*)node, v);
- break;
- case UA_ATTRIBUTEID_ACCESSLEVEL:
- CHECK_NODECLASS(UA_NODECLASS_VARIABLE);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_VariableNode*)node)->accessLevel,
- &UA_TYPES[UA_TYPES_BYTE]);
- break;
- case UA_ATTRIBUTEID_USERACCESSLEVEL:
- CHECK_NODECLASS(UA_NODECLASS_VARIABLE);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_VariableNode*)node)->userAccessLevel,
- &UA_TYPES[UA_TYPES_BYTE]);
- break;
- case UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL:
- CHECK_NODECLASS(UA_NODECLASS_VARIABLE);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_VariableNode*)node)->minimumSamplingInterval,
- &UA_TYPES[UA_TYPES_DOUBLE]);
- break;
- case UA_ATTRIBUTEID_HISTORIZING:
- CHECK_NODECLASS(UA_NODECLASS_VARIABLE);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_VariableNode*)node)->historizing,
- &UA_TYPES[UA_TYPES_BOOLEAN]);
- break;
- case UA_ATTRIBUTEID_EXECUTABLE:
- CHECK_NODECLASS(UA_NODECLASS_METHOD);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_MethodNode*)node)->executable,
- &UA_TYPES[UA_TYPES_BOOLEAN]);
- break;
- case UA_ATTRIBUTEID_USEREXECUTABLE:
- CHECK_NODECLASS(UA_NODECLASS_METHOD);
- retval = UA_Variant_setScalarCopy(&v->value, &((const UA_MethodNode*)node)->userExecutable,
- &UA_TYPES[UA_TYPES_BOOLEAN]);
- break;
- default:
- retval = UA_STATUSCODE_BADATTRIBUTEIDINVALID;
- break;
- }
- UA_NodeStore_release(node);
- if(retval != UA_STATUSCODE_GOOD) {
- v->hasValue = UA_FALSE;
- v->hasStatus = UA_TRUE;
- v->status = retval;
- }
- // Todo: what if the timestamp from the datasource are already present?
- handleServerTimestamps(timestamps, v);
- }
- void Service_Read(UA_Server *server, UA_Session *session, const UA_ReadRequest *request,
- UA_ReadResponse *response) {
- UA_LOG_DEBUG(server->logger, UA_LOGCATEGORY_SESSION,
- "Processing ReadRequest for Session (ns=%i,i=%i)",
- session->sessionId.namespaceIndex, session->sessionId.identifier.numeric);
- if(request->nodesToReadSize <= 0) {
- response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
- return;
- }
- if(request->timestampsToReturn > 3){
- response->responseHeader.serviceResult = UA_STATUSCODE_BADTIMESTAMPSTORETURNINVALID;
- return;
- }
- size_t size = request->nodesToReadSize;
- response->results = UA_Array_new(size, &UA_TYPES[UA_TYPES_DATAVALUE]);
- if(!response->results) {
- response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
- return;
- }
- response->resultsSize = size;
- if(request->maxAge < 0) {
- response->responseHeader.serviceResult = UA_STATUSCODE_BADMAXAGEINVALID;
- return;
- }
- #ifdef UA_EXTERNAL_NAMESPACES
- UA_Boolean isExternal[size];
- UA_UInt32 indices[size];
- memset(isExternal, UA_FALSE, sizeof(UA_Boolean) * size);
- for(size_t j = 0;j<server->externalNamespacesSize;j++) {
- size_t indexSize = 0;
- for(size_t i = 0;i < size;i++) {
- if(request->nodesToRead[i].nodeId.namespaceIndex != server->externalNamespaces[j].index)
- continue;
- isExternal[i] = UA_TRUE;
- indices[indexSize] = i;
- indexSize++;
- }
- if(indexSize == 0)
- continue;
- UA_ExternalNodeStore *ens = &server->externalNamespaces[j].externalNodeStore;
- ens->readNodes(ens->ensHandle, &request->requestHeader, request->nodesToRead,
- indices, indexSize, response->results, UA_FALSE, response->diagnosticInfos);
- }
- #endif
- for(size_t i = 0;i < size;i++) {
- #ifdef UA_EXTERNAL_NAMESPACES
- if(!isExternal[i])
- #endif
- Service_Read_single(server, session, request->timestampsToReturn,
- &request->nodesToRead[i], &response->results[i]);
- }
- #ifdef EXTENSION_STATELESS
- if(session==&anonymousSession){
- /* expiry header */
- UA_ExtensionObject additionalHeader;
- UA_ExtensionObject_init(&additionalHeader);
- additionalHeader.typeId = UA_TYPES[UA_TYPES_VARIANT].typeId;
- additionalHeader.encoding = UA_EXTENSIONOBJECT_ENCODINGMASK_BODYISBYTESTRING;
- UA_Variant variant;
- UA_Variant_init(&variant);
- UA_DateTime* expireArray = NULL;
- expireArray = UA_Array_new(&UA_TYPES[UA_TYPES_DATETIME], request->nodesToReadSize);
- variant.data = expireArray;
- /*expires in 20 seconds*/
- for(UA_Int32 i = 0;i < response->resultsSize;i++) {
- expireArray[i] = UA_DateTime_now() + 20 * 100 * 1000 * 1000;
- }
- UA_Variant_setArray(&variant, expireArray, request->nodesToReadSize, &UA_TYPES[UA_TYPES_DATETIME]);
- size_t offset = 0;
- UA_ByteString str;
- UA_ByteString_newMembers(&str, 65536);
- UA_Variant_encodeBinary(&variant, &str, &offset);
- UA_Array_delete(expireArray, &UA_TYPES[UA_TYPES_DATETIME], request->nodesToReadSize);
- additionalHeader.body = str;
- additionalHeader.body.length = offset;
- response->responseHeader.additionalHeader = additionalHeader;
- }
- #endif
- }
- /*******************/
- /* Write Attribute */
- /*******************/
- UA_StatusCode UA_Server_editNode(UA_Server *server, UA_Session *session, const UA_NodeId *nodeId,
- UA_EditNodeCallback callback, const void *data) {
- UA_StatusCode retval;
- do {
- const UA_Node *node = UA_NodeStore_get(server->nodestore, nodeId);
- if(!node)
- return UA_STATUSCODE_BADNODEIDUNKNOWN;
- #ifndef UA_MULTITHREADING
- retval = callback(server, session, (UA_Node*)(uintptr_t)node, data);
- UA_NodeStore_release(node);
- return retval;
- #else
- UA_Node *copy = UA_Node_copyAnyNodeClass(node);
- UA_NodeStore_release(node);
- if(!copy)
- return UA_STATUSCODE_BADOUTOFMEMORY;
- retval = callback(server, session, copy, data);
- if(retval != UA_STATUSCODE_GOOD) {
- UA_Node_deleteAnyNodeClass(copy);
- return retval;
- }
- retval = UA_NodeStore_replace(server->nodestore, node, copy, NULL);
- if(retval != UA_STATUSCODE_GOOD)
- UA_Node_deleteAnyNodeClass(copy);
- #endif
- } while(retval != UA_STATUSCODE_GOOD);
- return UA_STATUSCODE_GOOD;
- }
- #define CHECK_DATATYPE(EXP_DT) \
- if(!wvalue->value.hasValue || \
- &UA_TYPES[UA_TYPES_##EXP_DT] != wvalue->value.value.type || \
- !UA_Variant_isScalar(&wvalue->value.value)) { \
- retval = UA_STATUSCODE_BADTYPEMISMATCH; \
- break; \
- }
- #define CHECK_NODECLASS_WRITE(CLASS) \
- if((node->nodeClass & (CLASS)) == 0) { \
- retval = UA_STATUSCODE_BADNODECLASSINVALID; \
- break; \
- }
- static UA_StatusCode
- Service_Write_single_ValueDataSource(UA_Server *server, UA_Session *session, const UA_VariableNode *node,
- UA_WriteValue *wvalue) {
- UA_assert(wvalue->attributeId == UA_ATTRIBUTEID_VALUE);
- UA_assert(node->nodeClass == UA_NODECLASS_VARIABLE || node->nodeClass == UA_NODECLASS_VARIABLETYPE);
- UA_assert(node->valueSource == UA_VALUESOURCE_DATASOURCE);
- UA_StatusCode retval;
- if(wvalue->indexRange.length <= 0) {
- retval = node->value.dataSource.write(node->value.dataSource.handle, node->nodeId,
- &wvalue->value.value, NULL);
- } else {
- UA_NumericRange range;
- retval = parse_numericrange(&wvalue->indexRange, &range);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- retval = node->value.dataSource.write(node->value.dataSource.handle, node->nodeId,
- &wvalue->value.value, &range);
- UA_free(range.dimensions);
- }
- return retval;
- }
- enum type_equivalence {
- TYPE_EQUIVALENCE_NONE,
- TYPE_EQUIVALENCE_ENUM,
- TYPE_EQUIVALENCE_OPAQUE
- };
- static enum type_equivalence typeEquivalence(const UA_DataType *type) {
- if(type->membersSize != 1 || !type->members[0].namespaceZero)
- return TYPE_EQUIVALENCE_NONE;
- if(type->members[0].memberTypeIndex == UA_TYPES_INT32)
- return TYPE_EQUIVALENCE_ENUM;
- if(type->members[0].memberTypeIndex == UA_TYPES_BYTE && type->members[0].isArray)
- return TYPE_EQUIVALENCE_OPAQUE;
- return TYPE_EQUIVALENCE_NONE;
- }
- /* In the multithreaded case, node is a copy */
- static UA_StatusCode
- MoveValueIntoNode(UA_Server *server, UA_Session *session, UA_VariableNode *node, UA_WriteValue *wvalue) {
- UA_assert(wvalue->attributeId == UA_ATTRIBUTEID_VALUE);
- UA_assert(node->nodeClass == UA_NODECLASS_VARIABLE || node->nodeClass == UA_NODECLASS_VARIABLETYPE);
- UA_assert(node->valueSource == UA_VALUESOURCE_VARIANT);
- /* Parse the range */
- UA_NumericRange range;
- UA_NumericRange *rangeptr = NULL;
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- if(wvalue->indexRange.length > 0) {
- retval = parse_numericrange(&wvalue->indexRange, &range);
- if(retval != UA_STATUSCODE_GOOD)
- return retval;
- rangeptr = ⦥
- }
- /* The nodeid on the wire may be != the nodeid in the node: opaque types, enums and bytestrings.
- nodeV contains the correct type definition. */
- UA_Variant *newV = &wvalue->value.value;
- UA_Variant *oldV = &node->value.variant.value;
- UA_Variant cast_v;
- if(!UA_NodeId_equal(&oldV->type->typeId, &newV->type->typeId)) {
- cast_v = wvalue->value.value;
- newV = &cast_v;
- enum type_equivalence te1 = typeEquivalence(oldV->type);
- enum type_equivalence te2 = typeEquivalence(newV->type);
- if(te1 != TYPE_EQUIVALENCE_NONE && te1 == te2) {
- /* An enum was sent as an int32, or an opaque type as a bytestring. This is
- detected with the typeIndex indicated the "true" datatype. */
- newV->type = oldV->type;
- } else if(oldV->type == &UA_TYPES[UA_TYPES_BYTE] && !UA_Variant_isScalar(oldV) &&
- newV->type == &UA_TYPES[UA_TYPES_BYTESTRING] && UA_Variant_isScalar(newV)) {
- /* a string is written to a byte array */
- UA_ByteString *str = (UA_ByteString*) newV->data;
- newV->arrayLength = str->length;
- newV->data = str->data;
- newV->type = &UA_TYPES[UA_TYPES_BYTE];
- } else {
- if(rangeptr)
- UA_free(range.dimensions);
- return UA_STATUSCODE_BADTYPEMISMATCH;
- }
- }
-
- if(!rangeptr) {
- // TODO: Avoid copying the whole node and then delete the old value for multithreading
- UA_Variant_deleteMembers(&node->value.variant.value);
- node->value.variant.value = *newV;
- UA_Variant_init(&wvalue->value.value);
- } else {
- retval = UA_Variant_setRangeCopy(&node->value.variant.value, newV->data, newV->arrayLength, range);
- }
- if(node->value.variant.callback.onWrite)
- node->value.variant.callback.onWrite(node->value.variant.callback.handle, node->nodeId,
- &node->value.variant.value, rangeptr);
- if(rangeptr)
- UA_free(range.dimensions);
- return retval;
- }
- static UA_StatusCode
- MoveAttributeIntoNode(UA_Server *server, UA_Session *session, UA_Node *node, UA_WriteValue *wvalue) {
- UA_StatusCode retval = UA_STATUSCODE_GOOD;
- void *value = wvalue->value.value.data;
- switch(wvalue->attributeId) {
- case UA_ATTRIBUTEID_NODEID:
- case UA_ATTRIBUTEID_NODECLASS:
- case UA_ATTRIBUTEID_DATATYPE:
- retval = UA_STATUSCODE_BADWRITENOTSUPPORTED;
- break;
- case UA_ATTRIBUTEID_BROWSENAME:
- CHECK_DATATYPE(QUALIFIEDNAME);
- UA_QualifiedName_deleteMembers(&node->browseName);
- node->browseName = *(UA_QualifiedName*)value;
- UA_QualifiedName_init((UA_QualifiedName*)value);
- break;
- case UA_ATTRIBUTEID_DISPLAYNAME:
- CHECK_DATATYPE(LOCALIZEDTEXT);
- UA_LocalizedText_deleteMembers(&node->displayName);
- node->displayName = *(UA_LocalizedText*)value;
- UA_LocalizedText_init((UA_LocalizedText*)value);
- break;
- case UA_ATTRIBUTEID_DESCRIPTION:
- CHECK_DATATYPE(LOCALIZEDTEXT);
- UA_LocalizedText_deleteMembers(&node->description);
- node->description = *(UA_LocalizedText*)value;
- UA_LocalizedText_init((UA_LocalizedText*)value);
- break;
- case UA_ATTRIBUTEID_WRITEMASK:
- CHECK_DATATYPE(UINT32);
- node->writeMask = *(UA_UInt32*)value;
- break;
- case UA_ATTRIBUTEID_USERWRITEMASK:
- CHECK_DATATYPE(UINT32);
- node->userWriteMask = *(UA_UInt32*)value;
- break;
- case UA_ATTRIBUTEID_ISABSTRACT:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_OBJECTTYPE | UA_NODECLASS_REFERENCETYPE |
- UA_NODECLASS_VARIABLETYPE | UA_NODECLASS_DATATYPE);
- CHECK_DATATYPE(BOOLEAN);
- ((UA_ObjectTypeNode*)node)->isAbstract = *(UA_Boolean*)value;
- break;
- case UA_ATTRIBUTEID_SYMMETRIC:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_REFERENCETYPE);
- CHECK_DATATYPE(BOOLEAN);
- ((UA_ReferenceTypeNode*)node)->symmetric = *(UA_Boolean*)value;
- break;
- case UA_ATTRIBUTEID_INVERSENAME:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_REFERENCETYPE);
- CHECK_DATATYPE(LOCALIZEDTEXT);
- UA_ReferenceTypeNode *n = (UA_ReferenceTypeNode*)node;
- UA_LocalizedText_deleteMembers(&n->inverseName);
- n->inverseName = *(UA_LocalizedText*)value;
- UA_LocalizedText_init((UA_LocalizedText*)value);
- break;
- case UA_ATTRIBUTEID_CONTAINSNOLOOPS:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_VIEW);
- CHECK_DATATYPE(BOOLEAN);
- ((UA_ViewNode*)node)->containsNoLoops = *(UA_Boolean*)value;
- break;
- case UA_ATTRIBUTEID_EVENTNOTIFIER:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_VIEW | UA_NODECLASS_OBJECT);
- CHECK_DATATYPE(BYTE);
- ((UA_ViewNode*)node)->eventNotifier = *(UA_Byte*)value;
- break;
- case UA_ATTRIBUTEID_VALUE:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLETYPE);
- retval = MoveValueIntoNode(server, session, (UA_VariableNode*)node, wvalue);
- break;
- case UA_ATTRIBUTEID_ACCESSLEVEL:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_VARIABLE);
- CHECK_DATATYPE(BYTE);
- ((UA_VariableNode*)node)->accessLevel = *(UA_Byte*)value;
- break;
- case UA_ATTRIBUTEID_USERACCESSLEVEL:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_VARIABLE);
- CHECK_DATATYPE(BYTE);
- ((UA_VariableNode*)node)->userAccessLevel = *(UA_Byte*)value;
- break;
- case UA_ATTRIBUTEID_MINIMUMSAMPLINGINTERVAL:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_VARIABLE);
- CHECK_DATATYPE(DOUBLE);
- ((UA_VariableNode*)node)->minimumSamplingInterval = *(UA_Double*)value;
- break;
- case UA_ATTRIBUTEID_HISTORIZING:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_VARIABLE);
- CHECK_DATATYPE(BOOLEAN);
- ((UA_VariableNode*)node)->historizing = *(UA_Boolean*)value;
- break;
- case UA_ATTRIBUTEID_EXECUTABLE:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_METHOD);
- CHECK_DATATYPE(BOOLEAN);
- ((UA_MethodNode*)node)->executable = *(UA_Boolean*)value;
- break;
- case UA_ATTRIBUTEID_USEREXECUTABLE:
- CHECK_NODECLASS_WRITE(UA_NODECLASS_METHOD);
- CHECK_DATATYPE(BOOLEAN);
- ((UA_MethodNode*)node)->userExecutable = *(UA_Boolean*)value;
- break;
- default:
- retval = UA_STATUSCODE_BADATTRIBUTEIDINVALID;
- break;
- }
- return retval;
- }
- UA_StatusCode Service_Write_single(UA_Server *server, UA_Session *session, UA_WriteValue *wvalue) {
- if(!wvalue->value.hasValue || !wvalue->value.value.data)
- return UA_STATUSCODE_BADNODATA; // TODO: is this the right return code?
- if(wvalue->attributeId == UA_ATTRIBUTEID_VALUE) {
- const UA_Node *orig = UA_NodeStore_get(server->nodestore, &wvalue->nodeId);
- if(!orig)
- return UA_STATUSCODE_BADNODEIDUNKNOWN;
- if(orig->nodeClass & (UA_NODECLASS_VARIABLE | UA_NODECLASS_VARIABLE) &&
- ((const UA_VariableNode*)orig)->valueSource == UA_VALUESOURCE_DATASOURCE) {
- UA_StatusCode retval = Service_Write_single_ValueDataSource(server, session, (const UA_VariableNode*)orig, wvalue);
- UA_NodeStore_release(orig);
- return retval;
- }
- UA_NodeStore_release(orig);
- }
- return UA_Server_editNode(server, session, &wvalue->nodeId,
- (UA_EditNodeCallback)MoveAttributeIntoNode, wvalue);
- }
- void Service_Write(UA_Server *server, UA_Session *session, const UA_WriteRequest *request,
- UA_WriteResponse *response) {
- UA_assert(server != NULL && session != NULL && request != NULL && response != NULL);
- UA_LOG_DEBUG(server->logger, UA_LOGCATEGORY_SESSION,
- "Processing WriteRequest for Session (ns=%i,i=%i)",
- session->sessionId.namespaceIndex, session->sessionId.identifier.numeric);
- if(request->nodesToWriteSize <= 0) {
- response->responseHeader.serviceResult = UA_STATUSCODE_BADNOTHINGTODO;
- return;
- }
- response->results = UA_Array_new(request->nodesToWriteSize, &UA_TYPES[UA_TYPES_STATUSCODE]);
- if(!response->results) {
- response->responseHeader.serviceResult = UA_STATUSCODE_BADOUTOFMEMORY;
- return;
- }
- #ifdef UA_EXTERNAL_NAMESPACES
- UA_Boolean isExternal[request->nodesToWriteSize];
- UA_UInt32 indices[request->nodesToWriteSize];
- memset(isExternal, UA_FALSE, sizeof(UA_Boolean)*request->nodesToWriteSize);
- for(size_t j = 0; j < server->externalNamespacesSize; j++) {
- UA_UInt32 indexSize = 0;
- for(UA_Int32 i = 0; i < request->nodesToWriteSize; i++) {
- if(request->nodesToWrite[i].nodeId.namespaceIndex !=
- server->externalNamespaces[j].index)
- continue;
- isExternal[i] = UA_TRUE;
- indices[indexSize] = i;
- indexSize++;
- }
- if(indexSize == 0)
- continue;
- UA_ExternalNodeStore *ens = &server->externalNamespaces[j].externalNodeStore;
- ens->writeNodes(ens->ensHandle, &request->requestHeader, request->nodesToWrite,
- indices, indexSize, response->results, response->diagnosticInfos);
- }
- #endif
-
- response->resultsSize = request->nodesToWriteSize;
- for(size_t i = 0;i < request->nodesToWriteSize;i++) {
- #ifdef UA_EXTERNAL_NAMESPACES
- if(!isExternal[i])
- #endif
- response->results[i] = Service_Write_single(server, session, &request->nodesToWrite[i]);
- }
- }
|