source: ntrip/trunk/BNC/bncnetqueryv0.cpp@ 1783

Last change on this file since 1783 was 1783, checked in by mervart, 15 years ago

* empty log message *
File size: 3.1 KB
Line 
1/* -------------------------------------------------------------------------
2 * BKG NTRIP Client
3 * -------------------------------------------------------------------------
4 *
5 * Class: bncNetQueryV0
6 *
7 * Purpose: TCP/IP Network Requests, no NTRIP
8 *
9 * Author: G. Weber
10 *
11 * Created: 19-Feb-2009
12 *
13 * Changes:
14 *
15 * -----------------------------------------------------------------------*/
16
17#include <iostream>
18#include <iomanip>
19
20#include "bncnetqueryv0.h"
21#include "bncsettings.h"
22
23using namespace std;
24
25#define BNCVERSION "1.7"
26
27// Constructor
28////////////////////////////////////////////////////////////////////////////
29bncNetQueryV0::bncNetQueryV0() {
30 _socket = 0;
31 _timeOut = 20000;
32}
33
34// Destructor
35////////////////////////////////////////////////////////////////////////////
36bncNetQueryV0::~bncNetQueryV0() {
37 delete _socket;
38}
39
40//
41////////////////////////////////////////////////////////////////////////////
42void bncNetQueryV0::stop() {
43#ifndef sparc
44 if (_socket) {
45 _socket->abort();
46 }
47#endif
48 _status = finished;
49}
50
51//
52////////////////////////////////////////////////////////////////////////////
53void bncNetQueryV0::waitForRequestResult(const QUrl&, QByteArray&) {
54}
55
56//
57////////////////////////////////////////////////////////////////////////////
58void bncNetQueryV0::waitForReadyRead(QByteArray& outData) {
59 if (_socket && _socket->state() == QAbstractSocket::ConnectedState) {
60 while (true) {
61 int nBytes = _socket->bytesAvailable();
62 if (nBytes > 0) {
63 outData = _socket->readAll();
64 return;
65 }
66 else if (!_socket->waitForReadyRead(_timeOut)) {
67 delete _socket;
68 _socket = 0;
69 _status = error;
70 emit newMessage(_url.path().toAscii() + " read timeout", true);
71 return;
72 }
73 }
74 }
75}
76
77// Connect to Caster, send the Request
78////////////////////////////////////////////////////////////////////////////
79void bncNetQueryV0::startRequest(const QUrl& url, const QByteArray& /* gga */) {
80
81 _status = running;
82
83 delete _socket;
84 _socket = new QTcpSocket();
85
86 // Default scheme and path
87 // -----------------------
88 _url = url;
89 if (_url.scheme().isEmpty()) {
90 _url.setScheme("http");
91 }
92 if (_url.path().isEmpty()) {
93 _url.setPath("/");
94 }
95
96 // Connect the Socket
97 // ------------------
98 bncSettings settings;
99
100 _socket->connectToHost(_url.host(), _url.port());
101 if (!_socket->waitForConnected(_timeOut)) {
102 delete _socket;
103 _socket = 0;
104 _status = error;
105 emit(newMessage(_url.path().toAscii().replace(0,1,"")
106 + ": Connect timeout, reconnecting", true));
107 return;
108 }
109
110 // Read Caster Response
111 // --------------------
112 QStringList response;
113 while (true) {
114 if (!_socket->waitForReadyRead(_timeOut)) {
115 delete _socket;
116 _socket = 0;
117 _status = error;
118 emit newMessage(_url.path().toAscii().replace(0,1,"")
119 + ": Read timeout", true);
120 return;
121 }
122 if (_socket->canReadLine()) {
123 QString line = _socket->readLine();
124 response.push_back(line);
125 response.clear();
126 break;
127 }
128 }
129}
130
Note: See TracBrowser for help on using the repository browser.