Ticket #6323: patch
File patch, 1.3 KB (added by , 15 years ago) |
---|
-
ThreadedFileWriter.cpp
277 277 bufferHasData.wakeAll(); 278 278 279 279 remaining -= bytes; 280 if(remaining) 281 { 282 data = (const char*)data + bytes; 280 283 281 buflock.lock(); 282 if (remaining && (0 == BufFreePriv())) 283 bufferWroteData.wait(&buflock, 10000); 284 buflock.unlock(); 284 buflock.lock(); 285 if (0 == BufFreePriv()) 286 bufferWroteData.wait(&buflock, 10000); 287 buflock.unlock(); 288 } 285 289 } 286 290 287 291 return count; -
ThreadedFileWriter.h
53 53 long long tfw_min_write_size; 54 54 55 55 // buffer position state 56 uintrpos; ///< points to end of data written to disk57 uintwpos; ///< points to end of data added to buffer56 volatile uint rpos; ///< points to end of data written to disk 57 volatile uint wpos; ///< points to end of data added to buffer 58 58 mutable QMutex buflock; ///< lock needed to update rpos and wpos 59 59 long long written; 60 60