Changeset 4946 in ntrip

Timestamp:

Feb 23, 2013, 4:24:34 PM (12 years ago)

Author:

mervart

Message:

 

File:

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

trunk/GnssCenter/thrift/test2/server.cpp

@@ -6 +6 @@
 #include <thrift/transport/TServerSocket.h>
 #include <thrift/transport/TBufferTransports.h>
+#include <thrift/concurrency/Thread.h>
 
 #include "gen-cpp/myService.h"
@@ -15 +16 @@
 using namespace ::apache::thrift::transport;
 using namespace ::apache::thrift::server;
+using namespace ::apache::thrift::concurrency;
 
 class myService : virtual public myServiceIf {
@@ -52 +54 @@
 };
 
+class t_serverThread : public Runnable {
+ public:
+  t_serverThread() {}
+  void run() {
+    int port = 9090;
+    shared_ptr<TServerSocket>      serverTransport(new TServerSocket(port));
+    shared_ptr<myProcessorFactory> processorFactory(new myProcessorFactory());
+    shared_ptr<TTransportFactory>  transportFactory(new TBufferedTransportFactory());
+    shared_ptr<TProtocolFactory>   protocolFactory(new TBinaryProtocolFactory());
+
+    TThreadedServer server(processorFactory, serverTransport,
+                           transportFactory, protocolFactory);
+    server.serve();
+  }
+};
+
 int main(int argc, char **argv) {
-  int port = 9090;
-  shared_ptr<TServerSocket>      serverTransport(new TServerSocket(port));
-  shared_ptr<myProcessorFactory> processorFactory(new myProcessorFactory());
-  shared_ptr<TTransportFactory>  transportFactory(new TBufferedTransportFactory());
-  shared_ptr<TProtocolFactory>   protocolFactory(new TBinaryProtocolFactory());
 
-  TThreadedServer server(processorFactory, serverTransport,
-                         transportFactory, protocolFactory);
+  t_serverThread serverThread;
+  serverThread.run();
 
-  server.serve();
+  while (true) {
+    sleep(1);
+  }
 
   return 0;