ua_types.c 34 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004
  1. #include "ua_util.h"
  2. #include "ua_types.h"
  3. #include "ua_types_generated.h"
  4. #include "ua_types_generated_handling.h"
  5. #include "pcg_basic.h"
  6. #include "libc_time.h"
  7. /* Datatype Handling
  8. * -----------------
  9. * This file contains handling functions for the builtin types and functions
  10. * handling of structured types and arrays. These need type descriptions in a
  11. * UA_DataType structure. The UA_DataType structures as well as all non-builtin
  12. * datatypes are autogenerated. */
  13. /* Static definition of NULL type instances */
  14. const UA_String UA_STRING_NULL = {.length = 0, .data = NULL };
  15. const UA_ByteString UA_BYTESTRING_NULL = {.length = 0, .data = NULL };
  16. const UA_Guid UA_GUID_NULL = {.data1 = 0, .data2 = 0, .data3 = 0,
  17. .data4 = {0,0,0,0,0,0,0,0}};
  18. const UA_NodeId UA_NODEID_NULL = {0, UA_NODEIDTYPE_NUMERIC, {0}};
  19. const UA_ExpandedNodeId UA_EXPANDEDNODEID_NULL = {
  20. .nodeId = {.namespaceIndex = 0, .identifierType = UA_NODEIDTYPE_NUMERIC,
  21. .identifier.numeric = 0 },
  22. .namespaceUri = {.length = 0, .data = NULL}, .serverIndex = 0 };
  23. /***************************/
  24. /* Random Number Generator */
  25. /***************************/
  26. static UA_THREAD_LOCAL pcg32_random_t UA_rng = PCG32_INITIALIZER;
  27. void
  28. UA_random_seed(UA_UInt64 seed) {
  29. pcg32_srandom_r(&UA_rng, seed, (uint64_t)UA_DateTime_now());
  30. }
  31. UA_UInt32
  32. UA_UInt32_random(void) {
  33. return (UA_UInt32)pcg32_random_r(&UA_rng);
  34. }
  35. /*****************/
  36. /* Builtin Types */
  37. /*****************/
  38. static void deleteMembers_noInit(void *, const UA_DataType *);
  39. static UA_StatusCode copy_noInit(const void *, void *, const UA_DataType *);
  40. UA_String
  41. UA_String_fromChars(char const src[]) {
  42. UA_String str = UA_STRING_NULL;
  43. size_t length = strlen(src);
  44. if(length > 0) {
  45. str.data = UA_malloc(length);
  46. if(!str.data)
  47. return str;
  48. } else {
  49. str.data = UA_EMPTY_ARRAY_SENTINEL;
  50. }
  51. memcpy(str.data, src, length);
  52. str.length = length;
  53. return str;
  54. }
  55. UA_Boolean
  56. UA_String_equal(const UA_String *string1, const UA_String *string2) {
  57. if(string1->length != string2->length)
  58. return false;
  59. UA_Int32 is = memcmp((char const*)string1->data,
  60. (char const*)string2->data, string1->length);
  61. return (is == 0) ? true : false;
  62. }
  63. static void
  64. String_deleteMembers(UA_String *s, const UA_DataType *_) {
  65. UA_free((void*)((uintptr_t)s->data & ~(uintptr_t)UA_EMPTY_ARRAY_SENTINEL));
  66. }
  67. /* DateTime */
  68. UA_DateTimeStruct
  69. UA_DateTime_toStruct(UA_DateTime t) {
  70. /* Calculating the the milli-, micro- and nanoseconds */
  71. UA_DateTimeStruct dateTimeStruct;
  72. dateTimeStruct.nanoSec = (UA_UInt16)((t % 10) * 100);
  73. dateTimeStruct.microSec = (UA_UInt16)((t % 10000) / 10);
  74. dateTimeStruct.milliSec = (UA_UInt16)((t % 10000000) / 10000);
  75. /* Calculating the unix time with #include <time.h> */
  76. time_t secSinceUnixEpoch =
  77. (time_t)((t - UA_DATETIME_UNIX_EPOCH) / UA_SEC_TO_DATETIME);
  78. struct tm ts;
  79. memset(&ts, 0, sizeof(struct tm));
  80. __secs_to_tm(secSinceUnixEpoch, &ts);
  81. dateTimeStruct.sec = (UA_UInt16)ts.tm_sec;
  82. dateTimeStruct.min = (UA_UInt16)ts.tm_min;
  83. dateTimeStruct.hour = (UA_UInt16)ts.tm_hour;
  84. dateTimeStruct.day = (UA_UInt16)ts.tm_mday;
  85. dateTimeStruct.month = (UA_UInt16)(ts.tm_mon + 1);
  86. dateTimeStruct.year = (UA_UInt16)(ts.tm_year + 1900);
  87. return dateTimeStruct;
  88. }
  89. static void
  90. printNumber(UA_UInt16 n, UA_Byte *pos, size_t digits) {
  91. for(size_t i = digits; i > 0; i--) {
  92. pos[i-1] = (UA_Byte)((n % 10) + '0');
  93. n = n / 10;
  94. }
  95. }
  96. UA_String
  97. UA_DateTime_toString(UA_DateTime t) {
  98. UA_String str = UA_STRING_NULL;
  99. // length of the string is 31 (plus \0 at the end)
  100. if(!(str.data = UA_malloc(32)))
  101. return str;
  102. str.length = 31;
  103. UA_DateTimeStruct tSt = UA_DateTime_toStruct(t);
  104. printNumber(tSt.month, str.data, 2);
  105. str.data[2] = '/';
  106. printNumber(tSt.day, &str.data[3], 2);
  107. str.data[5] = '/';
  108. printNumber(tSt.year, &str.data[6], 4);
  109. str.data[10] = ' ';
  110. printNumber(tSt.hour, &str.data[11], 2);
  111. str.data[13] = ':';
  112. printNumber(tSt.min, &str.data[14], 2);
  113. str.data[16] = ':';
  114. printNumber(tSt.sec, &str.data[17], 2);
  115. str.data[19] = '.';
  116. printNumber(tSt.milliSec, &str.data[20], 3);
  117. str.data[23] = '.';
  118. printNumber(tSt.microSec, &str.data[24], 3);
  119. str.data[27] = '.';
  120. printNumber(tSt.nanoSec, &str.data[28], 3);
  121. return str;
  122. }
  123. /* Guid */
  124. UA_Boolean
  125. UA_Guid_equal(const UA_Guid *g1, const UA_Guid *g2) {
  126. if(memcmp(g1, g2, sizeof(UA_Guid)) == 0)
  127. return true;
  128. return false;
  129. }
  130. UA_Guid
  131. UA_Guid_random(void) {
  132. UA_Guid result;
  133. result.data1 = (UA_UInt32)pcg32_random_r(&UA_rng);
  134. UA_UInt32 r = (UA_UInt32)pcg32_random_r(&UA_rng);
  135. result.data2 = (UA_UInt16) r;
  136. result.data3 = (UA_UInt16) (r >> 16);
  137. r = (UA_UInt32)pcg32_random_r(&UA_rng);
  138. result.data4[0] = (UA_Byte)r;
  139. result.data4[1] = (UA_Byte)(r >> 4);
  140. result.data4[2] = (UA_Byte)(r >> 8);
  141. result.data4[3] = (UA_Byte)(r >> 12);
  142. r = (UA_UInt32)pcg32_random_r(&UA_rng);
  143. result.data4[4] = (UA_Byte)r;
  144. result.data4[5] = (UA_Byte)(r >> 4);
  145. result.data4[6] = (UA_Byte)(r >> 8);
  146. result.data4[7] = (UA_Byte)(r >> 12);
  147. return result;
  148. }
  149. /* ByteString */
  150. UA_StatusCode
  151. UA_ByteString_allocBuffer(UA_ByteString *bs, size_t length) {
  152. if(length == 0) {
  153. UA_ByteString_init(bs);
  154. return UA_STATUSCODE_GOOD;
  155. }
  156. if(!(bs->data = UA_malloc(length)))
  157. return UA_STATUSCODE_BADOUTOFMEMORY;
  158. bs->length = length;
  159. return UA_STATUSCODE_GOOD;
  160. }
  161. /* NodeId */
  162. static void
  163. NodeId_deleteMembers(UA_NodeId *p, const UA_DataType *_) {
  164. switch(p->identifierType) {
  165. case UA_NODEIDTYPE_STRING:
  166. case UA_NODEIDTYPE_BYTESTRING:
  167. String_deleteMembers(&p->identifier.string, NULL);
  168. break;
  169. default: break;
  170. }
  171. }
  172. static UA_StatusCode
  173. NodeId_copy(UA_NodeId const *src, UA_NodeId *dst, const UA_DataType *_) {
  174. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  175. switch(src->identifierType) {
  176. case UA_NODEIDTYPE_NUMERIC:
  177. *dst = *src;
  178. return UA_STATUSCODE_GOOD;
  179. case UA_NODEIDTYPE_STRING:
  180. retval |= UA_String_copy(&src->identifier.string,
  181. &dst->identifier.string);
  182. break;
  183. case UA_NODEIDTYPE_GUID:
  184. retval |= UA_Guid_copy(&src->identifier.guid, &dst->identifier.guid);
  185. break;
  186. case UA_NODEIDTYPE_BYTESTRING:
  187. retval |= UA_ByteString_copy(&src->identifier.byteString,
  188. &dst->identifier.byteString);
  189. break;
  190. default:
  191. return UA_STATUSCODE_BADINTERNALERROR;
  192. }
  193. dst->namespaceIndex = src->namespaceIndex;
  194. dst->identifierType = src->identifierType;
  195. return retval;
  196. }
  197. UA_Boolean
  198. UA_NodeId_isNull(const UA_NodeId *p) {
  199. if(p->namespaceIndex != 0)
  200. return false;
  201. switch(p->identifierType) {
  202. case UA_NODEIDTYPE_NUMERIC:
  203. return (p->identifier.numeric == 0);
  204. case UA_NODEIDTYPE_GUID:
  205. return (p->identifier.guid.data1 == 0 &&
  206. p->identifier.guid.data2 == 0 &&
  207. p->identifier.guid.data3 == 0 &&
  208. p->identifier.guid.data4[0] == 0 &&
  209. p->identifier.guid.data4[1] == 0 &&
  210. p->identifier.guid.data4[2] == 0 &&
  211. p->identifier.guid.data4[3] == 0 &&
  212. p->identifier.guid.data4[4] == 0 &&
  213. p->identifier.guid.data4[5] == 0 &&
  214. p->identifier.guid.data4[6] == 0 &&
  215. p->identifier.guid.data4[7] == 0);
  216. default:
  217. break;
  218. }
  219. return (p->identifier.string.length == 0);
  220. }
  221. UA_Boolean
  222. UA_NodeId_equal(const UA_NodeId *n1, const UA_NodeId *n2) {
  223. if(n1->namespaceIndex != n2->namespaceIndex ||
  224. n1->identifierType!=n2->identifierType)
  225. return false;
  226. switch(n1->identifierType) {
  227. case UA_NODEIDTYPE_NUMERIC:
  228. if(n1->identifier.numeric == n2->identifier.numeric)
  229. return true;
  230. else
  231. return false;
  232. case UA_NODEIDTYPE_STRING:
  233. return UA_String_equal(&n1->identifier.string,
  234. &n2->identifier.string);
  235. case UA_NODEIDTYPE_GUID:
  236. return UA_Guid_equal(&n1->identifier.guid,
  237. &n2->identifier.guid);
  238. case UA_NODEIDTYPE_BYTESTRING:
  239. return UA_ByteString_equal(&n1->identifier.byteString,
  240. &n2->identifier.byteString);
  241. }
  242. return false;
  243. }
  244. /* ExpandedNodeId */
  245. static void
  246. ExpandedNodeId_deleteMembers(UA_ExpandedNodeId *p, const UA_DataType *_) {
  247. NodeId_deleteMembers(&p->nodeId, _);
  248. String_deleteMembers(&p->namespaceUri, NULL);
  249. }
  250. static UA_StatusCode
  251. ExpandedNodeId_copy(UA_ExpandedNodeId const *src, UA_ExpandedNodeId *dst,
  252. const UA_DataType *_) {
  253. UA_StatusCode retval = NodeId_copy(&src->nodeId, &dst->nodeId, NULL);
  254. retval |= UA_String_copy(&src->namespaceUri, &dst->namespaceUri);
  255. dst->serverIndex = src->serverIndex;
  256. return retval;
  257. }
  258. /* ExtensionObject */
  259. static void
  260. ExtensionObject_deleteMembers(UA_ExtensionObject *p, const UA_DataType *_) {
  261. switch(p->encoding) {
  262. case UA_EXTENSIONOBJECT_ENCODED_NOBODY:
  263. case UA_EXTENSIONOBJECT_ENCODED_BYTESTRING:
  264. case UA_EXTENSIONOBJECT_ENCODED_XML:
  265. NodeId_deleteMembers(&p->content.encoded.typeId, NULL);
  266. String_deleteMembers(&p->content.encoded.body, NULL);
  267. break;
  268. case UA_EXTENSIONOBJECT_DECODED:
  269. if(p->content.decoded.data)
  270. UA_delete(p->content.decoded.data, p->content.decoded.type);
  271. break;
  272. default:
  273. break;
  274. }
  275. }
  276. static UA_StatusCode
  277. ExtensionObject_copy(UA_ExtensionObject const *src, UA_ExtensionObject *dst,
  278. const UA_DataType *_) {
  279. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  280. switch(src->encoding) {
  281. case UA_EXTENSIONOBJECT_ENCODED_NOBODY:
  282. case UA_EXTENSIONOBJECT_ENCODED_BYTESTRING:
  283. case UA_EXTENSIONOBJECT_ENCODED_XML:
  284. dst->encoding = src->encoding;
  285. retval = NodeId_copy(&src->content.encoded.typeId,
  286. &dst->content.encoded.typeId, NULL);
  287. retval |= UA_ByteString_copy(&src->content.encoded.body,
  288. &dst->content.encoded.body);
  289. break;
  290. case UA_EXTENSIONOBJECT_DECODED:
  291. case UA_EXTENSIONOBJECT_DECODED_NODELETE:
  292. if(!src->content.decoded.type || !src->content.decoded.data)
  293. return UA_STATUSCODE_BADINTERNALERROR;
  294. dst->encoding = UA_EXTENSIONOBJECT_DECODED;
  295. dst->content.decoded.type = src->content.decoded.type;
  296. retval = UA_Array_copy(src->content.decoded.data, 1,
  297. &dst->content.decoded.data, src->content.decoded.type);
  298. break;
  299. default:
  300. break;
  301. }
  302. return retval;
  303. }
  304. /* Variant */
  305. static void
  306. Variant_deletemembers(UA_Variant *p, const UA_DataType *_) {
  307. if(p->storageType != UA_VARIANT_DATA)
  308. return;
  309. if(p->type && p->data > UA_EMPTY_ARRAY_SENTINEL) {
  310. if(p->arrayLength == 0)
  311. p->arrayLength = 1;
  312. UA_Array_delete(p->data, p->arrayLength, p->type);
  313. }
  314. if((void*)p->arrayDimensions > UA_EMPTY_ARRAY_SENTINEL)
  315. UA_free(p->arrayDimensions);
  316. }
  317. static UA_StatusCode
  318. Variant_copy(UA_Variant const *src, UA_Variant *dst, const UA_DataType *_) {
  319. size_t length = src->arrayLength;
  320. if(UA_Variant_isScalar(src))
  321. length = 1;
  322. UA_StatusCode retval = UA_Array_copy(src->data, length,
  323. &dst->data, src->type);
  324. if(retval != UA_STATUSCODE_GOOD)
  325. return retval;
  326. dst->arrayLength = src->arrayLength;
  327. dst->type = src->type;
  328. if(src->arrayDimensions) {
  329. retval = UA_Array_copy(src->arrayDimensions, src->arrayDimensionsSize,
  330. (void**)&dst->arrayDimensions, &UA_TYPES[UA_TYPES_INT32]);
  331. if(retval != UA_STATUSCODE_GOOD)
  332. return retval;
  333. dst->arrayDimensionsSize = src->arrayDimensionsSize;
  334. }
  335. return UA_STATUSCODE_GOOD;
  336. }
  337. void
  338. UA_Variant_setScalar(UA_Variant *v, void * UA_RESTRICT p,
  339. const UA_DataType *type) {
  340. UA_Variant_init(v);
  341. v->type = type;
  342. v->arrayLength = 0;
  343. v->data = p;
  344. }
  345. UA_StatusCode
  346. UA_Variant_setScalarCopy(UA_Variant *v, const void *p,
  347. const UA_DataType *type) {
  348. void *new = UA_malloc(type->memSize);
  349. if(!new)
  350. return UA_STATUSCODE_BADOUTOFMEMORY;
  351. UA_StatusCode retval = UA_copy(p, new, type);
  352. if(retval != UA_STATUSCODE_GOOD) {
  353. UA_free(new);
  354. //cppcheck-suppress memleak
  355. return retval;
  356. }
  357. UA_Variant_setScalar(v, new, type);
  358. //cppcheck-suppress memleak
  359. return UA_STATUSCODE_GOOD;
  360. }
  361. void UA_Variant_setArray(UA_Variant *v, void * UA_RESTRICT array,
  362. size_t arraySize, const UA_DataType *type) {
  363. UA_Variant_init(v);
  364. v->data = array;
  365. v->arrayLength = arraySize;
  366. v->type = type;
  367. }
  368. UA_StatusCode
  369. UA_Variant_setArrayCopy(UA_Variant *v, const void *array,
  370. size_t arraySize, const UA_DataType *type) {
  371. UA_Variant_init(v);
  372. UA_StatusCode retval = UA_Array_copy(array, arraySize, &v->data, type);
  373. if(retval != UA_STATUSCODE_GOOD)
  374. return retval;
  375. v->arrayLength = arraySize;
  376. v->type = type;
  377. return UA_STATUSCODE_GOOD;
  378. }
  379. /* Test if a range is compatible with a variant. If yes, the following values
  380. * are set:
  381. * - total: how many elements are in the range
  382. * - block: how big is each contiguous block of elements in the variant that
  383. * maps into the range
  384. * - stride: how many elements are between the blocks (beginning to beginning)
  385. * - first: where does the first block begin */
  386. static UA_StatusCode
  387. computeStrides(const UA_Variant *v, const UA_NumericRange range,
  388. size_t *total, size_t *block, size_t *stride, size_t *first) {
  389. /* Test for max array size */
  390. #if(MAX_SIZE > 0xffffffff) /* 64bit only */
  391. if(v->arrayLength > UA_UINT32_MAX)
  392. return UA_STATUSCODE_BADINTERNALERROR;
  393. #endif
  394. /* Test the integrity of the source variant dimensions, make dimensions
  395. vector of one dimension if none defined */
  396. UA_UInt32 arrayLength = (UA_UInt32)v->arrayLength;
  397. const UA_UInt32 *dims = &arrayLength;
  398. size_t dims_count = 1;
  399. if(v->arrayDimensionsSize > 0) {
  400. size_t elements = 1;
  401. dims_count = v->arrayDimensionsSize;
  402. dims = (UA_UInt32*)v->arrayDimensions;
  403. for(size_t i = 0; i < dims_count; i++)
  404. elements *= dims[i];
  405. if(elements != v->arrayLength)
  406. return UA_STATUSCODE_BADINTERNALERROR;
  407. }
  408. /* Test the integrity of the range */
  409. size_t count = 1;
  410. if(range.dimensionsSize != dims_count)
  411. return UA_STATUSCODE_BADINDEXRANGENODATA;
  412. for(size_t i = 0; i < dims_count; i++) {
  413. if(range.dimensions[i].min > range.dimensions[i].max)
  414. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  415. if(range.dimensions[i].max >= dims[i])
  416. return UA_STATUSCODE_BADINDEXRANGENODATA;
  417. count *= (range.dimensions[i].max - range.dimensions[i].min) + 1;
  418. }
  419. *total = count;
  420. /* Compute the stride length and the position of the first element */
  421. *block = count; /* Assume the range describes the entire array. */
  422. *stride = v->arrayLength; /* So it can be copied as a contiguous block. */
  423. *first = 0;
  424. size_t running_dimssize = 1;
  425. UA_Boolean found_contiguous = false;
  426. for(size_t k = dims_count; k > 0;) {
  427. k--;
  428. size_t dimrange = 1 + range.dimensions[k].max - range.dimensions[k].min;
  429. if(!found_contiguous && dimrange != dims[k]) {
  430. /* Found the maximum block that can be copied contiguously */
  431. found_contiguous = true;
  432. *block = running_dimssize * dimrange;
  433. *stride = running_dimssize * dims[k];
  434. }
  435. *first += running_dimssize * range.dimensions[k].min;
  436. running_dimssize *= dims[k];
  437. }
  438. return UA_STATUSCODE_GOOD;
  439. }
  440. /* Is the type string-like? */
  441. static UA_Boolean
  442. isStringLike(const UA_DataType *type) {
  443. if(type->membersSize == 1 && type->members[0].isArray &&
  444. type->members[0].namespaceZero &&
  445. type->members[0].memberTypeIndex == UA_TYPES_BYTE)
  446. return true;
  447. return false;
  448. }
  449. static UA_StatusCode
  450. copySubString(const UA_String *src, UA_String *dst,
  451. const UA_NumericRangeDimension *dim) {
  452. if(dim->min > dim->max)
  453. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  454. if(dim->max >= src->length)
  455. return UA_STATUSCODE_BADINDEXRANGENODATA;
  456. size_t length = dim->max - dim->min + 1;
  457. UA_StatusCode retval = UA_ByteString_allocBuffer(dst, length);
  458. if(retval != UA_STATUSCODE_GOOD)
  459. return retval;
  460. memcpy(dst->data, &src->data[dim->min], length);
  461. return UA_STATUSCODE_GOOD;
  462. }
  463. UA_StatusCode
  464. UA_Variant_copyRange(const UA_Variant *orig_src, UA_Variant *dst,
  465. const UA_NumericRange range) {
  466. UA_Boolean isScalar = UA_Variant_isScalar(orig_src);
  467. UA_Boolean stringLike = isStringLike(orig_src->type);
  468. const UA_Variant *src = orig_src;
  469. UA_Variant arraySrc;
  470. /* Extract the range for copying at this level. The remaining range is dealt
  471. * with in the "scalar" type that may define an array by itself (string,
  472. * variant, ...). */
  473. UA_NumericRange thisrange, nextrange;
  474. UA_NumericRangeDimension scalarThisDimension = (UA_NumericRangeDimension){
  475. .min = 0, .max = 0}; /* a single entry */
  476. if(isScalar) {
  477. /* Replace scalar src with array of length 1 */
  478. arraySrc = *src;
  479. arraySrc.arrayLength = 1;
  480. src = &arraySrc;
  481. /* Deal with all range dimensions within the scalar */
  482. thisrange.dimensions = &scalarThisDimension;
  483. thisrange.dimensionsSize = 1;
  484. nextrange = range;
  485. } else {
  486. /* Deal with as many range dimensions as possible right now */
  487. size_t dims = src->arrayDimensionsSize;
  488. if(dims == 0)
  489. dims = 1;
  490. if(dims > range.dimensionsSize)
  491. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  492. thisrange = range;
  493. thisrange.dimensionsSize = dims;
  494. nextrange.dimensions = &range.dimensions[dims];
  495. nextrange.dimensionsSize = range.dimensionsSize - dims;
  496. }
  497. /* Compute the strides */
  498. size_t count, block, stride, first;
  499. UA_StatusCode retval = computeStrides(src, thisrange, &count,
  500. &block, &stride, &first);
  501. if(retval != UA_STATUSCODE_GOOD)
  502. return retval;
  503. /* Allocate the array */
  504. UA_Variant_init(dst);
  505. size_t elem_size = src->type->memSize;
  506. dst->data = UA_malloc(elem_size * count);
  507. if(!dst->data)
  508. return UA_STATUSCODE_BADOUTOFMEMORY;
  509. /* Copy the range */
  510. size_t block_count = count / block;
  511. uintptr_t nextdst = (uintptr_t)dst->data;
  512. uintptr_t nextsrc = (uintptr_t)src->data + (elem_size * first);
  513. if(nextrange.dimensionsSize == 0) {
  514. /* no nextrange */
  515. if(src->type->fixedSize) {
  516. for(size_t i = 0; i < block_count; i++) {
  517. memcpy((void*)nextdst, (void*)nextsrc, elem_size * block);
  518. nextdst += block * elem_size;
  519. nextsrc += stride * elem_size;
  520. }
  521. } else {
  522. for(size_t i = 0; i < block_count; i++) {
  523. for(size_t j = 0; j < block; j++) {
  524. retval = UA_copy((const void*)nextsrc,
  525. (void*)nextdst, src->type);
  526. nextdst += elem_size;
  527. nextsrc += elem_size;
  528. }
  529. nextsrc += (stride - block) * elem_size;
  530. }
  531. }
  532. } else {
  533. /* nextrange can only be used for variants and stringlike with remaining
  534. * range of dimension 1 */
  535. if(src->type != &UA_TYPES[UA_TYPES_VARIANT]) {
  536. if(!stringLike)
  537. retval = UA_STATUSCODE_BADINDEXRANGENODATA;
  538. if(nextrange.dimensionsSize != 1)
  539. retval = UA_STATUSCODE_BADINDEXRANGENODATA;
  540. }
  541. /* Copy the content */
  542. for(size_t i = 0; i < block_count; i++) {
  543. for(size_t j = 0; j < block && retval == UA_STATUSCODE_GOOD; j++) {
  544. if(stringLike)
  545. retval = copySubString((const UA_String*)nextsrc,
  546. (UA_String*)nextdst,
  547. nextrange.dimensions);
  548. else
  549. retval = UA_Variant_copyRange((const UA_Variant*)nextsrc,
  550. (UA_Variant*)nextdst,
  551. nextrange);
  552. nextdst += elem_size;
  553. nextsrc += elem_size;
  554. }
  555. nextsrc += (stride - block) * elem_size;
  556. }
  557. }
  558. /* Clean up if copying failed */
  559. if(retval != UA_STATUSCODE_GOOD) {
  560. UA_Array_delete(dst->data, count, src->type);
  561. dst->data = NULL;
  562. return retval;
  563. }
  564. /* Done if scalar */
  565. dst->type = src->type;
  566. if(isScalar)
  567. return retval;
  568. /* Copy array dimensions */
  569. dst->arrayLength = count;
  570. if(src->arrayDimensionsSize > 0) {
  571. dst->arrayDimensions =
  572. UA_Array_new(thisrange.dimensionsSize, &UA_TYPES[UA_TYPES_UINT32]);
  573. if(!dst->arrayDimensions) {
  574. Variant_deletemembers(dst, NULL);
  575. return UA_STATUSCODE_BADOUTOFMEMORY;
  576. }
  577. dst->arrayDimensionsSize = thisrange.dimensionsSize;
  578. for(size_t k = 0; k < thisrange.dimensionsSize; k++)
  579. dst->arrayDimensions[k] =
  580. thisrange.dimensions[k].max - thisrange.dimensions[k].min + 1;
  581. }
  582. return UA_STATUSCODE_GOOD;
  583. }
  584. /* TODO: Allow ranges to reach inside a scalars that are array-like, e.g.
  585. * variant and strings. This is already possible for reading... */
  586. static UA_StatusCode
  587. Variant_setRange(UA_Variant *v, void *array, size_t arraySize,
  588. const UA_NumericRange range, UA_Boolean copy) {
  589. /* Compute the strides */
  590. size_t count, block, stride, first;
  591. UA_StatusCode retval = computeStrides(v, range, &count,
  592. &block, &stride, &first);
  593. if(retval != UA_STATUSCODE_GOOD)
  594. return retval;
  595. if(count != arraySize)
  596. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  597. /* Move/copy the elements */
  598. size_t block_count = count / block;
  599. size_t elem_size = v->type->memSize;
  600. uintptr_t nextdst = (uintptr_t)v->data + (first * elem_size);
  601. uintptr_t nextsrc = (uintptr_t)array;
  602. if(v->type->fixedSize || !copy) {
  603. for(size_t i = 0; i < block_count; i++) {
  604. memcpy((void*)nextdst, (void*)nextsrc, elem_size * block);
  605. nextsrc += block * elem_size;
  606. nextdst += stride * elem_size;
  607. }
  608. } else {
  609. for(size_t i = 0; i < block_count; i++) {
  610. for(size_t j = 0; j < block; j++) {
  611. deleteMembers_noInit((void*)nextdst, v->type);
  612. retval |= UA_copy((void*)nextsrc, (void*)nextdst, v->type);
  613. nextdst += elem_size;
  614. nextsrc += elem_size;
  615. }
  616. nextdst += (stride - block) * elem_size;
  617. }
  618. }
  619. /* If members were moved, initialize original array to prevent reuse */
  620. if(!copy && !v->type->fixedSize)
  621. memset(array, 0, sizeof(elem_size)*arraySize);
  622. return retval;
  623. }
  624. UA_StatusCode
  625. UA_Variant_setRange(UA_Variant *v, void * UA_RESTRICT array,
  626. size_t arraySize, const UA_NumericRange range) {
  627. return Variant_setRange(v, array, arraySize, range, false);
  628. }
  629. UA_StatusCode
  630. UA_Variant_setRangeCopy(UA_Variant *v, const void *array,
  631. size_t arraySize, const UA_NumericRange range) {
  632. return Variant_setRange(v, (void*)(uintptr_t)array,
  633. arraySize, range, true);
  634. }
  635. /* LocalizedText */
  636. static void
  637. LocalizedText_deleteMembers(UA_LocalizedText *p, const UA_DataType *_) {
  638. String_deleteMembers(&p->locale, NULL);
  639. String_deleteMembers(&p->text, NULL);
  640. }
  641. static UA_StatusCode
  642. LocalizedText_copy(UA_LocalizedText const *src, UA_LocalizedText *dst,
  643. const UA_DataType *_) {
  644. UA_StatusCode retval = UA_String_copy(&src->locale, &dst->locale);
  645. retval |= UA_String_copy(&src->text, &dst->text);
  646. return retval;
  647. }
  648. /* DataValue */
  649. static void
  650. DataValue_deleteMembers(UA_DataValue *p, const UA_DataType *_) {
  651. Variant_deletemembers(&p->value, NULL);
  652. }
  653. static UA_StatusCode
  654. DataValue_copy(UA_DataValue const *src, UA_DataValue *dst,
  655. const UA_DataType *_) {
  656. memcpy(dst, src, sizeof(UA_DataValue));
  657. UA_Variant_init(&dst->value);
  658. UA_StatusCode retval = Variant_copy(&src->value, &dst->value, NULL);
  659. if(retval != UA_STATUSCODE_GOOD)
  660. DataValue_deleteMembers(dst, NULL);
  661. return retval;
  662. }
  663. /* DiagnosticInfo */
  664. static void
  665. DiagnosticInfo_deleteMembers(UA_DiagnosticInfo *p, const UA_DataType *_) {
  666. String_deleteMembers(&p->additionalInfo, NULL);
  667. if(p->hasInnerDiagnosticInfo && p->innerDiagnosticInfo) {
  668. DiagnosticInfo_deleteMembers(p->innerDiagnosticInfo, NULL);
  669. UA_free(p->innerDiagnosticInfo);
  670. }
  671. }
  672. static UA_StatusCode
  673. DiagnosticInfo_copy(UA_DiagnosticInfo const *src, UA_DiagnosticInfo *dst,
  674. const UA_DataType *_) {
  675. memcpy(dst, src, sizeof(UA_DiagnosticInfo));
  676. UA_String_init(&dst->additionalInfo);
  677. dst->innerDiagnosticInfo = NULL;
  678. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  679. if(src->hasAdditionalInfo)
  680. retval = UA_String_copy(&src->additionalInfo, &dst->additionalInfo);
  681. if(src->hasInnerDiagnosticInfo && src->innerDiagnosticInfo) {
  682. dst->innerDiagnosticInfo = UA_malloc(sizeof(UA_DiagnosticInfo));
  683. if(dst->innerDiagnosticInfo) {
  684. retval |= DiagnosticInfo_copy(src->innerDiagnosticInfo,
  685. dst->innerDiagnosticInfo, NULL);
  686. dst->hasInnerDiagnosticInfo = true;
  687. } else {
  688. dst->hasInnerDiagnosticInfo = false;
  689. retval |= UA_STATUSCODE_BADOUTOFMEMORY;
  690. }
  691. }
  692. return retval;
  693. }
  694. /********************/
  695. /* Structured Types */
  696. /********************/
  697. void *
  698. UA_new(const UA_DataType *type) {
  699. void *p = UA_calloc(1, type->memSize);
  700. return p;
  701. }
  702. static UA_StatusCode
  703. copyByte(const UA_Byte *src, UA_Byte *dst, const UA_DataType *_) {
  704. *dst = *src;
  705. return UA_STATUSCODE_GOOD;
  706. }
  707. static UA_StatusCode
  708. copy2Byte(const UA_UInt16 *src, UA_UInt16 *dst, const UA_DataType *_) {
  709. *dst = *src;
  710. return UA_STATUSCODE_GOOD;
  711. }
  712. static UA_StatusCode
  713. copy4Byte(const UA_UInt32 *src, UA_UInt32 *dst, const UA_DataType *_) {
  714. *dst = *src;
  715. return UA_STATUSCODE_GOOD;
  716. }
  717. static UA_StatusCode
  718. copy8Byte(const UA_UInt64 *src, UA_UInt64 *dst, const UA_DataType *_) {
  719. *dst = *src;
  720. return UA_STATUSCODE_GOOD;
  721. }
  722. static UA_StatusCode
  723. copyGuid(const UA_Guid *src, UA_Guid *dst, const UA_DataType *_) {
  724. *dst = *src;
  725. return UA_STATUSCODE_GOOD;
  726. }
  727. typedef UA_StatusCode
  728. (*UA_copySignature)(const void *src, void *dst, const UA_DataType *type);
  729. static const UA_copySignature copyJumpTable[UA_BUILTIN_TYPES_COUNT + 1] = {
  730. (UA_copySignature)copyByte, // Boolean
  731. (UA_copySignature)copyByte, // SByte
  732. (UA_copySignature)copyByte, // Byte
  733. (UA_copySignature)copy2Byte, // Int16
  734. (UA_copySignature)copy2Byte, // UInt16
  735. (UA_copySignature)copy4Byte, // Int32
  736. (UA_copySignature)copy4Byte, // UInt32
  737. (UA_copySignature)copy8Byte, // Int64
  738. (UA_copySignature)copy8Byte, // UInt64
  739. (UA_copySignature)copy4Byte, // Float
  740. (UA_copySignature)copy8Byte, // Double
  741. (UA_copySignature)copy_noInit, // String
  742. (UA_copySignature)copy8Byte, // DateTime
  743. (UA_copySignature)copyGuid, // Guid
  744. (UA_copySignature)copy_noInit, // ByteString
  745. (UA_copySignature)copy_noInit, // XmlElement
  746. (UA_copySignature)NodeId_copy,
  747. (UA_copySignature)ExpandedNodeId_copy,
  748. (UA_copySignature)copy4Byte, // StatusCode
  749. (UA_copySignature)copy_noInit, // QualifiedName
  750. (UA_copySignature)LocalizedText_copy, // LocalizedText
  751. (UA_copySignature)ExtensionObject_copy,
  752. (UA_copySignature)DataValue_copy,
  753. (UA_copySignature)Variant_copy,
  754. (UA_copySignature)DiagnosticInfo_copy,
  755. (UA_copySignature)copy_noInit // all others
  756. };
  757. static UA_StatusCode
  758. copy_noInit(const void *src, void *dst, const UA_DataType *type) {
  759. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  760. uintptr_t ptrs = (uintptr_t)src;
  761. uintptr_t ptrd = (uintptr_t)dst;
  762. UA_Byte membersSize = type->membersSize;
  763. for(size_t i = 0; i < membersSize; i++) {
  764. const UA_DataTypeMember *m= &type->members[i];
  765. const UA_DataType *typelists[2] = { UA_TYPES, &type[-type->typeIndex] };
  766. const UA_DataType *mt = &typelists[!m->namespaceZero][m->memberTypeIndex];
  767. if(!m->isArray) {
  768. ptrs += m->padding;
  769. ptrd += m->padding;
  770. size_t fi = mt->builtin ? mt->typeIndex : UA_BUILTIN_TYPES_COUNT;
  771. retval |= copyJumpTable[fi]((const void*)ptrs, (void*)ptrd, mt);
  772. ptrs += mt->memSize;
  773. ptrd += mt->memSize;
  774. } else {
  775. ptrs += m->padding;
  776. ptrd += m->padding;
  777. size_t *dst_size = (size_t*)ptrd;
  778. const size_t size = *((const size_t*)ptrs);
  779. ptrs += sizeof(size_t);
  780. ptrd += sizeof(size_t);
  781. retval |= UA_Array_copy(*(void* const*)ptrs, size, (void**)ptrd, mt);
  782. if(retval == UA_STATUSCODE_GOOD)
  783. *dst_size = size;
  784. else
  785. *dst_size = 0;
  786. ptrs += sizeof(void*);
  787. ptrd += sizeof(void*);
  788. }
  789. }
  790. return retval;
  791. }
  792. UA_StatusCode
  793. UA_copy(const void *src, void *dst, const UA_DataType *type) {
  794. memset(dst, 0, type->memSize); /* init */
  795. UA_StatusCode retval = copy_noInit(src, dst, type);
  796. if(retval != UA_STATUSCODE_GOOD)
  797. UA_deleteMembers(dst, type);
  798. return retval;
  799. }
  800. static void nopDeleteMembers(void *p, const UA_DataType *type) { }
  801. typedef void (*UA_deleteMembersSignature)(void *p, const UA_DataType *type);
  802. static const
  803. UA_deleteMembersSignature deleteMembersJumpTable[UA_BUILTIN_TYPES_COUNT + 1] = {
  804. (UA_deleteMembersSignature)nopDeleteMembers, // Boolean
  805. (UA_deleteMembersSignature)nopDeleteMembers, // SByte
  806. (UA_deleteMembersSignature)nopDeleteMembers, // Byte
  807. (UA_deleteMembersSignature)nopDeleteMembers, // Int16
  808. (UA_deleteMembersSignature)nopDeleteMembers, // UInt16
  809. (UA_deleteMembersSignature)nopDeleteMembers, // Int32
  810. (UA_deleteMembersSignature)nopDeleteMembers, // UInt32
  811. (UA_deleteMembersSignature)nopDeleteMembers, // Int64
  812. (UA_deleteMembersSignature)nopDeleteMembers, // UInt64
  813. (UA_deleteMembersSignature)nopDeleteMembers, // Float
  814. (UA_deleteMembersSignature)nopDeleteMembers, // Double
  815. (UA_deleteMembersSignature)String_deleteMembers, // String
  816. (UA_deleteMembersSignature)nopDeleteMembers, // DateTime
  817. (UA_deleteMembersSignature)nopDeleteMembers, // Guid
  818. (UA_deleteMembersSignature)String_deleteMembers, // ByteString
  819. (UA_deleteMembersSignature)String_deleteMembers, // XmlElement
  820. (UA_deleteMembersSignature)NodeId_deleteMembers,
  821. (UA_deleteMembersSignature)ExpandedNodeId_deleteMembers, // ExpandedNodeId
  822. (UA_deleteMembersSignature)nopDeleteMembers, // StatusCode
  823. (UA_deleteMembersSignature)deleteMembers_noInit, // QualifiedName
  824. (UA_deleteMembersSignature)LocalizedText_deleteMembers, // LocalizedText
  825. (UA_deleteMembersSignature)ExtensionObject_deleteMembers,
  826. (UA_deleteMembersSignature)DataValue_deleteMembers,
  827. (UA_deleteMembersSignature)Variant_deletemembers,
  828. (UA_deleteMembersSignature)DiagnosticInfo_deleteMembers,
  829. (UA_deleteMembersSignature)deleteMembers_noInit,
  830. };
  831. static void
  832. deleteMembers_noInit(void *p, const UA_DataType *type) {
  833. uintptr_t ptr = (uintptr_t)p;
  834. UA_Byte membersSize = type->membersSize;
  835. for(size_t i = 0; i < membersSize; i++) {
  836. const UA_DataTypeMember *m= &type->members[i];
  837. const UA_DataType *typelists[2] = { UA_TYPES, &type[-type->typeIndex] };
  838. const UA_DataType *mt = &typelists[!m->namespaceZero][m->memberTypeIndex];
  839. if(!m->isArray) {
  840. ptr += m->padding;
  841. size_t fi = mt->builtin ? mt->typeIndex : UA_BUILTIN_TYPES_COUNT;
  842. deleteMembersJumpTable[fi]((void*)ptr, mt);
  843. ptr += mt->memSize;
  844. } else {
  845. ptr += m->padding;
  846. size_t length = *(size_t*)ptr;
  847. ptr += sizeof(size_t);
  848. UA_Array_delete(*(void**)ptr, length, mt);
  849. ptr += sizeof(void*);
  850. }
  851. }
  852. }
  853. void
  854. UA_deleteMembers(void *p, const UA_DataType *type) {
  855. deleteMembers_noInit(p, type);
  856. memset(p, 0, type->memSize); /* init */
  857. }
  858. void
  859. UA_delete(void *p, const UA_DataType *type) {
  860. deleteMembers_noInit(p, type);
  861. UA_free(p);
  862. }
  863. /******************/
  864. /* Array Handling */
  865. /******************/
  866. void *
  867. UA_Array_new(size_t size, const UA_DataType *type) {
  868. if(size == 0)
  869. return UA_EMPTY_ARRAY_SENTINEL;
  870. return UA_calloc(size, type->memSize);
  871. }
  872. UA_StatusCode
  873. UA_Array_copy(const void *src, size_t src_size,
  874. void **dst, const UA_DataType *type) {
  875. if(src_size == 0) {
  876. if(src == NULL)
  877. *dst = NULL;
  878. else
  879. *dst= UA_EMPTY_ARRAY_SENTINEL;
  880. return UA_STATUSCODE_GOOD;
  881. }
  882. if(!type)
  883. return UA_STATUSCODE_BADINTERNALERROR;
  884. /* calloc, so we don't have to check retval in every iteration of copying */
  885. *dst = UA_calloc(src_size, type->memSize);
  886. if(!*dst)
  887. return UA_STATUSCODE_BADOUTOFMEMORY;
  888. if(type->fixedSize) {
  889. memcpy(*dst, src, type->memSize * src_size);
  890. return UA_STATUSCODE_GOOD;
  891. }
  892. uintptr_t ptrs = (uintptr_t)src;
  893. uintptr_t ptrd = (uintptr_t)*dst;
  894. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  895. for(size_t i = 0; i < src_size; i++) {
  896. retval |= UA_copy((void*)ptrs, (void*)ptrd, type);
  897. ptrs += type->memSize;
  898. ptrd += type->memSize;
  899. }
  900. if(retval != UA_STATUSCODE_GOOD) {
  901. UA_Array_delete(*dst, src_size, type);
  902. *dst = NULL;
  903. }
  904. return retval;
  905. }
  906. void
  907. UA_Array_delete(void *p, size_t size, const UA_DataType *type) {
  908. if(!type->fixedSize) {
  909. uintptr_t ptr = (uintptr_t)p;
  910. for(size_t i = 0; i < size; i++) {
  911. UA_deleteMembers((void*)ptr, type);
  912. ptr += type->memSize;
  913. }
  914. }
  915. UA_free((void*)((uintptr_t)p & ~(uintptr_t)UA_EMPTY_ARRAY_SENTINEL));
  916. }