Changeset 4953 in ntrip

Timestamp:

Feb 23, 2013, 5:36:26 PM (12 years ago)

Author:

mervart

Message:

 

File:

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

trunk/GnssCenter/thrift/test2/server.cpp

@@ -8 +8 @@
 #include <thrift/concurrency/Thread.h>
 #include <thrift/concurrency/PosixThreadFactory.h>
+#include <thrift/concurrency/Mutex.h>
 
 #include "gen-cpp/myService.h"
@@ -28 +29 @@
 };
 
+Mutex MUTEX;
 shared_ptr<t_connection> CONNECTION;
 
@@ -34 +36 @@
   myProcessorFactory() {};
   shared_ptr<TProcessor>   getProcessor(const TConnectionInfo& info) {
+
+    Guard m(MUTEX);
+
     shared_ptr<myServiceClient> client(new myServiceClient(info.output));
     shared_ptr<TProcessor>      processor(new myServiceProcessor(client));
@@ -78 +83 @@
   try {
     while (true) {
-      if (CONNECTION) {
-        CONNECTION->_client->answer("How are you?");
+      {
+        Guard m(MUTEX);
+        if (CONNECTION) {
+          CONNECTION->_client->answer("How are you?");
+        }
       }
       sleep(1);