agent_transmitter.cpp File Reference

#include "support/configCosmos.h"
#include <stdio.h>
#include "agent/agentclass.h"
#include "physics/physicslib.h"
#include "support/jsonlib.h"
#include <cstring>
#include "device/general/kisslib.h"
#include "device/general/cssl_lib.h"

Include dependency graph for agent_transmitter.cpp:

Macros
#define	SERIAL_USB0   16
#define	MAXBUFFERSIZE   256
#define	REQUEST_RUN_PROGRAM   0

Functions
int	agent_transmitter ()
int32_t	transmit_kiss (string &request, string &response, Agent *)
int	main (int argc, char *argv[])

Variables
char	agentname [COSMOS_MAX_NAME+1] = "gs_tx"
char	node [50] = "otb"
int	waitsec = 5
unsigned int	rx_report_interval
Agent *	agent
int32_t	diskfree
int32_t	stateflag
int32_t	myport
cssl_t *	handle

Macro Definition Documentation

#define SERIAL_USB0   16

#define MAXBUFFERSIZE   256

#define REQUEST_RUN_PROGRAM   0

Function Documentation

int agent_transmitter

(

)

{
    //FILE *fp;

    // Start performing the body of the agent
    while(agent->running())
    {
        unsigned int rxcount;
        unsigned char serial_input[1000];


        // Read Serial Port(s)
//      rxcount = RS232_PollComport(SERIAL_USB0, serial_input, 1000);
        rxcount = cssl_getdata(handle, serial_input, 1000);

        // Print Inbound Characters if New Input Found
        if (rxcount)
        {
            printf("RX: ");
            for(unsigned int i=0;i < rxcount;i++)
            {
                printf("%c",serial_input[i]);
            }
            printf("\n");
        }

        COSMOS_USLEEP(100000); // no support in win, sleep for 100ms
    }
    return 0;
}

int32_t transmit_kiss	(	string &	request,
		string &	response,
		Agent *
	)

{
    int32_t iretn = 0;
    unsigned char packet_buffer[600]; // w/c count will be 529 bytes (18+1+255*2)
    int payload_size; // Packet Byte Count
    int input_size; // Request Input Byte Count
    unsigned char *raw_byte_backdoor;

    request += 3;  // Advance pointer to skip "tx ", transmit the rest
    raw_byte_backdoor = reinterpret_cast<unsigned char *>(&request[0]);

    printf("Received Request");

    // Check Input Length
    input_size = request.length(); // Get size of null terminated string
    printf(".");
    /*
if(input_size == -1 || input_size > 255)
{
  memcpy(response,"Error: Input larger than 255 maximum", 36);
  iretn=1;
  return iretn;
}
*/

    printf("TX Input: ");
    for(int z=0;z<input_size;z++)
    {
        printf("%02x ", raw_byte_backdoor[z]);
    }
    printf("\n");

    // Encode KISS Packet
    payload_size = kissEncode(raw_byte_backdoor,input_size,packet_buffer);

    // Test Print
    printf("TX KISS Output: ");
    for(int z=0;z<payload_size;z++)
    {
        printf("%02x ", packet_buffer[z]);
    }
    printf("\n\n");


//  RS232_SendBuf(SERIAL_USB0,packet_buffer,payload_size);
    cssl_putdata(handle, packet_buffer, payload_size);


    //#printf("Transmitting: %s\n",request.substr(3));


    return iretn;
}

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

{
    int32_t iretn;

    // Check for other instance of this agent
    if (argc == 2)
        strcpy(node,argv[1]);

    // check if we are already running the agent
    if ((iretn=agent->check_agent(node, "radio", waitsec)) > 0)
        exit (iretn);

    // Initialization stuff

    // RS232 Library Initialization
//  RS232_OpenComport(SERIAL_USB0,19200); // 16=ttyUSB0, 19200bps
    handle = cssl_open("/dev/", 19200, 8, 0, 1);

    // Main Program RX Reporting Interval


    // Initialize the Agent
    // near future: support cubesat space protocol
    // port number = 0 in this case, automatic assignment of port
    if (!(agent = new Agent(node, "radio", 1., MAXBUFFERSIZE)))
        exit (iretn);

    // Add additional requests
    if ((iretn=agent->add_request("tx",transmit_kiss)))
        exit (iretn);

    // Start our own thread
    iretn = agent_transmitter();
}

Variable Documentation

char agentname[COSMOS_MAX_NAME+1] = "gs_tx"

char node[50] = "otb"

int waitsec = 5

unsigned int rx_report_interval

Agent* agent

int32_t diskfree

int32_t stateflag

int32_t myport

cssl_t* handle