ua_types.c 42 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264
  1. #include "ua_util.h"
  2. #include "ua_types.h"
  3. #include "ua_statuscodes.h"
  4. #include "ua_types_generated.h"
  5. /*****************/
  6. /* Helper Macros */
  7. /*****************/
  8. #define UA_TYPE_DEFAULT(TYPE) \
  9. UA_TYPE_NEW_DEFAULT(TYPE) \
  10. UA_TYPE_INIT_DEFAULT(TYPE) \
  11. UA_TYPE_DELETEMEMBERS_NOACTION(TYPE) \
  12. UA_TYPE_DELETE_DEFAULT(TYPE) \
  13. UA_TYPE_COPY_DEFAULT(TYPE) \
  14. #define UA_TYPE_NEW_DEFAULT(TYPE) \
  15. TYPE * TYPE##_new() { \
  16. TYPE *p = UA_malloc(sizeof(TYPE)); \
  17. if(p) TYPE##_init(p); \
  18. return p; \
  19. }
  20. #define UA_TYPE_INIT_DEFAULT(TYPE) \
  21. void TYPE##_init(TYPE * p) { \
  22. *p = (TYPE)0; \
  23. }
  24. #define UA_TYPE_DELETEMEMBERS_NOACTION(TYPE) \
  25. void TYPE##_deleteMembers(TYPE *p) { \
  26. }
  27. #define UA_TYPE_DELETE_DEFAULT(TYPE) \
  28. void TYPE##_delete(TYPE *p) { \
  29. TYPE##_deleteMembers(p); \
  30. UA_free(p); \
  31. }
  32. #define UA_TYPE_COPY_DEFAULT(TYPE) \
  33. UA_StatusCode TYPE##_copy(TYPE const *src, TYPE *dst) { \
  34. *dst = *src; \
  35. return UA_STATUSCODE_GOOD; \
  36. }
  37. /*****************/
  38. /* Builtin Types */
  39. /*****************/
  40. /* Boolean */
  41. UA_TYPE_DEFAULT(UA_Boolean)
  42. /* SByte */
  43. UA_TYPE_DEFAULT(UA_SByte)
  44. /* Byte */
  45. UA_TYPE_DEFAULT(UA_Byte)
  46. /* Int16 */
  47. UA_TYPE_DEFAULT(UA_Int16)
  48. /* UInt16 */
  49. UA_TYPE_DEFAULT(UA_UInt16)
  50. /* Int32 */
  51. UA_TYPE_DEFAULT(UA_Int32)
  52. /* UInt32 */
  53. UA_TYPE_DEFAULT(UA_UInt32)
  54. /* Int64 */
  55. UA_TYPE_DEFAULT(UA_Int64)
  56. /* UInt64 */
  57. UA_TYPE_DEFAULT(UA_UInt64)
  58. /* Float */
  59. UA_TYPE_DEFAULT(UA_Float)
  60. /* Double */
  61. UA_TYPE_DEFAULT(UA_Double)
  62. /* String */
  63. UA_TYPE_NEW_DEFAULT(UA_String)
  64. UA_TYPE_DELETE_DEFAULT(UA_String)
  65. void UA_String_init(UA_String *p) {
  66. p->length = -1;
  67. p->data = UA_NULL;
  68. }
  69. void UA_String_deleteMembers(UA_String *p) {
  70. UA_free(p->data);
  71. p->data = UA_NULL;
  72. }
  73. UA_StatusCode UA_String_copy(UA_String const *src, UA_String *dst) {
  74. UA_String_init(dst);
  75. if(src->length > 0) {
  76. if(!(dst->data = UA_malloc((UA_UInt32)src->length)))
  77. return UA_STATUSCODE_BADOUTOFMEMORY;
  78. UA_memcpy((void *)dst->data, src->data, (UA_UInt32)src->length);
  79. }
  80. dst->length = src->length;
  81. return UA_STATUSCODE_GOOD;
  82. }
  83. UA_String UA_String_fromChars(char const src[]) {
  84. UA_String str;
  85. size_t length = strlen(src);
  86. if(length == 0) {
  87. str.length = 0;
  88. str.data = UA_NULL;
  89. return str;
  90. }
  91. str.data = UA_malloc(length);
  92. if(!str.data) {
  93. str.length = -1;
  94. return str;
  95. }
  96. UA_memcpy(str.data, src, length);
  97. str.length = length;
  98. return str;
  99. }
  100. #define UA_STRING_ALLOCPRINTF_BUFSIZE 1024
  101. UA_StatusCode UA_String_copyprintf(char const fmt[], UA_String *dst, ...) {
  102. char src[UA_STRING_ALLOCPRINTF_BUFSIZE];
  103. va_list ap;
  104. va_start(ap, dst);
  105. #if defined(__GNUC__) || defined(__clang__)
  106. #pragma GCC diagnostic push
  107. #pragma GCC diagnostic ignored "-Wformat-nonliteral"
  108. #endif
  109. // vsnprintf should only take a literal and no variable to be secure
  110. UA_Int32 len = vsnprintf(src, UA_STRING_ALLOCPRINTF_BUFSIZE, fmt, ap);
  111. #if defined(__GNUC__) || defined(__clang__)
  112. #pragma GCC diagnostic pop
  113. #endif
  114. va_end(ap);
  115. if(len < 0) // FIXME: old glibc 2.0 would return -1 when truncated
  116. return UA_STATUSCODE_BADINTERNALERROR;
  117. // since glibc 2.1 vsnprintf returns the len that would have resulted if buf were large enough
  118. len = ( len > UA_STRING_ALLOCPRINTF_BUFSIZE ? UA_STRING_ALLOCPRINTF_BUFSIZE : len );
  119. if(!(dst->data = UA_malloc((UA_UInt32)len)))
  120. return UA_STATUSCODE_BADOUTOFMEMORY;
  121. UA_memcpy((void *)dst->data, src, (UA_UInt32)len);
  122. dst->length = len;
  123. return UA_STATUSCODE_GOOD;
  124. }
  125. UA_Boolean UA_String_equal(const UA_String *string1, const UA_String *string2) {
  126. if(string1->length <= 0 && string2->length <= 0)
  127. return UA_TRUE;
  128. if(string1->length != string2->length)
  129. return UA_FALSE;
  130. // casts are needed to overcome signed warnings
  131. UA_Int32 is = strncmp((char const *)string1->data, (char const *)string2->data, (size_t)string1->length);
  132. return (is == 0) ? UA_TRUE : UA_FALSE;
  133. }
  134. UA_Boolean UA_String_equalchars(const UA_String *string1, char *charString) {
  135. UA_String string2 = UA_STRING(charString);
  136. return UA_String_equal(string1, &string2);
  137. }
  138. /* DateTime */
  139. #define UNIX_EPOCH_BIAS_SEC 11644473600LL // Number of seconds from 1 Jan. 1601 00:00 to 1 Jan 1970 00:00 UTC
  140. #define HUNDRED_NANOSEC_PER_USEC 10LL
  141. #define HUNDRED_NANOSEC_PER_SEC (HUNDRED_NANOSEC_PER_USEC * 1000000LL)
  142. #ifdef __MINGW32__
  143. #ifndef _TIMEZONE_DEFINED
  144. #define _TIMEZONE_DEFINED
  145. struct timezone {
  146. int tz_minuteswest;
  147. int tz_dsttime;
  148. };
  149. #endif
  150. #endif
  151. #ifdef _WIN32
  152. static const unsigned __int64 epoch = 116444736000000000;
  153. int gettimeofday(struct timeval *tp, struct timezone *tzp);
  154. int gettimeofday(struct timeval *tp, struct timezone *tzp) {
  155. FILETIME ft;
  156. SYSTEMTIME st;
  157. ULARGE_INTEGER ul;
  158. GetSystemTime(&st);
  159. SystemTimeToFileTime(&st, &ft);
  160. ul.LowPart = ft.dwLowDateTime;
  161. ul.HighPart = ft.dwHighDateTime;
  162. tp->tv_sec = (ul.QuadPart - epoch) / 10000000L;
  163. tp->tv_usec = st.wMilliseconds * 1000;
  164. return 0;
  165. }
  166. #endif
  167. UA_DateTime UA_DateTime_now() {
  168. UA_DateTime dateTime;
  169. struct timeval tv;
  170. gettimeofday(&tv, UA_NULL);
  171. dateTime = (tv.tv_sec + UNIX_EPOCH_BIAS_SEC)
  172. * HUNDRED_NANOSEC_PER_SEC + tv.tv_usec * HUNDRED_NANOSEC_PER_USEC;
  173. return dateTime;
  174. }
  175. UA_DateTimeStruct UA_DateTime_toStruct(UA_DateTime atime) {
  176. UA_DateTimeStruct dateTimeStruct;
  177. //calcualting the the milli-, micro- and nanoseconds
  178. dateTimeStruct.nanoSec = (UA_Int16)((atime % 10) * 100);
  179. dateTimeStruct.microSec = (UA_Int16)((atime % 10000) / 10);
  180. dateTimeStruct.milliSec = (UA_Int16)((atime % 10000000) / 10000);
  181. //calculating the unix time with #include <time.h>
  182. time_t secSinceUnixEpoch = (atime/10000000) - UNIX_EPOCH_BIAS_SEC;
  183. struct tm ts = *gmtime(&secSinceUnixEpoch);
  184. dateTimeStruct.sec = (UA_Int16)ts.tm_sec;
  185. dateTimeStruct.min = (UA_Int16)ts.tm_min;
  186. dateTimeStruct.hour = (UA_Int16)ts.tm_hour;
  187. dateTimeStruct.day = (UA_Int16)ts.tm_mday;
  188. dateTimeStruct.month = (UA_Int16)(ts.tm_mon + 1);
  189. dateTimeStruct.year = (UA_Int16)(ts.tm_year + 1900);
  190. return dateTimeStruct;
  191. }
  192. UA_StatusCode UA_DateTime_toString(UA_DateTime atime, UA_String *timeString) {
  193. // length of the string is 31 (incl. \0 at the end)
  194. if(!(timeString->data = UA_malloc(32)))
  195. return UA_STATUSCODE_BADOUTOFMEMORY;
  196. timeString->length = 31;
  197. UA_DateTimeStruct tSt = UA_DateTime_toStruct(atime);
  198. sprintf((char*)timeString->data, "%02d/%02d/%04d %02d:%02d:%02d.%03d.%03d.%03d", tSt.month, tSt.day, tSt.year,
  199. tSt.hour, tSt.min, tSt.sec, tSt.milliSec, tSt.microSec, tSt.nanoSec);
  200. return UA_STATUSCODE_GOOD;
  201. }
  202. /* Guid */
  203. UA_TYPE_NEW_DEFAULT(UA_Guid)
  204. UA_TYPE_DELETEMEMBERS_NOACTION(UA_Guid)
  205. UA_TYPE_DELETE_DEFAULT(UA_Guid)
  206. UA_Boolean UA_Guid_equal(const UA_Guid *g1, const UA_Guid *g2) {
  207. if(memcmp(g1, g2, sizeof(UA_Guid)) == 0)
  208. return UA_TRUE;
  209. return UA_FALSE;
  210. }
  211. UA_Guid UA_Guid_random(UA_UInt32 *seed) {
  212. UA_Guid result;
  213. result.data1 = RAND(seed);
  214. UA_UInt32 r = RAND(seed);
  215. result.data2 = (UA_UInt16) r;
  216. result.data3 = (UA_UInt16) (r >> 16);
  217. r = RAND(seed);
  218. result.data4[0] = (UA_Byte)r;
  219. result.data4[1] = (UA_Byte)(r >> 4);
  220. result.data4[2] = (UA_Byte)(r >> 8);
  221. result.data4[3] = (UA_Byte)(r >> 12);
  222. r = RAND(seed);
  223. result.data4[4] = (UA_Byte)r;
  224. result.data4[5] = (UA_Byte)(r >> 4);
  225. result.data4[6] = (UA_Byte)(r >> 8);
  226. result.data4[7] = (UA_Byte)(r >> 12);
  227. return result;
  228. }
  229. void UA_Guid_init(UA_Guid *p) {
  230. p->data1 = 0;
  231. p->data2 = 0;
  232. p->data3 = 0;
  233. memset(p->data4, 0, sizeof(UA_Byte)*8);
  234. }
  235. UA_StatusCode UA_Guid_copy(UA_Guid const *src, UA_Guid *dst) {
  236. UA_memcpy((void *)dst, (const void *)src, sizeof(UA_Guid));
  237. return UA_STATUSCODE_GOOD;
  238. }
  239. /* ByteString */
  240. UA_StatusCode UA_ByteString_newMembers(UA_ByteString *p, UA_Int32 length) {
  241. if(length > 0) {
  242. if(!(p->data = UA_malloc((UA_UInt32)length)))
  243. return UA_STATUSCODE_BADOUTOFMEMORY;
  244. p->length = length;
  245. } else {
  246. p->data = UA_NULL;
  247. if(length == 0)
  248. p->length = 0;
  249. else
  250. p->length = -1;
  251. }
  252. return UA_STATUSCODE_GOOD;
  253. }
  254. /* XmlElement */
  255. /* NodeId */
  256. UA_TYPE_NEW_DEFAULT(UA_NodeId)
  257. UA_TYPE_DELETE_DEFAULT(UA_NodeId)
  258. void UA_NodeId_init(UA_NodeId *p) {
  259. p->identifierType = UA_NODEIDTYPE_NUMERIC;
  260. p->namespaceIndex = 0;
  261. memset(&p->identifier, 0, sizeof(p->identifier));
  262. }
  263. UA_StatusCode UA_NodeId_copy(UA_NodeId const *src, UA_NodeId *dst) {
  264. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  265. switch(src->identifierType) {
  266. case UA_NODEIDTYPE_NUMERIC:
  267. *dst = *src;
  268. return UA_STATUSCODE_GOOD;
  269. case UA_NODEIDTYPE_STRING: // Table 6, second entry
  270. retval |= UA_String_copy(&src->identifier.string, &dst->identifier.string);
  271. break;
  272. case UA_NODEIDTYPE_GUID: // Table 6, third entry
  273. retval |= UA_Guid_copy(&src->identifier.guid, &dst->identifier.guid);
  274. break;
  275. case UA_NODEIDTYPE_BYTESTRING: // Table 6, "OPAQUE"
  276. retval |= UA_ByteString_copy(&src->identifier.byteString, &dst->identifier.byteString);
  277. break;
  278. default:
  279. UA_NodeId_init(dst);
  280. return UA_STATUSCODE_BADINTERNALERROR;
  281. }
  282. dst->namespaceIndex = src->namespaceIndex;
  283. dst->identifierType = src->identifierType;
  284. if(retval) {
  285. UA_NodeId_deleteMembers(dst);
  286. UA_NodeId_init(dst);
  287. }
  288. return retval;
  289. }
  290. void UA_NodeId_deleteMembers(UA_NodeId *p) {
  291. switch(p->identifierType) {
  292. case UA_NODEIDTYPE_STRING:
  293. case UA_NODEIDTYPE_BYTESTRING:
  294. UA_ByteString_deleteMembers(&p->identifier.byteString);
  295. break;
  296. default:
  297. break;
  298. }
  299. }
  300. UA_Boolean UA_NodeId_equal(const UA_NodeId *n1, const UA_NodeId *n2) {
  301. if(n1->namespaceIndex != n2->namespaceIndex || n1->identifierType!=n2->identifierType)
  302. return UA_FALSE;
  303. switch(n1->identifierType) {
  304. case UA_NODEIDTYPE_NUMERIC:
  305. if(n1->identifier.numeric == n2->identifier.numeric)
  306. return UA_TRUE;
  307. else
  308. return UA_FALSE;
  309. case UA_NODEIDTYPE_STRING:
  310. return UA_String_equal(&n1->identifier.string, &n2->identifier.string);
  311. case UA_NODEIDTYPE_GUID:
  312. return UA_Guid_equal(&n1->identifier.guid, &n2->identifier.guid);
  313. case UA_NODEIDTYPE_BYTESTRING:
  314. return UA_ByteString_equal(&n1->identifier.byteString, &n2->identifier.byteString);
  315. }
  316. return UA_FALSE;
  317. }
  318. UA_Boolean UA_NodeId_isNull(const UA_NodeId *p) {
  319. switch(p->identifierType) {
  320. case UA_NODEIDTYPE_NUMERIC:
  321. if(p->namespaceIndex != 0 || p->identifier.numeric != 0)
  322. return UA_FALSE;
  323. break;
  324. case UA_NODEIDTYPE_STRING:
  325. if(p->namespaceIndex != 0 || p->identifier.string.length > 0)
  326. return UA_FALSE;
  327. break;
  328. case UA_NODEIDTYPE_GUID:
  329. if(p->namespaceIndex != 0 ||
  330. memcmp(&p->identifier.guid, (char[sizeof(UA_Guid)]) { 0 }, sizeof(UA_Guid)) != 0)
  331. return UA_FALSE;
  332. break;
  333. case UA_NODEIDTYPE_BYTESTRING:
  334. if(p->namespaceIndex != 0 || p->identifier.byteString.length > 0)
  335. return UA_FALSE;
  336. break;
  337. default:
  338. return UA_FALSE;
  339. }
  340. return UA_TRUE;
  341. }
  342. UA_NodeId UA_NodeId_fromInteger(UA_UInt16 nsIndex, UA_Int32 identifier) {
  343. return (UA_NodeId) { .namespaceIndex = nsIndex, .identifierType = UA_NODEIDTYPE_NUMERIC,
  344. .identifier.numeric = identifier };
  345. }
  346. UA_NodeId UA_NodeId_fromCharString(UA_UInt16 nsIndex, char identifier[]) {
  347. return (UA_NodeId) { .namespaceIndex = nsIndex, .identifierType = UA_NODEIDTYPE_STRING,
  348. .identifier.string = UA_STRING(identifier) };
  349. }
  350. UA_NodeId UA_NodeId_fromCharStringCopy(UA_UInt16 nsIndex, char const identifier[]) {
  351. return (UA_NodeId) {.namespaceIndex = nsIndex, .identifierType = UA_NODEIDTYPE_STRING,
  352. .identifier.string = UA_STRING_ALLOC(identifier) };
  353. }
  354. UA_NodeId UA_NodeId_fromString(UA_UInt16 nsIndex, UA_String identifier) {
  355. return (UA_NodeId) { .namespaceIndex = nsIndex, .identifierType = UA_NODEIDTYPE_STRING,
  356. .identifier.string = identifier };
  357. }
  358. UA_NodeId UA_NodeId_fromStringCopy(UA_UInt16 nsIndex, UA_String identifier) {
  359. UA_NodeId id;
  360. id.namespaceIndex = nsIndex;
  361. id.identifierType = UA_NODEIDTYPE_STRING;
  362. UA_String_copy(&identifier, &id.identifier.string);
  363. return id;
  364. }
  365. UA_NodeId UA_NodeId_fromGuid(UA_UInt16 nsIndex, UA_Guid identifier) {
  366. return (UA_NodeId) { .namespaceIndex = nsIndex, .identifierType = UA_NODEIDTYPE_GUID,
  367. .identifier.guid = identifier };
  368. }
  369. UA_NodeId UA_NodeId_fromCharByteString(UA_UInt16 nsIndex, char identifier[]) {
  370. return (UA_NodeId) { .namespaceIndex = nsIndex, .identifierType = UA_NODEIDTYPE_BYTESTRING,
  371. .identifier.byteString = UA_STRING(identifier) };
  372. }
  373. UA_NodeId UA_NodeId_fromCharByteStringCopy(UA_UInt16 nsIndex, char const identifier[]) {
  374. return (UA_NodeId) { .namespaceIndex = nsIndex, .identifierType = UA_NODEIDTYPE_BYTESTRING,
  375. .identifier.byteString = UA_STRING_ALLOC(identifier) };
  376. }
  377. UA_NodeId UA_NodeId_fromByteString(UA_UInt16 nsIndex, UA_ByteString identifier) {
  378. return (UA_NodeId) { .namespaceIndex = nsIndex, .identifierType = UA_NODEIDTYPE_BYTESTRING,
  379. .identifier.byteString = identifier };
  380. }
  381. UA_NodeId UA_NodeId_fromByteStringCopy(UA_UInt16 nsIndex, UA_ByteString identifier) {
  382. UA_NodeId id;
  383. id.namespaceIndex = nsIndex;
  384. id.identifierType = UA_NODEIDTYPE_BYTESTRING;
  385. UA_ByteString_copy(&identifier, &id.identifier.byteString);
  386. return id;
  387. }
  388. /* ExpandedNodeId */
  389. UA_TYPE_NEW_DEFAULT(UA_ExpandedNodeId)
  390. UA_TYPE_DELETE_DEFAULT(UA_ExpandedNodeId)
  391. void UA_ExpandedNodeId_deleteMembers(UA_ExpandedNodeId *p) {
  392. UA_NodeId_deleteMembers(&p->nodeId);
  393. UA_String_deleteMembers(&p->namespaceUri);
  394. }
  395. void UA_ExpandedNodeId_init(UA_ExpandedNodeId *p) {
  396. UA_NodeId_init(&p->nodeId);
  397. UA_String_init(&p->namespaceUri);
  398. p->serverIndex = 0;
  399. }
  400. UA_StatusCode UA_ExpandedNodeId_copy(UA_ExpandedNodeId const *src, UA_ExpandedNodeId *dst) {
  401. UA_StatusCode retval = UA_NodeId_copy(&src->nodeId, &dst->nodeId);
  402. retval |= UA_String_copy(&src->namespaceUri, &dst->namespaceUri);
  403. dst->serverIndex = src->serverIndex;
  404. if(retval) {
  405. UA_ExpandedNodeId_deleteMembers(dst);
  406. UA_ExpandedNodeId_init(dst);
  407. }
  408. return retval;
  409. }
  410. UA_Boolean UA_ExpandedNodeId_isNull(const UA_ExpandedNodeId *p) {
  411. return UA_NodeId_isNull(&p->nodeId);
  412. }
  413. /* StatusCode */
  414. /* QualifiedName */
  415. UA_TYPE_NEW_DEFAULT(UA_QualifiedName)
  416. UA_TYPE_DELETE_DEFAULT(UA_QualifiedName)
  417. void UA_QualifiedName_deleteMembers(UA_QualifiedName *p) {
  418. UA_String_deleteMembers(&p->name);
  419. }
  420. void UA_QualifiedName_init(UA_QualifiedName *p) {
  421. UA_String_init(&p->name);
  422. p->namespaceIndex = 0;
  423. }
  424. UA_StatusCode UA_QualifiedName_copy(UA_QualifiedName const *src, UA_QualifiedName *dst) {
  425. UA_StatusCode retval = UA_String_copy(&src->name, &dst->name);
  426. dst->namespaceIndex = src->namespaceIndex;
  427. if(retval) {
  428. UA_QualifiedName_deleteMembers(dst);
  429. UA_QualifiedName_init(dst);
  430. }
  431. return retval;
  432. }
  433. /* LocalizedText */
  434. UA_TYPE_NEW_DEFAULT(UA_LocalizedText)
  435. UA_TYPE_DELETE_DEFAULT(UA_LocalizedText)
  436. void UA_LocalizedText_deleteMembers(UA_LocalizedText *p) {
  437. UA_String_deleteMembers(&p->locale);
  438. UA_String_deleteMembers(&p->text);
  439. }
  440. void UA_LocalizedText_init(UA_LocalizedText *p) {
  441. UA_String_init(&p->locale);
  442. UA_String_init(&p->text);
  443. }
  444. UA_StatusCode UA_LocalizedText_copy(UA_LocalizedText const *src, UA_LocalizedText *dst) {
  445. UA_StatusCode retval = UA_String_copy(&src->locale, &dst->locale);
  446. retval |= UA_String_copy(&src->text, &dst->text);
  447. if(retval) {
  448. UA_LocalizedText_deleteMembers(dst);
  449. UA_LocalizedText_init(dst);
  450. }
  451. return retval;
  452. }
  453. /* ExtensionObject */
  454. UA_TYPE_NEW_DEFAULT(UA_ExtensionObject)
  455. UA_TYPE_DELETE_DEFAULT(UA_ExtensionObject)
  456. void UA_ExtensionObject_deleteMembers(UA_ExtensionObject *p) {
  457. UA_NodeId_deleteMembers(&p->typeId);
  458. UA_ByteString_deleteMembers(&p->body);
  459. }
  460. void UA_ExtensionObject_init(UA_ExtensionObject *p) {
  461. UA_NodeId_init(&p->typeId);
  462. p->encoding = UA_EXTENSIONOBJECT_ENCODINGMASK_NOBODYISENCODED;
  463. UA_ByteString_init(&p->body);
  464. }
  465. UA_StatusCode UA_ExtensionObject_copy(UA_ExtensionObject const *src, UA_ExtensionObject *dst) {
  466. UA_StatusCode retval = UA_ByteString_copy(&src->body, &dst->body);
  467. retval |= UA_NodeId_copy(&src->typeId, &dst->typeId);
  468. dst->encoding = src->encoding;
  469. if(retval) {
  470. UA_ExtensionObject_deleteMembers(dst);
  471. UA_ExtensionObject_init(dst);
  472. }
  473. return retval;
  474. }
  475. /* DataValue */
  476. UA_TYPE_NEW_DEFAULT(UA_DataValue)
  477. UA_TYPE_DELETE_DEFAULT(UA_DataValue)
  478. void UA_DataValue_deleteMembers(UA_DataValue *p) {
  479. UA_Variant_deleteMembers(&p->value);
  480. }
  481. void UA_DataValue_init(UA_DataValue *p) {
  482. *((UA_Byte*)p) = 0; // zero out the bitfield
  483. p->serverPicoseconds = 0;
  484. UA_DateTime_init(&p->serverTimestamp);
  485. p->sourcePicoseconds = 0;
  486. UA_DateTime_init(&p->sourceTimestamp);
  487. UA_StatusCode_init(&p->status);
  488. UA_Variant_init(&p->value);
  489. }
  490. UA_StatusCode UA_DataValue_copy(UA_DataValue const *src, UA_DataValue *dst) {
  491. UA_DataValue_init(dst);
  492. *((UA_Byte*)dst) = *((const UA_Byte*)src); // the bitfield
  493. UA_StatusCode retval = UA_DateTime_copy(&src->serverTimestamp, &dst->serverTimestamp);
  494. retval |= UA_DateTime_copy(&src->sourceTimestamp, &dst->sourceTimestamp);
  495. retval |= UA_Variant_copy(&src->value, &dst->value);
  496. dst->serverPicoseconds = src->serverPicoseconds;
  497. dst->sourcePicoseconds = src->sourcePicoseconds;
  498. dst->status = src->status;
  499. if(retval) {
  500. UA_DataValue_deleteMembers(dst);
  501. UA_DataValue_init(dst);
  502. }
  503. return retval;
  504. }
  505. /* Variant */
  506. UA_TYPE_NEW_DEFAULT(UA_Variant)
  507. UA_TYPE_DELETE_DEFAULT(UA_Variant)
  508. void UA_Variant_init(UA_Variant *p) {
  509. p->storageType = UA_VARIANT_DATA;
  510. p->arrayLength = -1;
  511. p->data = UA_NULL;
  512. p->arrayDimensions = UA_NULL;
  513. p->arrayDimensionsSize = -1;
  514. p->type = &UA_TYPES[UA_TYPES_BOOLEAN];
  515. }
  516. void UA_Variant_deleteMembers(UA_Variant *p) {
  517. if(p->storageType != UA_VARIANT_DATA)
  518. return;
  519. if(p->data) {
  520. if(p->arrayLength == -1)
  521. p->arrayLength = 1;
  522. UA_Array_delete(p->data, p->type, p->arrayLength);
  523. p->data = UA_NULL;
  524. p->arrayLength = -1;
  525. }
  526. if(p->arrayDimensions) {
  527. UA_free(p->arrayDimensions);
  528. p->arrayDimensions = UA_NULL;
  529. p->arrayDimensionsSize = -1;
  530. }
  531. }
  532. UA_StatusCode UA_Variant_copy(UA_Variant const *src, UA_Variant *dst) {
  533. UA_Variant_init(dst);
  534. UA_Int32 elements = src->arrayLength;
  535. if(UA_Variant_isScalar(src))
  536. elements = 1;
  537. UA_StatusCode retval = UA_Array_copy(src->data, &dst->data, src->type, elements);
  538. if(retval != UA_STATUSCODE_GOOD) {
  539. UA_Variant_deleteMembers(dst);
  540. UA_Variant_init(dst);
  541. return retval;
  542. }
  543. dst->arrayLength = src->arrayLength;
  544. dst->type = src->type;
  545. dst->storageType = UA_VARIANT_DATA;
  546. if(src->arrayDimensions) {
  547. retval |= UA_Array_copy(src->arrayDimensions, (void **)&dst->arrayDimensions,
  548. &UA_TYPES[UA_TYPES_INT32], src->arrayDimensionsSize);
  549. if(retval != UA_STATUSCODE_GOOD) {
  550. UA_Variant_deleteMembers(dst);
  551. UA_Variant_init(dst);
  552. return retval;
  553. }
  554. dst->arrayDimensionsSize = src->arrayDimensionsSize;
  555. }
  556. return retval;
  557. }
  558. UA_Boolean UA_Variant_isScalar(const UA_Variant *v) {
  559. return (v->data != UA_NULL && v->arrayLength == -1);
  560. }
  561. /**
  562. * Tests if a range is compatible with a variant. If yes, the following values are set:
  563. * - total: how many elements are indicated by the range
  564. * - block_size: how big is each contiguous block of elements in the variant denoted by the range
  565. * - block_distance: how many elements are between the blocks (beginning to beginning)
  566. * - first_elem: where does the first block begin
  567. */
  568. static UA_StatusCode
  569. testRangeWithVariant(const UA_Variant *v, const UA_NumericRange range, size_t *total,
  570. size_t *block_size, size_t *block_distance, size_t *first_elem)
  571. {
  572. /* Test the integrity of the source variant dimensions */
  573. UA_Int32 dims_count = 1;
  574. const UA_Int32 *dims = &v->arrayLength; // default: the array has only one dimension
  575. if(v->arrayDimensionsSize > 0) {
  576. dims_count = v->arrayDimensionsSize;
  577. dims = v->arrayDimensions;
  578. UA_Int32 elements = 1;
  579. for(UA_Int32 i = 0; i < dims_count; i++)
  580. elements *= dims[i];
  581. if(elements != v->arrayLength)
  582. return UA_STATUSCODE_BADINTERNALERROR;
  583. }
  584. /* Test the integrity of the range */
  585. size_t count = 1;
  586. if(range.dimensionsSize != dims_count)
  587. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  588. for(UA_Int32 i = 0; i < dims_count; i++) {
  589. if(range.dimensions[i].min > range.dimensions[i].max)
  590. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  591. if(range.dimensions[i].max > (UA_UInt32)*(dims+i))
  592. return UA_STATUSCODE_BADINDEXRANGENODATA;
  593. count *= (range.dimensions[i].max - range.dimensions[i].min) + 1;
  594. }
  595. /* Compute the block size and the position of the first element */
  596. size_t bs = 0;
  597. size_t bd = 0;
  598. size_t fe = 0;
  599. size_t running_dimssize = 1; // elements per block of dimensions k to k_max
  600. UA_Boolean found_contiguous = UA_FALSE;
  601. for(UA_Int32 k = dims_count - 1; k >= 0; k--) {
  602. if(!found_contiguous && (range.dimensions[k].min != 0 ||
  603. range.dimensions[k].max + 1 != (UA_UInt32)dims[k])) {
  604. found_contiguous = UA_TRUE;
  605. bs = (range.dimensions[k].max - range.dimensions[k].min + 1) * running_dimssize;
  606. bd = dims[k] * running_dimssize;
  607. }
  608. fe += running_dimssize * range.dimensions[k].min;
  609. running_dimssize *= dims[k];
  610. }
  611. *total = count;
  612. *block_size = bs;
  613. *block_distance = bd;
  614. *first_elem = fe;
  615. return UA_STATUSCODE_GOOD;
  616. }
  617. UA_StatusCode UA_Variant_copyRange(const UA_Variant *src, UA_Variant *dst, const UA_NumericRange range) {
  618. size_t count, block_size, block_distance, first_elem;
  619. UA_StatusCode retval = testRangeWithVariant(src, range, &count, &block_size, &block_distance, &first_elem);
  620. if(retval != UA_STATUSCODE_GOOD)
  621. return retval;
  622. UA_Variant_init(dst);
  623. size_t elem_size = src->type->memSize;
  624. dst->data = UA_malloc(elem_size * count);
  625. if(!dst->data)
  626. return UA_STATUSCODE_BADOUTOFMEMORY;
  627. /* Copy the range */
  628. size_t block_count = count / block_size;
  629. uintptr_t nextdst = (uintptr_t)dst->data;
  630. uintptr_t nextsrc = (uintptr_t)src->data + (elem_size * first_elem);
  631. if(src->type->fixedSize) {
  632. for(size_t i = 0; i < block_count; i++) {
  633. memcpy((void*)nextdst, (void*)nextsrc, elem_size * block_size);
  634. nextdst += block_size * elem_size;
  635. nextsrc += block_distance * elem_size;
  636. }
  637. } else {
  638. for(size_t i = 0; i < block_count; i++) {
  639. for(size_t j = 0; j < block_size && retval == UA_STATUSCODE_GOOD; j++) {
  640. retval = UA_copy((const void*)nextsrc, (void*)nextdst, src->type);
  641. nextdst += elem_size;
  642. nextsrc += elem_size;
  643. }
  644. nextsrc += (block_distance - block_size) * elem_size;
  645. }
  646. if(retval != UA_STATUSCODE_GOOD) {
  647. size_t copied = ((nextdst - elem_size) - (uintptr_t)dst->data) / elem_size;
  648. UA_Array_delete(dst->data, src->type, copied);
  649. return retval;
  650. }
  651. }
  652. /* Copy the range dimensions*/
  653. if(src->arrayDimensionsSize > 0) {
  654. dst->arrayDimensions = UA_malloc(sizeof(UA_Int32) * src->arrayDimensionsSize);
  655. if(!dst->arrayDimensions) {
  656. UA_Array_delete(dst->data, src->type, count);
  657. return UA_STATUSCODE_BADOUTOFMEMORY;
  658. }
  659. for(UA_Int32 k = 0; k < src->arrayDimensionsSize; k++)
  660. dst->arrayDimensions[k] = range.dimensions[k].max - range.dimensions[k].min + 1;
  661. dst->arrayDimensionsSize = src->arrayDimensionsSize;
  662. }
  663. dst->arrayLength = count;
  664. dst->type = src->type;
  665. return UA_STATUSCODE_GOOD;
  666. }
  667. UA_StatusCode UA_Variant_setRange(UA_Variant *v, void *dataArray, UA_Int32 dataArraySize,
  668. const UA_NumericRange range) {
  669. size_t count, block_size, block_distance, first_elem;
  670. UA_StatusCode retval = testRangeWithVariant(v, range, &count, &block_size, &block_distance, &first_elem);
  671. if(retval != UA_STATUSCODE_GOOD)
  672. return retval;
  673. if((UA_Int32)count != dataArraySize)
  674. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  675. size_t block_count = count / block_size;
  676. size_t elem_size = v->type->memSize;
  677. uintptr_t nextdst = (uintptr_t)v->data + (first_elem * elem_size);
  678. uintptr_t nextsrc = (uintptr_t)dataArray;
  679. for(size_t i = 0; i < block_count; i++) {
  680. if(!v->type->fixedSize) {
  681. for(size_t j = 0; j < block_size; j++) {
  682. UA_deleteMembers((void*)nextdst, v->type);
  683. nextdst += elem_size;
  684. }
  685. nextdst -= block_size * elem_size;
  686. }
  687. memcpy((void*)nextdst, (void*)nextsrc, elem_size * block_size);
  688. nextsrc += block_size * elem_size;
  689. nextdst += block_distance * elem_size;
  690. }
  691. return UA_STATUSCODE_GOOD;
  692. }
  693. UA_StatusCode UA_EXPORT UA_Variant_setRangeCopy(UA_Variant *v, const void *dataArray, UA_Int32 dataArraySize,
  694. const UA_NumericRange range) {
  695. size_t count, block_size, block_distance, first_elem;
  696. UA_StatusCode retval = testRangeWithVariant(v, range, &count, &block_size, &block_distance, &first_elem);
  697. if(retval != UA_STATUSCODE_GOOD)
  698. return retval;
  699. if((UA_Int32)count != dataArraySize)
  700. return UA_STATUSCODE_BADINDEXRANGEINVALID;
  701. size_t block_count = count / block_size;
  702. size_t elem_size = v->type->memSize;
  703. uintptr_t nextdst = (uintptr_t)v->data + (first_elem * elem_size);
  704. uintptr_t nextsrc = (uintptr_t)dataArray;
  705. if(v->type->fixedSize) {
  706. for(size_t i = 0; i < block_count; i++) {
  707. memcpy((void*)nextdst, (void*)nextsrc, elem_size * block_size);
  708. nextsrc += block_size * elem_size;
  709. nextdst += block_distance * elem_size;
  710. }
  711. } else {
  712. for(size_t i = 0; i < block_count; i++) {
  713. for(size_t j = 0; j < block_size; j++) {
  714. UA_deleteMembers((void*)nextdst, v->type);
  715. UA_copy((void*)nextsrc, (void*)nextdst, v->type);
  716. nextdst += elem_size;
  717. nextsrc += elem_size;
  718. }
  719. nextdst += (block_distance - block_size) * elem_size;
  720. }
  721. }
  722. return UA_STATUSCODE_GOOD;
  723. }
  724. UA_StatusCode UA_Variant_setScalar(UA_Variant *v, void *p, const UA_DataType *type) {
  725. return UA_Variant_setArray(v, p, -1, type);
  726. }
  727. UA_StatusCode UA_Variant_setScalarCopy(UA_Variant *v, const void *p, const UA_DataType *type) {
  728. void *new = UA_malloc(type->memSize);
  729. if(!new)
  730. return UA_STATUSCODE_BADOUTOFMEMORY;
  731. UA_StatusCode retval = UA_copy(p, new, type);
  732. if(retval != UA_STATUSCODE_GOOD) {
  733. UA_delete(new, type);
  734. return retval;
  735. }
  736. return UA_Variant_setArray(v, new, -1, type);
  737. }
  738. UA_StatusCode UA_Variant_setArray(UA_Variant *v, void *array, UA_Int32 noElements,
  739. const UA_DataType *type) {
  740. v->type = type;
  741. v->arrayLength = noElements;
  742. v->data = array;
  743. return UA_STATUSCODE_GOOD;
  744. }
  745. UA_StatusCode UA_Variant_setArrayCopy(UA_Variant *v, const void *array, UA_Int32 noElements,
  746. const UA_DataType *type) {
  747. void *new;
  748. UA_StatusCode retval = UA_Array_copy(array, &new, type, noElements);
  749. if(retval != UA_STATUSCODE_GOOD)
  750. return retval;
  751. return UA_Variant_setArray(v, new, noElements, type);
  752. }
  753. /* DiagnosticInfo */
  754. UA_TYPE_NEW_DEFAULT(UA_DiagnosticInfo)
  755. UA_TYPE_DELETE_DEFAULT(UA_DiagnosticInfo)
  756. void UA_DiagnosticInfo_deleteMembers(UA_DiagnosticInfo *p) {
  757. UA_String_deleteMembers(&p->additionalInfo);
  758. if(p->hasInnerDiagnosticInfo && p->innerDiagnosticInfo) {
  759. UA_DiagnosticInfo_delete(p->innerDiagnosticInfo);
  760. p->innerDiagnosticInfo = UA_NULL;
  761. }
  762. }
  763. void UA_DiagnosticInfo_init(UA_DiagnosticInfo *p) {
  764. *((UA_Byte*)p) = 0; // zero out the bitfield
  765. p->symbolicId = 0;
  766. p->namespaceUri = 0;
  767. p->localizedText = 0;
  768. p->locale = 0;
  769. UA_String_init(&p->additionalInfo);
  770. p->innerDiagnosticInfo = UA_NULL;
  771. UA_StatusCode_init(&p->innerStatusCode);
  772. }
  773. UA_StatusCode UA_DiagnosticInfo_copy(UA_DiagnosticInfo const *src, UA_DiagnosticInfo *dst) {
  774. UA_DiagnosticInfo_init(dst);
  775. *((UA_Byte*)dst) = *((const UA_Byte*)src); // the bitfield
  776. dst->symbolicId = src->symbolicId;
  777. dst->namespaceUri = src->namespaceUri;
  778. dst->localizedText = src->localizedText;
  779. dst->locale = src->locale;
  780. dst->innerStatusCode = src->innerStatusCode;
  781. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  782. if(src->hasAdditionalInfo)
  783. retval = UA_String_copy(&src->additionalInfo, &dst->additionalInfo);
  784. if(src->hasInnerDiagnosticInfo && src->innerDiagnosticInfo) {
  785. if((dst->innerDiagnosticInfo = UA_malloc(sizeof(UA_DiagnosticInfo)))) {
  786. retval |= UA_DiagnosticInfo_copy(src->innerDiagnosticInfo, dst->innerDiagnosticInfo);
  787. dst->hasInnerDiagnosticInfo = src->hasInnerDiagnosticInfo;
  788. }
  789. else
  790. retval |= UA_STATUSCODE_BADOUTOFMEMORY;
  791. }
  792. if(retval) {
  793. UA_DiagnosticInfo_deleteMembers(dst);
  794. UA_DiagnosticInfo_init(dst);
  795. }
  796. return retval;
  797. }
  798. /*******************/
  799. /* Structure Types */
  800. /*******************/
  801. void UA_init(void *p, const UA_DataType *dataType) {
  802. /* Do not check if the index is a builtin-type here. Builtins will be called
  803. with their very own _init functions normally. In the off case, that the
  804. generic function is called with the index of a builtin, their layout
  805. contains a single member of the builtin type, that will be inited in the
  806. for loop. */
  807. uintptr_t ptr = (uintptr_t)p;
  808. UA_Byte membersSize = dataType->membersSize;
  809. for(size_t i=0;i<membersSize; i++) {
  810. const UA_DataTypeMember *member = &dataType->members[i];
  811. if(member->isArray) {
  812. /* Padding contains bit-magic to split into padding before and after
  813. the length integer */
  814. ptr += (member->padding >> 3);
  815. *((UA_Int32*)ptr) = -1;
  816. ptr += sizeof(UA_Int32) + (member->padding & 0x07);
  817. *((void**)ptr) = UA_NULL;
  818. ptr += sizeof(void*);
  819. continue;
  820. }
  821. ptr += member->padding;
  822. if(!member->namespaceZero) {
  823. // pointer arithmetic
  824. const UA_DataType *memberType = &dataType[member->memberTypeIndex - dataType->typeIndex];
  825. UA_init((void*)ptr, memberType);
  826. ptr += memberType->memSize;
  827. continue;
  828. }
  829. switch(member->memberTypeIndex) {
  830. case UA_TYPES_BOOLEAN:
  831. case UA_TYPES_SBYTE:
  832. case UA_TYPES_BYTE:
  833. *(UA_Byte*)ptr = 0;
  834. break;
  835. case UA_TYPES_INT16:
  836. case UA_TYPES_UINT16:
  837. *(UA_Int16*)ptr = 0;
  838. break;
  839. case UA_TYPES_INT32:
  840. case UA_TYPES_UINT32:
  841. case UA_TYPES_STATUSCODE:
  842. case UA_TYPES_FLOAT:
  843. *(UA_Int32*)ptr = 0;
  844. break;
  845. case UA_TYPES_INT64:
  846. case UA_TYPES_UINT64:
  847. case UA_TYPES_DOUBLE:
  848. case UA_TYPES_DATETIME:
  849. *(UA_Int64*)ptr = 0;
  850. break;
  851. case UA_TYPES_GUID:
  852. UA_Guid_init((UA_Guid*)ptr);
  853. break;
  854. case UA_TYPES_NODEID:
  855. UA_NodeId_init((UA_NodeId*)ptr);
  856. break;
  857. case UA_TYPES_EXPANDEDNODEID:
  858. UA_ExpandedNodeId_init((UA_ExpandedNodeId*)ptr);
  859. break;
  860. case UA_TYPES_LOCALIZEDTEXT:
  861. UA_LocalizedText_init((UA_LocalizedText*)ptr);
  862. break;
  863. case UA_TYPES_EXTENSIONOBJECT:
  864. UA_ExtensionObject_init((UA_ExtensionObject*)ptr);
  865. break;
  866. case UA_TYPES_DATAVALUE:
  867. UA_DataValue_init((UA_DataValue*)ptr);
  868. break;
  869. case UA_TYPES_VARIANT:
  870. UA_Variant_init((UA_Variant*)ptr);
  871. break;
  872. case UA_TYPES_DIAGNOSTICINFO:
  873. UA_DiagnosticInfo_init((UA_DiagnosticInfo*)ptr);
  874. break;
  875. default:
  876. // QualifiedName, LocalizedText and strings are treated as structures, also
  877. UA_init((void*)ptr, &UA_TYPES[member->memberTypeIndex]);
  878. }
  879. ptr += UA_TYPES[member->memberTypeIndex].memSize;
  880. }
  881. }
  882. void * UA_new(const UA_DataType *dataType) {
  883. void *p = UA_malloc(dataType->memSize);
  884. if(p)
  885. UA_init(p, dataType);
  886. return p;
  887. }
  888. UA_StatusCode UA_copy(const void *src, void *dst, const UA_DataType *dataType) {
  889. if(dataType->fixedSize) {
  890. memcpy(dst, src, dataType->memSize);
  891. return UA_STATUSCODE_GOOD;
  892. }
  893. UA_init(dst, dataType);
  894. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  895. uintptr_t ptrs = (uintptr_t)src;
  896. uintptr_t ptrd = (uintptr_t)dst;
  897. UA_Byte membersSize = dataType->membersSize;
  898. for(size_t i=0;i<membersSize; i++) {
  899. const UA_DataTypeMember *member = &dataType->members[i];
  900. const UA_DataType *memberType;
  901. if(member->namespaceZero)
  902. memberType = &UA_TYPES[member->memberTypeIndex];
  903. else
  904. memberType = &dataType[member->memberTypeIndex - dataType->typeIndex];
  905. if(member->isArray) {
  906. ptrs += (member->padding >> 3);
  907. ptrd += (member->padding >> 3);
  908. UA_Int32 *dstNoElements = (UA_Int32*)ptrd;
  909. const UA_Int32 noElements = *((const UA_Int32*)ptrs);
  910. ptrs += sizeof(UA_Int32) + (member->padding & 0x07);
  911. ptrd += sizeof(UA_Int32) + (member->padding & 0x07);
  912. retval = UA_Array_copy(*(void* const*)ptrs, (void**)ptrd, memberType, noElements);
  913. if(retval != UA_STATUSCODE_GOOD) {
  914. UA_deleteMembers(dst, dataType);
  915. UA_init(dst, dataType);
  916. return retval;
  917. }
  918. *dstNoElements = noElements;
  919. ptrs += sizeof(void*);
  920. ptrd += sizeof(void*);
  921. continue;
  922. }
  923. ptrs += member->padding;
  924. ptrd += member->padding;
  925. if(!member->namespaceZero) {
  926. retval = UA_copy((const void*)ptrs, (void*)ptrd, memberType);
  927. if(retval != UA_STATUSCODE_GOOD) {
  928. UA_deleteMembers(dst, dataType);
  929. UA_init(dst, dataType);
  930. return retval;
  931. }
  932. ptrs += memberType->memSize;
  933. ptrd += memberType->memSize;
  934. continue;
  935. }
  936. switch(member->memberTypeIndex) {
  937. case UA_TYPES_BOOLEAN:
  938. case UA_TYPES_SBYTE:
  939. case UA_TYPES_BYTE:
  940. *((UA_Byte*)ptrd) = *((const UA_Byte*)ptrs);
  941. break;
  942. case UA_TYPES_INT16:
  943. case UA_TYPES_UINT16:
  944. *((UA_Int16*)ptrd) = *((const UA_Byte*)ptrs);
  945. break;
  946. case UA_TYPES_INT32:
  947. case UA_TYPES_UINT32:
  948. case UA_TYPES_STATUSCODE:
  949. case UA_TYPES_FLOAT:
  950. *((UA_Int32*)ptrd) = *((const UA_Int32*)ptrs);
  951. break;
  952. case UA_TYPES_INT64:
  953. case UA_TYPES_UINT64:
  954. case UA_TYPES_DOUBLE:
  955. case UA_TYPES_DATETIME:
  956. *((UA_Int64*)ptrd) = *((const UA_Int64*)ptrs);
  957. break;
  958. case UA_TYPES_GUID:
  959. *((UA_Guid*)ptrd) = *((const UA_Guid*)ptrs);
  960. break;
  961. case UA_TYPES_NODEID:
  962. retval |= UA_NodeId_copy((const UA_NodeId*)ptrs, (UA_NodeId*)ptrd);
  963. break;
  964. case UA_TYPES_EXPANDEDNODEID:
  965. retval |= UA_ExpandedNodeId_copy((const UA_ExpandedNodeId*)ptrs, (UA_ExpandedNodeId*)ptrd);
  966. break;
  967. case UA_TYPES_LOCALIZEDTEXT:
  968. retval |= UA_LocalizedText_copy((const UA_LocalizedText*)ptrs, (UA_LocalizedText*)ptrd);
  969. break;
  970. case UA_TYPES_EXTENSIONOBJECT:
  971. retval |= UA_ExtensionObject_copy((const UA_ExtensionObject*)ptrs, (UA_ExtensionObject*)ptrd);
  972. break;
  973. case UA_TYPES_DATAVALUE:
  974. retval |= UA_DataValue_copy((const UA_DataValue*)ptrs, (UA_DataValue*)ptrd);
  975. break;
  976. case UA_TYPES_VARIANT:
  977. retval |= UA_Variant_copy((const UA_Variant*)ptrs, (UA_Variant*)ptrd);
  978. break;
  979. case UA_TYPES_DIAGNOSTICINFO:
  980. retval |= UA_DiagnosticInfo_copy((const UA_DiagnosticInfo*)ptrs, (UA_DiagnosticInfo*)ptrd);
  981. break;
  982. default:
  983. // QualifiedName, LocalizedText and strings are treated as structures, also
  984. retval |= UA_copy((const void *)ptrs, (void*)ptrd, memberType);
  985. }
  986. ptrs += memberType->memSize;
  987. ptrd += memberType->memSize;
  988. }
  989. if(retval != UA_STATUSCODE_GOOD) {
  990. UA_deleteMembers(dst, dataType);
  991. UA_init(dst, dataType);
  992. }
  993. return retval;
  994. }
  995. void UA_deleteMembers(void *p, const UA_DataType *dataType) {
  996. uintptr_t ptr = (uintptr_t)p;
  997. if(dataType->fixedSize)
  998. return;
  999. UA_Byte membersSize = dataType->membersSize;
  1000. for(size_t i=0;i<membersSize; i++) {
  1001. const UA_DataTypeMember *member = &dataType->members[i];
  1002. const UA_DataType *memberType;
  1003. if(member->namespaceZero)
  1004. memberType = &UA_TYPES[member->memberTypeIndex];
  1005. else
  1006. memberType = &dataType[member->memberTypeIndex - dataType->typeIndex];
  1007. if(member->isArray) {
  1008. ptr += (member->padding >> 3);
  1009. UA_Int32 noElements = *((UA_Int32*)ptr);
  1010. ptr += sizeof(UA_Int32) + (member->padding & 0x07);
  1011. UA_Array_delete(*(void**)ptr, memberType, noElements);
  1012. *(void**)ptr = UA_NULL;
  1013. ptr += sizeof(void*);
  1014. continue;
  1015. }
  1016. ptr += member->padding;
  1017. if(!member->namespaceZero) {
  1018. UA_deleteMembers((void*)ptr, memberType);
  1019. ptr += memberType->memSize;
  1020. continue;
  1021. }
  1022. switch(member->memberTypeIndex) {
  1023. case UA_TYPES_BOOLEAN:
  1024. case UA_TYPES_SBYTE:
  1025. case UA_TYPES_BYTE:
  1026. case UA_TYPES_INT16:
  1027. case UA_TYPES_UINT16:
  1028. case UA_TYPES_INT32:
  1029. case UA_TYPES_UINT32:
  1030. case UA_TYPES_STATUSCODE:
  1031. case UA_TYPES_FLOAT:
  1032. case UA_TYPES_INT64:
  1033. case UA_TYPES_UINT64:
  1034. case UA_TYPES_DOUBLE:
  1035. case UA_TYPES_DATETIME:
  1036. case UA_TYPES_GUID:
  1037. break;
  1038. case UA_TYPES_NODEID:
  1039. UA_NodeId_deleteMembers((UA_NodeId*)ptr);
  1040. break;
  1041. case UA_TYPES_EXPANDEDNODEID:
  1042. UA_ExpandedNodeId_deleteMembers((UA_ExpandedNodeId*)ptr);
  1043. break;
  1044. case UA_TYPES_LOCALIZEDTEXT:
  1045. UA_LocalizedText_deleteMembers((UA_LocalizedText*)ptr);
  1046. break;
  1047. case UA_TYPES_EXTENSIONOBJECT:
  1048. UA_ExtensionObject_deleteMembers((UA_ExtensionObject*)ptr);
  1049. break;
  1050. case UA_TYPES_DATAVALUE:
  1051. UA_DataValue_deleteMembers((UA_DataValue*)ptr);
  1052. break;
  1053. case UA_TYPES_VARIANT:
  1054. UA_Variant_deleteMembers((UA_Variant*)ptr);
  1055. break;
  1056. case UA_TYPES_DIAGNOSTICINFO:
  1057. UA_DiagnosticInfo_deleteMembers((UA_DiagnosticInfo*)ptr);
  1058. break;
  1059. default:
  1060. // QualifiedName, LocalizedText and strings are treated as structures, also
  1061. UA_deleteMembers((void*)ptr, memberType);
  1062. }
  1063. ptr += memberType->memSize;
  1064. }
  1065. }
  1066. void UA_delete(void *p, const UA_DataType *dataType) {
  1067. UA_deleteMembers(p, dataType);
  1068. UA_free(p);
  1069. }
  1070. /******************/
  1071. /* Array Handling */
  1072. /******************/
  1073. void* UA_Array_new(const UA_DataType *dataType, UA_Int32 noElements) {
  1074. if(noElements <= 0)
  1075. return UA_NULL;
  1076. if((UA_Int32)dataType->memSize * noElements < 0 || dataType->memSize * noElements > MAX_ARRAY_SIZE )
  1077. return UA_NULL;
  1078. if(dataType->fixedSize)
  1079. return calloc(noElements, dataType->memSize);
  1080. void *p = malloc(dataType->memSize * (size_t)noElements);
  1081. if(!p)
  1082. return p;
  1083. uintptr_t ptr = (uintptr_t)p;
  1084. for(int i = 0; i<noElements; i++) {
  1085. UA_init((void*)ptr, dataType);
  1086. ptr += dataType->memSize;
  1087. }
  1088. return p;
  1089. }
  1090. UA_StatusCode UA_Array_copy(const void *src, void **dst, const UA_DataType *dataType, UA_Int32 noElements) {
  1091. if(noElements <= 0) {
  1092. *dst = UA_NULL;
  1093. return UA_STATUSCODE_GOOD;
  1094. }
  1095. if(!(*dst = UA_malloc((size_t)noElements * dataType->memSize)))
  1096. return UA_STATUSCODE_BADOUTOFMEMORY;
  1097. if(dataType->fixedSize) {
  1098. memcpy(*dst, src, dataType->memSize * (size_t)noElements);
  1099. return UA_STATUSCODE_GOOD;
  1100. }
  1101. uintptr_t ptrs = (uintptr_t)src;
  1102. uintptr_t ptrd = (uintptr_t)*dst;
  1103. UA_StatusCode retval = UA_STATUSCODE_GOOD;
  1104. for(int i = 0; i < noElements; i++) {
  1105. retval = UA_copy((void*)ptrs, (void*)ptrd, dataType);
  1106. ptrs += dataType->memSize;
  1107. ptrd += dataType->memSize;
  1108. }
  1109. if(retval != UA_STATUSCODE_GOOD)
  1110. UA_Array_delete(*dst, dataType, noElements);
  1111. return retval;
  1112. }
  1113. void UA_Array_delete(void *p, const UA_DataType *dataType, UA_Int32 noElements) {
  1114. if(!dataType->fixedSize) {
  1115. uintptr_t ptr = (uintptr_t)p;
  1116. for(UA_Int32 i = 0; i<noElements; i++) {
  1117. UA_deleteMembers((void*)ptr, dataType);
  1118. ptr += dataType->memSize;
  1119. }
  1120. }
  1121. UA_free(p);
  1122. }