jiigen666/libtorrent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

more invariant checks in disk_io_thread

Browse Source
This commit is contained in:
Arvid Norberg
2008-03-10 08:19:31 +00:00
parent 7ea28d9982
commit e5a98d1b7e
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/disk_io_thread.cpp
View File

@@ -753,6 +753,7 @@ namespace libtorrent
m_log << log_time() << " read " << j.buffer_size << std::endl;
#endif
mutex_t::scoped_lock l(m_mutex);
INVARIANT_CHECK;
if (j.buffer == 0)
{
j.buffer = allocate_buffer();
@@ -801,6 +802,7 @@ namespace libtorrent
m_log << log_time() << " write " << j.buffer_size << std::endl;
#endif
mutex_t::scoped_lock l(m_mutex);
INVARIANT_CHECK;
cache_t::iterator p
= find_cached_piece(m_pieces, j, l);
int block = j.offset / m_block_size;
@@ -833,6 +835,9 @@ namespace libtorrent
m_log << log_time() << " hash" << std::endl;
#endif
mutex_t::scoped_lock l(m_mutex);
INVARIANT_CHECK;
cache_t::iterator i
= find_cached_piece(m_pieces, j, l);
if (i != m_pieces.end()) flush_and_remove(i, l);
@@ -872,6 +877,8 @@ namespace libtorrent
#endif
mutex_t::scoped_lock l(m_mutex);
INVARIANT_CHECK;
cache_t::iterator i = std::remove_if(
m_pieces.begin(), m_pieces.end(), bind(&cached_piece_entry::storage, _1) == j.storage);
@@ -895,6 +902,8 @@ namespace libtorrent
#endif
mutex_t::scoped_lock l(m_mutex);
INVARIANT_CHECK;
cache_t::iterator i = std::remove_if(
m_pieces.begin(), m_pieces.end(), bind(&cached_piece_entry::storage, _1) == j.storage);