Changeset 5409 in ntrip for trunk/GnssCenter

Timestamp:

Sep 10, 2013, 3:15:35 PM (11 years ago)

Author:

mervart

Message:

 

Location:

trunk/GnssCenter/map_stations

Files:

• thriftclient.cpp (modified) (1 diff)
• thriftclient.h (modified) (2 diffs)

trunk/GnssCenter/map_stations/thriftclient.cpp

@@ -14 +14 @@
 using namespace boost;
 
-// // Program
-// //////////////////////////////////////////////////////////////////////////////
-// int main(int argc, char **argv) {
-// 
-//   // Parse Input Options
-//   // -------------------
-//   map<string, string> OPT;
-//   parseCmdLine(argc, argv, OPT);
-//   if (OPT.find("port") == OPT.end()) {
-//     cerr << "usage: rtnetThriftClient [--host <host>] --port <port>" << endl;
-//     return 1;
-//   }
-//   string host = OPT.find("host") == OPT.end() ? "localhost" : OPT["host"];
-//   int    port; istringstream(OPT["port"]) >> port;
-// 
-//   shared_ptr<TSocket>     socket(new TSocket(host, port));
-//   shared_ptr<TTransport>  transport(new TBufferedTransport(socket)); 
-//   shared_ptr<TProtocol>   protocol(new TBinaryProtocol(transport));
-//   shared_ptr<RtnetDataIf> dataHandler(new t_thriftClient());
-//   shared_ptr<TProcessor>  processor(new RtnetDataProcessor(dataHandler));
-// 
-//   try {
-//     transport->open();
-// 
-//     while (processor->process(protocol,protocol,0)) {}
-// 
-//     transport->close();
-//   } 
-//   catch (TException& e) {
-//     cerr << "Caught an exception generated by Thrift: " << e.what() << endl;
-//     return 1;
-//   } 
-//   catch (...) {
-//     cerr << "Unknown exception" << endl;
-//     return 1;
-//   }
-// 
-//   return 0;
-// }
+// Constructor
+//////////////////////////////////////////////////////////////////////////////
+t_thriftClient::t_thriftClient() {
+
+}
+
+// Destructor
+//////////////////////////////////////////////////////////////////////////////
+t_thriftClient::~t_thriftClient() {
+
+}
+
+// Run (virtual)
+//////////////////////////////////////////////////////////////////////////////
+void t_thriftClient::run() {
+
+  string host = "rtnet.rtcm-ntrip.org";
+  int    port = 7777;
+
+  shared_ptr<TSocket>     socket(new TSocket(host, port));
+  shared_ptr<TTransport>  transport(new TBufferedTransport(socket)); 
+  shared_ptr<TProtocol>   protocol(new TBinaryProtocol(transport));
+  shared_ptr<RtnetDataIf> dataHandler(new t_thriftClient());
+  shared_ptr<TProcessor>  processor(new RtnetDataProcessor(dataHandler));
+
+  try {
+    transport->open();
+    while (processor->process(protocol,protocol,0)) {}
+    transport->close();
+  } 
+  catch (TException& e) {
+    cerr << "Caught an exception generated by Thrift: " << e.what() << endl;
+  } 
+  catch (...) {
+    cerr << "Unknown exception" << endl;
+  }
+}
 
 // Handle Satellite Positions

trunk/GnssCenter/map_stations/thriftclient.h

@@ -4 +4 @@
 #include <string>
 #include <map>
+#include <QThread>
 
 #include <transport/TSocket.h>
@@ -15 +16 @@
 // Handler Class Definition
 //////////////////////////////////////////////////////////////////////////////
-class t_thriftClient : public com::gpssolutions::rtnet::RtnetDataIf {
+class t_thriftClient : public com::gpssolutions::rtnet::RtnetDataIf, QThread {
  public:
-  t_thriftClient() {}
-  ~t_thriftClient() {}
+  t_thriftClient();
+  ~t_thriftClient();
+  virtual void run();
 
   void startDataStream() {}