/usr/include/libktorrent/utp/localwindow.h is in libktorrent-dev 1.3.1-5.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 | /***************************************************************************
* Copyright (C) 2009 by Joris Guisson *
* joris.guisson@gmail.com *
* *
* This program 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 2 of the License, or *
* (at your option) any later version. *
* *
* This program 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 this program; if not, write to the *
* Free Software Foundation, Inc., *
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
***************************************************************************/
#ifndef UTP_LOCALWINDOW_H
#define UTP_LOCALWINDOW_H
#include <vector>
#include <ktorrent_export.h>
#include <util/constants.h>
#include <QSharedPointer>
#include "packetbuffer.h"
namespace utp
{
struct SelectiveAck;
struct Header;
const bt::Uint32 DEFAULT_CAPACITY = 64*1024;
struct WindowPacket
{
WindowPacket(bt::Uint16 seq_nr);
WindowPacket(bt::Uint16 seq_nr, bt::Buffer::Ptr packet, bt::Uint32 data_off);
~WindowPacket();
bt::Uint32 read(bt::Uint8* dst, bt::Uint32 max_len);
bool fullyRead() const;
void set(bt::Buffer::Ptr packet, bt::Uint32 data_off);
bt::Uint16 seq_nr;
bt::Buffer::Ptr packet;
bt::Uint32 bytes_read;
};
/**
Manages the local window of a UTP connection.
*/
class KTORRENT_EXPORT LocalWindow
{
public:
LocalWindow(bt::Uint32 cap = DEFAULT_CAPACITY);
virtual ~LocalWindow();
/// Get back the available space
bt::Uint32 availableSpace() const {return window_space;}
/// Get back how large the window is
bt::Uint32 currentWindow() const {return capacity - window_space;}
/// Get the window capacity
bt::Uint32 windowCapacity() const {return capacity;}
/// A packet was received
bool packetReceived(const Header* hdr, bt::Buffer::Ptr packet, bt::Uint32 data_off);
/// Set the last sequence number
void setLastSeqNr(bt::Uint16 lsn);
/// Get the last sequence number we can safely ack
bt::Uint16 lastSeqNr() const {return last_seq_nr;}
/// Is the window empty
bool isEmpty() const {return incoming_packets.empty();}
/// Read from the local window
bt::Uint32 read(bt::Uint8* data, bt::Uint32 max_len);
/// Is there something to read ?
bool isReadable() const {return bytes_available > 0;}
/// The amount of bytes available
bt::Uint32 bytesAvailable() const {return bytes_available;}
/// Get the number of selective ack bits needed when sending a packet
bt::Uint32 selectiveAckBits() const;
/// Fill a SelectiveAck structure
void fillSelectiveAck(SelectiveAck* sack);
private:
typedef std::vector<WindowPacket> WindowPacketList;
bt::Uint16 last_seq_nr;
bt::Uint16 first_seq_nr;
bt::Uint32 capacity;
WindowPacketList incoming_packets;
bt::Uint32 window_space;
bt::Uint32 bytes_available;
};
}
#endif // UTP_LOCALWINDOW_H
|