wornvirtue
/
premiere-libtorrent
forked from premiere/premiere-libtorrent
1
0
Fork 0
Code Pull Requests Activity

*** empty log message ***

This commit is contained in:
Arvid Norberg 2005-03-22 17:50:05 +00:00
parent 5751af2e6a
commit d9e93a3e99
2 changed files with 36 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/libtorrent/torrent_handle.hpp
View File

@ -192,6 +192,7 @@ namespace libtorrent
torrent_handle(): m_ses(0), m_chk(0) {}
void get_peer_info(std::vector<peer_info>& v) const;
bool send_chat_message(address ip, std::string message) const;
torrent_status status() const;
void get_download_queue(std::vector<partial_piece_info>& queue) const;

39
src/torrent_handle.cpp
View File

@ -74,7 +74,6 @@ using boost::bind;
namespace libtorrent
{
namespace
{
#if defined(_MSC_VER) && _MSC_VER < 1300
@ -173,8 +172,6 @@ namespace libtorrent
#endif
void torrent_handle::set_max_uploads(int max_uploads)
{
INVARIANT_CHECK;
@ -557,7 +554,7 @@ namespace libtorrent
{
peer_connection* peer = i->second;
// peers that hasn't finished the handshake should
// peers that haven't finished the handshake should
// not be included in this list
if (peer->associated_torrent() == 0) continue;
@ -616,6 +613,40 @@ namespace libtorrent
p.seed = peer->is_seed();
}
}
bool torrent_handle::send_chat_message(address ip, std::string message) const
{
if (m_ses == 0) throw invalid_handle();
boost::mutex::scoped_lock l(m_ses->m_mutex);
const torrent* t = m_ses->find_torrent(m_info_hash);
if (t == 0) return false;
for (torrent::const_peer_iterator i = t->begin();
i != t->end(); ++i)
{
peer_connection* peer = i->second;
// peers that haven't finished the handshake should
// not be included in this list
if (peer->associated_torrent() == 0) continue;
// peers that don's support chat message extension
// should not be included either
if (!peer->supports_extension(
peer_connection::extended_chat_message))
continue;
// loop until we find the required ip address
if (ip == peer->get_socket()->sender())
{
// send the message
peer->send_chat_message(message);
return true;
}
}
return false;
}
void torrent_handle::get_download_queue(std::vector<partial_piece_info>& queue) const
{