source: tmcsimulator/branches/SimpleFEPclient/fep_client.cpp @ 136

#include "fep_client.h"

#include "fep.h"

#include <stdio.h>

#include <stdlib.h>

#include <vector>

#include "network.h"

#include "DataPacker.h"



/* Author: John A. Torres

   The fep_program_32 function creates a new RPC Client which

   sends an fep_reply structure to the ATMS Server. After the

   reply is sent, the ATMS Sends a response and the RPC Client

   is destroyed.

   */

void FEPClient::fep_program_32(char *host)

{

   CLIENT *clnt;



   /* Declerations to construct an fep_reply */

   fep_answer_info fai;

   fep_answer_short_msg fasm;

   fep_shortanswer fsa;

   fep_reply  fep_reply; // the reply to be sent to ATMS



   /* Var to recieve message back from ATMS */

   void  *rv;



   /* Create RPC Client to communicate with ATMS */

   printf("Preparing to create RPC client\n");

   clnt = clnt_create(host, FEP_PROGRAM, FEP_VERSION, "tcp");



   /* Check if client creation failed */

   if (clnt == (CLIENT *) NULL)

   {

      fprintf(stderr, "can't create client to %s\n", host);

      /* Show why rpc handle couldn't be created */

      clnt_pcreateerror("");

      exit(1);

   }



   /* Populate fep_shortmessage data */

   printf("setting reply values\n");



   // DUMMY DATA FOR SINGLE GREEN DOT

   // STATION

   // lds_id  line    drop sch lineinfo       system_key      sch_seq glo_seq         count   freeway Dir     ca_pm   lds_name

   // 1204666 45      10      11      11      1123005841      26484   1357646         19      5       N       20      LAKE FOR2



   // LOOPS

   // FWY     Dir     POSTMI  LDS_ID  VDS_ID  LOOP_ID LOC    LANE LOOP_LOC            PARAMICS_NAME  PARAMICS_LANE

   // 



   vector<LOOP*> loops;

/*

   LOOP * newLoopOne = new LOOP;

   newLoopOne->loopID = 1210490;

   newLoopOne->loop_loc = "ML_1";

   newLoopOne->vol = 0;

   newLoopOne->occ = 0;

   newLoopOne->spd = 0;



   LOOP * newLoopTwo = new LOOP;

   newLoopTwo->loopID = 1210492;

   newLoopTwo->loop_loc = "ML_2";

   newLoopTwo->vol = 0;

   newLoopTwo->occ = 0;

   newLoopTwo->spd = 0;



   LOOP * newLoopThree = new LOOP;

   newLoopThree->loopID = 1210493;

   newLoopThree->loop_loc = "ML_3";

   newLoopThree->vol = 0;

   newLoopThree->occ = 0;

   newLoopThree->spd = 0;



   LOOP * newLoopFour = new LOOP;

   newLoopFour->loopID = 1210769;

   newLoopFour->loop_loc = "RAMP_ON";

   newLoopFour->vol = 0;

   newLoopFour->occ = 0;

   newLoopFour->spd = 0;



   loops.push_back(newLoopOne);

   loops.push_back(newLoopTwo);

   loops.push_back(newLoopThree);

   loops.push_back(newLoopFour);

*/

   STATION * dummyStation = new STATION;

   dummyStation->lds = 1204666;

   dummyStation->line_num = 45;

   dummyStation->drop = 10;

   // dummyStation->loops = loops;



   dummyStation->MlTotVol = 0;

   dummyStation->OppTotVol = 0;

   dummyStation->length = dummyStation->loops.size() * 2 + 27 /* CONTROL_DATA_LEN */;



   printf("Station length: %d\n", dummyStation->length);

   // CHECK TO SEE IF I AM UPDATING THIS EVERY 30S

   /*

   for(int i = 0; i < 3; i++)

   {

      dummyStation->MlTotVol += loops.at(i)->vol;

   }

   */

   printf("Station MLTOTVOL: %d\n", dummyStation->MlTotVol);



   dummyStation->dataPack = DataPacker::packData(dummyStation);





   fep_reply.reply = SHORTPOLL;

   fep_reply.schedule = 0;

   fep_reply.lineinfo = 0;

   fep_reply.kind = (enum polltype) 0;

   fep_reply.flag = (enum replykind) 0;



   fep_reply.schedule_sequence = 0;

   fep_reply.global_sequence = 0;



   fep_reply.schedule_time = time(NULL);



   fep_reply.user_info1 = dummyStation->line_num; // LINE NUM;

   fep_reply.user_info2 = dummyStation->line_num; // LINE NUM;

   fep_reply.system_key = 0;



   fep_reply.answers.size = 1;

   fep_reply.answers.fep_answer_list_u.shortp.count = 1;



   fasm.message_len = dummyStation->length + 2; // MESSAGE LEN;

   fasm.message[0] = 0x0d;

   fasm.message[1] = 0x0a;



   for (int k = 0; k < dummyStation->length; k++) {

      printf("Adding: %d %02X\n", k, dummyStation->dataPack[k]); 

      fasm.message[2 + k] = dummyStation->dataPack[k];

   }



   int length = dummyStation->length + 2; // NEED CORRECT LENGTH

   fasm.message[length + 2] = 0x0d;

   fasm.message[length + 3] = 0xff;



   for(int l = 0; l < fasm.message_len + 2; l++)

   {

      printf("%02X", (unsigned char) fasm.message[l]);

   }

   printf("\n");



   fai.poll_error_count = 0;

   fai.poll_user_info1 = 0 ;// DROP NUMBER HERE

   fai.poll_user_info2 = 1;

   fai.retries = 0;

   fai.status = (enum replystatus) 1;



   fsa.info = fai;

   fsa.msg = fasm;

   fep_reply.answers.fep_answer_list_u.shortp.answers[0] = fsa;



   /* Make RPC Call to transfer reply to ATMS */

   printf("transferring data\n");

   rv = fep_reply_xfer_32(&fep_reply, clnt);

   printf("checking reply`\n");



   /* If ATMS reply call fails */

   if (rv == (void *) NULL)

   {

      clnt_perror(clnt, "call failed");

   }

   /* If recieved reply is successful, but empty */

   else if ((char *) rv == "")

   {

      printf("rv is empty\n");

   }

   /* If recieved reply is successful */

   else

   {

      printf("Result = %s\n", (char *)rv);

   }



   /* Destroy client */

   printf("destroying client\n");

   clnt_destroy(clnt);

   printf("returning to main\n");

}



/* Creates a single client and sends an fep_reply to the ATMS */

int main(int argc, char *argv[]) {

   char *host;



   if (argc < 2)

   {

      printf("usage:  %s server_host\n", argv[0]);

      exit(1);

   }



   /* Create RPC Client to send an fep_reply to ATMS */

   host = argv[1];

   FEPClient cli;

   cli.fep_program_32(host);



   return 0;

}