source: ntrip/trunk/BNC/src/bncnetqueryudp.cpp@ 9961

Last change on this file since 9961 was 9961, checked in by stuerze, 16 months ago

minor changes to be msvc compatible

File size: 4.8 KB
Line 
1/* -------------------------------------------------------------------------
2 * BKG NTRIP Client
3 * -------------------------------------------------------------------------
4 *
5 * Class: bncNetQueryUdp
6 *
7 * Purpose: Blocking Network Requests (NTRIP Version 2 with plain UDP)
8 *
9 * Author: L. Mervart
10 *
11 * Created: 04-Feb-2009
12 *
13 * Changes:
14 *
15 * -----------------------------------------------------------------------*/
16
17#include <iostream>
18#include <iomanip>
19#include <time.h>
20
21#include <QHostInfo>
22
23#include "bncnetqueryudp.h"
24#include "bncsettings.h"
25#include "bncversion.h"
26
27using namespace std;
28
29#define TIME_RESOLUTION 125
30
31// Constructor
32////////////////////////////////////////////////////////////////////////////
33bncNetQueryUdp::bncNetQueryUdp() {
34 _port = 0;
35 _udpSocket = 0;
36 _eventLoop = new QEventLoop(this);
37
38 _keepAlive[0] = 128;
39 _keepAlive[1] = 96;
40 for (int ii = 2; ii <=11; ii++) {
41 _keepAlive[ii] = 0;
42 }
43}
44
45// Destructor
46////////////////////////////////////////////////////////////////////////////
47bncNetQueryUdp::~bncNetQueryUdp() {
48 delete _eventLoop;
49 delete _udpSocket;
50}
51
52//
53////////////////////////////////////////////////////////////////////////////
54void bncNetQueryUdp::stop() {
55 _eventLoop->quit();
56 _status = finished;
57}
58
59//
60////////////////////////////////////////////////////////////////////////////
61void bncNetQueryUdp::slotKeepAlive() {
62 if (_udpSocket) {
63 _udpSocket->writeDatagram(_keepAlive, 12, _address, _port);
64 }
65 QTimer::singleShot(15000, this, SLOT(slotKeepAlive()));
66}
67
68//
69////////////////////////////////////////////////////////////////////////////
70void bncNetQueryUdp::waitForRequestResult(const QUrl&, QByteArray&) {
71}
72
73//
74////////////////////////////////////////////////////////////////////////////
75void bncNetQueryUdp::waitForReadyRead(QByteArray& outData) {
76
77 // Wait Loop
78 // ---------
79 if (!_udpSocket->hasPendingDatagrams()) {
80 _eventLoop->exec();
81 }
82
83 // Append Data
84 // -----------
85 QByteArray datagram;
86 datagram.resize(_udpSocket->pendingDatagramSize());
87 _udpSocket->readDatagram(datagram.data(), datagram.size());
88
89 if (datagram.size() > 12) {
90 outData.append(datagram.mid(12));
91 }
92 else {
93 _status = error;
94 }
95}
96
97// Connect to Caster, send the Request
98////////////////////////////////////////////////////////////////////////////
99void bncNetQueryUdp::startRequest(const QUrl& url, const QByteArray& gga) {
100
101 _status = running;
102
103 // Default scheme and path
104 // -----------------------
105 _url = url;
106 if (_url.scheme().isEmpty()) {
107 _url.setScheme("http");
108 }
109 if (_url.path().isEmpty()) {
110 _url.setPath("/");
111 }
112
113 _port = _url.port();
114
115 delete _udpSocket;
116 _udpSocket = new QUdpSocket();
117 _udpSocket->bind(0);
118 connect(_udpSocket, SIGNAL(readyRead()), _eventLoop, SLOT(quit()));
119
120 QHostInfo hInfo = QHostInfo::fromName(url.host());
121
122 if (!hInfo.addresses().isEmpty()) {
123
124 _address = hInfo.addresses().first();
125
126 // Send Request
127 // ------------
128 QString uName = QUrl::fromPercentEncoding(_url.userName().toLatin1());
129 QString passW = QUrl::fromPercentEncoding(_url.password().toLatin1());
130 QByteArray userAndPwd;
131
132 if(!uName.isEmpty() || !passW.isEmpty()) {
133 userAndPwd = "Authorization: Basic " + (uName.toLatin1() + ":" +
134 passW.toLatin1()).toBase64() + "\r\n";
135 }
136
137 QByteArray reqStr = "GET " + _url.path().toLatin1() + " HTTP/1.1\r\n"
138 + "Host: " + _url.host().toLatin1() + "\r\n"
139 + "Ntrip-Version: Ntrip/2.0\r\n"
140 + "User-Agent: NTRIP BNC/" BNCVERSION " (" BNC_OS ")\r\n";
141 if (!gga.isEmpty()) {
142 reqStr += "Ntrip-GGA: " + gga + "\r\n";
143 }
144 reqStr += userAndPwd + "Connection: close\r\n\r\n";
145
146 char* rtpbuffer;
147 rtpbuffer = (char*)malloc((12 + reqStr.size())*sizeof(char));
148 rtpbuffer[0] = 128;
149 rtpbuffer[1] = 97;
150 for (int jj = 2; jj <= 11; jj++) {
151 rtpbuffer[jj] = _keepAlive[jj];
152 }
153 for (int ii = 0; ii < reqStr.size(); ii++) {
154 rtpbuffer[12+ii] = reqStr[ii];
155 }
156
157 _udpSocket->writeDatagram(rtpbuffer, 12 + reqStr.size(), _address, _port);
158
159 // Wait for Reply, read Session Number
160 // -----------------------------------
161 QByteArray repl;
162 waitForReadyRead(repl);
163
164 QTextStream in(repl);
165 QString line = in.readLine();
166 while (!line.isEmpty()) {
167 if (line.indexOf("Session:") == 0) {
168 _session = line.mid(9).toUInt();
169 _keepAlive[ 8] = (_session >> 24) & 0xFF;
170 _keepAlive[ 9] = (_session >> 16) & 0xFF;
171 _keepAlive[10] = (_session >> 8) & 0xFF;
172 _keepAlive[11] = (_session) & 0xFF;
173 break;
174 }
175 line = in.readLine();
176 }
177
178 QTimer::singleShot(15000, this, SLOT(slotKeepAlive()));
179 }
180}
181
182void bncNetQueryUdp::keepAliveRequest(const QUrl& /* url */ , const QByteArray& /* gga */) {
183}
Note: See TracBrowser for help on using the repository browser.