// get_average_bitrate.c  
  
#include "get_average_bitrate.h"  
#include <stdio.h>  
#include <stdlib.h>  
#include <pthread.h>  
#include <string.h>  
  
// Define the global variable  
double global_bitrate = 0.0;  
  
// Function executed by the thread  
void *run_bitrate_script(void *arg) {  
    char *command = (char *)arg;  
    char buffer[128];  
    FILE *pipe;  
  
    // Open the pipe to run the script  
    pipe = popen(command, "r");  
    if (pipe == NULL) {  
        perror("popen failed");  
        return NULL;  
    }  
  
    // Read the output from the script and parse the bitrate  
    while (fgets(buffer, sizeof(buffer), pipe) != NULL) {  
        if (sscanf(buffer, "Average Bitrate: %lf", &global_bitrate) == 1) {  
            // Successfully parsed the bitrate  
            break;  
        }  
    }  
  
    pclose(pipe);  
    return NULL;  
}  
  
// Function to start bitrate calculation asynchronously  
void calculate_bitrate_async(const char *port, const char *source_ip) {  
    pthread_t thread;  
    char command[256];  
  
    // Construct the command string with the port and source IP  
    snprintf(command, sizeof(command),  
             "./monitor_bitrate.sh %s %s", port, source_ip);  
  
    // Create a new thread to run the script  
    if (pthread_create(&thread, NULL, run_bitrate_script, (void *)command) != 0) {  
        perror("pthread_create failed");  
        return;  
    }  
  
    // Detach the thread so that it cleans up automatically  
    pthread_detach(thread);  
}

// get_average_bitrate.h  
  
#ifndef GET_AVERAGE_BITRATE_H  
#define GET_AVERAGE_BITRATE_H  
  
// Declare the global variable for storing bitrate  
extern double global_bitrate;  
  
// Function to start bitrate calculation asynchronously  
void calculate_bitrate_async(const char *port, const char *source_ip);  
  
#endif // GET_AVERAGE_BITRATE_H

// main.c  
  
#include "get_average_bitrate.h"  
#include <stdio.h>  
#include <stdlib.h>  
#include <unistd.h>  
  
int main(int argc, char *argv[]) {  
    if (argc != 3) {  
        fprintf(stderr, "Usage: %s <port> <source_ip>\n", argv[0]);  
        return 1;  
    }  
  
    const char *port = argv[1];  
    const char *source_ip = argv[2];  
  
    // Start calculating the bitrate in a separate thread  
    calculate_bitrate_async(port, source_ip);  
  
    // Continue doing other work here...  
    // The global_bitrate will be updated once the script finishes  
    // For demonstration purposes, let's wait a bit to check the result    sleep(5); // Adjust this if needed  
  
    // Print the result    printf("Average Bitrate: %.2f Mbps\n", global_bitrate);  
  
    return 0;  
}