source: ntrip/trunk/BNC/src/bncnetqueryrtp.cpp@ 6478

Last change on this file since 6478 was 4278, checked in by mervart, 12 years ago
File size: 7.1 KB
RevLine 
[1410]1/* -------------------------------------------------------------------------
2 * BKG NTRIP Client
3 * -------------------------------------------------------------------------
4 *
5 * Class: bncNetQueryRtp
6 *
[1411]7 * Purpose: Blocking Network Requests (NTRIP Version 2 with RTSP)
[1410]8 *
9 * Author: L. Mervart
10 *
11 * Created: 27-Dec-2008
12 *
13 * Changes:
14 *
15 * -----------------------------------------------------------------------*/
16
17#include <iostream>
18#include <iomanip>
19
20#include "bncnetqueryrtp.h"
[1535]21#include "bncsettings.h"
[2011]22#include "bncversion.h"
[1410]23
24using namespace std;
25
26// Constructor
27////////////////////////////////////////////////////////////////////////////
28bncNetQueryRtp::bncNetQueryRtp() {
[1412]29 _socket = 0;
30 _udpSocket = 0;
[1530]31 _CSeq = 0;
[1414]32 _eventLoop = new QEventLoop(this);
[1410]33}
34
35// Destructor
36////////////////////////////////////////////////////////////////////////////
37bncNetQueryRtp::~bncNetQueryRtp() {
[1414]38 delete _eventLoop;
[1410]39 delete _socket;
[1412]40 delete _udpSocket;
[1410]41}
42
43//
44////////////////////////////////////////////////////////////////////////////
45void bncNetQueryRtp::stop() {
[1414]46 _eventLoop->quit();
[1410]47 _status = finished;
[1532]48 if (_socket) {
49 QByteArray reqStr = "TEARDOWN " + _url.toEncoded() + " RTSP/1.0\r\n"
50 + "CSeq: " + QString("%1").arg(++_CSeq).toAscii() + "\r\n"
51 + "Session: " + _session + "\r\n"
52 + "\r\n";
53 _socket->write(reqStr, reqStr.length());
54 }
[1410]55}
56
57//
58////////////////////////////////////////////////////////////////////////////
[1532]59void bncNetQueryRtp::slotKeepAlive() {
60 if (_socket) {
61 QByteArray reqStr = "GET_PARAMETER " + _url.toEncoded() + " RTSP/1.0\r\n"
62 + "CSeq: " + QString("%1").arg(++_CSeq).toAscii() + "\r\n"
63 + "Session: " + _session + "\r\n"
64 + "\r\n";
65 _socket->write(reqStr, reqStr.length());
66 }
67 QTimer::singleShot(30000, this, SLOT(slotKeepAlive()));
68}
69
70//
71////////////////////////////////////////////////////////////////////////////
[1410]72void bncNetQueryRtp::waitForRequestResult(const QUrl&, QByteArray&) {
73}
74
75//
76////////////////////////////////////////////////////////////////////////////
77void bncNetQueryRtp::waitForReadyRead(QByteArray& outData) {
[1414]78
79 // Wait Loop
80 // ---------
81 if (!_udpSocket->hasPendingDatagrams()) {
82 _eventLoop->exec();
83 }
84
85 // Append Data
86 // -----------
87 QByteArray datagram;
88 datagram.resize(_udpSocket->pendingDatagramSize());
89 _udpSocket->readDatagram(datagram.data(), datagram.size());
[1415]90
[1416]91 if (datagram.size() > 12) {
92 outData.append(datagram.mid(12));
93 }
[1410]94}
95
96// Connect to Caster, send the Request
97////////////////////////////////////////////////////////////////////////////
98void bncNetQueryRtp::startRequest(const QUrl& url, const QByteArray& gga) {
99
100 const int timeOut = 5000;
101
102 _status = running;
103
104 delete _socket;
105 _socket = new QTcpSocket();
106
[1411]107 // Default scheme
108 // --------------
[1528]109 _url = url;
110 _url.setScheme("rtsp");
[1410]111
112 // Connect the Socket
113 // ------------------
[1535]114 bncSettings settings;
[1410]115 QString proxyHost = settings.value("proxyHost").toString();
116 int proxyPort = settings.value("proxyPort").toInt();
117
118 if ( proxyHost.isEmpty() ) {
[1528]119 _socket->connectToHost(_url.host(), _url.port());
[1410]120 }
121 else {
122 _socket->connectToHost(proxyHost, proxyPort);
123 }
124
[1411]125 // Send Request 1
126 // --------------
127 if (_socket->waitForConnected(timeOut)) {
[1528]128 QString uName = QUrl::fromPercentEncoding(_url.userName().toAscii());
129 QString passW = QUrl::fromPercentEncoding(_url.password().toAscii());
[1411]130 QByteArray userAndPwd;
131
132 if(!uName.isEmpty() || !passW.isEmpty()) {
133 userAndPwd = "Authorization: Basic " + (uName.toAscii() + ":" +
134 passW.toAscii()).toBase64() + "\r\n";
135 }
[1418]136
[1419]137 // Setup the RTSP Connection
138 // -------------------------
[1518]139 delete _udpSocket;
140 _udpSocket = new QUdpSocket();
141 _udpSocket->bind(0);
142 connect(_udpSocket, SIGNAL(readyRead()), _eventLoop, SLOT(quit()));
143 QByteArray clientPort = QString("%1").arg(_udpSocket->localPort()).toAscii();
144
145 QByteArray reqStr;
[1528]146 reqStr = "SETUP " + _url.toEncoded() + " RTSP/1.0\r\n"
[1530]147 + "CSeq: " + QString("%1").arg(++_CSeq).toAscii() + "\r\n"
[1518]148 + "Ntrip-Version: Ntrip/2.0\r\n"
149 + "Ntrip-Component: Ntripclient\r\n"
150 + "User-Agent: NTRIP BNC/" BNCVERSION "\r\n"
151 + "Transport: RTP/GNSS;unicast;client_port=" + clientPort + "\r\n"
[1533]152 + userAndPwd;
153 if (!gga.isEmpty()) {
154 reqStr += "Ntrip-GGA: " + gga + "\r\n";
155 }
156 reqStr += "\r\n";
157
[1518]158 _socket->write(reqStr, reqStr.length());
159
160 // Read Server Answer 1
161 // --------------------
162 if (_socket->waitForBytesWritten(timeOut)) {
163 if (_socket->waitForReadyRead(timeOut)) {
164 QTextStream in(_socket);
[1520]165 QByteArray serverPort;
[1518]166 QString line = in.readLine();
167 while (!line.isEmpty()) {
168 if (line.indexOf("Session:") == 0) {
[1530]169 _session = line.mid(9).toAscii();
[1411]170 }
[1520]171 int iSrv = line.indexOf("server_port=");
172 if (iSrv != -1) {
173 serverPort = line.mid(iSrv+12).toAscii();
174 }
[1518]175 line = in.readLine();
176 }
177
178 // Send Request 2
179 // --------------
[1530]180 if (!_session.isEmpty()) {
[1520]181
182 // Send initial RTP packet for firewall handling
183 // ---------------------------------------------
184 if (!serverPort.isEmpty()) {
[1818]185 unsigned sessInt = _session.toInt();
[1520]186 char rtpbuffer[12];
[1721]187 rtpbuffer[0] = 128;
188 rtpbuffer[1] = 96;
189 rtpbuffer[2] = 0;
190 rtpbuffer[3] = 0;
191 rtpbuffer[4] = 0;
192 rtpbuffer[5] = 0;
193 rtpbuffer[6] = 0;
194 rtpbuffer[7] = 0;
195 rtpbuffer[8] = (sessInt >> 24) & 0xFF;
196 rtpbuffer[9] = (sessInt >> 16) & 0xFF;
197 rtpbuffer[10] = (sessInt >> 8) & 0xFF;
198 rtpbuffer[11] = (sessInt ) & 0xFF;
[1520]199
[1522]200 _udpSocket->writeDatagram(rtpbuffer, 12,
201 _socket->peerAddress(), serverPort.toInt());
[1520]202 }
203
[1528]204 reqStr = "PLAY " + _url.toEncoded() + " RTSP/1.0\r\n"
[1530]205 + "CSeq: " + QString("%1").arg(++_CSeq).toAscii() + "\r\n"
206 + "Session: " + _session + "\r\n"
[1518]207 + "\r\n";
208 _socket->write(reqStr, reqStr.length());
209
210 // Read Server Answer 2
211 // --------------------
212 if (_socket->waitForBytesWritten(timeOut)) {
213 if (_socket->waitForReadyRead(timeOut)) {
214 QTextStream in(_socket);
215 line = in.readLine();
216 while (!line.isEmpty()) {
217 if (line.indexOf("200 OK") != -1) {
[1650]218 emit newMessage(_url.encodedPath().replace(0,1,"")
219 + ": UDP connection established", true);
[1532]220 slotKeepAlive();
[1518]221 return;
222 }
[1419]223 line = in.readLine();
[1411]224 }
225 }
226 }
227 }
228 }
229 }
[1410]230 }
231
[1411]232 delete _socket;
233 _socket = 0;
234 _status = error;
[1650]235 emit newMessage(_url.encodedPath().replace(0,1,"")
[1653]236 + ": NetQuery, waiting for connect", true);
[1410]237}
238
Note: See TracBrowser for help on using the repository browser.