plugin_checks.c 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129
  1. // SPDX-License-Identifier: GPL-3.0-or-later
  2. #include "plugin_checks.h"
  3. #ifdef NETDATA_INTERNAL_CHECKS
  4. static void checks_main_cleanup(void *ptr) {
  5. struct netdata_static_thread *static_thread = (struct netdata_static_thread *)ptr;
  6. static_thread->enabled = NETDATA_MAIN_THREAD_EXITING;
  7. info("cleaning up...");
  8. static_thread->enabled = NETDATA_MAIN_THREAD_EXITED;
  9. }
  10. void *checks_main(void *ptr) {
  11. netdata_thread_cleanup_push(checks_main_cleanup, ptr);
  12. usec_t usec = 0, susec = localhost->rrd_update_every * USEC_PER_SEC, loop_usec = 0, total_susec = 0;
  13. struct timeval now, last, loop;
  14. RRDSET *check1, *check2, *check3, *apps_cpu = NULL;
  15. check1 = rrdset_create_localhost(
  16. "netdata"
  17. , "check1"
  18. , NULL
  19. , "netdata"
  20. , NULL
  21. , "Caller gives microseconds"
  22. , "a million !"
  23. , "checks.plugin"
  24. , ""
  25. , NETDATA_CHART_PRIO_CHECKS
  26. , localhost->rrd_update_every
  27. , RRDSET_TYPE_LINE
  28. );
  29. rrddim_add(check1, "absolute", NULL, -1, 1, RRD_ALGORITHM_ABSOLUTE);
  30. rrddim_add(check1, "incremental", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  31. check2 = rrdset_create_localhost(
  32. "netdata"
  33. , "check2"
  34. , NULL
  35. , "netdata"
  36. , NULL
  37. , "Netdata calcs microseconds"
  38. , "a million !"
  39. , "checks.plugin"
  40. , ""
  41. , NETDATA_CHART_PRIO_CHECKS
  42. , localhost->rrd_update_every
  43. , RRDSET_TYPE_LINE
  44. );
  45. rrddim_add(check2, "absolute", NULL, -1, 1, RRD_ALGORITHM_ABSOLUTE);
  46. rrddim_add(check2, "incremental", NULL, 1, 1, RRD_ALGORITHM_INCREMENTAL);
  47. check3 = rrdset_create_localhost(
  48. "netdata"
  49. , "checkdt"
  50. , NULL
  51. , "netdata"
  52. , NULL
  53. , "Clock difference"
  54. , "microseconds diff"
  55. , "checks.plugin"
  56. , ""
  57. , NETDATA_CHART_PRIO_CHECKS
  58. , localhost->rrd_update_every
  59. , RRDSET_TYPE_LINE
  60. );
  61. rrddim_add(check3, "caller", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  62. rrddim_add(check3, "netdata", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  63. rrddim_add(check3, "apps.plugin", NULL, 1, 1, RRD_ALGORITHM_ABSOLUTE);
  64. now_realtime_timeval(&last);
  65. while(!netdata_exit) {
  66. usleep(susec);
  67. // find the time to sleep in order to wait exactly update_every seconds
  68. now_realtime_timeval(&now);
  69. loop_usec = dt_usec(&now, &last);
  70. usec = loop_usec - susec;
  71. debug(D_PROCNETDEV_LOOP, "CHECK: last loop took %llu usec (worked for %llu, sleeped for %llu).", loop_usec, usec, susec);
  72. if(usec < (localhost->rrd_update_every * USEC_PER_SEC / 2ULL)) susec = (localhost->rrd_update_every * USEC_PER_SEC) - usec;
  73. else susec = localhost->rrd_update_every * USEC_PER_SEC / 2ULL;
  74. // --------------------------------------------------------------------
  75. // Calculate loop time
  76. last.tv_sec = now.tv_sec;
  77. last.tv_usec = now.tv_usec;
  78. total_susec += loop_usec;
  79. // --------------------------------------------------------------------
  80. // check chart 1
  81. if(check1->counter_done) rrdset_next_usec(check1, loop_usec);
  82. rrddim_set(check1, "absolute", 1000000);
  83. rrddim_set(check1, "incremental", total_susec);
  84. rrdset_done(check1);
  85. // --------------------------------------------------------------------
  86. // check chart 2
  87. if(check2->counter_done) rrdset_next(check2);
  88. rrddim_set(check2, "absolute", 1000000);
  89. rrddim_set(check2, "incremental", total_susec);
  90. rrdset_done(check2);
  91. // --------------------------------------------------------------------
  92. // check chart 3
  93. if(!apps_cpu) apps_cpu = rrdset_find_localhost("apps.cpu");
  94. if(check3->counter_done) rrdset_next_usec(check3, loop_usec);
  95. now_realtime_timeval(&loop);
  96. rrddim_set(check3, "caller", (long long) dt_usec(&loop, &check1->last_collected_time));
  97. rrddim_set(check3, "netdata", (long long) dt_usec(&loop, &check2->last_collected_time));
  98. if(apps_cpu) rrddim_set(check3, "apps.plugin", (long long) dt_usec(&loop, &apps_cpu->last_collected_time));
  99. rrdset_done(check3);
  100. }
  101. netdata_thread_cleanup_pop(1);
  102. return NULL;
  103. }
  104. #endif // NETDATA_INTERNAL_CHECKS