-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[storage] background downloader queue is unified
- Loading branch information
1 parent
573b670
commit 1384b48
Showing
7 changed files
with
104 additions
and
116 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,87 @@ | ||
| #pragma once | ||
|
|
||
| #include "storage/downloader_queue_interface.hpp" | ||
| #include "storage/queued_country.hpp" | ||
| #include "storage/storage_defines.hpp" | ||
|
|
||
| #include <cstdint> | ||
| #include <optional> | ||
| #include <string> | ||
| #include <unordered_map> | ||
| #include <utility> | ||
|
|
||
| namespace storage | ||
| { | ||
| template <typename TaskInfoType> | ||
| class BackgroundDownloaderQueue : public QueueInterface | ||
| { | ||
| public: | ||
| bool IsEmpty() const override | ||
| { | ||
| return m_queue.empty(); | ||
| } | ||
|
|
||
| bool Contains(CountryId const & country) const override | ||
| { | ||
| return m_queue.find(country) != m_queue.cend(); | ||
| } | ||
|
|
||
| void ForEachCountry(ForEachCountryFunction const & fn) const override | ||
| { | ||
| for (auto const & item : m_queue) | ||
| { | ||
| fn(item.second.m_queuedCountry); | ||
| } | ||
| } | ||
|
|
||
| void Append(QueuedCountry && country) | ||
| { | ||
| auto const countryId = country.GetCountryId(); | ||
| auto const result = m_queue.emplace(countryId, std::move(country)); | ||
| result.first->second.m_queuedCountry.OnCountryInQueue(); | ||
| } | ||
|
|
||
| void SetTaskInfoForCountryId(CountryId const & countryId, TaskInfoType && taskInfo) | ||
| { | ||
| auto const it = m_queue.find(countryId); | ||
| CHECK(it != m_queue.cend(), ()); | ||
|
|
||
| it->second.m_taskInfo = std::move(taskInfo); | ||
| } | ||
|
|
||
| TaskInfoType const & GetTaskInfoForCountryId(CountryId const & countryId) const | ||
| { | ||
| auto const it = m_queue.find(countryId); | ||
| if (it == m_queue.cend()) | ||
| return {}; | ||
|
|
||
| return it->second.m_taskInfo; | ||
| } | ||
|
|
||
| QueuedCountry & GetCountryById(CountryId const & countryId) | ||
| { | ||
| return m_queue.at(countryId).m_queuedCountry; | ||
| } | ||
|
|
||
| void Remove(CountryId const & countryId) | ||
| { | ||
| m_queue.erase(countryId); | ||
| } | ||
|
|
||
| void Clear() | ||
| { | ||
| m_queue.clear(); | ||
| } | ||
|
|
||
| private: | ||
| struct TaskData | ||
| { | ||
| explicit TaskData(QueuedCountry && country) : m_queuedCountry(std::move(country)) {} | ||
|
|
||
| QueuedCountry m_queuedCountry; | ||
| TaskInfoType m_taskInfo; | ||
| }; | ||
|
|
||
| std::unordered_map<CountryId, TaskData> m_queue; | ||
| }; | ||
| } // namespace storage |
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters