diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-09 23:36:24 +0100 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-01-11 10:20:21 +0000 |
| commit | 30b670e47f69e37b10d2cd09c037ae4158e1ae54 (patch) | |
| tree | 655f9f5005594696ad27ee690d82f66bf61d8d2f /storage | |
| parent | 846f3f61aa16984d598d5d503e78a2b774562ee1 (diff) | |
Do not broadcast after fetching a message.
Diffstat (limited to 'storage')
| -rw-r--r-- | storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp b/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp index a3aab381c25..61284c3bda4 100644 --- a/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp +++ b/storage/src/vespa/storage/persistence/filestorage/filestorhandlerimpl.cpp @@ -628,9 +628,8 @@ FileStorHandlerImpl::getNextMessage(uint16_t disk, uint8_t maxPriority) if (!messageTimedOutInQueue(*msg, waitTime)) { std::unique_ptr<FileStorHandler::BucketLockInterface> locker( takeDiskBucketLockOwnership(lockGuard, t, id, *msg)); - MBUS_TRACE(trace, 9, "FileStorHandler: Got lock on bucket"); - lockGuard.broadcast(); // XXX: needed here? lockGuard.unlock(); + MBUS_TRACE(trace, 9, "FileStorHandler: Got lock on bucket"); return std::move(FileStorHandler::LockedMessage(std::move(locker), std::move(msg))); } else { std::shared_ptr<api::StorageReply> msgReply( |