LINUX.ORG.RU

boost.asio, boost.serialization


0

1

Почему сие зависает (и сервер, и клиент) при попытке клиента подключится? Server:

#include <ctime>
#include <iostream>
#include <string>
#include <boost/asio.hpp>
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>
using boost::asio::ip::tcp;
using namespace boost::archive;
using namespace std;
class rpc_function
{
	public:
		virtual void load(text_iarchive& arr,const unsigned version)=0;
		virtual void save(text_oarchive& arr,const unsigned version)const=0;
		BOOST_SERIALIZATION_SPLIT_MEMBER();
		virtual void operator()()=0;
};
class hello_world_func:public rpc_function
{
	string res;
	public:
		void load(text_iarchive& arr,const unsigned version)
		{
		}
		void save(text_oarchive& arr,const unsigned version)const
		{
			arr << res;
		}
		void operator()()
		{
			res="Hello, World!\n";
		}
		
};
const size_t func_cnt=1;
rpc_function* funcs[func_cnt];
struct func_data
{
	unsigned func_id;
	template<class archive>
	void load(archive& arr,const unsigned version)
	{
		arr >> func_id;
		arr >> (*funcs[func_id]);
	}
	template<class archive>
	void save(archive& arr,const unsigned version)const
	{
//		arr  func_id;
		arr << (*funcs[func_id]);
	}
	BOOST_SERIALIZATION_SPLIT_MEMBER();
	void operator()()
	{
		(*funcs[func_id])();
	}
};


int main()
{
	funcs[0]=new hello_world_func();
  try
  {
    boost::asio::io_service io_service;

    tcp::endpoint endpoint(tcp::v4(), 31005);
    tcp::acceptor acceptor(io_service, endpoint);

    for (;;)
    {
      tcp::iostream stream;
      acceptor.accept(*stream.rdbuf());
	  func_data fd;
	  text_iarchive ar(stream);
	  ar>>fd;
	  fd();
	  text_oarchive ar2(stream);
	  ar2<<fd;
	  stream.close();
    }
  }
  catch (std::exception& e)
  {
    std::cerr << e.what() << std::endl;
  }

  return 0;
}
Client:

#include <iostream>
#include <string>
#include <boost/asio.hpp>
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>

using boost::asio::ip::tcp;
using namespace boost::archive;
using namespace std;
class func_data
{
		unsigned int fdata;
		string res;
	public:
		func_data(unsigned int _fdata){fdata=_fdata;}
		template <typename Archive>
		void load(Archive& arr,const unsigned int version)
		{
			arr >> res;
		}
		template <typename Archive>
		void save(Archive& arr,const unsigned int version)const
		{
			arr << fdata;
		}
		void printRes(){cout<<res;}
		BOOST_SERIALIZATION_SPLIT_MEMBER();
};

int main(int argc, char* argv[])
{
  try
  {
    if (argc != 2)
    {
      std::cerr << "Usage: client2 <host>" << std::endl;
      return 1;
    }

    tcp::iostream stream(argv[1], "31005");
    /*std::string line;
    std::getline(s, line);
    std::cout << line << std::endl;*/
	func_data fd(0);
	{
		text_oarchive oar(stream);
		oar<<fd;
		text_iarchive iar(stream);
		iar>>fd;
	}
  }
  catch (std::exception& e)
  {
    std::cout << "Exception: " << e.what() << std::endl;
  }

  return 0;
}
PS. Признаюсь честно: часть скопипащена из экзамплов boost.

Запусти strace да посмотри. Код не читал

yoghurt ★★★★★ ()
Ответ на: комментарий от yoghurt

c++ код будет тяжко через strace разобрать, через gdb проще. в сервере не вижу вызова io_service.run(), зависает из за бесконечного цикла. клиент зависает из за того что подключается к серверу (acceptor-то создан и порт открыт) но дальшейшей обработки событий не происходит из за того что io_service.run() не вызывается. io_service.run() делает обработку событий которые находятся в очереди (например полученные данные или полученные соединения), вызывает нужные обработчики (из этого же треда в котором он был вызван) и помойму завершает выполнение. я обычно запускал отдельный тред в котором io_service.run() крутился по кругу в бесконечном цикле. смотрите примеры в asio.

ioan ()
Ответ на: комментарий от ioan

ps. io_service.run() должен пахать везде где юзаешь асинхронные сокеты. btw. я сразу не обратил внимание, может у вас синхронные, я ни разу их не юзал с asio, поэтому точно не скажу насчёт них.

ioan ()
Ответ на: комментарий от ioan

У мну сокеты синхронные. Там io_service.run() не нужен. С проблемой разобрался. Проблема была немного не в том. Зависало на конструкторах архивов (ждало ввода). Переписал - теперь данные считываются в буфер, из которого создается istringstream, из которого создается архив, из которого осуществляется ввод.

Потом вообще с нуля переписал, теперь ни капли копипасты, и совсем другая архитектура - намного проще и красивее :) и даже короче :)

Тему можно считать закрытой.

franchukroman ★★☆ ()
Вы не можете добавлять комментарии в эту тему. Тема перемещена в архив.