~ubuntu-branches/ubuntu/oneiric/libktorrent/oneiric

« back to all changes in this revision

Viewing changes to src/dht/dht.cpp

Committer: Bazaar Package Importer
Author(s): Modestas Vainius
Date: 2011-05-26 00:33:38 UTC
mfrom: (5.1.7 experimental)
Revision ID: james.westby@ubuntu.com-20110526003338-2r4zwyzn8bovsxay

Tags: 1.1.1-2

Release to unstable.

files added:
RoadMap

cmake/modules/FindLibGcrypt.cmake

debian/libktorrent3.install

debian/libktorrent3.symbols

examples

examples/CMakeLists.txt

examples/ktcli

examples/ktcli/CMakeLists.txt

examples/ktcli/ktcli.cpp

examples/ktcli/ktcli.h

examples/ktcli/main.cpp

src/datachecker/CMakeLists.txt

src/datachecker/tests

src/datachecker/tests/CMakeLists.txt

src/datachecker/tests/datacheckertest.cpp

src/diskio/CMakeLists.txt

src/diskio/tests

src/diskio/tests/CMakeLists.txt

src/diskio/tests/chunkmanagertest.cpp

src/download/CMakeLists.txt

src/download/streamingchunkselector.cpp

src/download/streamingchunkselector.h

src/download/tests

src/download/tests/CMakeLists.txt

src/download/tests/streamingchunkselectortest.cpp

src/mse/CMakeLists.txt

src/mse/tests

src/mse/tests/CMakeLists.txt

src/mse/tests/rc4encryptortest.cpp

src/net/serversocket.cpp

src/net/serversocket.h

src/peer/CMakeLists.txt

src/peer/superseeder.cpp

src/peer/superseeder.h

src/peer/tests

src/peer/tests/CMakeLists.txt

src/peer/tests/superseedtest.cpp

src/torrent/tests/torrentfilestreammultitest.cpp

src/torrent/tests/torrentfilestreamtest.cpp

src/torrent/torrentfilestream.cpp

src/torrent/torrentfilestream.h

src/tracker/CMakeLists.txt

src/upnp

src/upnp/CMakeLists.txt

src/upnp/httprequest.cpp

src/upnp/httprequest.h

src/upnp/soap.cpp

src/upnp/soap.h

src/upnp/upnpdescriptionparser.cpp

src/upnp/upnpdescriptionparser.h

src/upnp/upnpmcastsocket.cpp

src/upnp/upnpmcastsocket.h

src/upnp/upnprouter.cpp

src/upnp/upnprouter.h

src/util/resourcemanager.cpp

src/util/resourcemanager.h

src/util/signalcatcher.cpp

src/util/signalcatcher.h

src/util/tests/fileopstest.cpp

src/util/tests/resourcemanagertest.cpp

src/util/tests/signalcatchertest.cpp

src/utp/outputqueue.cpp

src/utp/outputqueue.h

src/utp/utpserver_p.h

testlib

testlib/CMakeLists.txt

testlib/dummytorrentcreator.cpp

testlib/dummytorrentcreator.h

files removed:
debian/libktorrent2.install

debian/libktorrent2.symbols

src/datachecker/datacheckerlistener.cpp

src/datachecker/datacheckerlistener.h

files modified:
CMakeLists.txt

ChangeLog

debian/changelog

debian/control

debian/copyright

debian/rules

po/ar/libktorrent.po

po/ast/libktorrent.po

po/be/libktorrent.po

po/bg/libktorrent.po

po/ca/libktorrent.po

po/ca@valencia/libktorrent.po

po/cs/libktorrent.po

po/da/libktorrent.po

po/de/libktorrent.po

po/el/libktorrent.po

po/en_GB/libktorrent.po

po/eo/libktorrent.po

po/es/libktorrent.po

po/et/libktorrent.po

po/eu/libktorrent.po

po/fi/libktorrent.po

po/fr/libktorrent.po

po/ga/libktorrent.po

po/gl/libktorrent.po

po/hi/libktorrent.po

po/hne/libktorrent.po

po/hr/libktorrent.po

po/hu/libktorrent.po

po/is/libktorrent.po

po/it/libktorrent.po

po/ja/libktorrent.po

po/km/libktorrent.po

po/ku/libktorrent.po

po/lt/libktorrent.po

po/lv/libktorrent.po

po/ms/libktorrent.po

po/nb/libktorrent.po

po/nds/libktorrent.po

po/nl/libktorrent.po

po/nn/libktorrent.po

po/oc/libktorrent.po

po/pl/libktorrent.po

po/pt/libktorrent.po

po/pt_BR/libktorrent.po

po/ro/libktorrent.po

po/ru/libktorrent.po

po/se/libktorrent.po

po/si/libktorrent.po

po/sk/libktorrent.po

po/sl/libktorrent.po

po/sr/libktorrent.po

po/sr@ijekavian/libktorrent.po

po/sr@ijekavianlatin/libktorrent.po

po/sr@latin/libktorrent.po

