ua_server_binary.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465
  1. #include "ua_util.h"
  2. #include "ua_server_internal.h"
  3. #include "ua_types_encoding_binary.h"
  4. #include "ua_transport_generated.h"
  5. #include "ua_services.h"
  6. #include "ua_statuscodes.h"
  7. #include "ua_securechannel_manager.h"
  8. #include "ua_session_manager.h"
  9. #include "ua_nodeids.h"
  10. /** Max size of messages that are allocated on the stack */
  11. #define MAX_STACK_MESSAGE 65536
  12. static void processHEL(UA_Connection *connection, const UA_ByteString *msg, size_t *pos) {
  13. UA_TcpHelloMessage helloMessage;
  14. if(UA_TcpHelloMessage_decodeBinary(msg, pos, &helloMessage) != UA_STATUSCODE_GOOD) {
  15. connection->close(connection);
  16. return;
  17. }
  18. connection->remoteConf.maxChunkCount = helloMessage.maxChunkCount;
  19. connection->remoteConf.maxMessageSize = helloMessage.maxMessageSize;
  20. connection->remoteConf.protocolVersion = helloMessage.protocolVersion;
  21. connection->remoteConf.recvBufferSize = helloMessage.receiveBufferSize;
  22. if(connection->localConf.sendBufferSize > helloMessage.receiveBufferSize)
  23. connection->localConf.sendBufferSize = helloMessage.receiveBufferSize;
  24. if(connection->localConf.recvBufferSize > helloMessage.sendBufferSize)
  25. connection->localConf.recvBufferSize = helloMessage.sendBufferSize;
  26. connection->remoteConf.sendBufferSize = helloMessage.sendBufferSize;
  27. connection->state = UA_CONNECTION_ESTABLISHED;
  28. UA_TcpHelloMessage_deleteMembers(&helloMessage);
  29. // build acknowledge response
  30. UA_TcpAcknowledgeMessage ackMessage;
  31. ackMessage.protocolVersion = connection->localConf.protocolVersion;
  32. ackMessage.receiveBufferSize = connection->localConf.recvBufferSize;
  33. ackMessage.sendBufferSize = connection->localConf.sendBufferSize;
  34. ackMessage.maxMessageSize = connection->localConf.maxMessageSize;
  35. ackMessage.maxChunkCount = connection->localConf.maxChunkCount;
  36. UA_TcpMessageHeader ackHeader;
  37. ackHeader.messageTypeAndFinal = UA_MESSAGETYPEANDFINAL_ACKF;
  38. ackHeader.messageSize = UA_TcpMessageHeader_calcSizeBinary(&ackHeader)
  39. + UA_TcpAcknowledgeMessage_calcSizeBinary(&ackMessage);
  40. UA_ByteString ack_msg;
  41. if(connection->getBuffer(connection, &ack_msg, ackHeader.messageSize) != UA_STATUSCODE_GOOD)
  42. return;
  43. size_t tmpPos = 0;
  44. UA_TcpMessageHeader_encodeBinary(&ackHeader, &ack_msg, &tmpPos);
  45. UA_TcpAcknowledgeMessage_encodeBinary(&ackMessage, &ack_msg, &tmpPos);
  46. connection->write(connection, &ack_msg);
  47. connection->releaseBuffer(connection, &ack_msg);
  48. }
  49. static void processOPN(UA_Connection *connection, UA_Server *server, const UA_ByteString *msg,
  50. size_t *pos) {
  51. if(connection->state != UA_CONNECTION_ESTABLISHED) {
  52. connection->close(connection);
  53. return;
  54. }
  55. UA_UInt32 secureChannelId;
  56. UA_StatusCode retval = UA_UInt32_decodeBinary(msg, pos, &secureChannelId);
  57. UA_AsymmetricAlgorithmSecurityHeader asymHeader;
  58. retval |= UA_AsymmetricAlgorithmSecurityHeader_decodeBinary(msg, pos, &asymHeader);
  59. UA_SequenceHeader seqHeader;
  60. retval |= UA_SequenceHeader_decodeBinary(msg, pos, &seqHeader);
  61. UA_NodeId requestType;
  62. retval |= UA_NodeId_decodeBinary(msg, pos, &requestType);
  63. UA_OpenSecureChannelRequest r;
  64. retval |= UA_OpenSecureChannelRequest_decodeBinary(msg, pos, &r);
  65. if(retval != UA_STATUSCODE_GOOD || requestType.identifier.numeric != 446) {
  66. UA_AsymmetricAlgorithmSecurityHeader_deleteMembers(&asymHeader);
  67. UA_SequenceHeader_deleteMembers(&seqHeader);
  68. UA_NodeId_deleteMembers(&requestType);
  69. UA_OpenSecureChannelRequest_deleteMembers(&r);
  70. connection->close(connection);
  71. return;
  72. }
  73. UA_OpenSecureChannelResponse p;
  74. UA_OpenSecureChannelResponse_init(&p);
  75. Service_OpenSecureChannel(server, connection, &r, &p);
  76. UA_OpenSecureChannelRequest_deleteMembers(&r);
  77. UA_SecureConversationMessageHeader respHeader;
  78. respHeader.messageHeader.messageTypeAndFinal = UA_MESSAGETYPEANDFINAL_OPNF;
  79. respHeader.messageHeader.messageSize = 0;
  80. respHeader.secureChannelId = p.securityToken.channelId;
  81. UA_NodeId responseType = UA_NODEID_NUMERIC(0, UA_NS0ID_OPENSECURECHANNELRESPONSE +
  82. UA_ENCODINGOFFSET_BINARY);
  83. respHeader.messageHeader.messageSize =
  84. UA_SecureConversationMessageHeader_calcSizeBinary(&respHeader)
  85. + UA_AsymmetricAlgorithmSecurityHeader_calcSizeBinary(&asymHeader)
  86. + UA_SequenceHeader_calcSizeBinary(&seqHeader)
  87. + UA_NodeId_calcSizeBinary(&responseType)
  88. + UA_OpenSecureChannelResponse_calcSizeBinary(&p);
  89. UA_ByteString resp_msg;
  90. retval = connection->getBuffer(connection, &resp_msg, respHeader.messageHeader.messageSize);
  91. if(retval != UA_STATUSCODE_GOOD) {
  92. UA_OpenSecureChannelResponse_deleteMembers(&p);
  93. UA_AsymmetricAlgorithmSecurityHeader_deleteMembers(&asymHeader);
  94. return;
  95. }
  96. size_t tmpPos = 0;
  97. UA_SecureConversationMessageHeader_encodeBinary(&respHeader, &resp_msg, &tmpPos);
  98. UA_AsymmetricAlgorithmSecurityHeader_encodeBinary(&asymHeader, &resp_msg, &tmpPos); // just mirror back
  99. UA_SequenceHeader_encodeBinary(&seqHeader, &resp_msg, &tmpPos); // just mirror back
  100. UA_NodeId_encodeBinary(&responseType, &resp_msg, &tmpPos);
  101. UA_OpenSecureChannelResponse_encodeBinary(&p, &resp_msg, &tmpPos);
  102. UA_OpenSecureChannelResponse_deleteMembers(&p);
  103. UA_AsymmetricAlgorithmSecurityHeader_deleteMembers(&asymHeader);
  104. connection->write(connection, &resp_msg);
  105. connection->releaseBuffer(connection, &resp_msg);
  106. }
  107. static void init_response_header(const UA_RequestHeader *p, UA_ResponseHeader *r) {
  108. r->requestHandle = p->requestHandle;
  109. r->stringTableSize = 0;
  110. r->timestamp = UA_DateTime_now();
  111. }
  112. /* The request/response are casted to the header (first element of their struct) */
  113. static void invoke_service(UA_Server *server, UA_SecureChannel *channel,
  114. UA_RequestHeader *request, UA_ResponseHeader *response,
  115. void (*service)(UA_Server*, UA_Session*, void*, void*)) {
  116. init_response_header(request, response);
  117. /* try to get the session from the securechannel first */
  118. UA_Session *session = UA_SecureChannel_getSession(channel, &request->authenticationToken);
  119. if(!session || session->channel != channel) {
  120. response->serviceResult = UA_STATUSCODE_BADSESSIONIDINVALID;
  121. return;
  122. }
  123. else if(session->activated == UA_FALSE) {
  124. response->serviceResult = UA_STATUSCODE_BADSESSIONNOTACTIVATED;
  125. /* the session is invalidated */
  126. UA_SessionManager_removeSession(&server->sessionManager, &request->authenticationToken);
  127. return;
  128. }
  129. UA_Session_updateLifetime(session);
  130. service(server, session, request, response);
  131. }
  132. #define INVOKE_SERVICE(TYPE) do { \
  133. UA_##TYPE##Request p; \
  134. UA_##TYPE##Response r; \
  135. if(UA_##TYPE##Request_decodeBinary(msg, pos, &p)) \
  136. return; \
  137. UA_##TYPE##Response_init(&r); \
  138. invoke_service(server, clientChannel, &p.requestHeader, \
  139. &r.responseHeader, \
  140. (void (*)(UA_Server*, UA_Session*, void*,void*))Service_##TYPE); \
  141. UA_##TYPE##Request_deleteMembers(&p); \
  142. retval = connection->getBuffer(connection, &message, \
  143. headerSize + UA_##TYPE##Response_calcSizeBinary(&r)); \
  144. if(retval != UA_STATUSCODE_GOOD) { \
  145. UA_##TYPE##Response_deleteMembers(&r); \
  146. return; \
  147. } \
  148. UA_##TYPE##Response_encodeBinary(&r, &message, &messagePos); \
  149. UA_##TYPE##Response_deleteMembers(&r); \
  150. } while(0)
  151. static void processMSG(UA_Connection *connection, UA_Server *server, const UA_ByteString *msg, size_t *pos) {
  152. // 1) Read in the securechannel
  153. UA_UInt32 secureChannelId;
  154. UA_StatusCode retval = UA_UInt32_decodeBinary(msg, pos, &secureChannelId);
  155. if(retval != UA_STATUSCODE_GOOD)
  156. return;
  157. UA_SecureChannel *clientChannel = connection->channel;
  158. #ifdef EXTENSION_STATELESS
  159. UA_SecureChannel anonymousChannel;
  160. if(!clientChannel) {
  161. UA_SecureChannel_init(&anonymousChannel);
  162. anonymousChannel.session = &anonymousSession;
  163. clientChannel = &anonymousChannel;
  164. }
  165. #endif
  166. // 2) Read the security header
  167. UA_UInt32 tokenId;
  168. UA_SequenceHeader sequenceHeader;
  169. retval = UA_UInt32_decodeBinary(msg, pos, &tokenId);
  170. retval |= UA_SequenceHeader_decodeBinary(msg, pos, &sequenceHeader);
  171. if(retval != UA_STATUSCODE_GOOD)
  172. return;
  173. //UA_SecureChannel_checkSequenceNumber(channel,sequenceHeader.sequenceNumber);
  174. //UA_SecureChannel_checkRequestId(channel,sequenceHeader.requestId);
  175. clientChannel->sequenceNumber = sequenceHeader.sequenceNumber;
  176. clientChannel->requestId = sequenceHeader.requestId;
  177. // 3) Build the header and compute the header size
  178. UA_SecureConversationMessageHeader respHeader;
  179. respHeader.messageHeader.messageTypeAndFinal = UA_MESSAGETYPEANDFINAL_MSGF;
  180. respHeader.messageHeader.messageSize = 0;
  181. respHeader.secureChannelId = clientChannel->securityToken.channelId;
  182. UA_SymmetricAlgorithmSecurityHeader symSecHeader;
  183. symSecHeader.tokenId = clientChannel->securityToken.tokenId;
  184. UA_SequenceHeader seqHeader;
  185. seqHeader.sequenceNumber = clientChannel->sequenceNumber;
  186. seqHeader.requestId = clientChannel->requestId;
  187. // 4) process the request
  188. UA_ByteString message;
  189. UA_NodeId requestType;
  190. if(UA_NodeId_decodeBinary(msg, pos, &requestType))
  191. return;
  192. if(requestType.identifierType != UA_NODEIDTYPE_NUMERIC) {
  193. UA_NodeId_deleteMembers(&requestType);
  194. return;
  195. }
  196. UA_NodeId response_nodeid = UA_NODEID_NUMERIC(0, requestType.identifier.numeric + 3);
  197. UA_UInt32 headerSize = UA_SecureConversationMessageHeader_calcSizeBinary(&respHeader)
  198. + UA_SymmetricAlgorithmSecurityHeader_calcSizeBinary(&symSecHeader)
  199. + UA_SequenceHeader_calcSizeBinary(&seqHeader)
  200. + UA_NodeId_calcSizeBinary(&response_nodeid);
  201. size_t messagePos = headerSize;
  202. //subtract UA_ENCODINGOFFSET_BINARY for binary encoding
  203. switch(requestType.identifier.numeric - UA_ENCODINGOFFSET_BINARY) {
  204. case UA_NS0ID_GETENDPOINTSREQUEST: {
  205. UA_GetEndpointsRequest p;
  206. UA_GetEndpointsResponse r;
  207. if(UA_GetEndpointsRequest_decodeBinary(msg, pos, &p))
  208. return;
  209. UA_GetEndpointsResponse_init(&r);
  210. init_response_header(&p.requestHeader, &r.responseHeader);
  211. Service_GetEndpoints(server, &p, &r);
  212. UA_GetEndpointsRequest_deleteMembers(&p);
  213. retval = connection->getBuffer(connection, &message, headerSize + UA_GetEndpointsResponse_calcSizeBinary(&r));
  214. if(retval != UA_STATUSCODE_GOOD) {
  215. UA_GetEndpointsResponse_deleteMembers(&r);
  216. return;
  217. }
  218. UA_GetEndpointsResponse_encodeBinary(&r, &message, &messagePos);
  219. UA_GetEndpointsResponse_deleteMembers(&r);
  220. break;
  221. }
  222. case UA_NS0ID_FINDSERVERSREQUEST: {
  223. UA_FindServersRequest p;
  224. UA_FindServersResponse r;
  225. if(UA_FindServersRequest_decodeBinary(msg, pos, &p))
  226. return;
  227. UA_FindServersResponse_init(&r);
  228. init_response_header(&p.requestHeader, &r.responseHeader);
  229. Service_FindServers(server, &p, &r);
  230. UA_FindServersRequest_deleteMembers(&p);
  231. retval = connection->getBuffer(connection, &message, headerSize + UA_FindServersResponse_calcSizeBinary(&r));
  232. if(retval != UA_STATUSCODE_GOOD) {
  233. UA_FindServersResponse_deleteMembers(&r);
  234. return;
  235. }
  236. UA_FindServersResponse_encodeBinary(&r, &message, &messagePos);
  237. UA_FindServersResponse_deleteMembers(&r);
  238. break;
  239. }
  240. case UA_NS0ID_CREATESESSIONREQUEST: {
  241. UA_CreateSessionRequest p;
  242. UA_CreateSessionResponse r;
  243. if(UA_CreateSessionRequest_decodeBinary(msg, pos, &p))
  244. return;
  245. UA_CreateSessionResponse_init(&r);
  246. init_response_header(&p.requestHeader, &r.responseHeader);
  247. Service_CreateSession(server, clientChannel, &p, &r);
  248. UA_CreateSessionRequest_deleteMembers(&p);
  249. retval = connection->getBuffer(connection, &message, headerSize + UA_CreateSessionResponse_calcSizeBinary(&r));
  250. if(retval != UA_STATUSCODE_GOOD) {
  251. UA_CreateSessionResponse_deleteMembers(&r);
  252. return;
  253. }
  254. UA_CreateSessionResponse_encodeBinary(&r, &message, &messagePos);
  255. UA_CreateSessionResponse_deleteMembers(&r);
  256. break;
  257. }
  258. case UA_NS0ID_ACTIVATESESSIONREQUEST: {
  259. UA_ActivateSessionRequest p;
  260. UA_ActivateSessionResponse r;
  261. if(UA_ActivateSessionRequest_decodeBinary(msg, pos, &p))
  262. return;
  263. UA_ActivateSessionResponse_init(&r);
  264. init_response_header(&p.requestHeader, &r.responseHeader);
  265. Service_ActivateSession(server, clientChannel, &p, &r);
  266. UA_ActivateSessionRequest_deleteMembers(&p);
  267. retval = connection->getBuffer(connection, &message, headerSize + UA_ActivateSessionResponse_calcSizeBinary(&r));
  268. if(retval != UA_STATUSCODE_GOOD) {
  269. UA_ActivateSessionResponse_deleteMembers(&r);
  270. return;
  271. }
  272. UA_ActivateSessionResponse_encodeBinary(&r, &message, &messagePos);
  273. UA_ActivateSessionResponse_deleteMembers(&r);
  274. break;
  275. }
  276. case UA_NS0ID_CLOSESESSIONREQUEST:
  277. INVOKE_SERVICE(CloseSession);
  278. break;
  279. case UA_NS0ID_READREQUEST:
  280. INVOKE_SERVICE(Read);
  281. break;
  282. case UA_NS0ID_WRITEREQUEST:
  283. INVOKE_SERVICE(Write);
  284. break;
  285. case UA_NS0ID_BROWSEREQUEST:
  286. INVOKE_SERVICE(Browse);
  287. break;
  288. case UA_NS0ID_BROWSENEXTREQUEST:
  289. INVOKE_SERVICE(BrowseNext);
  290. break;
  291. case UA_NS0ID_ADDREFERENCESREQUEST:
  292. INVOKE_SERVICE(AddReferences);
  293. break;
  294. case UA_NS0ID_REGISTERNODESREQUEST:
  295. INVOKE_SERVICE(RegisterNodes);
  296. break;
  297. case UA_NS0ID_UNREGISTERNODESREQUEST:
  298. INVOKE_SERVICE(UnregisterNodes);
  299. break;
  300. case UA_NS0ID_TRANSLATEBROWSEPATHSTONODEIDSREQUEST:
  301. INVOKE_SERVICE(TranslateBrowsePathsToNodeIds);
  302. break;
  303. #ifdef ENABLE_NODEMANAGEMENT
  304. case UA_NS0ID_ADDNODESREQUEST:
  305. INVOKE_SERVICE(AddNodes);
  306. break;
  307. #endif
  308. #ifdef ENABLE_SUBSCRIPTIONS
  309. case UA_NS0ID_CREATESUBSCRIPTIONREQUEST:
  310. INVOKE_SERVICE(CreateSubscription);
  311. break;
  312. case UA_NS0ID_PUBLISHREQUEST:
  313. INVOKE_SERVICE(Publish);
  314. break;
  315. case UA_NS0ID_DELETESUBSCRIPTIONSREQUEST:
  316. INVOKE_SERVICE(DeleteSubscriptions);
  317. break;
  318. case UA_NS0ID_CREATEMONITOREDITEMSREQUEST:
  319. INVOKE_SERVICE(CreateMonitoredItems);
  320. break;
  321. case UA_NS0ID_DELETEMONITOREDITEMSREQUEST:
  322. INVOKE_SERVICE(DeleteMonitoredItems);
  323. break;
  324. #endif
  325. default: {
  326. if(requestType.namespaceIndex == 0 && requestType.identifier.numeric==787){
  327. UA_LOG_INFO(server->logger, UA_LOGCATEGORY_COMMUNICATION,
  328. "Client requested a subscription that are not supported, the message will be skipped");
  329. }else{
  330. UA_LOG_INFO(server->logger, UA_LOGCATEGORY_COMMUNICATION, "Unknown request: NodeId(ns=%d, i=%d)",
  331. requestType.namespaceIndex, requestType.identifier.numeric);
  332. }
  333. UA_RequestHeader p;
  334. UA_ResponseHeader r;
  335. if(UA_RequestHeader_decodeBinary(msg, pos, &p) != UA_STATUSCODE_GOOD)
  336. return;
  337. UA_ResponseHeader_init(&r);
  338. init_response_header(&p, &r);
  339. r.serviceResult = UA_STATUSCODE_BADSERVICEUNSUPPORTED;
  340. #ifdef EXTENSION_STATELESS
  341. if(retval != UA_STATUSCODE_GOOD)
  342. r.serviceResult = retval;
  343. #endif
  344. UA_RequestHeader_deleteMembers(&p);
  345. retval = connection->getBuffer(connection, &message, headerSize + UA_ResponseHeader_calcSizeBinary(&r));
  346. if(retval != UA_STATUSCODE_GOOD) {
  347. UA_ResponseHeader_deleteMembers(&r);
  348. return;
  349. }
  350. UA_ResponseHeader_encodeBinary(&r, &message, &messagePos);
  351. UA_ResponseHeader_deleteMembers(&r);
  352. response_nodeid = UA_NODEID_NUMERIC(0, UA_NS0ID_RESPONSEHEADER + UA_ENCODINGOFFSET_BINARY);
  353. break;
  354. }
  355. }
  356. messagePos = 0;
  357. respHeader.messageHeader.messageSize = message.length;
  358. UA_SecureConversationMessageHeader_encodeBinary(&respHeader, &message, &messagePos);
  359. UA_SymmetricAlgorithmSecurityHeader_encodeBinary(&symSecHeader, &message, &messagePos);
  360. UA_SequenceHeader_encodeBinary(&seqHeader, &message, &messagePos);
  361. UA_NodeId_encodeBinary(&response_nodeid, &message, &messagePos);
  362. // todo: sign & encrypt
  363. // 5) Send it over the wire.
  364. connection->write(connection, &message);
  365. connection->releaseBuffer(connection, &message);
  366. }
  367. static void processCLO(UA_Connection *connection, UA_Server *server, const UA_ByteString *msg, size_t *pos) {
  368. UA_UInt32 secureChannelId;
  369. UA_StatusCode retval = UA_UInt32_decodeBinary(msg, pos, &secureChannelId);
  370. if(retval != UA_STATUSCODE_GOOD || !connection->channel ||
  371. connection->channel->securityToken.channelId != secureChannelId)
  372. return;
  373. Service_CloseSecureChannel(server, secureChannelId);
  374. }
  375. void UA_Server_processBinaryMessage(UA_Server *server, UA_Connection *connection, UA_ByteString *msg) {
  376. if(msg->length <= 0)
  377. return;
  378. size_t pos = 0;
  379. UA_TcpMessageHeader tcpMessageHeader;
  380. do {
  381. if(UA_TcpMessageHeader_decodeBinary(msg, &pos, &tcpMessageHeader) != UA_STATUSCODE_GOOD) {
  382. UA_LOG_INFO(server->logger, UA_LOGCATEGORY_COMMUNICATION, "Decoding of message header failed");
  383. connection->close(connection);
  384. break;
  385. }
  386. size_t targetpos = pos - 8 + tcpMessageHeader.messageSize;
  387. switch(tcpMessageHeader.messageTypeAndFinal & 0xffffff) {
  388. case UA_MESSAGETYPEANDFINAL_HELF & 0xffffff:
  389. processHEL(connection, msg, &pos);
  390. break;
  391. case UA_MESSAGETYPEANDFINAL_OPNF & 0xffffff:
  392. processOPN(connection, server, msg, &pos);
  393. break;
  394. case UA_MESSAGETYPEANDFINAL_MSGF & 0xffffff:
  395. #ifdef EXTENSION_STATELESS
  396. processMSG(connection, server, msg, &pos);
  397. break;
  398. #endif
  399. if(connection->state != UA_CONNECTION_ESTABLISHED) {
  400. connection->close(connection);
  401. break;
  402. }
  403. processMSG(connection, server, msg, &pos);
  404. break;
  405. case UA_MESSAGETYPEANDFINAL_CLOF & 0xffffff:
  406. processCLO(connection, server, msg, &pos);
  407. connection->close(connection);
  408. return;
  409. }
  410. UA_TcpMessageHeader_deleteMembers(&tcpMessageHeader);
  411. if(pos != targetpos) {
  412. UA_LOG_INFO(server->logger, UA_LOGCATEGORY_COMMUNICATION,
  413. "The message was not entirely processed, skipping to the end");
  414. pos = targetpos;
  415. }
  416. } while(msg->length > (UA_Int32)pos);
  417. }