1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
/******************************************************************************
**
** Copyright (C) 2016 The Qt Company Ltd.
** Contact: http://www.qt.io/licensing/
**
** This file is part of the Qt Debug Bridge.
**
** $QT_BEGIN_LICENSE:COMM$
**
** Commercial License Usage
** Licensees holding valid commercial Qt licenses may use this file in
** accordance with the commercial license agreement provided with the
** Software or, alternatively, in accordance with the terms contained in
** a written agreement between you and The Qt Company. For licensing terms
** and conditions see http://www.qt.io/terms-conditions. For further
** information use the contact form at http://www.qt.io/contact-us.
**
** $QT_END_LICENSE$
**
******************************************************************************/
#include "usbconnectionreader.h"
#include "libqdb/protocol/protocol.h"
#include <QtCore/qdebug.h>
#include <QtCore/qloggingcategory.h>
#include <QtCore/qthread.h>
#include <QtCore/qtimer.h>
#include <libusb.h>
Q_DECLARE_LOGGING_CATEGORY(usbC);
// Amount of milliseconds between yielding control to the event loop of the reading thread
static const int quitCheckingTimeout = 500;
UsbConnectionReader::UsbConnectionReader(libusb_device_handle *handle, uint8_t inAddress)
: m_handle{handle},
m_inAddress{inAddress},
m_errorCount{0}
{
}
void UsbConnectionReader::executeRead()
{
QByteArray buffer{qdbMessageSize, '\0'};
int transferred = 0;
int ret = libusb_bulk_transfer(m_handle, m_inAddress, reinterpret_cast<unsigned char *>(buffer.data()),
buffer.size(), &transferred, quitCheckingTimeout);
if (ret) {
if (ret != LIBUSB_ERROR_TIMEOUT) {
qCWarning(usbC) << "Could not read from USB connection:" << libusb_error_name(ret);
++m_errorCount;
if (m_errorCount == 5) {
emit newRead(QByteArray{});
m_errorCount = 0;
}
}
} else {
m_errorCount = 0;
buffer.resize(transferred);
emit newRead(buffer);
}
QTimer::singleShot(0, this, &UsbConnectionReader::executeRead);
}
|
