blob: ffd7c5611d117c634e03300d639e4bca0455cf49 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
#include "drape_frontend/metaline_manager.hpp"
#include "drape_frontend/map_data_provider.hpp"
#include "drape_frontend/message_subclasses.hpp"
#include "drape_frontend/threads_commutator.hpp"
#include "base/logging.hpp"
#include <functional>
namespace df
{
MetalineManager::MetalineManager(ref_ptr<ThreadsCommutator> commutator,
MapDataProvider & model)
: m_model(model)
, m_commutator(commutator)
{}
MetalineManager::~MetalineManager()
{
Stop();
}
void MetalineManager::Stop()
{
m_activeTasks.FinishAll();
}
void MetalineManager::Update(std::set<MwmSet::MwmId> const & mwms)
{
std::lock_guard<std::mutex> lock(m_mwmsMutex);
for (auto const & mwm : mwms)
{
auto const result = m_mwms.insert(mwm);
if (!result.second)
return;
auto readingTask = std::make_shared<ReadMetalineTask>(m_model, mwm);
auto routineResult = dp::DrapeRoutine::Run([this, readingTask]()
{
readingTask->Run();
OnTaskFinished(readingTask);
});
if (routineResult)
m_activeTasks.Add(readingTask, routineResult);
}
}
m2::SharedSpline MetalineManager::GetMetaline(FeatureID const & fid) const
{
std::lock_guard<std::mutex> lock(m_metalineCacheMutex);
auto const metalineIt = m_metalineCache.find(fid);
if (metalineIt == m_metalineCache.end())
return m2::SharedSpline();
return metalineIt->second;
}
void MetalineManager::OnTaskFinished(std::shared_ptr<ReadMetalineTask> const & task)
{
if (task->IsCancelled())
return;
std::lock_guard<std::mutex> lock(m_metalineCacheMutex);
// Update metalines cache.
auto const & metalines = task->GetMetalines();
for (auto const & metaline : metalines)
m_metalineCache[metaline.first] = metaline.second;
// Notify FR.
if (!metalines.empty())
{
LOG(LDEBUG, ("Metalines prepared:", task->GetMwmId()));
m_commutator->PostMessage(ThreadsCommutator::RenderThread,
make_unique_dp<UpdateMetalinesMessage>(),
MessagePriority::Normal);
}
// Remove task from active ones.
m_activeTasks.Remove(task);
}
} // namespace df
|
