ax25_recv.cpp File Reference

#include "support/configCosmos.h"
#include "support/jsondef.h"
#include "device/general/ax25class.h"
#include "support/timelib.h"
#include "device/serial/serialclass.h"
#include "support/socketlib.h"
#include "support/elapsedtime.h"
#include "support/stringlib.h"

Include dependency graph for ax25_recv.cpp:

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

Variables
static Ax25Handle	handle
static string	device = "127.0.0.1:10001"
static string	device_addr = "127.0.0.1"
static uint16_t	device_port = 10003
static string	source
static string	destination
static vector< uint8_t >	message

Function Documentation

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

{
    PORT_TYPE device_type;
    Serial *shandle = nullptr;
    socket_channel schannel;

    int32_t iretn;
    size_t tcount = 2000;

    switch (argc)
    {
    case 3:
        tcount = static_cast <size_t>(atol(argv[2]));
    case 2:
        device = argv[1];
        if (device.find(':') != string::npos)
        {
            device_type = PORT_TYPE_ETHERNET;
            device_port = static_cast <uint16_t>(stoi(device.substr(device.find(':')+1)));
            device_addr = device.substr(0, device.find(':'));
            iretn = socket_open(&schannel, NetworkType::UDP, "", device_port, SOCKET_LISTEN, true, 5000000);
        }
        else
        {
            device_type = PORT_TYPE_RS232;
            device_addr = device;
            shandle = new Serial(device_addr, 19200);
            shandle->set_timeout(5.);
        }
        break;
    default:
        printf("Usage: ax25_recv [device [tcount]]\n");
        exit(-1);
    }



    for (size_t i=0; i<tcount; ++i)
    {
        ElapsedTime et;
        vector <uint8_t> packet;

        if (device_type == PORT_TYPE_ETHERNET)
        {
            iretn = socket_recvfrom(schannel, packet, 1500);
        }
        else
        {
            iretn = shandle->get_data(packet);
        }
        if (iretn > 0)
        {
            handle.set_raw_packet(packet);
            handle.unload_packet();
            printf("Packet: [%s %u %s %u %u %u] ", handle.get_destination_callsign().c_str(), handle.get_destination_stationID(), handle.get_source_callsign().c_str(), handle.get_source_stationID(), handle.get_control(), handle.get_protocolID());
            printf("%s\n", to_hex_string(handle.get_packetData(), true).c_str());
        }
//        else
//        {
//            printf("Timeout: [%d] %s\n", iretn, cosmos_error_string(iretn).c_str());
//        }

        fflush(stdout);
    }
}

Variable Documentation

Ax25Handle handle

static

string device = "127.0.0.1:10001"

static

string device_addr = "127.0.0.1"

static

uint16_t device_port = 10003

static

string source

static

string destination

static

vector<uint8_t> message

static