opcua_basictypes.c 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995
  1. /*
  2. * opcua_basictypes.c
  3. *
  4. * Created on: 13.03.2014
  5. * Author: mrt
  6. */
  7. #include "opcua.h"
  8. #include <stdlib.h>
  9. #include <string.h>
  10. UA_Int32 UA_encode(void* const data, UA_Int32 *pos, UA_Int32 type, char* dst) {
  11. return UA_[type].encode(data,pos,dst);
  12. }
  13. UA_Int32 UA_decode(char* const data, UA_Int32* pos, UA_Int32 type, void* dst){
  14. return UA_[type].decode(data,pos,dst);
  15. }
  16. UA_Int32 UA_calcSize(void* const data, UInt32 type) {
  17. return (UA_[type].calcSize)(data);
  18. }
  19. UA_Int32 UA_Array_calcSize(UA_Int32 nElements, UA_Int32 type, void const ** data) {
  20. int length = sizeof(UA_Int32);
  21. int i;
  22. char** ptr = (char**)data;
  23. if (nElements > 0) {
  24. for(i=0; i<nElements;i++) {
  25. length += UA_calcSize((void*)ptr[i],type);
  26. }
  27. }
  28. return length;
  29. }
  30. UA_Int32 UA_Array_encode(void const **src, UA_Int32 noElements, UA_Int32 type, UA_Int32* pos, char * dst) {
  31. UA_Int32 length = sizeof(UA_Int32);
  32. UA_Int32 retVal = 0;
  33. UA_Int32 i = 0;
  34. char** ptr = (char**)src;
  35. UA_Int32_encode(&noElements, pos, dst);
  36. for(i=0; i<noElements; i++) {
  37. retVal |= UA_[type].encode((void*)src[i], pos, dst);
  38. }
  39. return retVal;
  40. }
  41. UA_Int32 UA_Array_decode(char const * src,UA_Int32 noElements, UA_Int32 type, UA_Int32* pos, void const **dst) {
  42. UA_Int32 length = sizeof(UA_Int32);
  43. UA_Int32 retval = 0;
  44. UA_Int32 i = 0;
  45. char** ptr = (char**)src;
  46. for(i=0; i<noElements; i++) {
  47. retval |= UA_[type].decode(src, pos, (void*)dst[i]);
  48. }
  49. return retval;
  50. }
  51. UA_Int32 UA_free(void * ptr){
  52. free(ptr);
  53. return UA_SUCCESS;
  54. }
  55. UA_Int32 UA_alloc(void ** ptr, int size){
  56. *ptr = malloc(size);
  57. if(*ptr == UA_NULL) return UA_ERR_NO_MEMORY;
  58. return UA_SUCCESS;
  59. }
  60. UA_Int32 UA_memcpy(void * dst, void const * src, int size){
  61. memcpy(dst, src, size);
  62. return UA_SUCCESS;
  63. }
  64. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_Boolean)
  65. UA_Int32 UA_Boolean_encode(UA_Boolean const * src, UA_Int32* pos, char * dst) {
  66. UA_Boolean tmpBool = ((*src > 0) ? UA_TRUE : UA_FALSE);
  67. memcpy(&(dst[(*pos)++]), &tmpBool, sizeof(UA_Boolean));
  68. return UA_SUCCESS;
  69. }
  70. UA_Int32 UA_Boolean_decode(char const * src, UA_Int32* pos, UA_Boolean * dst) {
  71. *dst = ((UA_Boolean) (src[(*pos)++]) > 0) ? UA_TRUE : UA_FALSE;
  72. return UA_SUCCESS;
  73. }
  74. UA_TYPE_METHOD_DELETE_FREE(UA_Boolean)
  75. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_Boolean)
  76. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_Byte)
  77. UA_Int32 UA_Byte_encode(UA_Byte const * src, UA_Int32* pos, char * dst) {
  78. *dst = src[(*pos)++];
  79. return UA_SUCCESS;
  80. }
  81. UA_Int32 UA_Byte_decode(char const * src, UA_Int32* pos, UA_Byte * dst) {
  82. memcpy(&(dst[(*pos)++]), src, sizeof(UA_Byte));
  83. return UA_SUCCESS;
  84. }
  85. UA_TYPE_METHOD_DELETE_FREE(UA_Byte)
  86. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_Byte)
  87. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_SByte)
  88. UA_Int32 UA_SByte_encode(UA_SByte const * src, UA_Int32* pos, char * dst) {
  89. dst[(*pos)++] = *src;
  90. return UA_SUCCESS;
  91. }
  92. UA_Int32 UA_SByte_decode(char const * src, UA_Int32* pos, UA_SByte * dst) {
  93. *dst = src[(*pos)++];
  94. return 1;
  95. }
  96. UA_TYPE_METHOD_DELETE_FREE(UA_SByte)
  97. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_SByte)
  98. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_UInt16)
  99. UA_Int32 UA_UInt16_encode(UA_UInt16 const *src, UA_Int32* pos, char * dst) {
  100. memcpy(&(dst[*pos]), src, sizeof(UA_UInt16));
  101. *pos += sizeof(UA_UInt16);
  102. return UA_SUCCESS;
  103. }
  104. UA_Int32 UA_UInt16_decode(char const * src, UA_Int32* pos, UA_UInt16* dst) {
  105. Byte t1 = src[(*pos)++];
  106. UInt16 t2 = (UInt16) (src[(*pos)++] << 8);
  107. *dst = t1 + t2;
  108. return UA_SUCCESS;
  109. }
  110. UA_TYPE_METHOD_DELETE_FREE(UA_UInt16)
  111. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_UInt16)
  112. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_Int16)
  113. UA_Int32 UA_Int16_encode(UA_Int16 const * src, UA_Int32* pos, char* dst) {
  114. memcpy(&(dst[*pos]), src, sizeof(UA_Int16));
  115. *pos += sizeof(UA_Int16);
  116. return UA_SUCCESS;
  117. }
  118. UA_Int32 UA_Int16_decode(char const * src, UA_Int32* pos, UA_Int16 *dst) {
  119. Int16 t1 = (Int16) (((SByte) (src[(*pos)++]) & 0xFF));
  120. Int16 t2 = (Int16) (((SByte) (src[(*pos)++]) & 0xFF) << 8);
  121. *dst = t1 + t2;
  122. return UA_SUCCESS;
  123. }
  124. UA_TYPE_METHOD_DELETE_FREE(UA_Int16)
  125. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_Int16)
  126. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_Int32)
  127. UA_Int32 UA_Int32_encode(UA_Int32 const * src, UA_Int32* pos, char *dst) {
  128. memcpy(&(dst[*pos]), src, sizeof(UA_Int32));
  129. *pos += sizeof(UA_Int32);
  130. return UA_SUCCESS;
  131. }
  132. UA_Int32 UA_Int32_decode(char const * src, UA_Int32* pos, UA_Int32* dst) {
  133. UA_Int32 t1 = (UA_Int32) (((SByte) (src[(*pos)++]) & 0xFF));
  134. UA_Int32 t2 = (UA_Int32) (((SByte) (src[(*pos)++]) & 0xFF) << 8);
  135. UA_Int32 t3 = (UA_Int32) (((SByte) (src[(*pos)++]) & 0xFF) << 16);
  136. UA_Int32 t4 = (UA_Int32) (((SByte) (src[(*pos)++]) & 0xFF) << 24);
  137. *dst = t1 + t2 + t3 + t4;
  138. return UA_SUCCESS;
  139. }
  140. UA_TYPE_METHOD_DELETE_FREE(UA_Int32)
  141. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_Int32)
  142. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_UInt32)
  143. UA_Int32 UA_UInt32_encode(UA_UInt32 const * src, UA_Int32* pos, char *dst) {
  144. memcpy(&(dst[*pos]), src, sizeof(UA_UInt32));
  145. *pos += sizeof(UA_UInt32);
  146. return UA_SUCCESS;
  147. }
  148. UA_Int32 UA_UInt32_decode(char const * src, UA_Int32* pos, UA_UInt32 *dst) {
  149. UInt32 t1 = (UInt32) src[(*pos)++];
  150. UInt32 t2 = (UInt32) src[(*pos)++] << 8;
  151. UInt32 t3 = (UInt32) src[(*pos)++] << 16;
  152. UInt32 t4 = (UInt32) src[(*pos)++] << 24;
  153. *dst = t1 + t2 + t3 + t4;
  154. return UA_SUCCESS;
  155. }
  156. UA_TYPE_METHOD_DELETE_FREE(UA_UInt32)
  157. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_UInt32)
  158. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_Int64)
  159. UA_Int32 UA_Int64_encode(UA_Int64 const * src, UA_Int32* pos, char *dst) {
  160. memcpy(&(dst[*pos]), src, sizeof(UA_Int64));
  161. *pos += sizeof(UA_Int64);
  162. return UA_SUCCESS;
  163. }
  164. UA_Int32 UA_Int64_decode(char const * src, UA_Int32* pos, UA_Int64* dst) {
  165. Int64 t1 = (Int64) src[(*pos)++];
  166. Int64 t2 = (Int64) src[(*pos)++] << 8;
  167. Int64 t3 = (Int64) src[(*pos)++] << 16;
  168. Int64 t4 = (Int64) src[(*pos)++] << 24;
  169. Int64 t5 = (Int64) src[(*pos)++] << 32;
  170. Int64 t6 = (Int64) src[(*pos)++] << 40;
  171. Int64 t7 = (Int64) src[(*pos)++] << 48;
  172. Int64 t8 = (Int64) src[(*pos)++] << 56;
  173. *dst = t1 + t2 + t3 + t4 + t5 + t6 + t7 + t8;
  174. return UA_SUCCESS;
  175. }
  176. UA_TYPE_METHOD_DELETE_FREE(UA_Int64)
  177. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_Int64)
  178. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_UInt64)
  179. UA_Int32 UA_UInt64_encode(UA_UInt64 const * src , UA_Int32* pos, char * dst) {
  180. memcpy(&(dst[*pos]), src, sizeof(UA_UInt64));
  181. *pos += sizeof(UInt64);
  182. return UA_SUCCESS;
  183. }
  184. UA_Int32 UA_UInt64_decode(char const * src, UA_Int32* pos, UA_UInt64* dst) {
  185. UInt64 t1 = (UInt64) src[(*pos)++];
  186. UInt64 t2 = (UInt64) src[(*pos)++] << 8;
  187. UInt64 t3 = (UInt64) src[(*pos)++] << 16;
  188. UInt64 t4 = (UInt64) src[(*pos)++] << 24;
  189. UInt64 t5 = (UInt64) src[(*pos)++] << 32;
  190. UInt64 t6 = (UInt64) src[(*pos)++] << 40;
  191. UInt64 t7 = (UInt64) src[(*pos)++] << 48;
  192. UInt64 t8 = (UInt64) src[(*pos)++] << 56;
  193. *dst = t1 + t2 + t3 + t4 + t5 + t6 + t7 + t8;
  194. return UA_SUCCESS;
  195. }
  196. UA_TYPE_METHOD_DELETE_FREE(UA_UInt64)
  197. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_UInt64)
  198. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_Float)
  199. UA_Int32 UA_Float_decode(char const * src, UA_Int32* pos, UA_Float* dst) {
  200. // TODO: not yet implemented
  201. memcpy(dst, &(src[*pos]), sizeof(UA_Float));
  202. *pos += sizeof(UA_Float);
  203. return UA_SUCCESS;
  204. }
  205. UA_Int32 UA_Float_encode(UA_Float const * src, UA_Int32* pos, char *dst) {
  206. // TODO: not yet implemented
  207. memcpy(&(dst[*pos]), src, sizeof(UA_Float));
  208. *pos += sizeof(UA_Float);
  209. return UA_SUCCESS;
  210. }
  211. UA_TYPE_METHOD_DELETE_FREE(UA_Float)
  212. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_Float)
  213. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_Double)
  214. UA_Int32 UA_Double_decode(char const * src, UA_Int32* pos, UA_Double * dst) {
  215. // TODO: not yet implemented
  216. Double tmpDouble;
  217. tmpDouble = (Double) (src[*pos]);
  218. *pos += sizeof(UA_Double);
  219. *dst = tmpDouble;
  220. return UA_SUCCESS;
  221. }
  222. UA_Int32 UA_Double_encode(UA_Double const * src, UA_Int32 *pos, char * dst) {
  223. // TODO: not yet implemented
  224. memcpy(&(dst[*pos]), src, sizeof(UA_Double));
  225. *pos *= sizeof(UA_Double);
  226. return UA_SUCCESS;
  227. }
  228. UA_TYPE_METHOD_DELETE_FREE(UA_Double)
  229. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_Double)
  230. UA_Int32 UA_String_calcSize(UA_String const * string) {
  231. if (string == UA_NULL) {
  232. // internal size for UA_memalloc
  233. return sizeof(UA_String);
  234. } else {
  235. // binary encoding size
  236. if (string->length > 0) {
  237. return sizeof(UA_Int32) + string->length * sizeof(UA_Byte);
  238. } else {
  239. return sizeof(UA_Int32);
  240. }
  241. }
  242. }
  243. UA_Int32 UA_String_encode(UA_String const * src, UA_Int32* pos, char *dst) {
  244. UA_Int32_encode(&(src->length),pos,dst);
  245. if (src->length > 0) {
  246. UA_memcpy((void*)&(dst[*pos]), src->data, src->length);
  247. *pos += src->length;
  248. }
  249. return UA_SUCCESS;
  250. }
  251. UA_Int32 UA_String_decode(char const * src, UA_Int32* pos, UA_String * dst) {
  252. UA_Int32 retval = UA_SUCCESS;
  253. retval |= UA_Int32_decode(src,pos,&(dst->length));
  254. if (dst->length > 0) {
  255. retval |= UA_alloc((void*)&(dst->data),dst->length);
  256. retval |= UA_memcpy((void*)&(src[*pos]),dst->data,dst->length);
  257. *pos += dst->length;
  258. } else {
  259. dst->data = UA_NULL;
  260. }
  261. return retval;
  262. }
  263. UA_TYPE_METHOD_DELETE_STRUCT(UA_String)
  264. UA_Int32 UA_String_deleteMembers(UA_String* p) { return UA_free(p->data); };
  265. UA_Int32 UA_String_copy(UA_String const * src, UA_String* dst) {
  266. UA_Int32 retval = UA_SUCCESS;
  267. dst->length = src->length;
  268. dst->data = UA_NULL;
  269. if (src->length > 0) {
  270. retval |= UA_alloc((void*)&(dst->data), src->length);
  271. if (retval == UA_SUCCESS) {
  272. retval |= UA_memcpy((void*)dst->data, src->data, src->length);
  273. }
  274. }
  275. return retval;
  276. }
  277. UA_String UA_String_null = { -1, UA_NULL };
  278. UA_Byte UA_Byte_securityPoliceNoneData[] = "http://opcfoundation.org/UA/SecurityPolicy#None";
  279. UA_String UA_String_securityPoliceNone = { sizeof(UA_Byte_securityPoliceNoneData), UA_Byte_securityPoliceNoneData };
  280. // TODO: should we really handle UA_String and UA_ByteString the same way?
  281. UA_TYPE_METHOD_CALCSIZE_AS(UA_ByteString, UA_String)
  282. UA_TYPE_METHOD_ENCODE_AS(UA_ByteString, UA_String)
  283. UA_TYPE_METHOD_DECODE_AS(UA_ByteString, UA_String)
  284. UA_TYPE_METHOD_DELETE_AS(UA_ByteString, UA_String)
  285. UA_TYPE_METHOD_DELETEMEMBERS_AS(UA_ByteString, UA_String)
  286. UA_Int32 UA_Guid_calcSize(UA_Guid const * p) {
  287. if (p == UA_NULL) {
  288. return sizeof(UA_Guid);
  289. } else {
  290. return 0
  291. + sizeof(p->data1)
  292. + sizeof(p->data2)
  293. + sizeof(p->data3)
  294. + UA_ByteString_calcSize(&(p->data4))
  295. ;
  296. }
  297. }
  298. UA_Int32 UA_Guid_encode(UA_Guid const *src, UA_Int32* pos, char *dst) {
  299. UA_Int32 retval = UA_SUCCESS;
  300. retval |= UA_UInt32_encode(&(src->data1), pos, dst);
  301. retval |= UA_UInt16_encode(&(src->data2), pos, dst);
  302. retval |= UA_UInt16_encode(&(src->data3), pos, dst);
  303. retval |= UA_ByteString_encode(&(src->data4), pos, dst);
  304. return UA_SUCCESS;
  305. }
  306. UA_Int32 UA_Guid_decode(char const * src, UA_Int32* pos, UA_Guid *dst) {
  307. UA_Int32 retval = UA_SUCCESS;
  308. retval |= UA_Int32_decode(src,pos,&(dst->data1));
  309. retval |= UA_Int16_decode(src,pos,&(dst->data2));
  310. retval |= UA_Int16_decode(src,pos,&(dst->data3));
  311. retval |= UA_ByteString_decode(src,pos,&(dst->data4));
  312. return retval;
  313. }
  314. UA_TYPE_METHOD_DELETE_STRUCT(UA_Guid)
  315. UA_Int32 UA_Guid_deleteMembers(UA_Guid* p) { return UA_ByteString_delete(&(p->data4)); };
  316. UA_Int32 UA_LocalizedText_calcSize(UA_LocalizedText const * p) {
  317. UA_Int32 length = 0;
  318. if (p==UA_NULL) {
  319. // size for UA_memalloc
  320. length = sizeof(UA_LocalizedText);
  321. } else {
  322. // size for binary encoding
  323. length += p->encodingMask;
  324. if (p->encodingMask & 0x01) {
  325. length += UA_String_calcSize(&(p->locale));
  326. }
  327. if (p->encodingMask & 0x02) {
  328. length += UA_String_calcSize(&(p->text));
  329. }
  330. }
  331. return length;
  332. }
  333. UA_Int32 UA_LocalizedText_encode(UA_LocalizedText const * src, UA_Int32 *pos,
  334. char * dst) {
  335. UA_Int32 retval = UA_SUCCESS;
  336. retval |= UA_Byte_encode(&(src->encodingMask),pos,dst);
  337. if (src->encodingMask & 0x01) {
  338. UA_String_encode(&(src->locale),pos,dst);
  339. }
  340. if (src->encodingMask & 0x02) {
  341. UA_String_encode(&(src->text),pos,dst);
  342. }
  343. return retval;
  344. }
  345. UA_Int32 UA_LocalizedText_decode(char const * src, UA_Int32 *pos,
  346. UA_LocalizedText *dst) {
  347. UA_Int32 retval = UA_SUCCESS;
  348. retval |= UA_String_copy(&UA_String_null,&(dst->locale));
  349. retval |= UA_String_copy(&UA_String_null,&(dst->text));
  350. retval |= UA_Byte_decode(src,pos,&(dst->encodingMask));
  351. if (dst->encodingMask & 0x01) {
  352. retval |= UA_String_decode(src,pos,&(dst->locale));
  353. }
  354. if (dst->encodingMask & 0x02) {
  355. retval |= UA_String_decode(src,pos,&(dst->text));
  356. }
  357. return retval;
  358. }
  359. UA_TYPE_METHOD_DELETE_STRUCT(UA_LocalizedText)
  360. UA_Int32 UA_LocalizedText_deleteMembers(UA_LocalizedText* p) {
  361. return UA_SUCCESS
  362. || UA_String_deleteMembers(&(p->locale))
  363. || UA_String_deleteMembers(&(p->text))
  364. ;
  365. };
  366. /* Serialization of UA_NodeID is specified in 62541-6, §5.2.2.9 */
  367. UA_Int32 UA_NodeId_calcSize(UA_NodeId const *p) {
  368. UA_Int32 length = 0;
  369. if (p == UA_NULL) {
  370. length = sizeof(UA_NodeId);
  371. } else {
  372. switch (p->encodingByte) {
  373. case UA_NodeIdType_TwoByte:
  374. length += 2 * sizeof(UA_Byte);
  375. break;
  376. case UA_NodeIdType_FourByte:
  377. length += 4 * sizeof(UA_Byte);
  378. break;
  379. case UA_NodeIdType_Numeric:
  380. length += sizeof(UA_Byte) + sizeof(UA_UInt16) + sizeof(UInt32);
  381. break;
  382. case UA_NodeIdType_String:
  383. length += sizeof(UA_Byte) + sizeof(UA_UInt16) + UA_String_calcSize(&(p->identifier.string));
  384. break;
  385. case UA_NodeIdType_Guid:
  386. length += sizeof(UA_Byte) + sizeof(UA_UInt16) + UA_Guid_calcSize(&(p->identifier.guid));
  387. break;
  388. case UA_NodeIdType_ByteString:
  389. length += sizeof(UA_Byte) + sizeof(UA_UInt16) + UA_ByteString_calcSize(&(p->identifier.byteString));
  390. break;
  391. default:
  392. break;
  393. }
  394. }
  395. return length;
  396. }
  397. UA_Int32 UA_NodeId_encode(UA_NodeId const * src, UA_Int32* pos, char *dst) {
  398. // temporary variables for endian-save code
  399. UA_Byte srcByte;
  400. UA_UInt16 srcUInt16;
  401. int retval = UA_SUCCESS;
  402. retval |= UA_Byte_encode(&(src->encodingByte),pos,dst);
  403. switch (src->encodingByte) {
  404. case UA_NodeIdType_TwoByte:
  405. srcByte = src->identifier.numeric;
  406. retval |= UA_Byte_encode(&srcByte,pos,dst);
  407. break;
  408. case UA_NodeIdType_FourByte:
  409. srcByte = src->namespace;
  410. srcUInt16 = src->identifier.numeric;
  411. retval |= UA_Byte_encode(&srcByte,pos,dst);
  412. retval |= UA_UInt16_encode(&srcUInt16,pos,dst);
  413. break;
  414. case UA_NodeIdType_Numeric:
  415. retval |= UA_UInt16_encode(&(src->namespace), pos, dst);
  416. retval |= UA_UInt32_encode(&(src->identifier.numeric), pos, dst);
  417. break;
  418. case UA_NodeIdType_String:
  419. retval |= UA_UInt16_encode(&(src->namespace), pos, dst);
  420. retval |= UA_String_encode(&(src->identifier.string), pos, dst);
  421. break;
  422. case UA_NodeIdType_Guid:
  423. retval |= UA_UInt16_encode(&(src->namespace), pos, dst);
  424. retval |= UA_Guid_encode(&(src->identifier.guid), pos, dst);
  425. break;
  426. case UA_NodeIdType_ByteString:
  427. retval |= UA_UInt16_encode(&(src->namespace), pos, dst);
  428. retval |= UA_ByteString_encode(&(src->identifier.byteString), pos, dst);
  429. break;
  430. }
  431. return retval;
  432. }
  433. UA_Int32 UA_NodeId_decode(char const * src, UA_Int32* pos, UA_NodeId *dst) {
  434. int retval = UA_SUCCESS;
  435. // temporary variables to overcome decoder's non-endian-saveness for datatypes
  436. Byte dstByte;
  437. UInt16 dstUInt16;
  438. retval |= UA_Byte_decode(src,pos,&(dst->encodingByte));
  439. switch (dst->encodingByte) {
  440. case UA_NodeIdType_TwoByte: // Table 7
  441. retval |=UA_Byte_decode(src, pos, &dstByte);
  442. dst->identifier.numeric = dstByte;
  443. dst->namespace = 0; // default namespace
  444. break;
  445. case UA_NodeIdType_FourByte: // Table 8
  446. retval |=UA_Byte_decode(src, pos, &dstByte);
  447. dst->namespace= dstByte;
  448. retval |=UA_UInt16_decode(src, pos, &dstUInt16);
  449. dst->identifier.numeric = dstUInt16;
  450. break;
  451. case UA_NodeIdType_Numeric: // Table 6, first entry
  452. retval |=UA_Int16_decode(src,pos,&(dst->namespace));
  453. retval |=UA_Int32_decode(src,pos,&(dst->identifier.numeric));
  454. break;
  455. case UA_NodeIdType_String: // Table 6, second entry
  456. retval |=UA_Int16_decode(src,pos,&(dst->namespace));
  457. retval |=UA_String_decode(src,pos,&(dst->identifier.string));
  458. break;
  459. case UA_NodeIdType_Guid: // Table 6, third entry
  460. retval |=UA_Int16_decode(src,pos,&(dst->namespace));
  461. retval |=UA_Guid_decode(src,pos,&(dst->identifier.guid));
  462. break;
  463. case UA_NodeIdType_ByteString: // Table 6, "OPAQUE"
  464. retval |=UA_Int16_decode(src,pos,&(dst->namespace));
  465. retval |=UA_ByteString_decode(src,pos,&(dst->identifier.byteString));
  466. break;
  467. }
  468. return retval;
  469. }
  470. UA_TYPE_METHOD_DELETE_STRUCT(UA_NodeId)
  471. UA_Int32 UA_NodeId_deleteMembers(UA_NodeId* p) {
  472. int retval = UA_SUCCESS;
  473. switch (p->encodingByte) {
  474. case UA_NodeIdType_TwoByte:
  475. case UA_NodeIdType_FourByte:
  476. case UA_NodeIdType_Numeric:
  477. // nothing to do
  478. break;
  479. case UA_NodeIdType_String: // Table 6, second entry
  480. retval |= UA_String_deleteMembers(&(p->identifier.string));
  481. break;
  482. case UA_NodeIdType_Guid: // Table 6, third entry
  483. retval |= UA_Guid_deleteMembers(&(p->identifier.guid));
  484. break;
  485. case UA_NodeIdType_ByteString: // Table 6, "OPAQUE"
  486. retval |= UA_ByteString_deleteMembers(&(p->identifier.byteString));
  487. break;
  488. }
  489. return retval;
  490. }
  491. //FIXME: Sten Where do these two flags come from?
  492. #define NIEVT_NAMESPACE_URI_FLAG 0x80 //Is only for ExpandedNodeId required
  493. #define NIEVT_SERVERINDEX_FLAG 0x40 //Is only for ExpandedNodeId required
  494. UA_Int32 UA_ExpandedNodeId_calcSize(UA_ExpandedNodeId const * p) {
  495. UA_Int32 length = 0;
  496. if (p == UA_NULL) {
  497. length = sizeof(UA_ExpandedNodeId);
  498. } else {
  499. length = UA_NodeId_calcSize(&(p->nodeId));
  500. if (p->nodeId.encodingByte & NIEVT_NAMESPACE_URI_FLAG) {
  501. length += UA_String_calcSize(&(p->namespaceUri)); //p->namespaceUri
  502. }
  503. if (p->nodeId.encodingByte & NIEVT_SERVERINDEX_FLAG) {
  504. length += sizeof(UA_UInt32); //p->serverIndex
  505. }
  506. }
  507. return length;
  508. }
  509. UA_Int32 UA_ExpandedNodeId_encode(UA_ExpandedNodeId const * src, UA_Int32* pos, char *dst) {
  510. UInt32 retval = UA_SUCCESS;
  511. retval |= UA_NodeId_encode(&(src->nodeId),pos,dst);
  512. if (src->nodeId.encodingByte & NIEVT_NAMESPACE_URI_FLAG) {
  513. retval |= UA_String_encode(&(src->namespaceUri),pos,dst);
  514. }
  515. if (src->nodeId.encodingByte & NIEVT_SERVERINDEX_FLAG) {
  516. retval |= UA_UInt32_encode(&(src->serverIndex),pos,dst);
  517. }
  518. return retval;
  519. }
  520. UA_Int32 UA_ExpandedNodeId_decode(char const * src, UA_Int32* pos,
  521. UA_ExpandedNodeId *dst) {
  522. UInt32 retval = UA_SUCCESS;
  523. retval |= UA_NodeId_decode(src,pos,&(dst->nodeId));
  524. if (dst->nodeId.encodingByte & NIEVT_NAMESPACE_URI_FLAG) {
  525. dst->nodeId.namespace = 0;
  526. retval |= UA_String_decode(src,pos,&(dst->namespaceUri));
  527. } else {
  528. retval |= UA_String_copy(&UA_String_null, &(dst->namespaceUri));
  529. }
  530. if (dst->nodeId.encodingByte & NIEVT_SERVERINDEX_FLAG) {
  531. retval |= UA_UInt32_decode(src,pos,&(dst->serverIndex));
  532. }
  533. return retval;
  534. }
  535. UA_TYPE_METHOD_DELETE_STRUCT(UA_ExpandedNodeId)
  536. UA_Int32 UA_ExpandedNodeId_deleteMembers(UA_ExpandedNodeId* p) {
  537. UA_Int32 retval = UA_SUCCESS;
  538. retval |= UA_NodeId_deleteMembers(&(p->nodeId));
  539. retval |= UA_String_deleteMembers(&(p->namespaceUri));
  540. return retval;
  541. }
  542. UA_Int32 UA_ExtensionObject_calcSize(UA_ExtensionObject const * p) {
  543. UA_Int32 length = 0;
  544. if (p == UA_NULL) {
  545. length = sizeof(UA_ExtensionObject);
  546. } else {
  547. length += UA_NodeId_calcSize(&(p->typeId));
  548. length += sizeof(Byte); //p->encoding
  549. switch (p->encoding) {
  550. case 0x00:
  551. length += sizeof(UA_Int32); //p->body.length
  552. break;
  553. case 0x01:
  554. length += UA_ByteString_calcSize(&(p->body));
  555. break;
  556. case 0x02:
  557. length += UA_ByteString_calcSize(&(p->body));
  558. break;
  559. }
  560. }
  561. return length;
  562. }
  563. UA_Int32 UA_ExtensionObject_encode(UA_ExtensionObject const *src, UA_Int32* pos, char * dst) {
  564. UA_Int32 retval = UA_SUCCESS;
  565. retval |= UA_NodeId_encode(&(src->typeId),pos,dst);
  566. retval |= UA_Byte_encode(&(src->encoding),pos,dst);
  567. switch (src->encoding) {
  568. case UA_ExtensionObject_NoBodyIsEncoded:
  569. break;
  570. case UA_ExtensionObject_BodyIsByteString:
  571. case UA_ExtensionObject_BodyIsXml:
  572. retval |= UA_ByteString_encode(&(src->body),pos,dst);
  573. break;
  574. }
  575. return retval;
  576. }
  577. UA_Int32 UA_ExtensionObject_decode(char const * src, UA_Int32 *pos,
  578. UA_ExtensionObject *dst) {
  579. UA_Int32 retval = UA_SUCCESS;
  580. retval |= UA_NodeId_decode(src,pos,&(dst->typeId));
  581. retval |= UA_Byte_decode(src,pos,&(dst->encoding));
  582. retval |= UA_String_copy(&UA_String_null, (UA_String*) &(dst->body));
  583. switch (dst->encoding) {
  584. case UA_ExtensionObject_NoBodyIsEncoded:
  585. break;
  586. case UA_ExtensionObject_BodyIsByteString:
  587. case UA_ExtensionObject_BodyIsXml:
  588. retval |= UA_ByteString_decode(src,pos,&(dst->body));
  589. break;
  590. }
  591. return retval;
  592. }
  593. UA_TYPE_METHOD_DELETE_STRUCT(UA_ExtensionObject)
  594. UA_Int32 UA_ExtensionObject_deleteMembers(UA_ExtensionObject *p) {
  595. UA_Int32 retval = UA_SUCCESS;
  596. retval |= UA_NodeId_deleteMembers(&(p->typeId));
  597. retval |= UA_ByteString_deleteMembers(&(p->body));
  598. return retval;
  599. }
  600. // TODO: UA_DataValue_encode
  601. // TODO: UA_DataValue_decode
  602. // TODO: UA_DataValue_delete
  603. // TODO: UA_DataValue_deleteMembers
  604. /** DiagnosticInfo - Part: 4, Chapter: 7.9, Page: 116 */
  605. UA_Int32 UA_DiagnosticInfo_decode(char const * src, UA_Int32 *pos, UA_DiagnosticInfo *dst) {
  606. UA_Int32 retval = UA_SUCCESS;
  607. int i;
  608. retval |= UA_Byte_decode(src, pos, &(dst->encodingMask));
  609. for (i = 0; i < 7; i++) {
  610. switch ( (0x01 << i) & dst->encodingMask) {
  611. case UA_DiagnosticInfoEncodingMaskType_SymbolicId:
  612. retval |= UA_Int32_decode(src, pos, &(dst->symbolicId));
  613. break;
  614. case UA_DiagnosticInfoEncodingMaskType_Namespace:
  615. retval |= UA_Int32_decode(src, pos, &(dst->namespaceUri));
  616. break;
  617. case UA_DiagnosticInfoEncodingMaskType_LocalizedText:
  618. retval |= UA_Int32_decode(src, pos, &(dst->localizedText));
  619. break;
  620. case UA_DiagnosticInfoEncodingMaskType_Locale:
  621. retval |= UA_Int32_decode(src, pos, &(dst->locale));
  622. break;
  623. case UA_DiagnosticInfoEncodingMaskType_AdditionalInfo:
  624. retval |= UA_String_decode(src, pos, &(dst->additionalInfo));
  625. break;
  626. case UA_DiagnosticInfoEncodingMaskType_InnerStatusCode:
  627. retval |= UA_StatusCode_decode(src, pos, &(dst->innerStatusCode));
  628. break;
  629. case UA_DiagnosticInfoEncodingMaskType_InnerDiagnosticInfo:
  630. // innerDiagnosticInfo is a pointer to struct, therefore allocate
  631. retval |= UA_alloc((void **) &(dst->innerDiagnosticInfo),UA_DiagnosticInfo_calcSize(UA_NULL));
  632. retval |= UA_DiagnosticInfo_decode(src, pos, dst->innerDiagnosticInfo);
  633. break;
  634. }
  635. }
  636. return retval;
  637. }
  638. UA_Int32 UA_DiagnosticInfo_encode(UA_DiagnosticInfo const *src, UA_Int32 *pos, char *dst) {
  639. UA_Int32 retval = UA_SUCCESS;
  640. Byte mask;
  641. int i;
  642. UA_Byte_encode(&(src->encodingMask), pos, dst);
  643. for (i = 0; i < 7; i++) {
  644. switch ( (0x01 << i) & src->encodingMask) {
  645. case UA_DiagnosticInfoEncodingMaskType_SymbolicId:
  646. retval |= UA_Int32_encode(&(src->symbolicId), pos, dst);
  647. break;
  648. case UA_DiagnosticInfoEncodingMaskType_Namespace:
  649. retval |= UA_Int32_encode( &(src->namespaceUri), pos, dst);
  650. break;
  651. case UA_DiagnosticInfoEncodingMaskType_LocalizedText:
  652. retval |= UA_Int32_encode(&(src->localizedText), pos, dst);
  653. break;
  654. case UA_DiagnosticInfoEncodingMaskType_Locale:
  655. retval |= UA_Int32_encode(&(src->locale), pos, dst);
  656. break;
  657. case UA_DiagnosticInfoEncodingMaskType_AdditionalInfo:
  658. retval |= UA_String_encode(&(src->additionalInfo), pos, dst);
  659. break;
  660. case UA_DiagnosticInfoEncodingMaskType_InnerStatusCode:
  661. retval |= UA_StatusCode_encode(&(src->innerStatusCode), pos, dst);
  662. break;
  663. case UA_DiagnosticInfoEncodingMaskType_InnerDiagnosticInfo:
  664. retval |= UA_DiagnosticInfo_encode(src->innerDiagnosticInfo, pos, dst);
  665. break;
  666. }
  667. }
  668. return retval;
  669. }
  670. UA_Int32 UA_DiagnosticInfo_calcSize(UA_DiagnosticInfo const * ptr) {
  671. UA_Int32 length = 0;
  672. if (ptr == UA_NULL) {
  673. length = sizeof(UA_DiagnosticInfo);
  674. } else {
  675. Byte mask;
  676. length += sizeof(Byte); // EncodingMask
  677. for (mask = 0x01; mask <= 0x40; mask *= 2) {
  678. switch (mask & (ptr->encodingMask)) {
  679. case UA_DiagnosticInfoEncodingMaskType_SymbolicId:
  680. // puts("diagnosticInfo symbolic id");
  681. length += sizeof(UA_Int32);
  682. break;
  683. case UA_DiagnosticInfoEncodingMaskType_Namespace:
  684. length += sizeof(UA_Int32);
  685. break;
  686. case UA_DiagnosticInfoEncodingMaskType_LocalizedText:
  687. length += sizeof(UA_Int32);
  688. break;
  689. case UA_DiagnosticInfoEncodingMaskType_Locale:
  690. length += sizeof(UA_Int32);
  691. break;
  692. case UA_DiagnosticInfoEncodingMaskType_AdditionalInfo:
  693. length += UA_String_calcSize(&(ptr->additionalInfo));
  694. break;
  695. case UA_DiagnosticInfoEncodingMaskType_InnerStatusCode:
  696. length += sizeof(UA_StatusCode);
  697. break;
  698. case UA_DiagnosticInfoEncodingMaskType_InnerDiagnosticInfo:
  699. length += UA_DiagnosticInfo_calcSize(ptr->innerDiagnosticInfo);
  700. break;
  701. }
  702. }
  703. }
  704. return length;
  705. }
  706. UA_TYPE_METHOD_DELETE_STRUCT(UA_DiagnosticInfo)
  707. UA_Int32 UA_DiagnosticInfo_deleteMembers(UA_DiagnosticInfo *p) {
  708. UA_Int32 retval = UA_SUCCESS;
  709. if (p->encodingMask & UA_DiagnosticInfoEncodingMaskType_InnerDiagnosticInfo) {
  710. retval |= UA_DiagnosticInfo_deleteMembers(p->innerDiagnosticInfo);
  711. retval |= UA_free(p->innerDiagnosticInfo);
  712. }
  713. return retval;
  714. }
  715. UA_TYPE_METHOD_CALCSIZE_SIZEOF(UA_DateTime)
  716. UA_TYPE_METHOD_ENCODE_AS(UA_DateTime,UA_Int64)
  717. UA_TYPE_METHOD_DECODE_AS(UA_DateTime,UA_Int64)
  718. UA_TYPE_METHOD_DELETE_FREE(UA_DateTime)
  719. UA_TYPE_METHOD_DELETEMEMBERS_NOACTION(UA_DateTime)
  720. UA_TYPE_METHOD_CALCSIZE_AS(UA_XmlElement, UA_ByteString)
  721. UA_TYPE_METHOD_ENCODE_AS(UA_XmlElement, UA_ByteString)
  722. UA_TYPE_METHOD_DECODE_AS(UA_XmlElement, UA_ByteString)
  723. UA_TYPE_METHOD_DELETE_AS(UA_XmlElement, UA_ByteString)
  724. UA_TYPE_METHOD_DELETEMEMBERS_AS(UA_XmlElement, UA_ByteString)
  725. /** IntegerId - Part: 4, Chapter: 7.13, Page: 118 */
  726. UA_TYPE_METHOD_CALCSIZE_AS(UA_IntegerId, UA_Int32)
  727. UA_TYPE_METHOD_ENCODE_AS(UA_IntegerId, UA_Int32)
  728. UA_TYPE_METHOD_DECODE_AS(UA_IntegerId, UA_Int32)
  729. UA_TYPE_METHOD_DELETE_AS(UA_IntegerId, UA_Int32)
  730. UA_TYPE_METHOD_DELETEMEMBERS_AS(UA_IntegerId, UA_Int32)
  731. UA_TYPE_METHOD_CALCSIZE_AS(UA_StatusCode, UA_UInt32)
  732. UA_TYPE_METHOD_ENCODE_AS(UA_StatusCode, UA_UInt32)
  733. UA_TYPE_METHOD_DECODE_AS(UA_StatusCode, UA_UInt32)
  734. UA_TYPE_METHOD_DELETE_AS(UA_StatusCode, UA_UInt32)
  735. UA_TYPE_METHOD_DELETEMEMBERS_AS(UA_StatusCode, UA_UInt32)
  736. UA_Int32 UA_QualifiedName_calcSize(UA_QualifiedName const * p) {
  737. UA_Int32 length = 0;
  738. length += sizeof(UInt16); //qualifiedName->namespaceIndex
  739. length += sizeof(UInt16); //qualifiedName->reserved
  740. length += UA_String_calcSize(&(p->name)); //qualifiedName->name
  741. return length;
  742. }
  743. UA_Int32 UA_QualifiedName_decode(char const * src, UA_Int32 *pos,
  744. UA_QualifiedName *dst) {
  745. UA_Int32 retval = UA_SUCCESS;
  746. retval |= UA_UInt16_decode(src,pos,&(dst->namespaceIndex));
  747. retval |= UA_UInt16_decode(src,pos,&(dst->reserved));
  748. retval |= UA_String_decode(src,pos,&(dst->name));
  749. return retval;
  750. }
  751. UA_Int32 UA_QualifiedName_encode(UA_QualifiedName const *src, UA_Int32* pos,
  752. char *dst) {
  753. UA_Int32 retval = UA_SUCCESS;
  754. retval |= UA_UInt16_encode(&(src->namespaceIndex),pos,dst);
  755. retval |= UA_UInt16_encode(&(src->reserved),pos,dst);
  756. retval |= UA_String_encode(&(src->name),pos,dst);
  757. return retval;
  758. }
  759. UA_Int32 UA_Variant_calcSize(UA_Variant const * p) {
  760. UA_Int32 length = 0;
  761. UA_Int32 ns0Id = p->encodingMask & 0x1F; // Bits 1-5
  762. Boolean isArray = p->encodingMask & (0x01 << 7); // Bit 7
  763. Boolean hasDimensions = p->encodingMask & (0x01 << 6); // Bit 6
  764. int i;
  765. if (p->vt == UA_NULL || p->encodingMask != p->vt->Id) {
  766. return UA_ERR_INCONSISTENT;
  767. }
  768. length += sizeof(Byte); //p->encodingMask
  769. if (isArray) { // array length is encoded
  770. length += sizeof(UA_Int32); //p->arrayLength
  771. if (p->arrayLength > 0) {
  772. // TODO: add suggestions of @jfpr to not iterate over arrays with fixed len elements
  773. for (i=0;i<p->arrayLength;i++) {
  774. length += p->vt->calcSize(p->data[i]);
  775. }
  776. }
  777. } else { //single value to encode
  778. length += p->vt->calcSize(p->data[0]);
  779. }
  780. if (hasDimensions) {
  781. //ToDo: tobeInsert: length += the calcSize for dimensions
  782. }
  783. return length;
  784. }
  785. UA_Int32 UA_Variant_encode(UA_Variant const *src, UA_Int32* pos, char *dst) {
  786. UA_Int32 retval = UA_SUCCESS;
  787. int i;
  788. if (src->vt == UA_NULL || src->encodingMask != src->vt->Id) {
  789. return UA_ERR_INCONSISTENT;
  790. }
  791. retval |= UA_Byte_encode(&(src->encodingMask),pos,dst);
  792. if (src->encodingMask & (0x01 << 7)) { // encode array length
  793. retval |= UA_Int32_encode(&(src->arrayLength),pos,dst);
  794. }
  795. if (src->arrayLength > 0) {
  796. //encode array as given by variant type
  797. for (i=0;i<src->arrayLength;i++) {
  798. retval |= src->vt->encode(src->data[i],pos,dst);
  799. }
  800. } else {
  801. retval |= src->vt->encode(src->data[i],pos,dst);
  802. }
  803. if (src->encodingMask & (1 << 6)) { // encode array dimension field
  804. // TODO: encode array dimension field
  805. }
  806. return retval;
  807. }
  808. UA_Int32 UA_Variant_decode(char const * src, UA_Int32 *pos, UA_Variant *dst) {
  809. UA_Int32 retval = UA_SUCCESS;
  810. UA_Int32 ns0Id;
  811. int i;
  812. retval |= UA_Byte_decode(src,pos,&(dst->encodingMask));
  813. ns0Id = dst->encodingMask & 0x1F;
  814. // initialize vTable
  815. if (ns0Id < UA_BOOLEAN && ns0Id > UA_DOUBLECOMPLEXNUMBERTYPE) {
  816. return UA_ERR_INVALID_VALUE;
  817. } else {
  818. dst->vt = &UA_[UA_toIndex(ns0Id)];
  819. }
  820. // get size of array
  821. if (dst->encodingMask & (0x01 << 7)) { // encode array length
  822. retval |= UA_Int32_decode(src,pos,&(dst->arrayLength));
  823. } else {
  824. dst->arrayLength = 1;
  825. }
  826. // allocate place for arrayLength pointers to any type
  827. retval |= UA_alloc(dst->data,dst->arrayLength * sizeof(void*));
  828. for (i=0;i<dst->arrayLength;i++) {
  829. // TODO: this is crazy, how to work with variants with variable size?
  830. // actually we have two different sizes - the storage size without
  831. // dynamic members and the storage size with the dynamic members, e.g.
  832. // for a string we here need to allocate definitely 8 byte (length=4, data*=4)
  833. // on a 32-bit architecture - so this code is definitely wrong
  834. retval |= UA_alloc(&(dst->data[i]),dst->vt->calcSize(UA_NULL));
  835. retval |= dst->vt->decode(src,pos,dst->data[i]);
  836. }
  837. if (dst->encodingMask & (1 << 6)) {
  838. // TODO: decode array dimension field
  839. }
  840. return retval;
  841. }
  842. //TODO: place this define at the server configuration
  843. #define MAX_PICO_SECONDS 1000
  844. UA_Int32 UA_DataValue_decode(char const * src, UA_Int32* pos, UA_DataValue* dst) {
  845. UA_Int32 retval = UA_SUCCESS;
  846. retval |= UA_Byte_decode(src,pos,&(dst->encodingMask));
  847. if (dst->encodingMask & 0x01) {
  848. retval |= UA_Variant_decode(src,pos,&(dst->value));
  849. }
  850. if (dst->encodingMask & 0x02) {
  851. retval |= UA_StatusCode_decode(src,pos,&(dst->status));
  852. }
  853. if (dst->encodingMask & 0x04) {
  854. retval |= UA_DateTime_decode(src,pos,&(dst->sourceTimestamp));
  855. }
  856. if (dst->encodingMask & 0x08) {
  857. retval |= UA_DateTime_decode(src,pos,&(dst->serverTimestamp));
  858. }
  859. if (dst->encodingMask & 0x10) {
  860. retval |= UA_UInt16_decode(src,pos,&(dst->sourcePicoseconds));
  861. if (dst->sourcePicoseconds > MAX_PICO_SECONDS) {
  862. dst->sourcePicoseconds = MAX_PICO_SECONDS;
  863. }
  864. }
  865. if (dst->encodingMask & 0x20) {
  866. retval |= UA_UInt16_decode(src,pos,&(dst->serverPicoseconds));
  867. if (dst->serverPicoseconds > MAX_PICO_SECONDS) {
  868. dst->serverPicoseconds = MAX_PICO_SECONDS;
  869. }
  870. }
  871. return retval;
  872. }
  873. UA_Int32 UA_DataValue_encode(UA_DataValue const * src, UA_Int32* pos, char *dst) {
  874. UA_Int32 retval = UA_SUCCESS;
  875. retval |= UA_Byte_encode(&(src->encodingMask),pos,dst);
  876. if (src->encodingMask & 0x01) {
  877. retval |= UA_Variant_encode(&(src->value),pos,dst);
  878. }
  879. if (src->encodingMask & 0x02) {
  880. retval |= UA_StatusCode_encode(&(src->status),pos,dst);
  881. }
  882. if (src->encodingMask & 0x04) {
  883. retval |= UA_DateTime_encode(&(src->sourceTimestamp),pos,dst);
  884. }
  885. if (src->encodingMask & 0x08) {
  886. retval |= UA_DateTime_encode(&(src->serverTimestamp),pos,dst);
  887. }
  888. if (src->encodingMask & 0x10) {
  889. retval |= UA_UInt16_encode(&(src->sourcePicoseconds),pos,dst);
  890. }
  891. if (src->encodingMask & 0x10) {
  892. retval |= UA_UInt16_encode(&(src->serverPicoseconds),pos,dst);
  893. }
  894. return retval;
  895. }
  896. UA_Int32 UA_DataValue_calcSize(UA_DataValue const * p) {
  897. UA_Int32 length = 0;
  898. if (p == UA_NULL) { // get static storage size
  899. length = sizeof(UA_DataValue);
  900. } else { // get decoding size
  901. length = sizeof(UA_Byte);
  902. if (p->encodingMask & 0x01) {
  903. length += UA_Variant_calcSize(&(p->value));
  904. }
  905. if (p->encodingMask & 0x02) {
  906. length += sizeof(UInt32); //dataValue->status
  907. }
  908. if (p->encodingMask & 0x04) {
  909. length += sizeof(Int64); //dataValue->sourceTimestamp
  910. }
  911. if (p->encodingMask & 0x08) {
  912. length += sizeof(Int64); //dataValue->serverTimestamp
  913. }
  914. if (p->encodingMask & 0x10) {
  915. length += sizeof(Int64); //dataValue->sourcePicoseconds
  916. }
  917. if (p->encodingMask & 0x20) {
  918. length += sizeof(Int64); //dataValue->serverPicoseconds
  919. }
  920. }
  921. return length;
  922. }