opcuaServer.c 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. /*
  2. * This work is licensed under a Creative Commons CCZero 1.0 Universal License.
  3. * See http://creativecommons.org/publicdomain/zero/1.0/ for more information.
  4. */
  5. #include <stdio.h>
  6. #include <stdlib.h>
  7. #include <signal.h>
  8. #include <errno.h> // errno, EINTR
  9. // provided by the open62541 lib
  10. #include "ua_server.h"
  11. #include "ua_namespace_0.h"
  12. // provided by the user, implementations available in the /examples folder
  13. #include "logger_stdout.h"
  14. #include "networklayer_tcp.h"
  15. #include "nodestoreAccessExample.h"
  16. #include "../src/server/ua_nodestore.h"
  17. #include "../src/server/ua_namespace_manager.h"
  18. UA_Boolean running = UA_TRUE;
  19. UA_Boolean running = 1;
  20. void stopHandler(int sign) {
  21. running = 0;
  22. }
  23. void serverCallback(UA_Server *server) {
  24. // printf("does whatever servers do\n");
  25. }
  26. UA_ByteString loadCertificate() {
  27. UA_ByteString certificate = UA_STRING_NULL;
  28. FILE *fp = NULL;
  29. //FIXME: a potiential bug of locating the certificate, we need to get the path from the server's config
  30. fp=fopen("localhost.der", "rb");
  31. if(!fp) {
  32. errno = 0; // otherwise we think sth went wrong on the tcp socket level
  33. return certificate;
  34. }
  35. fseek(fp, 0, SEEK_END);
  36. certificate.length = ftell(fp);
  37. certificate.data = malloc(certificate.length*sizeof(UA_Byte));
  38. fseek(fp, 0, SEEK_SET);
  39. if(fread(certificate.data, sizeof(UA_Byte), certificate.length, fp) < (size_t)certificate.length)
  40. UA_ByteString_deleteMembers(&certificate); // error reading the cert
  41. fclose(fp);
  42. return certificate;
  43. }
  44. int main(int argc, char** argv) {
  45. signal(SIGINT, stopHandler); /* catches ctrl-c */
  46. UA_Server server;
  47. UA_String endpointUrl;
  48. UA_String_copycstring("no endpoint url",&endpointUrl);
  49. UA_Server_init(&server, &endpointUrl);
  50. UA_NodeStore newNodeStore;
  51. UA_Server_addNamespace(&server,0,&newNodeStore);
  52. initMyNode();
  53. UA_NodeStore_registerReadNodesOperation(&newNodeStore,readNodes);
  54. UA_NodeStore_registerWriteNodesOperation(&newNodeStore,writeNodes);
  55. Logger_Stdout_init(&server.logger);
  56. server.serverCertificate = loadCertificate();
  57. UA_Int32 myInteger = 42;
  58. UA_String myIntegerName;
  59. UA_STRING_STATIC(myIntegerName, "The Answer");
  60. UA_Server_addScalarVariableNode(&server, &myIntegerName, (void*)&myInteger, &UA_[UA_INT32],
  61. &server.objectsNodeId, &server.hasComponentReferenceTypeId);
  62. #ifdef BENCHMARK
  63. UA_UInt32 nodeCount = 500;
  64. UA_VariableNode *tmpNode;
  65. UA_Int32 data = 42;
  66. char str[15];
  67. for(UA_UInt32 i = 0;i<nodeCount;i++) {
  68. UA_VariableNode_new(&tmpNode);
  69. sprintf(str,"%d",i);
  70. UA_QualifiedName_copycstring(str,&tmpNode->browseName);
  71. UA_LocalizedText_copycstring(str,&tmpNode->displayName);
  72. UA_LocalizedText_copycstring("integer value", &tmpNode->description);
  73. tmpNode->nodeId.identifier.numeric = 19000+i;
  74. tmpNode->nodeClass = UA_NODECLASS_VARIABLE;
  75. //tmpNode->valueRank = -1;
  76. tmpNode->value.vt = &UA_[UA_INT32];
  77. tmpNode->value.storage.data.dataPtr = &data;
  78. tmpNode->value.storageType = UA_VARIANT_DATA_NODELETE;
  79. tmpNode->value.storage.data.arrayLength = 1;
  80. UA_Server_addNode(&server, (UA_Node**)&tmpNode, &server.objectsNodeId,
  81. &server.hasComponentReferenceTypeId);
  82. }
  83. #endif
  84. #define PORT 16664
  85. NetworklayerTCP* nl;
  86. NetworklayerTCP_new(&nl, UA_ConnectionConfig_standard, PORT);
  87. printf("Server started, connect to to opc.tcp://127.0.0.1:%i\n", PORT);
  88. struct timeval callback_interval = {1, 0}; // 1 second
  89. UA_Int32 retval = NetworkLayerTCP_run(nl, &server, callback_interval,
  90. serverCallback, &running);
  91. UA_Server_deleteMembers(&server);
  92. NetworklayerTCP_delete(nl);
  93. UA_String_deleteMembers(&endpointUrl);
  94. return retval == UA_STATUSCODE_GOOD ? 0 : retval;
  95. }