← Back to branch summary

~gabriel1984sibiu/minitube/qt5.6

« back to all changes in this revision

Viewing changes to examples/network/blockingfortuneclient/fortunethread.cpp

  • Committer: Grevutiu Gabriel
  • Date: 2017-06-13 08:43:17 UTC
  • Revision ID: gabriel1984sibiu@gmail.com-20170613084317-ek0zqe0u9g3ocvi8
Original upstream code

Show diffs side-by-side

added added

removed removed

Lines of Context:
examples/network/blockingfortuneclient/fortunethread.cpp
 
1
/****************************************************************************
 
2
**
 
3
** Copyright (C) 2016 The Qt Company Ltd.
 
4
** Contact: https://www.qt.io/licensing/
 
5
**
 
6
** This file is part of the examples of the Qt Toolkit.
 
7
**
 
8
** $QT_BEGIN_LICENSE:BSD$
 
9
** Commercial License Usage
 
10
** Licensees holding valid commercial Qt licenses may use this file in
 
11
** accordance with the commercial license agreement provided with the
 
12
** Software or, alternatively, in accordance with the terms contained in
 
13
** a written agreement between you and The Qt Company. For licensing terms
 
14
** and conditions see https://www.qt.io/terms-conditions. For further
 
15
** information use the contact form at https://www.qt.io/contact-us.
 
16
**
 
17
** BSD License Usage
 
18
** Alternatively, you may use this file under the terms of the BSD license
 
19
** as follows:
 
20
**
 
21
** "Redistribution and use in source and binary forms, with or without
 
22
** modification, are permitted provided that the following conditions are
 
23
** met:
 
24
**   * Redistributions of source code must retain the above copyright
 
25
**     notice, this list of conditions and the following disclaimer.
 
26
**   * Redistributions in binary form must reproduce the above copyright
 
27
**     notice, this list of conditions and the following disclaimer in
 
28
**     the documentation and/or other materials provided with the
 
29
**     distribution.
 
30
**   * Neither the name of The Qt Company Ltd nor the names of its
 
31
**     contributors may be used to endorse or promote products derived
 
32
**     from this software without specific prior written permission.
 
33
**
 
34
**
 
35
** THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 
36
** "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 
37
** LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 
38
** A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 
39
** OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 
40
** SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 
41
** LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 
42
** DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 
43
** THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 
44
** (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 
45
** OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE."
 
46
**
 
47
** $QT_END_LICENSE$
 
48
**
 
49
****************************************************************************/
 
50
 
 
51
#include <QtNetwork>
 
52
 
 
53
#include "fortunethread.h"
 
54
 
 
55
FortuneThread::FortuneThread(QObject *parent)
 
56
    : QThread(parent), quit(false)
 
57
{
 
58
}
 
59
 
 
60
//! [0]
 
61
FortuneThread::~FortuneThread()
 
62
{
 
63
    mutex.lock();
 
64
    quit = true;
 
65
    cond.wakeOne();
 
66
    mutex.unlock();
 
67
    wait();
 
68
}
 
69
//! [0]
 
70
 
 
71
//! [1] //! [2]
 
72
void FortuneThread::requestNewFortune(const QString &hostName, quint16 port)
 
73
{
 
74
//! [1]
 
75
    QMutexLocker locker(&mutex);
 
76
    this->hostName = hostName;
 
77
    this->port = port;
 
78
//! [3]
 
79
    if (!isRunning())
 
80
        start();
 
81
    else
 
82
        cond.wakeOne();
 
83
}
 
84
//! [2] //! [3]
 
85
 
 
86
//! [4]
 
87
void FortuneThread::run()
 
88
{
 
89
    mutex.lock();
 
90
//! [4] //! [5]
 
91
    QString serverName = hostName;
 
92
    quint16 serverPort = port;
 
93
    mutex.unlock();
 
94
//! [5]
 
95
 
 
96
//! [6]
 
97
    while (!quit) {
 
98
//! [7]
 
99
        const int Timeout = 5 * 1000;
 
100
 
 
101
        QTcpSocket socket;
 
102
        socket.connectToHost(serverName, serverPort);
 
103
//! [6] //! [8]
 
104
 
 
105
        if (!socket.waitForConnected(Timeout)) {
 
106
            emit error(socket.error(), socket.errorString());
 
107
            return;
 
108
        }
 
109
//! [8] //! [11]
 
110
 
 
111
        QDataStream in(&socket);
 
112
        in.setVersion(QDataStream::Qt_4_0);
 
113
        QString fortune;
 
114
//! [11] //! [12]
 
115
 
 
116
        do {
 
117
            if (!socket.waitForReadyRead(Timeout)) {
 
118
                emit error(socket.error(), socket.errorString());
 
119
                return;
 
120
            }
 
121
 
 
122
            in.startTransaction();
 
123
            in >> fortune;
 
124
        } while (!in.commitTransaction());
 
125
//! [12] //! [15]
 
126
 
 
127
        mutex.lock();
 
128
        emit newFortune(fortune);
 
129
//! [7]
 
130
 
 
131
        cond.wait(&mutex);
 
132
        serverName = hostName;
 
133
        serverPort = port;
 
134
        mutex.unlock();
 
135
    }
 
136
//! [15]
 
137
}