2 * Copyright (c) 2022 Samsung Electronics Co., Ltd.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
19 #include "svg-rasterize-thread.h"
22 #include <dali/devel-api/adaptor-framework/file-loader.h>
23 #include <dali/devel-api/adaptor-framework/thread-settings.h>
24 #include <dali/integration-api/adaptor-framework/adaptor.h>
25 #include <dali/integration-api/debug.h>
28 #include <dali-toolkit/internal/visuals/svg/svg-visual.h>
36 SvgTask::SvgTask(SvgVisual* svgVisual, VectorImageRenderer vectorRenderer)
37 : mSvgVisual(svgVisual),
38 mVectorRenderer(vectorRenderer),
43 SvgVisual* SvgTask::GetSvgVisual() const
45 return mSvgVisual.Get();
48 PixelData SvgTask::GetPixelData() const
53 bool SvgTask::HasSucceeded() const
58 SvgLoadingTask::SvgLoadingTask(SvgVisual* svgVisual, VectorImageRenderer vectorRenderer, const VisualUrl& url, float dpi)
59 : SvgTask(svgVisual, vectorRenderer),
65 SvgLoadingTask::~SvgLoadingTask()
69 void SvgLoadingTask::Process()
71 if(mVectorRenderer.IsLoaded())
78 Dali::Vector<uint8_t> buffer;
80 if(!mUrl.IsLocalResource())
82 if(!Dali::FileLoader::DownloadFileSynchronously(mUrl.GetUrl(), buffer))
84 DALI_LOG_ERROR("Failed to download file! [%s]\n", mUrl.GetUrl().c_str());
90 if(!Dali::FileLoader::ReadFile(mUrl.GetUrl(), buffer))
92 DALI_LOG_ERROR("Failed to read file! [%s]\n", mUrl.GetUrl().c_str());
97 buffer.PushBack('\0');
99 if(!mVectorRenderer.Load(buffer, mDpi))
101 DALI_LOG_ERROR("Failed to load data! [%s]\n", mUrl.GetUrl().c_str());
105 mHasSucceeded = true;
108 SvgRasterizingTask::SvgRasterizingTask(SvgVisual* svgVisual, VectorImageRenderer vectorRenderer, unsigned int width, unsigned int height)
109 : SvgTask(svgVisual, vectorRenderer),
115 SvgRasterizingTask::~SvgRasterizingTask()
119 void SvgRasterizingTask::Process()
121 if(!mVectorRenderer.IsLoaded())
123 DALI_LOG_ERROR("File is not loaded!\n");
127 Devel::PixelBuffer pixelBuffer = mVectorRenderer.Rasterize(mWidth, mHeight);
130 DALI_LOG_ERROR("Rasterize is failed!\n");
134 mPixelData = Devel::PixelBuffer::Convert(pixelBuffer);
135 mHasSucceeded = true;
138 PixelData SvgRasterizingTask::GetPixelData() const
143 SvgRasterizeThread::SvgRasterizeThread()
144 : mTrigger(new EventThreadCallback(MakeCallback(this, &SvgRasterizeThread::ApplyRasterizedSVGToSampler))),
145 mLogFactory(Dali::Adaptor::Get().GetLogFactory()),
146 mIsThreadWaiting(false),
147 mProcessorRegistered(false)
151 SvgRasterizeThread::~SvgRasterizeThread()
153 if(mProcessorRegistered)
155 Adaptor::Get().UnregisterProcessor(*this);
159 void SvgRasterizeThread::TerminateThread(SvgRasterizeThread*& thread)
163 // add an empty task would stop the thread from conditional wait.
164 thread->AddTask(SvgTaskPtr());
173 void SvgRasterizeThread::AddTask(SvgTaskPtr task)
175 bool wasEmpty = false;
178 // Lock while adding task to the queue
179 ConditionalWait::ScopedLock lock(mConditionalWait);
180 wasEmpty = mRasterizeTasks.empty();
181 if(!wasEmpty && task)
183 // Remove the tasks with the same renderer.
184 // Older task which waiting to rasterize and apply the svg to the same renderer is expired.
185 // Rasterizing task only, loading task is not duplicated.
186 for(std::vector<SvgTaskPtr>::iterator it = mRasterizeTasks.begin(), endIt = mRasterizeTasks.end(); it != endIt; ++it)
188 if((*it) && (*it)->GetSvgVisual() == task->GetSvgVisual())
190 SvgRasterizingTask* oldTask = dynamic_cast<SvgRasterizingTask*>(it->Get());
191 SvgRasterizingTask* newTask = dynamic_cast<SvgRasterizingTask*>(task.Get());
192 if(oldTask && newTask)
194 mRasterizeTasks.erase(it);
200 mRasterizeTasks.push_back(task);
202 if(!mProcessorRegistered)
204 Adaptor::Get().RegisterProcessor(*this);
205 mProcessorRegistered = true;
211 // wake up the image loading thread
212 mConditionalWait.Notify();
216 SvgTaskPtr SvgRasterizeThread::NextCompletedTask()
218 // Lock while popping task out from the queue
219 Mutex::ScopedLock lock(mMutex);
221 if(mCompletedTasks.empty())
226 std::vector<SvgTaskPtr>::iterator next = mCompletedTasks.begin();
227 SvgTaskPtr nextTask = *next;
228 mCompletedTasks.erase(next);
233 void SvgRasterizeThread::RemoveTask(SvgVisual* visual)
235 // Lock while remove task from the queue
236 ConditionalWait::ScopedLock lock(mConditionalWait);
237 if(!mRasterizeTasks.empty())
239 for(std::vector<SvgTaskPtr>::iterator it = mRasterizeTasks.begin(), endIt = mRasterizeTasks.end(); it != endIt; ++it)
241 if((*it) && (*it)->GetSvgVisual() == visual)
243 mRasterizeTasks.erase(it);
248 UnregisterProcessor();
251 SvgTaskPtr SvgRasterizeThread::NextTaskToProcess()
253 // Lock while popping task out from the queue
254 ConditionalWait::ScopedLock lock(mConditionalWait);
257 while(mRasterizeTasks.empty())
259 mIsThreadWaiting = true;
260 mConditionalWait.Wait(lock);
262 mIsThreadWaiting = false;
264 // pop out the next task from the queue
265 std::vector<SvgTaskPtr>::iterator next = mRasterizeTasks.begin();
266 SvgTaskPtr nextTask = *next;
267 mRasterizeTasks.erase(next);
272 void SvgRasterizeThread::AddCompletedTask(SvgTaskPtr task)
274 // Lock while adding task to the queue
275 Mutex::ScopedLock lock(mMutex);
276 mCompletedTasks.push_back(task);
278 // wake up the main thread
282 void SvgRasterizeThread::Run()
284 SetThreadName("SVGThread");
285 mLogFactory.InstallLogFunction();
287 while(SvgTaskPtr task = NextTaskToProcess())
290 AddCompletedTask(task);
294 void SvgRasterizeThread::ApplyRasterizedSVGToSampler()
296 while(SvgTaskPtr task = NextCompletedTask())
298 task->GetSvgVisual()->ApplyRasterizedImage(task->GetPixelData(), task->HasSucceeded());
301 UnregisterProcessor();
304 void SvgRasterizeThread::Process(bool postProcessor)
306 ApplyRasterizedSVGToSampler();
309 void SvgRasterizeThread::UnregisterProcessor()
311 if(mProcessorRegistered)
313 if(mRasterizeTasks.empty() && mCompletedTasks.empty())
315 Adaptor::Get().UnregisterProcessor(*this);
316 mProcessorRegistered = false;
321 } // namespace Internal
323 } // namespace Toolkit