twisterarmy/twister-core
1
0
Fork 0
mirror of https://github.com/twisterarmy/twister-core.git synced 2025-01-08 22:08:00 +00:00
Code Issues Projects Releases Wiki Activity

recheck piece just before sending to other torrent peer. fix #15.

Browse Source
This commit is contained in:
Miguel Freitas 2014-01-28 18:10:16 -02:00
parent a9f53cce98
commit fa386c250d
1 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
libtorrent/src/peer_connection.cpp
View File

@ -4569,7 +4569,7 @@ namespace libtorrent
return;
}
if (ret <= 0)
if (ret <= 0)
{
if (t->has_picker() && t->have_piece(j.piece) ) {
printf("on_disk_read_complete: read error (database corrupt?) - setting we_dont_have(%d)\n", j.piece);
@ -4592,8 +4592,8 @@ namespace libtorrent
}
return;
}
//[MF]
r.length = j.buffer_size;
//[MF]
r.length = j.buffer_size;
if (t)
{
@ -4609,7 +4609,18 @@ namespace libtorrent
#if TORRENT_DISK_STATS
if (j.buffer) m_ses.m_disk_thread.rename_buffer(j.buffer, "dispatched send buffer");
#endif
write_piece(r, buffer);
// [MF] recheck piece just before sending (issue #15)
std::string errmsg;
if( acceptSignedPost(j.buffer, j.buffer_size, j.storage->info()->name(),
j.piece, errmsg, NULL ) ) {
write_piece(r, buffer);
} else {
printf("on_disk_read_complete: [piece: %d l: %d] failed! (%s)\n",
j.piece, j.buffer_size, errmsg.c_str());
t->we_dont_have(j.piece);
m_ses.free_disk_buffer(buffer.get());
buffer.release();
}
}
void peer_connection::assign_bandwidth(int channel, int amount)