Changeset 4943 in ntrip for trunk/GnssCenter/thrift

Timestamp:

Feb 23, 2013, 3:41:59 PM (12 years ago)

Author:

mervart

Message:

 

Location:

trunk/GnssCenter/thrift/test2

Files:

• Makefile (modified) (1 diff)
• server.cpp (modified) (3 diffs)

trunk/GnssCenter/thrift/test2/Makefile

@@ -24 +24 @@
 
 server: server.o $(GEN_OBJ)
-        $(CXX) $^ -o $@ -L$(LIB_DIR) -lthrift 
+        $(CXX) $^ -o $@ -L$(LIB_DIR) -lthrift
 
 client: client.o $(GEN_OBJ)
-        $(CXX) $^ -o $@ -L$(LIB_DIR) -lthrift 
+        $(CXX) $^ -o $@ -L$(LIB_DIR) -lthrift
 
 clean:

trunk/GnssCenter/thrift/test2/server.cpp

@@ -3 +3 @@
 
 #include <thrift/protocol/TBinaryProtocol.h>
-#include <thrift/server/TSimpleServer.h>
+#include <thrift/server/TThreadedServer.h>
 #include <thrift/transport/TServerSocket.h>
 #include <thrift/transport/TBufferTransports.h>
@@ -19 +19 @@
  public:
   myServiceHandler() {}
-  void answer(std::string& /* answ */, const std::string& /* question */) {
+  void answer(std::string& answ, const std::string& question) {
     // implemented on the client-side only
   }
 };
 
-class myServerEventHandler : virtual public TServerEventHandler {
+class myProcessorFactory : virtual public TProcessorFactory {
  public:
-  myServerEventHandler() {};
-  virtual void* createContext(shared_ptr<TProtocol> input,
-                              shared_ptr<TProtocol> output) {
-    void* context = TServerEventHandler::createContext(input, output);
-    cout << "createContext " << context << endl;
-
-    string* str = static_cast<string*>(context);
-    cout << "str = " << str << endl;
-
-    return context;
+  myProcessorFactory() {};
+  shared_ptr<TProcessor> getProcessor(const TConnectionInfo& info) {
+    shared_ptr<myServiceHandler> handler(new myServiceHandler());
+    shared_ptr<TProcessor>       processor(new myServiceProcessor(handler));
+    return processor;
   }
 };
@@ -41 +36 @@
 int main(int argc, char **argv) {
   int port = 9090;
-  shared_ptr<myServiceHandler>  handler(new myServiceHandler());
-  shared_ptr<TProcessor>        processor(new myServiceProcessor(handler));
-  shared_ptr<TServerSocket>     serverTransport(new TServerSocket(port));
-  shared_ptr<TTransportFactory> transportFactory(new TBufferedTransportFactory());
-  shared_ptr<TProtocolFactory>  protocolFactory(new TBinaryProtocolFactory());
+  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());
 
-  TSimpleServer server(processor, serverTransport, 
-                       transportFactory, protocolFactory);
-
-  shared_ptr<TServerEventHandler> eventHandler(new myServerEventHandler());
-  server.setServerEventHandler(eventHandler);
+  TThreadedServer server(processorFactory, serverTransport,
+                         transportFactory, protocolFactory);
 
   server.serve();
+
   return 0;
 }