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

fix warning for Xcode 9, added const and minor code refactor to bt_peer_connection.cpp

This commit is contained in:
Alden Torres 2017-09-21 18:49:10 -04:00 committed by Arvid Norberg
parent 8648de3706
commit 1d9b10a32b
2 changed files with 26 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/libtorrent/bt_peer_connection.hpp
View File

@ -410,6 +410,8 @@ namespace libtorrent {
#pragma clang diagnostic push
// macOS clang doesn't have -Wshadow-field
#pragma clang diagnostic ignored "-Wunknown-pragmas"
// Xcode 9 needs this
#pragma clang diagnostic ignored "-Wunknown-warning-option"
#pragma clang diagnostic ignored "-Wshadow-field"
#endif
crypto_receive_buffer m_recv_buffer;

50
src/bt_peer_connection.cpp
View File

@ -77,13 +77,11 @@ POSSIBILITY OF SUCH DAMAGE.
namespace libtorrent {
namespace mp = boost::multiprecision;
#if !defined(TORRENT_DISABLE_ENCRYPTION) && !defined(TORRENT_DISABLE_EXTENSIONS)
namespace {
std::size_t const handshake_len = 68;
std::size_t const dh_key_len = 96;
constexpr std::size_t handshake_len = 68;
constexpr std::size_t dh_key_len = 96;
// stream key (info hash of attached torrent)
// secret is the DH shared secret
@ -135,15 +133,15 @@ namespace {
if (ep.address().is_v4())
{
#endif
peers4_t::value_type v(ep.address().to_v4().to_bytes(), ep.port());
auto i = std::lower_bound(m_peers.begin(), m_peers.end(), v);
peers4_t::value_type const v(ep.address().to_v4().to_bytes(), ep.port());
auto const i = std::lower_bound(m_peers.begin(), m_peers.end(), v);
return i != m_peers.end() && *i == v;
#if TORRENT_USE_IPV6
}
else
{
peers6_t::value_type v(ep.address().to_v6().to_bytes(), ep.port());
auto i = std::lower_bound(m_peers6.begin(), m_peers6.end(), v);
peers6_t::value_type const v(ep.address().to_v6().to_bytes(), ep.port());
auto const i = std::lower_bound(m_peers6.begin(), m_peers6.end(), v);
return i != m_peers6.end() && *i == v;
}
#endif
@ -193,13 +191,13 @@ namespace {
#if !defined(TORRENT_DISABLE_ENCRYPTION) && !defined(TORRENT_DISABLE_EXTENSIONS)
void bt_peer_connection::switch_send_crypto(std::shared_ptr<crypto_plugin> crypto)
{
if (m_enc_handler.switch_send_crypto(crypto, send_buffer_size() - get_send_barrier()))
if (m_enc_handler.switch_send_crypto(std::move(crypto), send_buffer_size() - get_send_barrier()))
set_send_barrier(send_buffer_size());
}
void bt_peer_connection::switch_recv_crypto(std::shared_ptr<crypto_plugin> crypto)
{
m_enc_handler.switch_recv_crypto(crypto, m_recv_buffer);
m_enc_handler.switch_recv_crypto(std::move(crypto), m_recv_buffer);
}
#endif
@ -215,7 +213,7 @@ namespace {
#ifndef TORRENT_DISABLE_LOGGING
peer_log(peer_log_alert::info, "ON_CONNECTED", "graceful-paused");
#endif
disconnect(error_code(errors::torrent_paused), operation_t::bittorrent);
disconnect(errors::torrent_paused, operation_t::bittorrent);
return;
}
@ -339,7 +337,7 @@ namespace {
#endif
}
void bt_peer_connection::write_dht_port(int listen_port)
void bt_peer_connection::write_dht_port(int const listen_port)
{
INVARIANT_CHECK;
@ -605,7 +603,7 @@ namespace {
send_buffer({msg, sizeof(msg) - 512 + pad_size});
}
void bt_peer_connection::write_pe4_sync(int crypto_select)
void bt_peer_connection::write_pe4_sync(int const crypto_select)
{
INVARIANT_CHECK;
@ -1028,14 +1026,14 @@ namespace {
// ----------- PIECE -----------
// -----------------------------
void bt_peer_connection::on_piece(int received)
void bt_peer_connection::on_piece(int const received)
{
INVARIANT_CHECK;
TORRENT_ASSERT(received >= 0);
span<char const> recv_buffer = m_recv_buffer.get();
int recv_pos = m_recv_buffer.pos(); // recv_buffer.end - recv_buffer.begin;
int const recv_pos = m_recv_buffer.pos(); // recv_buffer.end - recv_buffer.begin;
std::shared_ptr<torrent> t = associated_torrent().lock();
TORRENT_ASSERT(t);
@ -1249,7 +1247,7 @@ namespace {
span<char const> recv_buffer = m_recv_buffer.get();
const char* ptr = recv_buffer.begin() + 1;
int listen_port = detail::read_uint16(ptr);
int const listen_port = detail::read_uint16(ptr);
incoming_dht_port(listen_port);
@ -1344,7 +1342,7 @@ namespace {
if (!m_recv_buffer.packet_finished()) return;
span<char const> recv_buffer = m_recv_buffer.get();
const char* ptr = recv_buffer.begin() + 1;
piece_index_t index(detail::read_int32(ptr));
piece_index_t const index(detail::read_int32(ptr));
incoming_allowed_fast(index);
}
@ -1597,7 +1595,7 @@ namespace {
TORRENT_ASSERT(recv_buffer.front() == msg_extended);
recv_buffer = recv_buffer.subspan(1);
int extended_id = aux::read_uint8(recv_buffer);
int const extended_id = aux::read_uint8(recv_buffer);
if (extended_id == 0)
{
@ -1743,7 +1741,7 @@ namespace {
}
// there is supposed to be a remote listen port
int listen_port = int(root.dict_find_int_value("p"));
int const listen_port = int(root.dict_find_int_value("p"));
if (listen_port > 0 && peer_info_struct() != nullptr)
{
t->update_peer_port(listen_port, peer_info_struct(), peer_info::incoming);
@ -1757,10 +1755,10 @@ namespace {
int const last_seen_complete = int(root.dict_find_int_value("complete_ago", -1));
if (last_seen_complete >= 0) set_last_seen_complete(last_seen_complete);
auto client_info = root.dict_find_string_value("v");
auto const client_info = root.dict_find_string_value("v");
if (!client_info.empty()) m_client_version = client_info.to_string();
int reqq = int(root.dict_find_int_value("reqq"));
int const reqq = int(root.dict_find_int_value("reqq"));
if (reqq > 0) max_out_request_queue(reqq);
if (root.dict_find_int_value("upload_only", 0))
@ -1770,7 +1768,7 @@ namespace {
&& root.dict_find_int_value("share_mode", 0))
set_share_mode(true);
auto myip = root.dict_find_string_value("yourip");
auto const myip = root.dict_find_string_value("yourip");
if (!myip.empty())
{
if (myip.size() == std::tuple_size<address_v4::bytes_type>::value)
@ -2080,7 +2078,7 @@ namespace {
// add predictive pieces to the bitfield as well, since we won't
// announce them again
for (piece_index_t p : t->predictive_pieces())
for (piece_index_t const p : t->predictive_pieces())
msg[5 + static_cast<int>(p) / 8] |= (0x80 >> (static_cast<int>(p) & 7));
#ifndef TORRENT_DISABLE_LOGGING
@ -2255,7 +2253,7 @@ namespace {
send_message(msg_not_interested, counters::num_outgoing_not_interested, 0);
}
void bt_peer_connection::write_have(piece_index_t index)
void bt_peer_connection::write_have(piece_index_t const index)
{
INVARIANT_CHECK;
TORRENT_ASSERT(associated_torrent().lock()->valid_metadata());
@ -3325,7 +3323,7 @@ namespace {
int packet_size = detail::read_int32(ptr);
// don't accept packets larger than 1 MB
if (packet_size > 1024*1024 || packet_size < 0)
if (packet_size > 1024 * 1024 || packet_size < 0)
{
// packet too large
received_bytes(0, int(bytes_transferred));
@ -3409,7 +3407,7 @@ namespace {
// --------------------------
void bt_peer_connection::on_sent(error_code const& error
, std::size_t bytes_transferred)
, std::size_t const bytes_transferred)
{
INVARIANT_CHECK;