server.c 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103
  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 <time.h>
  6. #include <stdio.h>
  7. #include <stdlib.h>
  8. #include <signal.h>
  9. #include <errno.h> // errno, EINTR
  10. #ifdef NOT_AMALGATED
  11. #include "ua_types.h"
  12. #include "ua_server.h"
  13. #else
  14. #include "open62541.h"
  15. #endif
  16. // provided by the user, implementations available in the /examples folder
  17. #include "logger_stdout.h"
  18. #include "networklayer_tcp.h"
  19. UA_Boolean running = 1;
  20. UA_Logger logger;
  21. static void stopHandler(int sign) {
  22. printf("Received Ctrl-C\n");
  23. running = 0;
  24. }
  25. static UA_ByteString loadCertificate(void) {
  26. UA_ByteString certificate = UA_STRING_NULL;
  27. FILE *fp = NULL;
  28. //FIXME: a potiential bug of locating the certificate, we need to get the path from the server's config
  29. fp=fopen("localhost.der", "rb");
  30. if(!fp) {
  31. errno = 0; // we read errno also from the tcp layer...
  32. return certificate;
  33. }
  34. fseek(fp, 0, SEEK_END);
  35. certificate.length = ftell(fp);
  36. certificate.data = malloc(certificate.length*sizeof(UA_Byte));
  37. if(!certificate.data)
  38. return certificate;
  39. fseek(fp, 0, SEEK_SET);
  40. if(fread(certificate.data, sizeof(UA_Byte), certificate.length, fp) < (size_t)certificate.length)
  41. UA_ByteString_deleteMembers(&certificate); // error reading the cert
  42. fclose(fp);
  43. return certificate;
  44. }
  45. static void testCallback(UA_Server *server, void *data) {
  46. logger.log_info(UA_LOGGERCATEGORY_USERLAND, "testcallback");
  47. }
  48. int main(int argc, char** argv) {
  49. signal(SIGINT, stopHandler); /* catches ctrl-c */
  50. UA_Server *server = UA_Server_new();
  51. logger = Logger_Stdout_new();
  52. UA_Server_setLogger(server, logger);
  53. UA_Server_setServerCertificate(server, loadCertificate());
  54. UA_Server_addNetworkLayer(server, ServerNetworkLayerTCP_new(UA_ConnectionConfig_standard, 16664));
  55. UA_WorkItem work = {.type = UA_WORKITEMTYPE_METHODCALL, .work.methodCall = {.method = testCallback, .data = NULL} };
  56. UA_Server_addRepeatedWorkItem(server, &work, 20000000, NULL); // call every 2 sec
  57. // add a variable node to the adresspace
  58. UA_Int32 *myInteger = UA_Int32_new();
  59. *myInteger = 42;
  60. UA_Variant *myIntegerVariant = UA_Variant_new();
  61. UA_Variant_setValue(myIntegerVariant, myInteger, &UA_TYPES[UA_TYPES_INT32]);
  62. UA_QualifiedName myIntegerName;
  63. UA_QUALIFIEDNAME_ASSIGN(myIntegerName, "the answer");
  64. UA_Server_addVariableNode(server, myIntegerVariant, &UA_NODEID_NULL, &myIntegerName,
  65. &UA_NODEID_STATIC(0, UA_NS0ID_OBJECTSFOLDER),
  66. &UA_NODEID_STATIC(0, UA_NS0ID_ORGANIZES));
  67. #ifdef BENCHMARK
  68. UA_UInt32 nodeCount = 500;
  69. char str[15];
  70. for(UA_UInt32 i = 0;i<nodeCount;i++) {
  71. UA_Int32 *data = UA_Int32_new();
  72. *data = 42;
  73. UA_Variant *variant = UA_Variant_new();
  74. UA_Variant_setValue(variant, data, &UA_TYPES[UA_TYPES_INT32]);
  75. UA_QualifiedName *nodeName = UA_QualifiedName_new();
  76. sprintf(str,"%d",i);
  77. UA_QualifiedName_copycstring(str, nodeName);
  78. UA_Server_addVariableNode(server, variant, &UA_NODEID_NULL, nodeName,
  79. &UA_NODEID_STATIC(0, UA_NS0ID_OBJECTSFOLDER),
  80. &UA_NODEID_STATIC(0, UA_NS0ID_ORGANIZES));
  81. }
  82. #endif
  83. UA_StatusCode retval = UA_Server_run(server, 1, &running);
  84. UA_Server_delete(server);
  85. return retval;
  86. }