mcast.cpp

Go to the documentation of this file.

#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#include <sys/time.h>
#include <time.h>

#include <boost/bind.hpp>
#include <boost/program_options.hpp>

#include "SystemConfig.h"
#include "DateTime.h"
#include "Exception.h"
#include "NetAddress.h"
//#include "Sender.h"
//#include "Receiver.h"
#include "Communication.h"

#include "CNER.h"
#include "Messages.h"
#include "Types.h"

using namespace castor::net;

CastorChannel *cx;
CastorChannel *sx;

void creceive(const char *buffer, size_t, NetAddressPtr address) {
        std::cout << "(C) " << buffer << " from " << *address << std::endl;
}

void sreceive(const char *buffer, size_t, NetAddressPtr address) {
        std::cout << "(R) " << buffer << " from " << *address << std::endl;
        sx->send("Return", 7, *address);
}

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

        if (argc < 2) return 0;

        CommunicationPtr comm = Communication::getInstance();

        CastorChannelPtr s = comm->create(argv[1]);

        sx = s.get();

        if (argc == 2) {
                s->accept();
                s->callback = sreceive;
        } else {
                s->connect();
                s->callback = creceive;
        }

        s->start();

        comm->start(1);

        if (argc == 2) {
                sleep(1000);
        } else {

                for (int i = 0; i < 100; i++) {
                        std::cout << "SEND" << std::endl;
                        s->send("Bla", 4);
                        sleep(1);
                }

                sleep(1000);
        }

        return 0;
}