agent_route.cpp File Reference

#include "support/configCosmos.h"
#include <stdio.h>
#include "agent/agentclass.h"

Include dependency graph for agent_route.cpp:

Macros
#define	MAXBUFFERSIZE   2560

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

Variables
char	agentname [COSMOS_MAX_NAME+1] = "route"
int	waitsec = 5
Agent *	agent
socket_channel	rcvchan

Macro Definition Documentation

#define MAXBUFFERSIZE   2560

Function Documentation

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

{
    // Initialize the Agent
    if (!(agent = new Agent("", "route", 0., MAXBUFFERSIZE)))
    {
        exit (AGENT_ERROR_JSON_CREATE);
    }

    // Preload the information about the interfaces
    uint32_t addr_out[AGENTMAXIF];
//  uint32_t addr_to[AGENTMAXIF];
    for (uint16_t i=0; i<agent->cinfo->agent[0].ifcnt; ++i)
    {
#ifdef COSMOS_WIN_OS
        addr_out[i] = uint32from((uint8_t *)&agent->cinfo->agent[0].pub[i].caddr.sin_addr.S_un.S_addr, ByteOrder::NETWORK);
//      addr_to[i] = uint32from((uint8_t *)&agent->cinfo->agent[0].pub[i].baddr.sin_addr.S_un.S_addr, ByteOrder::NETWORK);
#else
        addr_out[i] = uint32from((uint8_t *)&agent->cinfo->agent[0].pub[i].caddr.sin_addr.s_addr, ByteOrder::NETWORK);
//      addr_to[i] = uint32from((uint8_t *)&agent->cinfo->agent[0].pub[i].baddr.sin_addr.s_addr, ByteOrder::NETWORK);
#endif
    }

    // Start performing the body of the agent
    int nbytes;
    char input[AGENTMAXBUFFER];
    ElapsedTime ret;
    while(agent->running())
    {
        if (ret.split() > 5.)
        {
            agent->post(Agent::AgentMessage::REQUEST, "heartbeat");
//            agent->post(Agent::AgentMessage::REQUEST, "postsoh");
            ret.reset();
        }
        nbytes = recvfrom(agent->cinfo->agent[0].sub.cudp,input,AGENTMAXBUFFER,0,(struct sockaddr *)&agent->cinfo->agent[0].sub.caddr,(socklen_t *)&agent->cinfo->agent[0].sub.addrlen);
        if (nbytes > 0)
        {
#ifdef COSMOS_WIN_OS
            uint32_t addr_in = uint32from((uint8_t *)&agent->cinfo->agent[0].sub.caddr.sin_addr.S_un.S_addr, ByteOrder::NETWORK);
#else
            uint32_t addr_in = uint32from((uint8_t *)&agent->cinfo->agent[0].sub.caddr.sin_addr.s_addr, ByteOrder::NETWORK);
#endif
            bool forward=true;
            for (uint16_t i=0; i<agent->cinfo->agent[0].ifcnt; ++i)
            {
                if (addr_in == addr_out[i])
                {
                    forward = false;
                    break;
                }
            }

            if (forward)
            {
                for (uint16_t i=0; i<agent->cinfo->agent[0].ifcnt; ++i)
                {
                    uint32_t address_xor = addr_in ^ addr_out[i];
                    if (address_xor > 255)
                    {
//                      printf("%x:%x:%x %d\n%s\n", addr_in, addr_out[i], addr_to[i], address_xor, input);
                        sendto(agent->cinfo->agent[0].pub[i].cudp,(const char *)input,nbytes,0,(struct sockaddr *)&agent->cinfo->agent[0].pub[i].baddr,sizeof(struct sockaddr_in));
//                      fflush(stdout);
                    }
                }
            }
        }
    }

    agent->shutdown();
}

Variable Documentation

char agentname[COSMOS_MAX_NAME+1] = "route"

int waitsec = 5

Agent* agent

socket_channel rcvchan