Qt и boost

INCLUDEPATH += C:/Program Files/boost/boost_1_47/boost
LIBS += C:/Program Files/boost/boost_1_47/lib

INCLUDEPATH += "C:/Program Files/boost/boost_1_47"  // Кавычки

#include <boost/...>

INCLUDEPATH += "/usr/include/boost "

#-------------------------------------------------
#
# Project created by QtCreator 2014-01-11T17:55:39
#
#-------------------------------------------------
 
QT       += core
 
QT       -= gui
 
TARGET = server
CONFIG   += console
CONFIG   -= app_bundle
 
TEMPLATE = app
 
 
SOURCES += main.cpp
 
INCLUDEPATH += "/usr/include/boost"
 
LIBS += -lboost_asio -lboost_bind -lboost_shared_ptr -lboost_shared -lboost_thread

#include <QCoreApplication>
#include <QDebug>
#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/shared_array.hpp>
#include <boost/thread.hpp>
 
// максимальная длина принимаемого сообщения.
static const size_t message_len = 32;
 
typedef boost::shared_ptr<boost::asio::ip::tcp::socket> socket_ptr;
 
// начало приема запросов на подключение.
void start_accept(
   boost::asio::ip::tcp::acceptor* acceptor
);
 
// создаем асинхронную операцию аксепта.
void on_accept(
   boost::asio::ip::tcp::acceptor* acceptor,
   socket_ptr socket
);
 
// вызовется при подключении.
void on_accept_handler(
   boost::asio::ip::tcp::acceptor* acceptor,
   socket_ptr socket,
   const boost::system::error_code& error // объект ошибки
);
 
// вызовется при завершении асинхронной записи.
void on_async_read(
   socket_ptr socket,
   boost::shared_array<char> message, // shared_array мы сюда передаем для
                                      // того, чтоб не дать ему удалить данные которыми он
                                      // владеет до завершения асинхронной записи.
   const boost::system::error_code& error // объект ошибки
);
 
/***************************************************************************/
 
int main() {
   static const char* ip = "127.0.0.1";
   static const boost::uint16_t port = 44550;
 
   // io_service - основа asio.
   boost::asio::io_service ios;
 
   // объект реализующий "вечную задачу".
   boost::shared_ptr<boost::asio::io_service::work> work(new boost::asio::io_service::work(ios));
 
   // определяем кол-во ядер.
   size_t cpu_count = boost::thread::hardware_concurrency();
 
   // создаем кол-во рабочих потоков равное кол-ву ядер.
   boost::thread_group work_threads;
   for ( size_t idx = 0; idx < cpu_count; ++idx ) {
      work_threads.create_thread(boost::bind(&boost::asio::io_service::run, &ios));
   }
 
   // объект представляющий адрес для TCP соединений.
   boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string(ip), port);
 
   // объект акксептора соединений.
   boost::asio::ip::tcp::acceptor acceptor(ios, endpoint);
 
   // запускаем асинхронный прием запросов на подключение
   start_accept(&acceptor);
 
   // сбрасываем "вечную задачу".
   work.reset();
 
   // работаем пока не завершаться все потоки.
   work_threads.join_all();
 
   // завершаемся.
   return 0;
}
 
/***************************************************************************/
 
// создаем асинхронную операцию аксепта
void start_accept(
   boost::asio::ip::tcp::acceptor* acceptor)
{
   // создаем объект сокета который будет связан с принятым подключением.
   socket_ptr socket(new socket_ptr::element_type(acceptor->get_io_service()));
 
   // создаем операци. асинхронного аксепта.
   acceptor->async_accept(
      *socket,
      boost::bind(
         &on_accept_handler,
         acceptor,
         socket,
         boost::asio::placeholders::error
      )
   );
}
 
// вызовется при приеме нового подключения.
void on_accept_handler(
   boost::asio::ip::tcp::acceptor* acceptor,
   socket_ptr socket,
   const boost::system::error_code& error)
{
   if ( !error ) {
      // создаем shared_array который должен жить вплоть до окончании асинхронного чтения.
      // для этого, message передаем как аргумент в функциональный объект, для того, чтоб инкрементировать счетчик ссылок.
      boost::shared_array<char> message(new char[message_len]);
 
      // для принятого соединения запускаем операцию асинхронного чтения.
      boost::asio::async_read(
         *socket,
         boost::asio::buffer(message.get(), message_len),
         boost::asio::transfer_at_least(2),
         boost::bind(
            &on_async_read,
            socket,
            message,
            boost::asio::placeholders::error
         )
      );
   } else {
      std::cout << "on_accept_handler() error: " << error.message() << std::endl;
   }
 
   // снова запускаем асинхронный прием запросов на подключение
   start_accept(acceptor);
}
 
/***************************************************************************/
 
// вызовется при завершении асинхронного чтения.
 
// примечание: аргумент message и socket, разрушаться при выходе из функции.
void on_async_read(
   socket_ptr socket,
   boost::shared_array<char> message,
   const boost::system::error_code& error)
{
   if ( !error ) {
      std::cout << "received message: " << message.get() << std::endl;
   } else {
      std::cout << "on_async_read() error: " << error.message() << std::endl;
   }
}
 
/***************************************************************************/