Неблокирующий Thrift-сервер в C ++ и Thrift-клиент в Python - PullRequest
Новая
       37

Неблокирующий Thrift-сервер в C ++ и Thrift-клиент в Python

3 голосов
/ 16 ноября 2011

У меня есть неблокирующий многопоточный сервер Thrift, написанный на C ++, и клиент Thrift, написанный на Python.Ниже приведены фрагменты кода, в которых кратко показано, как выполняются настройки Thrift-протокола и привязки как на сервере C ++, так и на Python-клиенте.

Моя проблема заключается в том, что, когда клиент Python выполняет вызов на C ++-сервер с помощью Thrift, я получаю сообщение об ошибке:« Условие перегрузки неблокирующего сервера » в выходных данных сервера C ++ (т. Е. Терминала), которые указаны в 3-м и 4-м фрагментах ниже.Я прилагаю стек, который извлекается с помощью команды GDB backtrace, а также для вашей информации.Может кто-нибудь сказать мне, что мне здесь не хватает?Как вы думаете, может быть причиной этой ошибки.Есть ли что-то не так в конфигурации Thrift на стороне Python или C ++.Пожалуйста, обратитесь к приведенным ниже фрагментам.Я много гуглил, но пока не мог найти подсказки.Спасибо.

1) Клиент Python - конфигурация Thrift 

     try:
        self.transport = TSocket.TSocket( host , port)
        <----- NONBLOCKING --------->
        self.transport = TTransport.TFramedTransport(self.transport)    
        <----- NONBLOCKING --------->
        protocol = TBinaryProtocol.TBinaryProtocol(self.transport)


        # Instantiate the thrift client
        self.client = MyService.Client(protocol)
        # Connect to the thrift server
        self.transport.open()
        print 'Connection established via thrift...\n'

2) Сервер C ++ - конфигурация Thrift 

    using boost::shared_ptr;
    printf("          *** Starting non-block THRIFT! ***\n");
    shared_ptr<MyServiceHandler> handler(new MyServiceHandler(this));
    shared_ptr<TProcessor> processor(new MyServiceProcessor(handler));
    shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory());

    shared_ptr<ThreadManager>  threadManager=ThreadManager::newSimpleThreadManager(15);
    shared_ptr<PosixThreadFactory> threadFactory =
    shared_ptr<PosixThreadFactory>(new PosixThreadFactory());
    threadManager->threadFactory(threadFactory);
    threadManager->start();
    ats::TNonblockingServer server(processor,protocolFactory, port, threadManager);
    server.serve();

3) Вывод ошибок на сервере C ++ 

   !!!! ERROR BEGIN !!!! 
   Thrift: Tue Nov 15 17:59:49 2011 **thrift non-blocking server overload condition**
   !!!! ERROR IS END !!!!

4) Стек обратной трассировки GDB 

   thrift non-blocking server overload condition

   Program received signal SIGSEGV, Segmentation fault.
   [Switching to Thread 0xb7ad7b70 (LWP 17961)]
   0x080bb3a8 in vtable for __cxxabiv1::__si_class_type_info ()
  (gdb) bt
  #0 0x080bb3a8 in vtable for __cxxabiv1::__si_class_type_info ()
  #1 0xb7ec8195 in apache::thrift::server::TConnection::workSocket (this=0x80be4f0)
  at src/server/TNonblockingServer.cpp:168
  #2 0xb7ecc88d in apache::thrift::server::TConnection::eventHandler (fd=13, v=0x80be4f0)
  at src/server/TNonblockingServer.h:915
  #3 0xb7ea8e90 in event_base_loop () from /usr/lib/libevent-1.4.so.2
  #4 0xb7ec782f in apache::thrift::server::TNonblockingServer::serve (this=0xb7ad7194)
  at src/server/TNonblockingServer.cpp:923
  #5 0x0807bef5 in MyConfiguration::runNonBlockingServer (this=0xbffff2ec, port=9090)
  at /home/configuration/my_configuration.cpp:485
  #6 0x0807de19 in MyConfiguration::run (this=0xbffff2ec)
  at /home/configuration/my_configuration.cpp:54
  #7 0x08078a2a in redirectPthreadRun (m=0xbffff2ec)
  at /home/src/common/p_thread_run.cpp:107
  #8 0xb7fa0725 in start_thread () from /lib/libpthread.so.0
  #9 0xb7ceb1ce in clone () from /lib/libc.so.6
...