1
// libTorrent - BitTorrent library
2
// Copyright (C) 2005-2006, Jari Sundell
4
// This program is free software; you can redistribute it and/or modify
5
// it under the terms of the GNU General Public License as published by
6
// the Free Software Foundation; either version 2 of the License, or
7
// (at your option) any later version.
9
// This program is distributed in the hope that it will be useful,
10
// but WITHOUT ANY WARRANTY; without even the implied warranty of
11
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12
// GNU General Public License for more details.
14
// You should have received a copy of the GNU General Public License
15
// along with this program; if not, write to the Free Software
16
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
18
// In addition, as a special exception, the copyright holders give
19
// permission to link the code of portions of this program with the
20
// OpenSSL library under certain conditions as described in each
21
// individual source file, and distribute linked combinations
24
// You must obey the GNU General Public License in all respects for
25
// all of the code used other than OpenSSL. If you modify file(s)
26
// with this exception, you may extend this exception to your version
27
// of the file(s), but you are not obligated to do so. If you do not
28
// wish to do so, delete this exception statement from your version.
29
// If you delete this exception statement from all source files in the
30
// program, then also delete it here.
32
// Contact: Jari Sundell <jaris@ifi.uio.no>
35
// 3185 Skoppum, NORWAY
41
#include <rak/functional.h>
42
#include <rak/socket_address.h>
44
#include "download/available_list.h"
46
#include "exceptions.h"
48
#include "peer_info.h"
49
#include "peer_list.h"
54
socket_address_key::operator < (const socket_address_key& sa) const {
55
const rak::socket_address* sa1 = rak::socket_address::cast_from(m_sockaddr);
56
const rak::socket_address* sa2 = rak::socket_address::cast_from(sa.m_sockaddr);
58
if (sa1->family() != sa2->family())
59
return sa1->family() > sa2->family();
61
else if (sa1->family() == rak::socket_address::af_inet)
62
// Sort by hardware byte order to ensure proper ordering for
64
return sa1->sa_inet()->address_h() < sa2->sa_inet()->address_h();
67
// When we implement INET6 handling, embed the ipv4 address in
69
throw internal_error("socket_address_key(...) tried to compare an invalid family type.");
72
struct peer_list_equal_port : public std::binary_function<PeerList::reference, uint16_t, bool> {
73
bool operator () (PeerList::reference p, uint16_t port) {
74
return rak::socket_address::cast_from(p.second->socket_address())->port() == port;
78
PeerList::PeerList() :
79
m_availableList(new AvailableList) {
82
PeerList::~PeerList() {
83
std::for_each(begin(), end(), rak::on(rak::mem_ref(&value_type::second), rak::call_delete<PeerInfo>()));
86
delete m_availableList;
90
PeerList::insert_address(const sockaddr* sa, int flags) {
91
range_type range = base_type::equal_range(sa);
93
// Do some special handling if we got a new port number but the
94
// address was present.
96
// What we do depends on the flags, but for now just allow one
97
// PeerInfo per address key and do nothing.
98
if (range.first != range.second)
101
const rak::socket_address* address = rak::socket_address::cast_from(sa);
103
PeerInfo* peerInfo = new PeerInfo(sa);
104
peerInfo->set_listen_port(address->port());
106
base_type::insert(range.second, value_type(socket_address_key(peerInfo->socket_address()), peerInfo));
108
if (flags & address_available && peerInfo->listen_port() != 0)
109
m_availableList->push_back(address);
115
PeerList::connected(const sockaddr* sa, int flags) {
117
const rak::socket_address* address = rak::socket_address::cast_from(sa);
119
range_type range = base_type::equal_range(sa);
121
if (range.first == range.second) {
122
// Create a new entry.
123
peerInfo = new PeerInfo(sa);
125
base_type::insert(range.second, value_type(socket_address_key(peerInfo->socket_address()), peerInfo));
127
} else if (!range.first->second->is_connected()) {
129
peerInfo = range.first->second;
130
peerInfo->set_port(address->port());
133
// Make sure we don't end up throwing away the port the host is
134
// actually listening on, when there may be several simultaneous
135
// connection attempts to/from different ports.
137
// This also ensure we can connect to peers running on the same
138
// host as the tracker.
139
if (flags & connect_keep_handshakes &&
140
range.first->second->is_handshake() &&
141
rak::socket_address::cast_from(range.first->second->socket_address())->port() != address->port())
142
m_availableList->buffer()->push_back(*address);
147
if (!(flags & connect_incoming))
148
peerInfo->set_listen_port(address->port());
150
if (flags & connect_incoming)
151
peerInfo->set_flags(PeerInfo::flag_incoming);
153
peerInfo->unset_flags(PeerInfo::flag_incoming);
155
peerInfo->set_flags(PeerInfo::flag_connected);
156
peerInfo->set_last_connection(cachedTime.seconds());
161
// Make sure we properly clear port when disconnecting.
164
PeerList::disconnected(PeerInfo* p, int flags) {
165
range_type range = base_type::equal_range(p->socket_address());
167
iterator itr = std::find_if(range.first, range.second, rak::equal(p, rak::mem_ref(&value_type::second)));
169
if (itr == range.second)
170
if (std::find_if(base_type::begin(), base_type::end(), rak::equal(p, rak::mem_ref(&value_type::second))) == base_type::end())
171
throw internal_error("PeerList::disconnected(...) itr == range.second, doesn't exist.");
173
throw internal_error("PeerList::disconnected(...) itr == range.second, not in the range.");
175
disconnected(itr, flags);
179
PeerList::disconnected(iterator itr, int flags) {
180
if (itr == base_type::end())
181
throw internal_error("PeerList::disconnected(...) itr == end().");
183
if (!itr->second->is_connected())
184
throw internal_error("PeerList::disconnected(...) !itr->is_connected().");
186
itr->second->unset_flags(PeerInfo::flag_connected);
187
itr->second->set_last_connection(cachedTime.seconds());
189
// Replace the socket address port with the listening port so that
190
// future outgoing connections will connect to the right port.
191
itr->second->set_port(0);
193
if (flags & disconnect_available && itr->second->listen_port() != 0)
194
m_availableList->push_back(rak::socket_address::cast_from(itr->second->socket_address()));
196
// Do magic to get rid of unneeded entries.
201
PeerList::cull_peers(int flags) {
202
uint32_t counter = 0;
205
if (flags & cull_old)
206
timer = cachedTime.seconds() - 24 * 60 * 60;
210
for (iterator itr = base_type::begin(); itr != base_type::end(); ) {
211
if (itr->second->is_connected() ||
212
itr->second->transfer_counter() != 0 ||
213
itr->second->last_connection() >= timer ||
215
(flags & cull_keep_interesting && itr->second->failed_counter() != 0)) {
220
// The key is a pointer to a member in the value, although the key
221
// shouldn't actually be used in erase (I think), just ot be safe
222
// we delete it after erase.
223
iterator tmp = itr++;
224
PeerInfo* peerInfo = tmp->second;
226
base_type::erase(tmp);
added
removed
src/torrent/peer_list.cc
