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

#include "fep.h"
#include <stdio.h>
#include <stdlib.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 fep_program_32(char *host)
{
        CLIENT *clnt;

    /* Declerations to construct an fep_reply */
        fep_answer_info fai;
        fep_pollerror fpe;
        fep_answer_short_msg fasm;
        fep_shortanswer fsa;
        fep_reply  fep_reply_xfer_32_arg; // 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");

        fasm.message_len = 5;
        fasm.message[0] = 0x0a;
        fasm.message[1] = 0x0d;
        fasm.message[2] = 0x11;
        fasm.message[3] = 0x12;
        fasm.message[4] = 0x13;

        fpe.msgerror = (enum answererror) 0;
        fpe.state = (enum Polling_FSM_States) 0x00;
        fpe.perrno = 0;
        fpe.termination = 0;
        fpe.count = 0;

        fai.poll_time = 1111443466;
        fai.status = (enum replystatus) 1;
        fai.poll_user_info1 = 1;
        fai.poll_user_info2 = 2;
        fai.retries = 0;
        fai.poll_error_count = 1;
        fai.pollerror[0] = fpe;

        fsa.info = fai;
        fsa.msg = fasm;

        fep_reply_xfer_32_arg.reply = 0;
        fep_reply_xfer_32_arg.schedule = 0;
        fep_reply_xfer_32_arg.lineinfo = 0;
        fep_reply_xfer_32_arg.kind = (enum polltype)0;
        fep_reply_xfer_32_arg.flag = (enum replykind) 0;
        fep_reply_xfer_32_arg.schedule_sequence = 0;
        fep_reply_xfer_32_arg.global_sequence = 0;
        fep_reply_xfer_32_arg.schedule_time = 1111443466;
        fep_reply_xfer_32_arg.user_info1 = 0;
        fep_reply_xfer_32_arg.user_info2 = 0;
        fep_reply_xfer_32_arg.system_key = 0;
        fep_reply_xfer_32_arg.answers.size = 0;
        fep_reply_xfer_32_arg.answers.fep_answer_list_u.shortp.count = 1;
        fep_reply_xfer_32_arg.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_xfer_32_arg, 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];
        fep_program_32(host);

        return 0;
}