Changeset 4952 in ntrip for trunk/GnssCenter/thrift/test2

Timestamp:

Feb 23, 2013, 5:24:52 PM (12 years ago)

Author:

mervart

Message:

 

File:

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

trunk/GnssCenter/thrift/test2/server.cpp

@@ -19 +19 @@
 using namespace apache::thrift::concurrency;
 
-class myService : virtual public myServiceIf {
- public:
-  myService() {}
-  void answer(const std::string& question) {
-    // implemented on the client-side only
-  }
-};
-
 class t_connection {
  public:
-  shared_ptr<myService>       _service;
   shared_ptr<myServiceClient> _client;
   shared_ptr<TProcessor>      _processor;
@@ -44 +35 @@
   shared_ptr<TProcessor>   getProcessor(const TConnectionInfo& info) {
     shared_ptr<myServiceClient> client(new myServiceClient(info.output));
-    shared_ptr<myService>       service(new myService());
-    shared_ptr<TProcessor>      processor(new myServiceProcessor(service));
-    cout << "connection " << endl;
+    shared_ptr<TProcessor>      processor(new myServiceProcessor(client));
+
+    cout << "new connection " << endl;
 
     CONNECTION.reset(new t_connection);   
-    CONNECTION->_service     = service;
     CONNECTION->_client      = client;
     CONNECTION->_processor   = processor;
@@ -86 +76 @@
   thread->start();
 
-  cout << "server thread started" << endl;
-
-  while (true) {
-    cout << "sleep ..." << endl;
-    if (CONNECTION) {
-      cout << "CONNECTION " << endl;
-      CONNECTION->_client->answer("How are you?");
+  try {
+    while (true) {
+      if (CONNECTION) {
+        CONNECTION->_client->answer("How are you?");
+      }
+      sleep(1);
     }
-    sleep(1);
+  } catch (TException& exc) {
+    cout << "Exception: " << exc.what() << endl;
   }