mirrors/urbackup_backend
2
0
Fork 0
mirror of https://github.com/uroni/urbackup_backend.git synced 2025-10-26 11:36:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix new read-ahead

Browse Source
This commit is contained in:
Martin Raiber 2019-06-22 22:34:14 +02:00
parent d2d49c2e39
commit 4bc9e763b7
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
fsimageplugin/filesystem.cpp
View File

@ -383,9 +383,10 @@ void Filesystem::overlappedIoCompletion(SNextBlock * block, DWORD dwErrorCode, D
for(size_t i=0;i<block->n_buffers;++i)
block->buffers[i].state = ENextBlockState_Error;
}
else if (dwNumberOfBytesTransfered != getBlocksize())
else if (dwNumberOfBytesTransfered != block->n_buffers*getBlocksize())
{
Server->Log("Reading from device at position " + convert(offset) + " failed. OS returned only "+convert((int64)dwNumberOfBytesTransfered)+" bytes", LL_ERROR);
Server->Log("Reading from device at position " + convert(offset) + " failed. OS returned only "+convert((int64)dwNumberOfBytesTransfered)+" bytes"
". Expected "+convert(block->n_buffers*getBlocksize())+" bytes", LL_ERROR);
has_error = true;
for(size_t i=0;i<block->n_buffers;++i)
block->buffers[i].state = ENextBlockState_Error;
@ -563,6 +564,7 @@ void Filesystem::initReadahead(IFSImageFactory::EReadaheadMode read_ahead, bool
}
next_blocks[i].buffers[0].state = ENextBlockState_Queued;
next_blocks[i].fs = this;
next_blocks[i].buffers[0].block = &next_blocks[i];
for(size_t j=1;j<n_max_buffers;++j)
{
@ -641,7 +643,6 @@ bool Filesystem::queueOverlappedReads(bool force_queue)
}
#endif
ret = true;
overlapped_next_block = next_block_callback->nextBlock(overlapped_next_block);
if (Server->getTimeMS() - queue_starttime > 500)
{