po/sv/libktorrent.po

po/tr/libktorrent.po

po/uk/libktorrent.po

po/zh_CN/libktorrent.po

po/zh_TW/libktorrent.po

scripts/gen_pkg.rb

src/CMakeLists.txt

src/bcodec/value.h

src/datachecker/datachecker.cpp

src/datachecker/datachecker.h

src/datachecker/datacheckerjob.cpp

src/datachecker/datacheckerjob.h

src/datachecker/datacheckerthread.cpp

src/datachecker/datacheckerthread.h

src/datachecker/multidatachecker.cpp

src/datachecker/multidatachecker.h

src/datachecker/singledatachecker.cpp

src/datachecker/singledatachecker.h

src/dht/announcetask.cpp

src/dht/announcetask.h

src/dht/dht.cpp

src/dht/dht.h

src/dht/kbucket.cpp

src/dht/kbucket.h

src/dht/node.cpp

src/dht/node.h

src/dht/nodelookup.cpp

src/dht/nodelookup.h

src/dht/rpccall.cpp

src/dht/rpccall.h

src/dht/rpcmsg.cpp

src/dht/rpcmsg.h

src/dht/rpcserver.cpp

src/dht/rpcserver.h

src/dht/task.cpp

src/dht/task.h

src/diskio/cache.cpp

src/diskio/cache.h

src/diskio/cachefile.cpp

src/diskio/chunk.cpp

src/diskio/chunk.h

src/diskio/chunkmanager.cpp

src/diskio/chunkmanager.h

src/diskio/dndfile.cpp

src/diskio/movedatafilesjob.cpp

src/diskio/movedatafilesjob.h

src/diskio/multifilecache.cpp

src/diskio/multifilecache.h

src/diskio/piecedata.cpp

src/diskio/piecedata.h

src/diskio/singlefilecache.cpp

src/diskio/singlefilecache.h

src/download/chunkdownload.cpp

src/download/chunkdownload.h

src/download/chunkselector.cpp

src/download/chunkselector.h

src/download/downloader.cpp

src/download/downloader.h

src/download/httpconnection.cpp

src/download/httpconnection.h

src/download/packet.cpp

src/download/webseed.cpp

src/download/webseed.h

src/interfaces/chunkselectorinterface.cpp

src/interfaces/chunkselectorinterface.h

src/interfaces/peerinterface.cpp

src/interfaces/peerinterface.h

src/interfaces/piecedownloader.h

src/interfaces/serverinterface.cpp

src/interfaces/serverinterface.h

src/interfaces/torrentfileinterface.cpp

src/interfaces/torrentfileinterface.h

src/interfaces/torrentinterface.h

src/interfaces/trackerinterface.cpp

src/interfaces/trackerinterface.h

src/magnet/magnetdownloader.cpp

src/magnet/magnetdownloader.h

src/magnet/magnetlink.cpp

src/magnet/magnetlink.h

src/magnet/tests/magnetlinktest.cpp

src/mse/encryptedauthenticate.cpp

src/mse/encryptedauthenticate.h

src/mse/encryptedserverauthenticate.cpp

src/mse/encryptedserverauthenticate.h

src/mse/rc4encryptor.cpp

src/mse/rc4encryptor.h

src/mse/streamsocket.cpp

src/mse/streamsocket.h

src/net/CMakeLists.txt

src/net/downloadthread.h

src/net/socket.cpp

src/net/socket.h

src/net/socketdevice.cpp

src/net/socketdevice.h

src/net/socketmonitor.cpp

src/net/socketmonitor.h

src/net/socks.cpp

src/net/socks.h

src/net/uploadthread.h

src/net/wakeuppipe.cpp

src/peer/authenticate.cpp

src/peer/authenticate.h

src/peer/authenticatebase.cpp

src/peer/authenticatebase.h

src/peer/authenticationmonitor.cpp

src/peer/authenticationmonitor.h

src/peer/chunkcounter.h

src/peer/packetreader.cpp

src/peer/packetreader.h

src/peer/packetwriter.cpp

src/peer/peer.cpp

src/peer/peer.h

src/peer/peerconnector.cpp

src/peer/peerconnector.h

src/peer/peerdownloader.cpp

src/peer/peermanager.cpp

src/peer/peermanager.h

src/peer/peeruploader.cpp

src/peer/peeruploader.h

src/peer/serverauthenticate.cpp

src/peer/serverauthenticate.h

src/peer/utpex.cpp

src/peer/utpex.h

src/torrent/CMakeLists.txt

src/torrent/advancedchokealgorithm.cpp

src/torrent/globals.cpp

src/torrent/job.cpp

src/torrent/job.h

src/torrent/jobqueue.cpp

src/torrent/server.cpp

src/torrent/server.h

src/torrent/tests/CMakeLists.txt

src/torrent/timeestimator.cpp

src/torrent/torrent.cpp

src/torrent/torrentcontrol.cpp

src/torrent/torrentcontrol.h

src/torrent/torrentfile.cpp

src/torrent/torrentfile.h

