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

fix i2p support

This commit is contained in:
arvidn 2017-11-27 10:10:45 +01:00 committed by Arvid Norberg
parent 83e71e16d8
commit a286b9da47
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ChangeLog
View File

@ -1,4 +1,5 @@
* fix i2p support
* fix loading resume data when in seed mode * fix loading resume data when in seed mode
* fix part-file creation race condition * fix part-file creation race condition
* fix issue with initializing settings on session construction * fix issue with initializing settings on session construction

11
src/http_connection.cpp
View File

@ -495,11 +495,10 @@ void http_connection::connect_i2p_tracker(char const* destination)
{ {
#ifdef TORRENT_USE_OPENSSL #ifdef TORRENT_USE_OPENSSL
TORRENT_ASSERT(m_ssl == false); TORRENT_ASSERT(m_ssl == false);
TORRENT_ASSERT(m_sock.get<socket_type>()); TORRENT_ASSERT(m_sock.get<i2p_stream>());
TORRENT_ASSERT(m_sock.get<socket_type>()->get<i2p_stream>()); m_sock.get<i2p_stream>()->set_destination(destination);
m_sock.get<socket_type>()->get<i2p_stream>()->set_destination(destination); m_sock.get<i2p_stream>()->set_command(i2p_stream::cmd_connect);
m_sock.get<socket_type>()->get<i2p_stream>()->set_command(i2p_stream::cmd_connect); m_sock.get<i2p_stream>()->set_session_id(m_i2p_conn->session_id());
m_sock.get<socket_type>()->get<i2p_stream>()->set_session_id(m_i2p_conn->session_id());
#else #else
m_sock.get<i2p_stream>()->set_destination(destination); m_sock.get<i2p_stream>()->set_destination(destination);
m_sock.get<i2p_stream>()->set_command(i2p_stream::cmd_connect); m_sock.get<i2p_stream>()->set_command(i2p_stream::cmd_connect);
@ -508,6 +507,8 @@ void http_connection::connect_i2p_tracker(char const* destination)
#if defined TORRENT_ASIO_DEBUGGING #if defined TORRENT_ASIO_DEBUGGING
add_outstanding_async("http_connection::on_connect"); add_outstanding_async("http_connection::on_connect");
#endif #endif
TORRENT_ASSERT(!m_connecting);
m_connecting = true;
m_sock.async_connect(tcp::endpoint(), boost::bind(&http_connection::on_connect m_sock.async_connect(tcp::endpoint(), boost::bind(&http_connection::on_connect
, shared_from_this(), _1)); , shared_from_this(), _1));
} }