| 465 | } |
| 466 | |
| 467 | void BackupRelationTask::putCleanBuffer(IOBuffer* buf) |
| 468 | { |
| 469 | Item* item = static_cast<Item*>(buf->getItem()); |
| 470 | { |
| 471 | MutexLockGuard guard(item->m_mutex, FB_FUNCTION); |
| 472 | |
| 473 | if (item->m_cleanBuffers.isEmpty()) |
| 474 | item->m_cleanCond.notifyOne(); |
| 475 | |
| 476 | item->m_cleanBuffers.push(buf); |
| 477 | } |
| 478 | buf->unlock(); |
| 479 | } |
| 480 | |
| 481 | void BackupRelationTask::initItem(BurpGlobals* tdgbl, Item& item) |
| 482 | { |