Changeset 4948 in ntrip

Timestamp:

Feb 23, 2013, 4:56:07 PM (12 years ago)

Author:

mervart

Message:

 

File:

• trunk/GnssCenter/thrift/test2/server.cpp (modified) (5 diffs)

trunk/GnssCenter/thrift/test2/server.cpp

@@ -7 +7 @@
 #include <thrift/transport/TBufferTransports.h>
 #include <thrift/concurrency/Thread.h>
+#include <thrift/concurrency/PosixThreadFactory.h>
 
 #include "gen-cpp/myService.h"
@@ -12 +13 @@
 using namespace std;
 using namespace boost;
-using namespace ::apache::thrift;
-using namespace ::apache::thrift::protocol;
-using namespace ::apache::thrift::transport;
-using namespace ::apache::thrift::server;
-using namespace ::apache::thrift::concurrency;
+using namespace apache::thrift;
+using namespace apache::thrift::protocol;
+using namespace apache::thrift::transport;
+using namespace apache::thrift::server;
+using namespace apache::thrift::concurrency;
 
 class myService : virtual public myServiceIf {
@@ -45 +46 @@
     cout << "connection " << endl;
 
-    shared_ptr<t_connection> connection(new t_connection);
-    connection->_service     = service;
-    connection->_processor   = processor;
-    connection->_protocolInp = info.input;
-    connection->_protocolOut = info.output;
-    connection->_transport   = info.transport;
+    CONNECTION.reset(new t_connection);   
+    CONNECTION->_service     = service;
+    CONNECTION->_processor   = processor;
+    CONNECTION->_protocolInp = info.input;
+    CONNECTION->_protocolOut = info.output;
+    CONNECTION->_transport   = info.transport;
    
     return processor;
@@ -56 +57 @@
 };
 
-class t_serverThread : public Runnable {
+class t_serverThread : public apache::thrift::concurrency::Runnable {
  public:
   t_serverThread() {}
+  ~t_serverThread() {}
   void run() {
     int port = 9090;
@@ -69 +71 @@
                            transportFactory, protocolFactory);
     server.serve();
-  }
+  }   
 };
 
 int main(int argc, char **argv) {
 
-  t_serverThread serverThread;
-  serverThread.run();
+  shared_ptr<PosixThreadFactory> threadFactory(new PosixThreadFactory);
+
+  shared_ptr<t_serverThread> serverThread(new t_serverThread);  
+
+  shared_ptr<Thread> thread = threadFactory->newThread(serverThread);
+  thread->start();
+
+  cout << "server thread started" << endl;
 
   while (true) {
+    cout << "sleep ..." << endl;
     sleep(1);
   }