source: ntrip/trunk/GnssCenter/map_stations/thriftclient.cpp@ 5427

Last change on this file since 5427 was 5427, checked in by mervart, 9 years ago
File size: 3.7 KB
Line 
1
2#include <iostream>
3#include <iomanip>
4#include <sstream>
5#include <vector>
6
7#include "thriftclient.h"
8#include "map_stations.h"
9
10using namespace apache::thrift;
11using namespace apache::thrift::protocol;
12using namespace apache::thrift::transport;
13
14using namespace com::gpssolutions::rtnet;
15using namespace std;
16using namespace boost;
17
18// Constructor
19//////////////////////////////////////////////////////////////////////////////
20t_thriftClient::t_thriftClient(GnssCenter::t_map_stations* parent) {
21 _stop = false;
22 _parent = parent;
23}
24
25// Destructor
26//////////////////////////////////////////////////////////////////////////////
27t_thriftClient::~t_thriftClient() {
28}
29
30// Run (virtual)
31//////////////////////////////////////////////////////////////////////////////
32void t_thriftClient::run() {
33
34 string host = "rtnet.rtcm-ntrip.org";
35 int port = 7777;
36
37 shared_ptr<TSocket> socket(new TSocket(host, port));
38 shared_ptr<TTransport> transport(new TBufferedTransport(socket));
39 shared_ptr<TProtocol> protocol(new TBinaryProtocol(transport));
40 shared_ptr<RtnetDataIf> dataHandler(new t_thriftHandler(_parent));
41 shared_ptr<TProcessor> processor(new RtnetDataProcessor(dataHandler));
42
43 try {
44 transport->open();
45 while (true) {
46 {
47 QMutexLocker locker(&_mutex);
48 if (_stop) {
49 break;
50 }
51 }
52 if (processor->process(protocol,protocol,0) == 0) {
53 break;
54 }
55 }
56 transport->close();
57 }
58 catch (TException& e) {
59 cerr << "Caught an exception generated by Thrift: " << e.what() << endl;
60 }
61 catch (...) {
62 cerr << "Unknown exception" << endl;
63 }
64 this->terminate();
65 this->deleteLater();
66}
67
68// Constructor
69//////////////////////////////////////////////////////////////////////////////
70t_thriftHandler::t_thriftHandler(GnssCenter::t_map_stations* parent) {
71 _parent = parent;
72}
73
74// Destructor
75//////////////////////////////////////////////////////////////////////////////
76t_thriftHandler::~t_thriftHandler() {
77}
78
79// Handle Satellite Positions
80//////////////////////////////////////////////////////////////////////////////
81void t_thriftHandler::
82handleSatelliteXYZ(const vector<SatelliteXYZ>& svXYZList) {
83 cout.setf(ios::fixed);
84 for (unsigned ii = 0; ii < svXYZList.size(); ii++) {
85// const SatelliteXYZ& sat = svXYZList[ii];
86// cout << unsigned(sat.ID) << ' '
87// << setprecision(3) << sat.xyz.x << ' '
88// << setprecision(3) << sat.xyz.y << ' '
89// << setprecision(3) << sat.xyz.z << endl;
90 }
91// cout << endl;
92}
93
94// Handle Station Info
95//////////////////////////////////////////////////////////////////////////////
96void t_thriftHandler::
97handleStationInfo(const vector<StationInfo>& stationList) {
98 for (unsigned ii = 0; ii < stationList.size(); ii++) {
99 const StationInfo& staInfo = stationList[ii];
100 _stationCrd[staInfo.ID]._x = staInfo.xyz.x;
101 _stationCrd[staInfo.ID]._y = staInfo.xyz.y;
102 _stationCrd[staInfo.ID]._z = staInfo.xyz.z;
103 }
104}
105
106// Handle Epoch Results
107//////////////////////////////////////////////////////////////////////////////
108void t_thriftHandler::
109handleEpochResults(const RtnetEpoch& epoch) {
110 vector<t_thriftResult*>* results = new vector<t_thriftResult*>;
111 for (unsigned ii = 0; ii < epoch.stationResultList.size(); ii++) {
112 const StationResults& staRes = epoch.stationResultList[ii];
113 t_thriftResult* res = new t_thriftResult;
114 res->_name = staRes.stationName;
115 res->_nGPS = staRes.nsv_gps_used;
116 res->_nGLO = staRes.nsv_glonass_used;
117 if (_stationCrd.find(staRes.stationName) != _stationCrd.end()) {
118 res->_x = _stationCrd[staRes.stationName]._x;
119 res->_y = _stationCrd[staRes.stationName]._y;
120 res->_z = _stationCrd[staRes.stationName]._z;
121 }
122 results->push_back(res);
123 }
124 _parent->putThriftResults(results);
125}
Note: See TracBrowser for help on using the repository browser.