source: source/ariba/utility/transport/test_transport.hpp@ 6797

// test_transport.hpp, created on 01.07.2009 by Sebastian Mies

#ifndef TEST_TRANSPORT_HPP_
#define TEST_TRANSPORT_HPP_

#include "transport_peer.hpp"
#include "transport_listener.hpp"

#include "rfcomm/rfcomm.hpp"

#include <iostream>
#include <string>
#include <sys/types.h>
#include <unistd.h>

namespace ariba {
namespace transport {
namespace detail {

using namespace std;
using namespace ariba::transport;
using namespace ariba::addressing;

class listener : public transport_listener {
public:
        virtual void receive_message(
                transport_protocol* transport,
                const address_vf local, const address_vf remote,
                const uint8_t* data, size_t size
        ) {
                cout << "transport_listener: " << endl;
                cout << "received message data='" << data << "' local=" << local->to_string() << " remote=" << remote->to_string() << endl;
        }
};

void test_transport_process( endpoint_set& local, endpoint_set& remote ) {
        cout << "started " << local.to_string() << endl;
        transport_peer* peer = new transport_peer( local );
        peer->register_listener( new listener() );
        peer->start();
        peer->send( remote, (uint8_t*)"Hello!", 7 );
        getchar();
}

/**
 * TODO: Doc
 *
 * @author Sebastian Mies <mies@tm.uka.de>
 */
void tcp_test() {

        endpoint_set local  = string("tcp{5001};ip{127.0.0.1 | 2001:638:204:6:216:d3ff:fece:1070}");
        endpoint_set remote = string("tcp{5002};ip{127.0.0.1 | 2001:638:204:6:216:d3ff:fece:1070}");

        pid_t pID = fork();
        if (pID < 0) {
                cerr << "Failed to fork" << endl;
        } else
        if (pID == 0) {
                test_transport_process(local,remote);
        } else {
                getchar();
                test_transport_process(remote,local);
        }
        getchar();
}

void bluetooth_test( string& endp_str ) {
        cout << endp_str << endl;
        rfcomm* rfc = new rfcomm( 3 );
        rfc->register_listener( new listener() );
        rfc->start();
        if (endp_str.size()!=0) {
                rfcomm_endpoint endp = endp_str;
                rfc->send( endp, (uint8_t*)"Hello!", 7 );
        }
        getchar();
}

}}} // namespace ariba::transport::detail

#endif /* TEST_TRANSPORT_HPP_ */