1 files changed, 117 insertions, 0 deletions

diff --git a/analysis/rtt/src/mqtt_rtt_logger.c b/analysis/rtt/src/mqtt_rtt_logger.c
new file mode 100644
index 0000000..60e5d2d
--- /dev/null
+++ b/analysis/rtt/src/mqtt_rtt_logger.c
@@ -0,0 +1,117 @@
+// #include <mosquitto.h>
+// #include <stdio.h>
+// #include <stdlib.h>
+// #include <string.h>
+// #include <sys/time.h>
+// #include <time.h>
+// #include <unistd.h>
+//
+// #define BROKER_ADDRESS "192.168.1.101"
+// #define BROKER_PORT 1883
+// #define TOPIC "device/echo/in"
+// #define CSV_FILE "rtt_throughput_log.csv"
+// #define WINDOW_SEC 1
+// #define MAX_TIMES 1000
+//
+// // Kolejka czasów przyjścia wiadomości (dla throughput)
+// double msg_times[MAX_TIMES];
+// int msg_count = 0;
+//
+// // Zwraca aktualny czas w milisekundach
+// long long current_time_ms() {
+//   struct timeval tv;
+//   gettimeofday(&tv, NULL);
+//   return ((long long)tv.tv_sec * 1000) + (tv.tv_usec / 1000);
+// }
+//
+// // Zwraca aktualny czas w sekundach z ułamkiem
+// double current_time_sec() {
+//   struct timeval tv;
+//   gettimeofday(&tv, NULL);
+//   return (double)tv.tv_sec + (tv.tv_usec / 1e6);
+// }
+//
+// // Aktualizuje throughput window i zwraca liczbę wiadomości w oknie
+// int update_throughput_window(double now) {
+//   int i, new_count = 0;
+//   for (i = 0; i < msg_count; i++) {
+//     if (now - msg_times[i] < WINDOW_SEC) {
+//       msg_times[new_count++] = msg_times[i];
+//     }
+//   }
+//   msg_times[new_count++] = now;
+//   msg_count = new_count;
+//   return msg_count;
+// }
+//
+// // Callback po odebraniu wiadomości
+// void on_message(struct mosquitto *mosq, void *userdata,
+//                 const struct mosquitto_message *msg) {
+//   char *payload = (char *)msg->payload;
+//   long long sent_ms = atoll(payload);
+//   long long received_ms = current_time_ms();
+//   long long rtt = received_ms - sent_ms;
+//
+//   double now_sec = current_time_sec();
+//   int throughput = update_throughput_window(now_sec);
+//
+//   // Timestamp ISO 8601
+//   time_t now = time(NULL);
+//   struct tm *tm_info = localtime(&now);
+//   char iso_time[32];
+//   strftime(iso_time, sizeof(iso_time), "%Y-%m-%dT%H:%M:%S", tm_info);
+//
+//   // Zapisz do CSV
+//   FILE *f = fopen(CSV_FILE, "a");
+//   if (f) {
+//     fprintf(f, "%s,%lld,%lld,%lld,%d\n", iso_time, sent_ms, received_ms, rtt,
+//             throughput);
+//     fclose(f);
+//   }
+//
+//   // Wydruk
+//   printf("RTT: %lld ms | Throughput: %d msg/s\n", rtt, throughput);
+// }
+//
+// int main() {
+//   printf("Start programu\n");
+//
+//   FILE *f = fopen(CSV_FILE, "w");
+//   if (!f) {
+//     perror("Nie można otworzyć pliku CSV");
+//     return 1;
+//   }
+//   fprintf(f, "timestamp,sent_ms,received_ms,rtt_ms,throughput_msg_per_s\n");
+//   fclose(f);
+//   printf("Plik CSV utworzony\n");
+//
+//   mosquitto_lib_init();
+//   struct mosquitto *mosq = mosquitto_new(NULL, true, NULL);
+//   if (!mosq) {
+//     fprintf(stderr, "Błąd tworzenia klienta MQTT\n");
+//     return 1;
+//   }
+//   printf("Klient MQTT utworzony\n");
+//
+//   mosquitto_message_callback_set(mosq, on_message);
+//
+//   int rc = mosquitto_connect(mosq, BROKER_ADDRESS, BROKER_PORT, 60);
+//   if (rc != MOSQ_ERR_SUCCESS) {
+//     fprintf(stderr, "Nie można połączyć się z brokerem MQTT, kod błędu:
+//     %d\n",
+//             rc);
+//     return 1;
+//   }
+//   printf("Połączono z brokerem MQTT\n");
+//
+//   mosquitto_subscribe(mosq, NULL, TOPIC, 0);
+//   printf("Subskrypcja tematu %s ustawiona\n", TOPIC);
+//
+//   printf("Oczekiwanie na wiadomości...\n");
+//   mosquitto_loop_forever(mosq, -1, 1);
+//
+//   mosquitto_destroy(mosq);
+//   mosquitto_lib_cleanup();
+//
+//   return 0;
+// }