source: tmcsimulator/branches/FEPSimulator/FEPSim.h @ 233

/* 
 * File: FEPSim.h
 * 
 * The FEP Simulator simulates the Front End Processor(FEP), which has the
 * responsibility of "polling" Loop Detector Stations for highway status data.
 * The actual FEP "polls" actual stations over serial communication lines, whereas
 * the FEP Simulator receives highways status data over a socket from the Java
 * ATMS Driver. The highways status data is then parsed by the Network Reader.
 * 
 * The data is reconfigured into an fep_reply struct, then sent to the ATMS via 
 * RPC Calls. The RPC Calls to the ATMS Server send an the fep_reply structs. 
 * There is one fep_reply structure sent to the ATMS for every station.
 *
 * @author John A. Torres
 * @version 9/8/2017
 */

// Include guard
#ifndef __FEPSIM_H_INCLUDED__
#define __FEPSIM_H_INCLUDED__

// Forward declared dependencies
class HighwaysParser;

// Included dependencies
#include "fep.h"
#include <iostream>
#include <fstream>
#include <stdio.h>
#include <stdlib.h>
#include "time.h"
#include "HighwaysParser.h"
#include <netdb.h>
#include <sys/types.h> 
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <time.h>

// this buffer is the size of the entire highways data message + 1 for the
// appended newline character, when sent over the socket
const int BUFF_SIZE = 1266341;
// Log file for FEPSimulator
static ofstream FEPLogFile;
    
class FEPSim {
public:
    // The RPC Client
    CLIENT *clnt;

    /**
     * Constructor. Sets data values for RPC Client and socket server.
     * 
     * @param ATMSHost The IP of ATMS Server
     * @param FEP RPC program number
     * @param FEP RPC program revision number
     * @param Socket Server listen port
     */
    FEPSim(char * ATMSHost, int FEP_PROG, int FEP_REV, int SOCK_PORT);
    
    /**
     * Creates a socket server and awaits the highway status message from the
     * ATMS Driver. Upon receipt of the highway status message, creates an RPC
     * client and sends the fep_replys to the ATMS.
     */
    void runSockServer();
    
    /**
     * Creates an RPC Client, and on successful creation, sends fep_replys to ATMS.
     * @param The recieved highway status msg.
     */
    void manageClientConnection(char * buffer);
    
    /**
     * Destructor: closes the log file if open
     */
    ~FEPSim(); // Destructor

private:
    // atms ip address
    char * ATMSHost;
    // rpc program number
    int FEP_PROG;
    // rpc revision number
    int FEP_REV;
    // socket port
    int SOCK_PORT;
    // name of logging file
    char * FEPLogFileName;
    
    /**
     * Handler for the ATMS RPC Response (to the client RPC Call)
     * @param response pointer to fep_reply struct
     */
    void handleCallResponse(void *response);
    
    /**
     * Creates an RPC Client to the ATMS Server. If unsuccessful, returns false
     * @return bool success
     */
    bool createClient();
    
    /**
     * Sends an fep_reply for each station on the FEPLine. 
     * Gets highway status from recieved socket msg.
     * 
     * @param buffer The recieved highway status msg.
     */
    void sendReplys(char * buffer);
};

#endif // __FEPSIM_H_INCLUDED__