/*===================================================================== QGroundControl Open Source Ground Control Station (c) 2009, 2010 QGROUNDCONTROL PROJECT This file is part of the QGROUNDCONTROL project QGROUNDCONTROL is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. QGROUNDCONTROL is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with QGROUNDCONTROL. If not, see . ======================================================================*/ /** * @file * @brief Definition of UDP connection (server) for unmanned vehicles * @author Lorenz Meier * */ #include #include #include #include #include #include "UDPLink.h" #include "LinkManager.h" #include "QGC.h" //#include UDPLink::UDPLink(QHostAddress host, quint16 port) { this->host = host; this->port = port; this->connectState = false; this->hosts = new QList(); //this->ports = new QMap(); this->ports = new QList(); // Set unique ID and add link to the list of links this->id = getNextLinkId(); this->name = tr("UDP Link (port:%1)").arg(14550); LinkManager::instance()->add(this); } UDPLink::~UDPLink() { disconnect(); } /** * @brief Runs the thread * **/ void UDPLink::run() { // forever // { // QGC::SLEEP::msleep(5000); // } exec(); } void UDPLink::setAddress(QString address) { Q_UNUSED(address); // FIXME TODO Implement address //socket->setLocalAddress(QHostAddress(address)); } void UDPLink::setPort(int port) { this->port = port; disconnect(); connect(); } /** * @param host Hostname in standard formatting, e.g. localhost:14551 or 192.168.1.1:14551 */ void UDPLink::addHost(const QString& host) { if (host.contains(":")) { // Add host hosts->append(QHostAddress(host.split(":").first())); // Set port according to user input ports->append(host.split(":").last().toInt()); } else { // Add host hosts->append(QHostAddress(host)); // Set port according to default (this port) ports->append(port); } } void UDPLink::writeBytes(const char* data, qint64 size) { // Broadcast to all connected systems //QList::iterator h; // for (h = hosts->begin(); h != hosts->end(); ++h) for (int h = 0; h < hosts->size(); h++) { QHostAddress currentHost = hosts->at(h); quint16 currentPort = ports->at(h); for (int i=0; iwriteDatagram(data, size, currentHost, currentPort); } } /** * @brief Read a number of bytes from the interface. * * @param data Pointer to the data byte array to write the bytes to * @param maxLength The maximum number of bytes to write **/ void UDPLink::readBytes() { const qint64 maxLength = 2048; char data[maxLength]; QHostAddress sender; quint16 senderPort; unsigned int s = socket->pendingDatagramSize(); if (s > maxLength) std::cerr << __FILE__ << __LINE__ << " UDP datagram overflow, allowed to read less bytes than datagram size" << std::endl; socket->readDatagram(data, maxLength, &sender, &senderPort); // FIXME TODO Check if this method is better than retrieving the data by individual processes QByteArray b(data, s); emit bytesReceived(this, b); // // Echo data for debugging purposes // std::cerr << __FILE__ << __LINE__ << "Received datagram:" << std::endl; // int i; // for (i=0; icontains(sender)) { hosts->append(sender); ports->append(senderPort); // ports->insert(sender, senderPort); } else { int index = hosts->indexOf(sender); ports->replace(index, senderPort); } } /** * @brief Get the number of bytes to read. * * @return The number of bytes to read **/ qint64 UDPLink::bytesAvailable() { return socket->pendingDatagramSize(); } /** * @brief Disconnect the connection. * * @return True if connection has been disconnected, false if connection couldn't be disconnected. **/ bool UDPLink::disconnect() { delete socket; socket = NULL; connectState = false; emit disconnected(); emit connected(false); return !connectState; } /** * @brief Connect the connection. * * @return True if connection has been established, false if connection couldn't be established. **/ bool UDPLink::connect() { socket = new QUdpSocket(this); //Check if we are using a multicast-address // bool multicast = false; // if (host.isInSubnet(QHostAddress("224.0.0.0"),4)) // { // multicast = true; // connectState = socket->bind(port, QUdpSocket::ShareAddress); // } // else // { connectState = socket->bind(host, port); // } //Provides Multicast functionality to UdpSocket /* not working yet if (multicast) { int sendingFd = socket->socketDescriptor(); if (sendingFd != -1) { // set up destination address struct sockaddr_in sendAddr; memset(&sendAddr,0,sizeof(sendAddr)); sendAddr.sin_family=AF_INET; sendAddr.sin_addr.s_addr=inet_addr(HELLO_GROUP); sendAddr.sin_port=htons(port); // set TTL unsigned int ttl = 1; // restricted to the same subnet if (setsockopt(sendingFd, IPPROTO_IP, IP_MULTICAST_TTL, (unsigned int*)&ttl, sizeof(ttl) ) < 0) { std::cout << "TTL failed\n"; } } } */ //QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(readPendingDatagrams())); QObject::connect(socket, SIGNAL(readyRead()), this, SLOT(readBytes())); emit connected(connectState); if (connectState) { emit connected(); connectionStartTime = QGC::groundTimeUsecs()/1000; } start(HighPriority); return connectState; } /** * @brief Check if connection is active. * * @return True if link is connected, false otherwise. **/ bool UDPLink::isConnected() { return connectState; } int UDPLink::getId() { return id; } QString UDPLink::getName() { return name; } void UDPLink::setName(QString name) { this->name = name; emit nameChanged(this->name); } qint64 UDPLink::getNominalDataRate() { return 54000000; // 54 Mbit } qint64 UDPLink::getTotalUpstream() { statisticsMutex.lock(); qint64 totalUpstream = bitsSentTotal / ((QGC::groundTimeUsecs()/1000 - connectionStartTime) / 1000); statisticsMutex.unlock(); return totalUpstream; } qint64 UDPLink::getCurrentUpstream() { return 0; // TODO } qint64 UDPLink::getMaxUpstream() { return 0; // TODO } qint64 UDPLink::getBitsSent() { return bitsSentTotal; } qint64 UDPLink::getBitsReceived() { return bitsReceivedTotal; } qint64 UDPLink::getTotalDownstream() { statisticsMutex.lock(); qint64 totalDownstream = bitsReceivedTotal / ((QGC::groundTimeUsecs()/1000 - connectionStartTime) / 1000); statisticsMutex.unlock(); return totalDownstream; } qint64 UDPLink::getCurrentDownstream() { return 0; // TODO } qint64 UDPLink::getMaxDownstream() { return 0; // TODO } bool UDPLink::isFullDuplex() { return true; } int UDPLink::getLinkQuality() { /* This feature is not supported with this interface */ return -1; }