You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
102 lines
4.1 KiB
C++
102 lines
4.1 KiB
C++
/*
|
|
* All or portions of this file Copyright (c) Amazon.com, Inc. or its affiliates or
|
|
* its licensors.
|
|
*
|
|
* For complete copyright and license terms please see the LICENSE at the root of this
|
|
* distribution (the "License"). All use of this software is governed by the License,
|
|
* or, if provided, by the license below or the license accompanying this file. Do not
|
|
* remove or modify any license notices. This file is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
*
|
|
*/
|
|
|
|
#include <AzCore/std/containers/vector.h>
|
|
#include <AzCore/std/string/string.h>
|
|
#include <AzCore/Outcome/Outcome.h>
|
|
#include <AzToolsFramework/API/EditorAssetSystemAPI.h> // for AssetSystemJobRequestBus
|
|
#include <AzToolsFramework/Debug/TraceContext.h>
|
|
#include <SceneAPI/SceneUI/CommonWidgets/JobWatcher.h>
|
|
|
|
namespace AZ
|
|
{
|
|
namespace SceneAPI
|
|
{
|
|
namespace SceneUI
|
|
{
|
|
const int JobWatcher::s_jobQueryInterval = 750; // ms
|
|
|
|
JobWatcher::JobWatcher(const AZStd::string& sourceAssetFullPath, Uuid traceTag)
|
|
: m_jobQueryTimer(new QTimer(this))
|
|
, m_sourceAssetFullPath(sourceAssetFullPath)
|
|
, m_traceTag(traceTag)
|
|
{
|
|
connect(m_jobQueryTimer, &QTimer::timeout, this, &JobWatcher::OnQueryJobs);
|
|
}
|
|
|
|
void JobWatcher::StartMonitoring()
|
|
{
|
|
m_jobQueryTimer->start(s_jobQueryInterval);
|
|
}
|
|
|
|
void JobWatcher::OnQueryJobs()
|
|
{
|
|
using namespace AzToolsFramework;
|
|
using namespace AzToolsFramework::AssetSystem;
|
|
|
|
AZ_TraceContext("Tag", m_traceTag);
|
|
|
|
// Query for the relevant jobs
|
|
Outcome<AssetSystem::JobInfoContainer> result = Failure();
|
|
AssetSystemJobRequestBus::BroadcastResult(result, &AssetSystemJobRequestBus::Events::GetAssetJobsInfo, m_sourceAssetFullPath, true);
|
|
|
|
if (!result.IsSuccess())
|
|
{
|
|
m_jobQueryTimer->stop();
|
|
emit JobQueryFailed("Failed to retrieve job information from Asset Processor.");
|
|
return;
|
|
}
|
|
|
|
JobInfoContainer& allJobs = result.GetValue();
|
|
if (allJobs.empty())
|
|
{
|
|
m_jobQueryTimer->stop();
|
|
emit JobQueryFailed("Queued file didn't produce any jobs.");
|
|
return;
|
|
}
|
|
|
|
bool allFinished = true;
|
|
for (const JobInfo& job : allJobs)
|
|
{
|
|
AZ_Assert(job.m_status != JobStatus::Any,
|
|
"The 'Any' status for job should be exclusive to the database and never be a result to a query.");
|
|
if (job.m_status != JobStatus::Queued && job.m_status != JobStatus::InProgress)
|
|
{
|
|
if (AZStd::find(m_reportedJobs.begin(), m_reportedJobs.end(), job.m_jobRunKey) == m_reportedJobs.end())
|
|
{
|
|
bool wasSuccessful = job.m_status == AzToolsFramework::AssetSystem::JobStatus::Completed;
|
|
|
|
Outcome<AZStd::string> logFetchResult = Failure();
|
|
AssetSystemJobRequestBus::BroadcastResult(logFetchResult, &AssetSystemJobRequestBus::Events::GetJobLog, job.m_jobRunKey);
|
|
emit JobProcessingComplete(job.m_platform, job.m_jobRunKey, wasSuccessful,
|
|
logFetchResult.IsSuccess() ? logFetchResult.GetValue() : "");
|
|
|
|
m_reportedJobs.push_back(job.m_jobRunKey);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
allFinished = false;
|
|
}
|
|
}
|
|
if (allFinished)
|
|
{
|
|
m_jobQueryTimer->stop();
|
|
emit AllJobsComplete();
|
|
}
|
|
}
|
|
} // namespace SceneUI
|
|
} // namespace SceneAPI
|
|
} // namespace AZ
|
|
|
|
#include <CommonWidgets/moc_JobWatcher.cpp>
|