car_server.cpp

#include "car_server.h"

#include <cstring>

CarServer::CarServer(CarState* state, int fd_socket, int port):
  state(state),
  fd_socket(fd_socket),
  port(port) {}

CarServer::~CarServer(){
  thread_on = 0;
  server_thread->join();
  std::cout<<"CLOSING SERVER!"<<std::endl;
}

void CarServer::Start(){
  s.sin_family = AF_INET;
  s.sin_port = htons(port);
  s.sin_addr.s_addr = htonl(INADDR_BROADCAST);

  server_thread = std::unique_ptr<std::thread>(new std::thread(&CarServer::SyncronizeState, this));
}

void CarServer::SendMessage(char* message) {
  sendto(fd_socket, message, strlen(message), 0, (struct sockaddr *)&s, sizeof(struct sockaddr_in));
}

void CarServer::SyncronizeState(){
  struct sockaddr_in s;
  clock_t last_time = clock();
  while(thread_on){
    if (state->get_car_state() != CarState::WAITING) {
        clock_t current_time = clock();
        if ((float)(current_time - last_time) / CLOCKS_PER_SEC > 0.01) {
            unsigned char telegrama[6];
            state->get_my_state(telegrama);
            SendMessage((char*)telegrama);
            last_time = current_time;
        }
    }
  }
}