cclient.c

Go to the documentation of this file.

#include <stdio.h>
#include <stdlib.h>
#include <math.h>
#include "utilSocket.h"

int main(int argc, char *argv[]){
  // Declare variables for the socket communication
  // File name used to get the port number
  const char *const simCfgFilNam = "socket.cfg";
  // Client error flag
  const int cliErrFla = -1;
  // Client stop flag
  const int stoFla = 1;
  // Flags to exchange the status of the simulation program
  // and of the middleware.
  int flaWri = 0;
  int flaRea = 0;
  // Number of variables to be exchanged
  const int nDblWri = 2;
  int nDblRea;
  // Number of rooms
  int nRoo =2;
  // Arrays that contain the variables to be exchanged
  double dblValWri[2];
  double dblValRea[2];
  int i, iSte, sockfd, retVal;
  // set simulation time step
  double delTim;
  double endTim = 6.*3600;

  // Declare variables of the room model
  double simTimWri = 0;
  double simTimRea = 0;
  double TIni   = 10;
  double tau    = 2*3600;
  double Q0Hea  = 100;
  double UA     = Q0Hea / 20;
  double TOut   = 5;
  double C[]    = {tau*UA, 2*tau*UA};
  double TRoo[] = {TIni, TIni};

  double y[]    = {0, 0};
  int nSte;
  if (argc <= 1) {
    printf("Usage: %s simulation_timestep_in_seconds\n", argv[0]);
    return(1);
  }
  delTim = atof(argv[1]);
  fprintf(stderr,"Simulation model has time step  %8.5g\n", delTim);
  fprintf(stderr,"Simulation model has end time   %8.5g\n", endTim);

  if (delTim <= 0){
    printf("Error: End time must be bigger than zero.\n");
    printf("Usage: %s simulation_timestep_in_seconds end_time_in_seconds\n", argv[0]);
    exit(1);
  }

  //nSte = (int)nearbyint(endTim/delTim);
  nSte = (int)floor((endTim/delTim) + 0.5); // added by TNouidui. nearbyint not defined on Windows.
  if (abs(nSte*delTim-endTim) > 1E-10*endTim){
    printf("Error: End time divided by time step must be an integer.\n");
    printf("       Number of time steps is %d.\n", nSte);
    printf("Usage: %s simulation_timestep_in_seconds end_time_in_seconds\n", argv[0]);
    exit(1);
  }

  // Establish the client socket
  sockfd = establishclientsocket(simCfgFilNam);
  if (sockfd < 0){
    fprintf(stderr,"Error: Failed to obtain socket file descriptor. sockfd=%d.\n", sockfd);
    exit((sockfd)+100);
  }

  // Simulation loop
  for(iSte=0; iSte < nSte+1; iSte++){
    // Set simulation time
    simTimWri = (double)iSte*delTim; // set simulation time
    // assign values to be exchanged
    for(i=0; i < nDblWri; i++)
      dblValWri[i]=TRoo[i];

    // Exchange values
    retVal = exchangedoubleswithsocket(&sockfd, &flaWri, &flaRea,
                                       &nDblWri, &nDblRea,
                                       &simTimWri, dblValWri,
                                       &simTimRea, dblValRea);
    // Check flags
    if (retVal < 0){
      sendclientmessage(&sockfd, &cliErrFla);
      printf("Simulator received value %d when reading from socket. Exit simulation.\n", retVal);
      closeipc(&sockfd);
      exit((retVal)+100);
    }

    if (flaRea == 1){
      printf("Simulator received end of simulation signal from server. Exit simulation.\n");
      closeipc(&sockfd);
      exit(0);
    }

    if (flaRea != 0){
      printf("Simulator received flag = %d from server. Exit simulation.\n", flaRea);
      closeipc(&sockfd);
      exit(1);
    }
    // Check for the correct number of double values
    if (nDblRea != 2){
      printf("Simulator received nDblRea = %d from server, but expected 2. Exit simulation.\n", 
         nDblRea);
      closeipc(&sockfd);
      exit(1);
    }
    // No flags found that require the simulation to terminate.
    // Assign exchanged variables
    for(i=0; i < nRoo; i++)
      y[i] = dblValRea[i];

    // Having obtained y_k, we compute the new state x_k+1 = f(y_k)
    // This is the actual simulation of the client.
    for(i=0; i < nRoo; i++)
      TRoo[i] = TRoo[i] + delTim/C[i] * ( UA * (TOut-TRoo[i] ) + Q0Hea * y[i] );
  } // end of simulation loop
  // Close socket at end of simulation
  sendclientmessage(&sockfd, &stoFla);
  closeipc(&sockfd);
  exit(0);
}