Home · All Classes · Main Classes · Grouped Classes · Modules · Functions

peerwireclient.h Example File
^{network/torrent/peerwireclient.h}

    /****************************************************************************
    **
    ** Copyright (C) 2004-2006 Trolltech AS. All rights reserved.
    **
    ** This file is part of the documentation of the Qt Toolkit.
    **
    ** This file may be used under the terms of the GNU General Public
    ** License version 2.0 as published by the Free Software Foundation
    ** and appearing in the file LICENSE.GPL included in the packaging of
    ** this file.  Please review the following information to ensure GNU
    ** General Public Licensing requirements will be met:
    ** http://www.trolltech.com/products/qt/opensource.html
    **
    ** If you are unsure which license is appropriate for your use, please
    ** review the following information:
    ** http://www.trolltech.com/products/qt/licensing.html or contact the
    ** sales department at sales@trolltech.com.
    **
    ** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
    ** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
    **
    ****************************************************************************/

    #ifndef PEERWIRECLIENT_H
    #define PEERWIRECLIENT_H

    class QHostAddress;
    class QTimerEvent;
    class TorrentPeer;

    #include <QBitArray>
    #include <QList>
    #include <QTcpSocket>

    struct TorrentBlock
    {
        inline TorrentBlock(int p, int o, int l)
            : pieceIndex(p), offset(o), length(l)
        {
        }
        inline bool operator==(const TorrentBlock &other) const
        {
            return pieceIndex == other.pieceIndex
                    && offset == other.offset
                    && length == other.length;
        }

        int pieceIndex;
        int offset;
        int length;
    };

    class PeerWireClient : public QTcpSocket
    {
        Q_OBJECT
    public:
        enum PeerWireStateFlag {
            ChokingPeer = 0x1,
            InterestedInPeer = 0x2,
            ChokedByPeer = 0x4,
            PeerIsInterested = 0x8
        };
        Q_DECLARE_FLAGS(PeerWireState, PeerWireStateFlag)

        PeerWireClient(const QByteArray &peerId, QObject *parent = 0);
        void initialize(const QByteArray &infoHash, int pieceCount);

        void setPeer(TorrentPeer *peer);
        TorrentPeer *peer() const;

        // State
        inline PeerWireState peerWireState() const { return pwState; }
        QBitArray availablePieces() const;
        QList<TorrentBlock> incomingBlocks() const;

        // Protocol
        void chokePeer();
        void unchokePeer();
        void sendInterested();
        void sendKeepAlive();
        void sendNotInterested();
        void sendPieceNotification(int piece);
        void sendPieceList(const QBitArray &bitField);
        void requestBlock(int piece, int offset, int length);
        void cancelRequest(int piece, int offset, int length);
        void sendBlock(int piece, int offset, const QByteArray &data);

        // Rate control
        qint64 writeToSocket(qint64 bytes);
        qint64 readFromSocket(qint64 bytes);
        qint64 downloadSpeed() const;
        qint64 uploadSpeed() const;

        bool canTransferMore() const;
        qint64 bytesAvailable() const { return incomingBuffer.size(); }
        qint64 socketBytesAvailable() const { return QTcpSocket::bytesAvailable(); }

    signals:
        void infoHashReceived(const QByteArray &infoHash);
        void readyToTransfer();

        void choked();
        void unchoked();
        void interested();
        void notInterested();

        void piecesAvailable(const QBitArray &pieces);
        void blockRequested(int pieceIndex, int begin, int length);
        void blockReceived(int pieceIndex, int begin, const QByteArray &data);

        void bytesReceived(qint64 size);

    protected slots:
        void timerEvent(QTimerEvent *event);

    protected:
        qint64 readData(char *data, qint64 maxlen);
        qint64 readLineData(char *data, qint64 maxlen);
        qint64 writeData(const char *data, qint64 len);

    private slots:
        void sendHandShake();
        void processIncomingData();

    private:
        // Data waiting to be read/written
        QByteArray incomingBuffer;
        QByteArray outgoingBuffer;

        struct BlockInfo {
            int pieceIndex;
            int offset;
            int length;
            QByteArray block;
        };
        QList<BlockInfo> pendingBlocks;
        int pendingBlockSizes;
        QList<TorrentBlock> incoming;

        enum PacketType {
            ChokePacket = 0,
            UnchokePacket = 1,
            InterestedPacket = 2,
            NotInterestedPacket = 3,
            HavePacket = 4,
            BitFieldPacket = 5,
            RequestPacket = 6,
            PiecePacket = 7,
            CancelPacket = 8
        };

        // State
        PeerWireState pwState;
        bool receivedHandShake;
        bool gotPeerId;
        bool sentHandShake;
        int nextPacketLength;

        // Upload/download speed records
        qint64 uploadSpeedData[8];
        qint64 downloadSpeedData[8];
        int transferSpeedTimer;

        // Timeout handling
        int timeoutTimer;
        int pendingRequestTimer;
        bool invalidateTimeout;
        int keepAliveTimer;

        // Checksum, peer ID and set of available pieces
        QByteArray infoHash;
        QByteArray peerIdString;
        QBitArray peerPieces;
        TorrentPeer *torrentPeer;
    };

    Q_DECLARE_OPERATORS_FOR_FLAGS(PeerWireClient::PeerWireState)

    #endif