src/syncTcpConnection.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

#include "syncTcpConnection.h"
#include <boost/bind.hpp>
#include <boost/asio.hpp>

#include <sstream>
#include <iostream>
#include <string>
#include "routingTable.h"
#include "rtpSessionTable.h"
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>


#include "syncCommand.h"
#include "buffer.h"

boost::asio::ip::tcp::socket& SyncTcpConnection::socket()
{
  return socket_;
}

void SyncTcpConnection::start()
{
  onConnect(this);
}

void SyncTcpConnection::Send(std::string message)
{
    boost::asio::async_write(socket_, boost::asio::buffer(message),
        boost::bind(&SyncTcpConnection::handle_write, shared_from_this(),
          boost::asio::placeholders::error,
          boost::asio::placeholders::bytes_transferred));
}
SyncTcpConnection::SyncTcpConnection(boost::asio::io_service& io_service)
	: socket_(io_service)
{
}

void SyncTcpConnection::handle_write(const boost::system::error_code& /*error*/,
		size_t /*bytes_transferred*/)
{
}