This repository was archived by the owner on Jul 15, 2023. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -221,13 +221,13 @@ class WriteBlockOp
221
221
size_t blockIdx;
222
222
{
223
223
boost::mutex::scoped_lock lock (m_state.compressMutex );
224
- blockIdx = m_state.nextBlockToCompress ;
224
+ blockIdx = m_state.nextBlockToCompress ++ ;
225
225
// Step counter to next
226
226
while (m_state.nextBlockToCompress < m_state.numBlocks ) {
227
- m_state.nextBlockToCompress ++;
228
227
if (m_state.blocks [m_state.nextBlockToCompress ].isAllocated ) {
229
228
break ;
230
229
}
230
+ m_state.nextBlockToCompress ++;
231
231
}
232
232
}
233
233
// Loop over blocks until we run out
@@ -261,24 +261,25 @@ class WriteBlockOp
261
261
// Do the writing
262
262
m_state.data .addData (cmpLen, &m_cache[0 ]);
263
263
// Let next block write
264
+ m_state.nextBlockToWrite ++;
264
265
while (m_state.nextBlockToWrite < m_state.numBlocks ){
265
266
// Increment to next
266
- m_state.nextBlockToWrite ++;
267
267
if (m_state.blocks [m_state.nextBlockToWrite ].isAllocated ) {
268
268
break ;
269
269
}
270
+ m_state.nextBlockToWrite ++;
270
271
}
271
272
}
272
273
// Get next block idx
273
274
{
274
275
boost::mutex::scoped_lock lock (m_state.compressMutex );
275
- blockIdx = m_state.nextBlockToCompress ;
276
+ blockIdx = m_state.nextBlockToCompress ++ ;
276
277
// Step counter to next
277
278
while (m_state.nextBlockToCompress < m_state.numBlocks ) {
278
- m_state.nextBlockToCompress ++;
279
279
if (m_state.blocks [m_state.nextBlockToCompress ].isAllocated ) {
280
280
break ;
281
281
}
282
+ m_state.nextBlockToCompress ++;
282
283
}
283
284
}
284
285
}
You can’t perform that action at this time.
0 commit comments