src/torrent/torrentstats.cpp

src/torrent/torrentstats.h

src/torrent/uploader.cpp

src/torrent/uploader.h

src/tracker/httpannouncejob.cpp

src/tracker/httpannouncejob.h

src/tracker/httptracker.cpp

src/tracker/udptracker.cpp

src/tracker/udptracker.h

src/tracker/udptrackersocket.cpp

src/tracker/udptrackersocket.h

src/util/CMakeLists.txt

src/util/file.cpp

src/util/file.h

src/util/fileops.cpp

src/util/fileops.h

src/util/functions.cpp

src/util/functions.h

src/util/log.cpp

src/util/log.h

src/util/pipe.cpp

src/util/sha1hashgen.cpp

src/util/sha1hashgen.h

src/util/tests/CMakeLists.txt

src/util/waitjob.cpp

src/util/waitjob.h

src/utp/connection.cpp

src/utp/connection.h

src/utp/delaywindow.cpp

src/utp/delaywindow.h

src/utp/localwindow.cpp

src/utp/localwindow.h

src/utp/pollpipe.h

src/utp/remotewindow.cpp

src/utp/remotewindow.h

src/utp/tests/congestiontest.cpp

src/utp/tests/connectiontest.cpp

src/utp/tests/connecttest.cpp

src/utp/tests/fintest.cpp

src/utp/tests/localwindowtest.cpp

src/utp/tests/packetlosstest.cpp

src/utp/tests/remotewindowtest.cpp

src/utp/tests/sendtest.cpp

src/utp/tests/sockettest.cpp

src/utp/tests/transmittest.cpp

src/utp/tests/utppolltest.cpp

src/utp/utpserver.cpp

src/utp/utpserver.h

src/utp/utpserverthread.cpp

src/utp/utpsocket.cpp

src/utp/utpsocket.h

src/version.cpp

src/version.h

Show diffs side-by-side

added added

removed removed

src/dht/dht.cpp

102

delete srv; srv = 0;

103

}

104

105

void DHT::ping(PingReq* r)

105

void DHT::ping(PingReq::Ptr r)

106

{

107

if (!running)

108

return;

114

Out(SYS_DHT|LOG_NOTICE) << "DHT: Sending ping response" << endl;

115

PingRsp rsp(r->getMTID(),node->getOurID());

116

rsp.setOrigin(r->getOrigin());

117

srv->sendMsg(&rsp);

117

srv->sendMsg(rsp);

118

node->received(this,r);

119

}

120

121

122

123

void DHT::findNode(FindNodeReq* r)

123

void DHT::findNode(FindNodeReq::Ptr r)

124

{

125

if (!running)

126

return;

140

// pack the found nodes in a byte array

141

kns.pack(&fnr);

142

fnr.setOrigin(r->getOrigin());

143

srv->sendMsg(&fnr);

143

srv->sendMsg(fnr);

144

}

145

146

NodeLookup* DHT::findOwnNode()

161

}

162

163

164

void DHT::announce(AnnounceReq* r)

164

void DHT::announce(AnnounceReq::Ptr r)

165

{

166

if (!running)

167

return;

182

// send a proper response to indicate everything is OK

183

AnnounceRsp rsp(r->getMTID(),node->getOurID());

184

rsp.setOrigin(r->getOrigin());

185

srv->sendMsg(&rsp);

185

srv->sendMsg(rsp);

186

}

187

188

189

190

void DHT::getPeers(GetPeersReq* r)

190

void DHT::getPeers(GetPeersReq::Ptr r)

191

{

192

if (!running)

193

return;

215

GetPeersRsp fnr(r->getMTID(),node->getOurID(),token);

216

kns.pack(&fnr);

217

fnr.setOrigin(r->getOrigin());

218

srv->sendMsg(&fnr);

218

srv->sendMsg(fnr);

219

}

220

else

221

{

222

// send a get peers response

223

GetPeersRsp fvr(r->getMTID(),node->getOurID(),dbl,token);

224

fvr.setOrigin(r->getOrigin());

225

srv->sendMsg(&fvr);

225

srv->sendMsg(fvr);

226

}

227

}

228

229

void DHT::response(MsgBase* r)

229

void DHT::response(MsgBase::Ptr r)

230

{

231

if (!running)

232

return;

234

node->received(this,r);

235

}

236

237

void DHT::error(ErrMsg* )

237

void DHT::error(ErrMsg::Ptr )

238

{}

239

240

244

return;

245

246

Out(SYS_DHT|LOG_DEBUG) << "Sending ping request to " << ip << ":" << port << endl;

247

PingReq* r = new PingReq(node->getOurID());

247

MsgBase::Ptr r(new PingReq(node->getOurID()));

248

r->setOrigin(KInetSocketAddress(ip,port));

249

srv->doCall(r);

250

}

346

}

347

}

348

349

void DHT::timeout(const MsgBase* r)

349

void DHT::timeout(MsgBase::Ptr r)

350

{

351

node->onTimeout(r);

352

}

Older »