22 changed files with 850 additions and 735 deletions
-
17src/core/CMakeLists.txt
-
28src/core/hle/service/bcat/backend/backend.cpp
-
54src/core/hle/service/bcat/backend/backend.h
-
30src/core/hle/service/bcat/bcat.cpp
-
9src/core/hle/service/bcat/bcat.h
-
61src/core/hle/service/bcat/bcat_interface.cpp
-
40src/core/hle/service/bcat/bcat_interface.h
-
606src/core/hle/service/bcat/bcat_module.cpp
-
46src/core/hle/service/bcat/bcat_module.h
-
20src/core/hle/service/bcat/bcat_result.h
-
131src/core/hle/service/bcat/bcat_service.cpp
-
45src/core/hle/service/bcat/bcat_service.h
-
60src/core/hle/service/bcat/bcat_types.h
-
39src/core/hle/service/bcat/bcat_util.h
-
81src/core/hle/service/bcat/delivery_cache_directory_service.cpp
-
33src/core/hle/service/bcat/delivery_cache_directory_service.h
-
81src/core/hle/service/bcat/delivery_cache_file_service.cpp
-
33src/core/hle/service/bcat/delivery_cache_file_service.h
-
41src/core/hle/service/bcat/delivery_cache_progress_service.cpp
-
35src/core/hle/service/bcat/delivery_cache_progress_service.h
-
57src/core/hle/service/bcat/delivery_cache_storage_service.cpp
-
36src/core/hle/service/bcat/delivery_cache_storage_service.h
@ -1,24 +1,26 @@ |
|||||
// SPDX-FileCopyrightText: Copyright 2018 yuzu Emulator Project
|
// SPDX-FileCopyrightText: Copyright 2018 yuzu Emulator Project
|
||||
// SPDX-License-Identifier: GPL-2.0-or-later
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
||||
|
|
||||
|
#include "core/hle/service/bcat/backend/backend.h"
|
||||
#include "core/hle/service/bcat/bcat.h"
|
#include "core/hle/service/bcat/bcat.h"
|
||||
|
#include "core/hle/service/bcat/bcat_interface.h"
|
||||
|
#include "core/hle/service/server_manager.h"
|
||||
|
|
||||
namespace Service::BCAT { |
namespace Service::BCAT { |
||||
|
|
||||
BCAT::BCAT(Core::System& system_, std::shared_ptr<Module> module_, |
|
||||
FileSystem::FileSystemController& fsc_, const char* name_) |
|
||||
: Interface(system_, std::move(module_), fsc_, name_) { |
|
||||
// clang-format off
|
|
||||
static const FunctionInfo functions[] = { |
|
||||
{0, &BCAT::CreateBcatService, "CreateBcatService"}, |
|
||||
{1, &BCAT::CreateDeliveryCacheStorageService, "CreateDeliveryCacheStorageService"}, |
|
||||
{2, &BCAT::CreateDeliveryCacheStorageServiceWithApplicationId, "CreateDeliveryCacheStorageServiceWithApplicationId"}, |
|
||||
{3, nullptr, "CreateDeliveryCacheProgressService"}, |
|
||||
{4, nullptr, "CreateDeliveryCacheProgressServiceWithApplicationId"}, |
|
||||
}; |
|
||||
// clang-format on
|
|
||||
RegisterHandlers(functions); |
|
||||
|
void LoopProcess(Core::System& system) { |
||||
|
auto server_manager = std::make_unique<ServerManager>(system); |
||||
|
|
||||
|
server_manager->RegisterNamedService("bcat:a", |
||||
|
std::make_shared<BcatInterface>(system, "bcat:a")); |
||||
|
server_manager->RegisterNamedService("bcat:m", |
||||
|
std::make_shared<BcatInterface>(system, "bcat:m")); |
||||
|
server_manager->RegisterNamedService("bcat:u", |
||||
|
std::make_shared<BcatInterface>(system, "bcat:u")); |
||||
|
server_manager->RegisterNamedService("bcat:s", |
||||
|
std::make_shared<BcatInterface>(system, "bcat:s")); |
||||
|
|
||||
|
ServerManager::RunServer(std::move(server_manager)); |
||||
} |
} |
||||
|
|
||||
BCAT::~BCAT() = default; |
|
||||
} // namespace Service::BCAT
|
} // namespace Service::BCAT
|
||||
@ -0,0 +1,61 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2018 yuzu Emulator Project
|
||||
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
||||
|
|
||||
|
#include "core/hle/service/bcat/bcat_interface.h"
|
||||
|
#include "core/hle/service/bcat/bcat_service.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_storage_service.h"
|
||||
|
#include "core/hle/service/cmif_serialization.h"
|
||||
|
#include "core/hle/service/filesystem/filesystem.h"
|
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
std::unique_ptr<BcatBackend> CreateBackendFromSettings([[maybe_unused]] Core::System& system, |
||||
|
DirectoryGetter getter) { |
||||
|
return std::make_unique<NullBcatBackend>(std::move(getter)); |
||||
|
} |
||||
|
|
||||
|
BcatInterface::BcatInterface(Core::System& system_, const char* name_) |
||||
|
: ServiceFramework{system_, name_}, fsc{system.GetFileSystemController()} { |
||||
|
// clang-format off
|
||||
|
static const FunctionInfo functions[] = { |
||||
|
{0, C<&BcatInterface::CreateBcatService>, "CreateBcatService"}, |
||||
|
{1, C<&BcatInterface::CreateDeliveryCacheStorageService>, "CreateDeliveryCacheStorageService"}, |
||||
|
{2, C<&BcatInterface::CreateDeliveryCacheStorageServiceWithApplicationId>, "CreateDeliveryCacheStorageServiceWithApplicationId"}, |
||||
|
{3, nullptr, "CreateDeliveryCacheProgressService"}, |
||||
|
{4, nullptr, "CreateDeliveryCacheProgressServiceWithApplicationId"}, |
||||
|
}; |
||||
|
// clang-format on
|
||||
|
|
||||
|
RegisterHandlers(functions); |
||||
|
|
||||
|
backend = |
||||
|
CreateBackendFromSettings(system_, [this](u64 tid) { return fsc.GetBCATDirectory(tid); }); |
||||
|
} |
||||
|
|
||||
|
BcatInterface::~BcatInterface() = default; |
||||
|
|
||||
|
Result BcatInterface::CreateBcatService(OutInterface<IBcatService> out_interface) { |
||||
|
LOG_INFO(Service_BCAT, "called"); |
||||
|
*out_interface = std::make_shared<IBcatService>(system, *backend); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result BcatInterface::CreateDeliveryCacheStorageService( |
||||
|
OutInterface<IDeliveryCacheStorageService> out_interface) { |
||||
|
LOG_INFO(Service_BCAT, "called"); |
||||
|
|
||||
|
const auto title_id = system.GetApplicationProcessProgramID(); |
||||
|
*out_interface = |
||||
|
std::make_shared<IDeliveryCacheStorageService>(system, fsc.GetBCATDirectory(title_id)); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result BcatInterface::CreateDeliveryCacheStorageServiceWithApplicationId( |
||||
|
u64 title_id, OutInterface<IDeliveryCacheStorageService> out_interface) { |
||||
|
LOG_DEBUG(Service_BCAT, "called, title_id={:016X}", title_id); |
||||
|
*out_interface = |
||||
|
std::make_shared<IDeliveryCacheStorageService>(system, fsc.GetBCATDirectory(title_id)); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
} // namespace Service::BCAT
|
||||
@ -0,0 +1,40 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include "core/hle/service/cmif_types.h" |
||||
|
#include "core/hle/service/service.h" |
||||
|
|
||||
|
namespace Core { |
||||
|
class System; |
||||
|
} |
||||
|
|
||||
|
namespace Service::FileSystem { |
||||
|
class FileSystemController; |
||||
|
} |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
class BcatBackend; |
||||
|
class IBcatService; |
||||
|
class IDeliveryCacheStorageService; |
||||
|
|
||||
|
class BcatInterface final : public ServiceFramework<BcatInterface> { |
||||
|
public: |
||||
|
explicit BcatInterface(Core::System& system_, const char* name_); |
||||
|
~BcatInterface() override; |
||||
|
|
||||
|
private: |
||||
|
Result CreateBcatService(OutInterface<IBcatService> out_interface); |
||||
|
|
||||
|
Result CreateDeliveryCacheStorageService( |
||||
|
OutInterface<IDeliveryCacheStorageService> out_interface); |
||||
|
|
||||
|
Result CreateDeliveryCacheStorageServiceWithApplicationId( |
||||
|
u64 title_id, OutInterface<IDeliveryCacheStorageService> out_interface); |
||||
|
|
||||
|
std::unique_ptr<BcatBackend> backend; |
||||
|
Service::FileSystem::FileSystemController& fsc; |
||||
|
}; |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
@ -1,606 +0,0 @@ |
|||||
// SPDX-FileCopyrightText: Copyright 2018 yuzu Emulator Project
|
|
||||
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
||||
|
|
||||
#include <cctype>
|
|
||||
#include <mbedtls/md5.h>
|
|
||||
#include "common/hex_util.h"
|
|
||||
#include "common/logging/log.h"
|
|
||||
#include "common/settings.h"
|
|
||||
#include "common/string_util.h"
|
|
||||
#include "core/core.h"
|
|
||||
#include "core/file_sys/vfs/vfs.h"
|
|
||||
#include "core/hle/kernel/k_readable_event.h"
|
|
||||
#include "core/hle/service/bcat/backend/backend.h"
|
|
||||
#include "core/hle/service/bcat/bcat.h"
|
|
||||
#include "core/hle/service/bcat/bcat_module.h"
|
|
||||
#include "core/hle/service/filesystem/filesystem.h"
|
|
||||
#include "core/hle/service/ipc_helpers.h"
|
|
||||
#include "core/hle/service/server_manager.h"
|
|
||||
|
|
||||
namespace Service::BCAT { |
|
||||
|
|
||||
constexpr Result ERROR_INVALID_ARGUMENT{ErrorModule::BCAT, 1}; |
|
||||
constexpr Result ERROR_FAILED_OPEN_ENTITY{ErrorModule::BCAT, 2}; |
|
||||
constexpr Result ERROR_ENTITY_ALREADY_OPEN{ErrorModule::BCAT, 6}; |
|
||||
constexpr Result ERROR_NO_OPEN_ENTITY{ErrorModule::BCAT, 7}; |
|
||||
|
|
||||
// The command to clear the delivery cache just calls fs IFileSystem DeleteFile on all of the files
|
|
||||
// and if any of them have a non-zero result it just forwards that result. This is the FS error code
|
|
||||
// for permission denied, which is the closest approximation of this scenario.
|
|
||||
constexpr Result ERROR_FAILED_CLEAR_CACHE{ErrorModule::FS, 6400}; |
|
||||
|
|
||||
using BCATDigest = std::array<u8, 0x10>; |
|
||||
|
|
||||
namespace { |
|
||||
|
|
||||
u64 GetCurrentBuildID(const Core::System::CurrentBuildProcessID& id) { |
|
||||
u64 out{}; |
|
||||
std::memcpy(&out, id.data(), sizeof(u64)); |
|
||||
return out; |
|
||||
} |
|
||||
|
|
||||
// The digest is only used to determine if a file is unique compared to others of the same name.
|
|
||||
// Since the algorithm isn't ever checked in game, MD5 is safe.
|
|
||||
BCATDigest DigestFile(const FileSys::VirtualFile& file) { |
|
||||
BCATDigest out{}; |
|
||||
const auto bytes = file->ReadAllBytes(); |
|
||||
mbedtls_md5_ret(bytes.data(), bytes.size(), out.data()); |
|
||||
return out; |
|
||||
} |
|
||||
|
|
||||
// For a name to be valid it must be non-empty, must have a null terminating character as the final
|
|
||||
// char, can only contain numbers, letters, underscores and a hyphen if directory and a period if
|
|
||||
// file.
|
|
||||
bool VerifyNameValidInternal(HLERequestContext& ctx, std::array<char, 0x20> name, char match_char) { |
|
||||
const auto null_chars = std::count(name.begin(), name.end(), 0); |
|
||||
const auto bad_chars = std::count_if(name.begin(), name.end(), [match_char](char c) { |
|
||||
return !std::isalnum(static_cast<u8>(c)) && c != '_' && c != match_char && c != '\0'; |
|
||||
}); |
|
||||
if (null_chars == 0x20 || null_chars == 0 || bad_chars != 0 || name[0x1F] != '\0') { |
|
||||
LOG_ERROR(Service_BCAT, "Name passed was invalid!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_INVALID_ARGUMENT); |
|
||||
return false; |
|
||||
} |
|
||||
|
|
||||
return true; |
|
||||
} |
|
||||
|
|
||||
bool VerifyNameValidDir(HLERequestContext& ctx, DirectoryName name) { |
|
||||
return VerifyNameValidInternal(ctx, name, '-'); |
|
||||
} |
|
||||
|
|
||||
bool VerifyNameValidFile(HLERequestContext& ctx, FileName name) { |
|
||||
return VerifyNameValidInternal(ctx, name, '.'); |
|
||||
} |
|
||||
|
|
||||
} // Anonymous namespace
|
|
||||
|
|
||||
struct DeliveryCacheDirectoryEntry { |
|
||||
FileName name; |
|
||||
u64 size; |
|
||||
BCATDigest digest; |
|
||||
}; |
|
||||
|
|
||||
class IDeliveryCacheProgressService final : public ServiceFramework<IDeliveryCacheProgressService> { |
|
||||
public: |
|
||||
explicit IDeliveryCacheProgressService(Core::System& system_, Kernel::KReadableEvent& event_, |
|
||||
const DeliveryCacheProgressImpl& impl_) |
|
||||
: ServiceFramework{system_, "IDeliveryCacheProgressService"}, event{event_}, impl{impl_} { |
|
||||
// clang-format off
|
|
||||
static const FunctionInfo functions[] = { |
|
||||
{0, &IDeliveryCacheProgressService::GetEvent, "GetEvent"}, |
|
||||
{1, &IDeliveryCacheProgressService::GetImpl, "GetImpl"}, |
|
||||
}; |
|
||||
// clang-format on
|
|
||||
|
|
||||
RegisterHandlers(functions); |
|
||||
} |
|
||||
|
|
||||
private: |
|
||||
void GetEvent(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2, 1}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushCopyObjects(event); |
|
||||
} |
|
||||
|
|
||||
void GetImpl(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
ctx.WriteBuffer(impl); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
} |
|
||||
|
|
||||
Kernel::KReadableEvent& event; |
|
||||
const DeliveryCacheProgressImpl& impl; |
|
||||
}; |
|
||||
|
|
||||
class IBcatService final : public ServiceFramework<IBcatService> { |
|
||||
public: |
|
||||
explicit IBcatService(Core::System& system_, Backend& backend_) |
|
||||
: ServiceFramework{system_, "IBcatService"}, backend{backend_}, |
|
||||
progress{{ |
|
||||
ProgressServiceBackend{system_, "Normal"}, |
|
||||
ProgressServiceBackend{system_, "Directory"}, |
|
||||
}} { |
|
||||
// clang-format off
|
|
||||
static const FunctionInfo functions[] = { |
|
||||
{10100, &IBcatService::RequestSyncDeliveryCache, "RequestSyncDeliveryCache"}, |
|
||||
{10101, &IBcatService::RequestSyncDeliveryCacheWithDirectoryName, "RequestSyncDeliveryCacheWithDirectoryName"}, |
|
||||
{10200, nullptr, "CancelSyncDeliveryCacheRequest"}, |
|
||||
{20100, nullptr, "RequestSyncDeliveryCacheWithApplicationId"}, |
|
||||
{20101, nullptr, "RequestSyncDeliveryCacheWithApplicationIdAndDirectoryName"}, |
|
||||
{20300, nullptr, "GetDeliveryCacheStorageUpdateNotifier"}, |
|
||||
{20301, nullptr, "RequestSuspendDeliveryTask"}, |
|
||||
{20400, nullptr, "RegisterSystemApplicationDeliveryTask"}, |
|
||||
{20401, nullptr, "UnregisterSystemApplicationDeliveryTask"}, |
|
||||
{20410, nullptr, "SetSystemApplicationDeliveryTaskTimer"}, |
|
||||
{30100, &IBcatService::SetPassphrase, "SetPassphrase"}, |
|
||||
{30101, nullptr, "Unknown30101"}, |
|
||||
{30102, nullptr, "Unknown30102"}, |
|
||||
{30200, nullptr, "RegisterBackgroundDeliveryTask"}, |
|
||||
{30201, nullptr, "UnregisterBackgroundDeliveryTask"}, |
|
||||
{30202, nullptr, "BlockDeliveryTask"}, |
|
||||
{30203, nullptr, "UnblockDeliveryTask"}, |
|
||||
{30210, nullptr, "SetDeliveryTaskTimer"}, |
|
||||
{30300, nullptr, "RegisterSystemApplicationDeliveryTasks"}, |
|
||||
{90100, nullptr, "EnumerateBackgroundDeliveryTask"}, |
|
||||
{90101, nullptr, "Unknown90101"}, |
|
||||
{90200, nullptr, "GetDeliveryList"}, |
|
||||
{90201, &IBcatService::ClearDeliveryCacheStorage, "ClearDeliveryCacheStorage"}, |
|
||||
{90202, nullptr, "ClearDeliveryTaskSubscriptionStatus"}, |
|
||||
{90300, nullptr, "GetPushNotificationLog"}, |
|
||||
{90301, nullptr, "Unknown90301"}, |
|
||||
}; |
|
||||
// clang-format on
|
|
||||
RegisterHandlers(functions); |
|
||||
} |
|
||||
|
|
||||
private: |
|
||||
enum class SyncType { |
|
||||
Normal, |
|
||||
Directory, |
|
||||
Count, |
|
||||
}; |
|
||||
|
|
||||
std::shared_ptr<IDeliveryCacheProgressService> CreateProgressService(SyncType type) { |
|
||||
auto& progress_backend{GetProgressBackend(type)}; |
|
||||
return std::make_shared<IDeliveryCacheProgressService>(system, progress_backend.GetEvent(), |
|
||||
progress_backend.GetImpl()); |
|
||||
} |
|
||||
|
|
||||
void RequestSyncDeliveryCache(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
backend.Synchronize({system.GetApplicationProcessProgramID(), |
|
||||
GetCurrentBuildID(system.GetApplicationProcessBuildID())}, |
|
||||
GetProgressBackend(SyncType::Normal)); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushIpcInterface(CreateProgressService(SyncType::Normal)); |
|
||||
} |
|
||||
|
|
||||
void RequestSyncDeliveryCacheWithDirectoryName(HLERequestContext& ctx) { |
|
||||
IPC::RequestParser rp{ctx}; |
|
||||
const auto name_raw = rp.PopRaw<DirectoryName>(); |
|
||||
const auto name = |
|
||||
Common::StringFromFixedZeroTerminatedBuffer(name_raw.data(), name_raw.size()); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, name={}", name); |
|
||||
|
|
||||
backend.SynchronizeDirectory({system.GetApplicationProcessProgramID(), |
|
||||
GetCurrentBuildID(system.GetApplicationProcessBuildID())}, |
|
||||
name, GetProgressBackend(SyncType::Directory)); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushIpcInterface(CreateProgressService(SyncType::Directory)); |
|
||||
} |
|
||||
|
|
||||
void SetPassphrase(HLERequestContext& ctx) { |
|
||||
IPC::RequestParser rp{ctx}; |
|
||||
const auto title_id = rp.PopRaw<u64>(); |
|
||||
|
|
||||
const auto passphrase_raw = ctx.ReadBuffer(); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, title_id={:016X}, passphrase={}", title_id, |
|
||||
Common::HexToString(passphrase_raw)); |
|
||||
|
|
||||
if (title_id == 0) { |
|
||||
LOG_ERROR(Service_BCAT, "Invalid title ID!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_INVALID_ARGUMENT); |
|
||||
} |
|
||||
|
|
||||
if (passphrase_raw.size() > 0x40) { |
|
||||
LOG_ERROR(Service_BCAT, "Passphrase too large!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_INVALID_ARGUMENT); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
Passphrase passphrase{}; |
|
||||
std::memcpy(passphrase.data(), passphrase_raw.data(), |
|
||||
std::min(passphrase.size(), passphrase_raw.size())); |
|
||||
|
|
||||
backend.SetPassphrase(title_id, passphrase); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
} |
|
||||
|
|
||||
void ClearDeliveryCacheStorage(HLERequestContext& ctx) { |
|
||||
IPC::RequestParser rp{ctx}; |
|
||||
const auto title_id = rp.PopRaw<u64>(); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, title_id={:016X}", title_id); |
|
||||
|
|
||||
if (title_id == 0) { |
|
||||
LOG_ERROR(Service_BCAT, "Invalid title ID!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_INVALID_ARGUMENT); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
if (!backend.Clear(title_id)) { |
|
||||
LOG_ERROR(Service_BCAT, "Could not clear the directory successfully!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_FAILED_CLEAR_CACHE); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
} |
|
||||
|
|
||||
ProgressServiceBackend& GetProgressBackend(SyncType type) { |
|
||||
return progress.at(static_cast<size_t>(type)); |
|
||||
} |
|
||||
|
|
||||
const ProgressServiceBackend& GetProgressBackend(SyncType type) const { |
|
||||
return progress.at(static_cast<size_t>(type)); |
|
||||
} |
|
||||
|
|
||||
Backend& backend; |
|
||||
std::array<ProgressServiceBackend, static_cast<size_t>(SyncType::Count)> progress; |
|
||||
}; |
|
||||
|
|
||||
void Module::Interface::CreateBcatService(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushIpcInterface<IBcatService>(system, *backend); |
|
||||
} |
|
||||
|
|
||||
class IDeliveryCacheFileService final : public ServiceFramework<IDeliveryCacheFileService> { |
|
||||
public: |
|
||||
explicit IDeliveryCacheFileService(Core::System& system_, FileSys::VirtualDir root_) |
|
||||
: ServiceFramework{system_, "IDeliveryCacheFileService"}, root(std::move(root_)) { |
|
||||
// clang-format off
|
|
||||
static const FunctionInfo functions[] = { |
|
||||
{0, &IDeliveryCacheFileService::Open, "Open"}, |
|
||||
{1, &IDeliveryCacheFileService::Read, "Read"}, |
|
||||
{2, &IDeliveryCacheFileService::GetSize, "GetSize"}, |
|
||||
{3, &IDeliveryCacheFileService::GetDigest, "GetDigest"}, |
|
||||
}; |
|
||||
// clang-format on
|
|
||||
|
|
||||
RegisterHandlers(functions); |
|
||||
} |
|
||||
|
|
||||
private: |
|
||||
void Open(HLERequestContext& ctx) { |
|
||||
IPC::RequestParser rp{ctx}; |
|
||||
const auto dir_name_raw = rp.PopRaw<DirectoryName>(); |
|
||||
const auto file_name_raw = rp.PopRaw<FileName>(); |
|
||||
|
|
||||
const auto dir_name = |
|
||||
Common::StringFromFixedZeroTerminatedBuffer(dir_name_raw.data(), dir_name_raw.size()); |
|
||||
const auto file_name = |
|
||||
Common::StringFromFixedZeroTerminatedBuffer(file_name_raw.data(), file_name_raw.size()); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, dir_name={}, file_name={}", dir_name, file_name); |
|
||||
|
|
||||
if (!VerifyNameValidDir(ctx, dir_name_raw) || !VerifyNameValidFile(ctx, file_name_raw)) |
|
||||
return; |
|
||||
|
|
||||
if (current_file != nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "A file has already been opened on this interface!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_ENTITY_ALREADY_OPEN); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
const auto dir = root->GetSubdirectory(dir_name); |
|
||||
|
|
||||
if (dir == nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "The directory of name={} couldn't be opened!", dir_name); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_FAILED_OPEN_ENTITY); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
current_file = dir->GetFile(file_name); |
|
||||
|
|
||||
if (current_file == nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "The file of name={} couldn't be opened!", file_name); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_FAILED_OPEN_ENTITY); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
} |
|
||||
|
|
||||
void Read(HLERequestContext& ctx) { |
|
||||
IPC::RequestParser rp{ctx}; |
|
||||
const auto offset{rp.PopRaw<u64>()}; |
|
||||
|
|
||||
auto size = ctx.GetWriteBufferSize(); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, offset={:016X}, size={:016X}", offset, size); |
|
||||
|
|
||||
if (current_file == nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "There is no file currently open!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_NO_OPEN_ENTITY); |
|
||||
} |
|
||||
|
|
||||
size = std::min<u64>(current_file->GetSize() - offset, size); |
|
||||
const auto buffer = current_file->ReadBytes(size, offset); |
|
||||
ctx.WriteBuffer(buffer); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 4}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.Push<u64>(buffer.size()); |
|
||||
} |
|
||||
|
|
||||
void GetSize(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
if (current_file == nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "There is no file currently open!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_NO_OPEN_ENTITY); |
|
||||
} |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 4}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.Push<u64>(current_file->GetSize()); |
|
||||
} |
|
||||
|
|
||||
void GetDigest(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
if (current_file == nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "There is no file currently open!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_NO_OPEN_ENTITY); |
|
||||
} |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 6}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushRaw(DigestFile(current_file)); |
|
||||
} |
|
||||
|
|
||||
FileSys::VirtualDir root; |
|
||||
FileSys::VirtualFile current_file; |
|
||||
}; |
|
||||
|
|
||||
class IDeliveryCacheDirectoryService final |
|
||||
: public ServiceFramework<IDeliveryCacheDirectoryService> { |
|
||||
public: |
|
||||
explicit IDeliveryCacheDirectoryService(Core::System& system_, FileSys::VirtualDir root_) |
|
||||
: ServiceFramework{system_, "IDeliveryCacheDirectoryService"}, root(std::move(root_)) { |
|
||||
// clang-format off
|
|
||||
static const FunctionInfo functions[] = { |
|
||||
{0, &IDeliveryCacheDirectoryService::Open, "Open"}, |
|
||||
{1, &IDeliveryCacheDirectoryService::Read, "Read"}, |
|
||||
{2, &IDeliveryCacheDirectoryService::GetCount, "GetCount"}, |
|
||||
}; |
|
||||
// clang-format on
|
|
||||
|
|
||||
RegisterHandlers(functions); |
|
||||
} |
|
||||
|
|
||||
private: |
|
||||
void Open(HLERequestContext& ctx) { |
|
||||
IPC::RequestParser rp{ctx}; |
|
||||
const auto name_raw = rp.PopRaw<DirectoryName>(); |
|
||||
const auto name = |
|
||||
Common::StringFromFixedZeroTerminatedBuffer(name_raw.data(), name_raw.size()); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, name={}", name); |
|
||||
|
|
||||
if (!VerifyNameValidDir(ctx, name_raw)) |
|
||||
return; |
|
||||
|
|
||||
if (current_dir != nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "A file has already been opened on this interface!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_ENTITY_ALREADY_OPEN); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
current_dir = root->GetSubdirectory(name); |
|
||||
|
|
||||
if (current_dir == nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "Failed to open the directory name={}!", name); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_FAILED_OPEN_ENTITY); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
} |
|
||||
|
|
||||
void Read(HLERequestContext& ctx) { |
|
||||
auto write_size = ctx.GetWriteBufferNumElements<DeliveryCacheDirectoryEntry>(); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, write_size={:016X}", write_size); |
|
||||
|
|
||||
if (current_dir == nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "There is no open directory!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_NO_OPEN_ENTITY); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
const auto files = current_dir->GetFiles(); |
|
||||
write_size = std::min<u64>(write_size, files.size()); |
|
||||
std::vector<DeliveryCacheDirectoryEntry> entries(write_size); |
|
||||
std::transform( |
|
||||
files.begin(), files.begin() + write_size, entries.begin(), [](const auto& file) { |
|
||||
FileName name{}; |
|
||||
std::memcpy(name.data(), file->GetName().data(), |
|
||||
std::min(file->GetName().size(), name.size())); |
|
||||
return DeliveryCacheDirectoryEntry{name, file->GetSize(), DigestFile(file)}; |
|
||||
}); |
|
||||
|
|
||||
ctx.WriteBuffer(entries); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 3}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.Push(static_cast<u32>(write_size * sizeof(DeliveryCacheDirectoryEntry))); |
|
||||
} |
|
||||
|
|
||||
void GetCount(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
if (current_dir == nullptr) { |
|
||||
LOG_ERROR(Service_BCAT, "There is no open directory!"); |
|
||||
IPC::ResponseBuilder rb{ctx, 2}; |
|
||||
rb.Push(ERROR_NO_OPEN_ENTITY); |
|
||||
return; |
|
||||
} |
|
||||
|
|
||||
const auto files = current_dir->GetFiles(); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 3}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.Push(static_cast<u32>(files.size())); |
|
||||
} |
|
||||
|
|
||||
FileSys::VirtualDir root; |
|
||||
FileSys::VirtualDir current_dir; |
|
||||
}; |
|
||||
|
|
||||
class IDeliveryCacheStorageService final : public ServiceFramework<IDeliveryCacheStorageService> { |
|
||||
public: |
|
||||
explicit IDeliveryCacheStorageService(Core::System& system_, FileSys::VirtualDir root_) |
|
||||
: ServiceFramework{system_, "IDeliveryCacheStorageService"}, root(std::move(root_)) { |
|
||||
// clang-format off
|
|
||||
static const FunctionInfo functions[] = { |
|
||||
{0, &IDeliveryCacheStorageService::CreateFileService, "CreateFileService"}, |
|
||||
{1, &IDeliveryCacheStorageService::CreateDirectoryService, "CreateDirectoryService"}, |
|
||||
{10, &IDeliveryCacheStorageService::EnumerateDeliveryCacheDirectory, "EnumerateDeliveryCacheDirectory"}, |
|
||||
}; |
|
||||
// clang-format on
|
|
||||
|
|
||||
RegisterHandlers(functions); |
|
||||
|
|
||||
for (const auto& subdir : root->GetSubdirectories()) { |
|
||||
DirectoryName name{}; |
|
||||
std::memcpy(name.data(), subdir->GetName().data(), |
|
||||
std::min(sizeof(DirectoryName) - 1, subdir->GetName().size())); |
|
||||
entries.push_back(name); |
|
||||
} |
|
||||
} |
|
||||
|
|
||||
private: |
|
||||
void CreateFileService(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushIpcInterface<IDeliveryCacheFileService>(system, root); |
|
||||
} |
|
||||
|
|
||||
void CreateDirectoryService(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushIpcInterface<IDeliveryCacheDirectoryService>(system, root); |
|
||||
} |
|
||||
|
|
||||
void EnumerateDeliveryCacheDirectory(HLERequestContext& ctx) { |
|
||||
auto size = ctx.GetWriteBufferNumElements<DirectoryName>(); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, size={:016X}", size); |
|
||||
|
|
||||
size = std::min<u64>(size, entries.size() - next_read_index); |
|
||||
ctx.WriteBuffer(entries.data() + next_read_index, size * sizeof(DirectoryName)); |
|
||||
next_read_index += size; |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 3}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.Push(static_cast<u32>(size)); |
|
||||
} |
|
||||
|
|
||||
FileSys::VirtualDir root; |
|
||||
std::vector<DirectoryName> entries; |
|
||||
u64 next_read_index = 0; |
|
||||
}; |
|
||||
|
|
||||
void Module::Interface::CreateDeliveryCacheStorageService(HLERequestContext& ctx) { |
|
||||
LOG_DEBUG(Service_BCAT, "called"); |
|
||||
|
|
||||
const auto title_id = system.GetApplicationProcessProgramID(); |
|
||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushIpcInterface<IDeliveryCacheStorageService>(system, fsc.GetBCATDirectory(title_id)); |
|
||||
} |
|
||||
|
|
||||
void Module::Interface::CreateDeliveryCacheStorageServiceWithApplicationId(HLERequestContext& ctx) { |
|
||||
IPC::RequestParser rp{ctx}; |
|
||||
const auto title_id = rp.PopRaw<u64>(); |
|
||||
|
|
||||
LOG_DEBUG(Service_BCAT, "called, title_id={:016X}", title_id); |
|
||||
|
|
||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1}; |
|
||||
rb.Push(ResultSuccess); |
|
||||
rb.PushIpcInterface<IDeliveryCacheStorageService>(system, fsc.GetBCATDirectory(title_id)); |
|
||||
} |
|
||||
|
|
||||
std::unique_ptr<Backend> CreateBackendFromSettings([[maybe_unused]] Core::System& system, |
|
||||
DirectoryGetter getter) { |
|
||||
return std::make_unique<NullBackend>(std::move(getter)); |
|
||||
} |
|
||||
|
|
||||
Module::Interface::Interface(Core::System& system_, std::shared_ptr<Module> module_, |
|
||||
FileSystem::FileSystemController& fsc_, const char* name) |
|
||||
: ServiceFramework{system_, name}, fsc{fsc_}, module{std::move(module_)}, |
|
||||
backend{CreateBackendFromSettings(system_, |
|
||||
[&fsc_](u64 tid) { return fsc_.GetBCATDirectory(tid); })} {} |
|
||||
|
|
||||
Module::Interface::~Interface() = default; |
|
||||
|
|
||||
void LoopProcess(Core::System& system) { |
|
||||
auto server_manager = std::make_unique<ServerManager>(system); |
|
||||
auto module = std::make_shared<Module>(); |
|
||||
|
|
||||
server_manager->RegisterNamedService( |
|
||||
"bcat:a", |
|
||||
std::make_shared<BCAT>(system, module, system.GetFileSystemController(), "bcat:a")); |
|
||||
server_manager->RegisterNamedService( |
|
||||
"bcat:m", |
|
||||
std::make_shared<BCAT>(system, module, system.GetFileSystemController(), "bcat:m")); |
|
||||
server_manager->RegisterNamedService( |
|
||||
"bcat:u", |
|
||||
std::make_shared<BCAT>(system, module, system.GetFileSystemController(), "bcat:u")); |
|
||||
server_manager->RegisterNamedService( |
|
||||
"bcat:s", |
|
||||
std::make_shared<BCAT>(system, module, system.GetFileSystemController(), "bcat:s")); |
|
||||
ServerManager::RunServer(std::move(server_manager)); |
|
||||
} |
|
||||
|
|
||||
} // namespace Service::BCAT
|
|
||||
@ -1,46 +0,0 @@ |
|||||
// SPDX-FileCopyrightText: Copyright 2018 yuzu Emulator Project |
|
||||
// SPDX-License-Identifier: GPL-2.0-or-later |
|
||||
|
|
||||
#pragma once |
|
||||
|
|
||||
#include "core/hle/service/service.h" |
|
||||
|
|
||||
namespace Core { |
|
||||
class System; |
|
||||
} |
|
||||
|
|
||||
namespace Service { |
|
||||
|
|
||||
namespace FileSystem { |
|
||||
class FileSystemController; |
|
||||
} // namespace FileSystem |
|
||||
|
|
||||
namespace BCAT { |
|
||||
|
|
||||
class Backend; |
|
||||
|
|
||||
class Module final { |
|
||||
public: |
|
||||
class Interface : public ServiceFramework<Interface> { |
|
||||
public: |
|
||||
explicit Interface(Core::System& system_, std::shared_ptr<Module> module_, |
|
||||
FileSystem::FileSystemController& fsc_, const char* name); |
|
||||
~Interface() override; |
|
||||
|
|
||||
void CreateBcatService(HLERequestContext& ctx); |
|
||||
void CreateDeliveryCacheStorageService(HLERequestContext& ctx); |
|
||||
void CreateDeliveryCacheStorageServiceWithApplicationId(HLERequestContext& ctx); |
|
||||
|
|
||||
protected: |
|
||||
FileSystem::FileSystemController& fsc; |
|
||||
|
|
||||
std::shared_ptr<Module> module; |
|
||||
std::unique_ptr<Backend> backend; |
|
||||
}; |
|
||||
}; |
|
||||
|
|
||||
void LoopProcess(Core::System& system); |
|
||||
|
|
||||
} // namespace BCAT |
|
||||
|
|
||||
} // namespace Service |
|
||||
@ -0,0 +1,20 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include "core/hle/result.h" |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
constexpr Result ResultInvalidArgument{ErrorModule::BCAT, 1}; |
||||
|
constexpr Result ResultFailedOpenEntity{ErrorModule::BCAT, 2}; |
||||
|
constexpr Result ResultEntityAlreadyOpen{ErrorModule::BCAT, 6}; |
||||
|
constexpr Result ResultNoOpenEntry{ErrorModule::BCAT, 7}; |
||||
|
|
||||
|
// The command to clear the delivery cache just calls fs IFileSystem DeleteFile on all of the |
||||
|
// files and if any of them have a non-zero result it just forwards that result. This is the FS |
||||
|
// error code for permission denied, which is the closest approximation of this scenario. |
||||
|
constexpr Result ResultFailedClearCache{ErrorModule::FS, 6400}; |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
@ -0,0 +1,131 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2018 yuzu Emulator Project
|
||||
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
||||
|
|
||||
|
#include "common/hex_util.h"
|
||||
|
#include "common/string_util.h"
|
||||
|
#include "core/core.h"
|
||||
|
#include "core/hle/service/bcat/backend/backend.h"
|
||||
|
#include "core/hle/service/bcat/bcat_result.h"
|
||||
|
#include "core/hle/service/bcat/bcat_service.h"
|
||||
|
#include "core/hle/service/bcat/bcat_util.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_progress_service.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_storage_service.h"
|
||||
|
#include "core/hle/service/cmif_serialization.h"
|
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
u64 GetCurrentBuildID(const Core::System::CurrentBuildProcessID& id) { |
||||
|
u64 out{}; |
||||
|
std::memcpy(&out, id.data(), sizeof(u64)); |
||||
|
return out; |
||||
|
} |
||||
|
|
||||
|
IBcatService::IBcatService(Core::System& system_, BcatBackend& backend_) |
||||
|
: ServiceFramework{system_, "IBcatService"}, backend{backend_}, |
||||
|
progress{{ |
||||
|
ProgressServiceBackend{system_, "Normal"}, |
||||
|
ProgressServiceBackend{system_, "Directory"}, |
||||
|
}} { |
||||
|
// clang-format off
|
||||
|
static const FunctionInfo functions[] = { |
||||
|
{10100, C<&IBcatService::RequestSyncDeliveryCache>, "RequestSyncDeliveryCache"}, |
||||
|
{10101, C<&IBcatService::RequestSyncDeliveryCacheWithDirectoryName>, "RequestSyncDeliveryCacheWithDirectoryName"}, |
||||
|
{10200, nullptr, "CancelSyncDeliveryCacheRequest"}, |
||||
|
{20100, nullptr, "RequestSyncDeliveryCacheWithApplicationId"}, |
||||
|
{20101, nullptr, "RequestSyncDeliveryCacheWithApplicationIdAndDirectoryName"}, |
||||
|
{20300, nullptr, "GetDeliveryCacheStorageUpdateNotifier"}, |
||||
|
{20301, nullptr, "RequestSuspendDeliveryTask"}, |
||||
|
{20400, nullptr, "RegisterSystemApplicationDeliveryTask"}, |
||||
|
{20401, nullptr, "UnregisterSystemApplicationDeliveryTask"}, |
||||
|
{20410, nullptr, "SetSystemApplicationDeliveryTaskTimer"}, |
||||
|
{30100, C<&IBcatService::SetPassphrase>, "SetPassphrase"}, |
||||
|
{30101, nullptr, "Unknown30101"}, |
||||
|
{30102, nullptr, "Unknown30102"}, |
||||
|
{30200, nullptr, "RegisterBackgroundDeliveryTask"}, |
||||
|
{30201, nullptr, "UnregisterBackgroundDeliveryTask"}, |
||||
|
{30202, nullptr, "BlockDeliveryTask"}, |
||||
|
{30203, nullptr, "UnblockDeliveryTask"}, |
||||
|
{30210, nullptr, "SetDeliveryTaskTimer"}, |
||||
|
{30300, C<&IBcatService::RegisterSystemApplicationDeliveryTasks>, "RegisterSystemApplicationDeliveryTasks"}, |
||||
|
{90100, nullptr, "EnumerateBackgroundDeliveryTask"}, |
||||
|
{90101, nullptr, "Unknown90101"}, |
||||
|
{90200, nullptr, "GetDeliveryList"}, |
||||
|
{90201, C<&IBcatService::ClearDeliveryCacheStorage>, "ClearDeliveryCacheStorage"}, |
||||
|
{90202, nullptr, "ClearDeliveryTaskSubscriptionStatus"}, |
||||
|
{90300, nullptr, "GetPushNotificationLog"}, |
||||
|
{90301, nullptr, "Unknown90301"}, |
||||
|
}; |
||||
|
// clang-format on
|
||||
|
RegisterHandlers(functions); |
||||
|
} |
||||
|
|
||||
|
IBcatService::~IBcatService() = default; |
||||
|
|
||||
|
Result IBcatService::RequestSyncDeliveryCache( |
||||
|
OutInterface<IDeliveryCacheProgressService> out_interface) { |
||||
|
LOG_DEBUG(Service_BCAT, "called"); |
||||
|
|
||||
|
auto& progress_backend{GetProgressBackend(SyncType::Normal)}; |
||||
|
backend.Synchronize({system.GetApplicationProcessProgramID(), |
||||
|
GetCurrentBuildID(system.GetApplicationProcessBuildID())}, |
||||
|
GetProgressBackend(SyncType::Normal)); |
||||
|
|
||||
|
*out_interface = std::make_shared<IDeliveryCacheProgressService>( |
||||
|
system, progress_backend.GetEvent(), progress_backend.GetImpl()); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IBcatService::RequestSyncDeliveryCacheWithDirectoryName( |
||||
|
DirectoryName name_raw, OutInterface<IDeliveryCacheProgressService> out_interface) { |
||||
|
const auto name = Common::StringFromFixedZeroTerminatedBuffer(name_raw.data(), name_raw.size()); |
||||
|
|
||||
|
LOG_DEBUG(Service_BCAT, "called, name={}", name); |
||||
|
|
||||
|
auto& progress_backend{GetProgressBackend(SyncType::Directory)}; |
||||
|
backend.SynchronizeDirectory({system.GetApplicationProcessProgramID(), |
||||
|
GetCurrentBuildID(system.GetApplicationProcessBuildID())}, |
||||
|
name, progress_backend); |
||||
|
|
||||
|
*out_interface = std::make_shared<IDeliveryCacheProgressService>( |
||||
|
system, progress_backend.GetEvent(), progress_backend.GetImpl()); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IBcatService::SetPassphrase(u64 title_id, |
||||
|
InBuffer<BufferAttr_HipcPointer> passphrase_buffer) { |
||||
|
LOG_DEBUG(Service_BCAT, "called, title_id={:016X}, passphrase={}", title_id, |
||||
|
Common::HexToString(passphrase_buffer)); |
||||
|
|
||||
|
R_UNLESS(title_id != 0, ResultInvalidArgument); |
||||
|
R_UNLESS(passphrase_buffer.size() <= 0x40, ResultInvalidArgument); |
||||
|
|
||||
|
Passphrase passphrase{}; |
||||
|
std::memcpy(passphrase.data(), passphrase_buffer.data(), |
||||
|
std::min(passphrase.size(), passphrase_buffer.size())); |
||||
|
|
||||
|
backend.SetPassphrase(title_id, passphrase); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IBcatService::RegisterSystemApplicationDeliveryTasks() { |
||||
|
LOG_WARNING(Service_BCAT, "(STUBBED) called"); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IBcatService::ClearDeliveryCacheStorage(u64 title_id) { |
||||
|
LOG_DEBUG(Service_BCAT, "called, title_id={:016X}", title_id); |
||||
|
|
||||
|
R_UNLESS(title_id != 0, ResultInvalidArgument); |
||||
|
R_UNLESS(backend.Clear(title_id), ResultFailedClearCache); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
ProgressServiceBackend& IBcatService::GetProgressBackend(SyncType type) { |
||||
|
return progress.at(static_cast<size_t>(type)); |
||||
|
} |
||||
|
|
||||
|
const ProgressServiceBackend& IBcatService::GetProgressBackend(SyncType type) const { |
||||
|
return progress.at(static_cast<size_t>(type)); |
||||
|
} |
||||
|
|
||||
|
} // namespace Service::BCAT
|
||||
@ -0,0 +1,45 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include "core/hle/service/bcat/backend/backend.h" |
||||
|
#include "core/hle/service/bcat/bcat_types.h" |
||||
|
#include "core/hle/service/cmif_types.h" |
||||
|
#include "core/hle/service/service.h" |
||||
|
|
||||
|
namespace Core { |
||||
|
class System; |
||||
|
} |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
class BcatBackend; |
||||
|
class IDeliveryCacheStorageService; |
||||
|
class IDeliveryCacheProgressService; |
||||
|
|
||||
|
class IBcatService final : public ServiceFramework<IBcatService> { |
||||
|
public: |
||||
|
explicit IBcatService(Core::System& system_, BcatBackend& backend_); |
||||
|
~IBcatService() override; |
||||
|
|
||||
|
private: |
||||
|
Result RequestSyncDeliveryCache(OutInterface<IDeliveryCacheProgressService> out_interface); |
||||
|
|
||||
|
Result RequestSyncDeliveryCacheWithDirectoryName( |
||||
|
DirectoryName name, OutInterface<IDeliveryCacheProgressService> out_interface); |
||||
|
|
||||
|
Result SetPassphrase(u64 title_id, InBuffer<BufferAttr_HipcPointer> passphrase_buffer); |
||||
|
|
||||
|
Result RegisterSystemApplicationDeliveryTasks(); |
||||
|
|
||||
|
Result ClearDeliveryCacheStorage(u64 title_id); |
||||
|
|
||||
|
private: |
||||
|
ProgressServiceBackend& GetProgressBackend(SyncType type); |
||||
|
const ProgressServiceBackend& GetProgressBackend(SyncType type) const; |
||||
|
|
||||
|
BcatBackend& backend; |
||||
|
std::array<ProgressServiceBackend, static_cast<size_t>(SyncType::Count)> progress; |
||||
|
}; |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
@ -0,0 +1,60 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include "common/common_funcs.h" |
||||
|
#include "common/common_types.h" |
||||
|
#include "core/file_sys/vfs/vfs_types.h" |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
using DirectoryName = std::array<char, 0x20>; |
||||
|
using FileName = std::array<char, 0x20>; |
||||
|
using BcatDigest = std::array<u8, 0x10>; |
||||
|
using Passphrase = std::array<u8, 0x20>; |
||||
|
using DirectoryGetter = std::function<FileSys::VirtualDir(u64)>; |
||||
|
|
||||
|
enum class SyncType { |
||||
|
Normal, |
||||
|
Directory, |
||||
|
Count, |
||||
|
}; |
||||
|
|
||||
|
enum class DeliveryCacheProgressStatus : s32 { |
||||
|
None = 0x0, |
||||
|
Queued = 0x1, |
||||
|
Connecting = 0x2, |
||||
|
ProcessingDataList = 0x3, |
||||
|
Downloading = 0x4, |
||||
|
Committing = 0x5, |
||||
|
Done = 0x9, |
||||
|
}; |
||||
|
|
||||
|
struct DeliveryCacheDirectoryEntry { |
||||
|
FileName name; |
||||
|
u64 size; |
||||
|
BcatDigest digest; |
||||
|
}; |
||||
|
|
||||
|
struct TitleIDVersion { |
||||
|
u64 title_id; |
||||
|
u64 build_id; |
||||
|
}; |
||||
|
|
||||
|
struct DeliveryCacheProgressImpl { |
||||
|
DeliveryCacheProgressStatus status; |
||||
|
Result result = ResultSuccess; |
||||
|
DirectoryName current_directory; |
||||
|
FileName current_file; |
||||
|
s64 current_downloaded_bytes; ///< Bytes downloaded on current file. |
||||
|
s64 current_total_bytes; ///< Bytes total on current file. |
||||
|
s64 total_downloaded_bytes; ///< Bytes downloaded on overall download. |
||||
|
s64 total_bytes; ///< Bytes total on overall download. |
||||
|
INSERT_PADDING_BYTES( |
||||
|
0x198); ///< Appears to be unused in official code, possibly reserved for future use. |
||||
|
}; |
||||
|
static_assert(sizeof(DeliveryCacheProgressImpl) == 0x200, |
||||
|
"DeliveryCacheProgressImpl has incorrect size."); |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
@ -0,0 +1,39 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include <array> |
||||
|
#include <cctype> |
||||
|
#include <mbedtls/md5.h> |
||||
|
|
||||
|
#include "core/hle/service/bcat/bcat_result.h" |
||||
|
#include "core/hle/service/bcat/bcat_types.h" |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
// For a name to be valid it must be non-empty, must have a null terminating character as the final |
||||
|
// char, can only contain numbers, letters, underscores and a hyphen if directory and a period if |
||||
|
// file. |
||||
|
constexpr Result VerifyNameValidInternal(std::array<char, 0x20> name, char match_char) { |
||||
|
const auto null_chars = std::count(name.begin(), name.end(), 0); |
||||
|
const auto bad_chars = std::count_if(name.begin(), name.end(), [match_char](char c) { |
||||
|
return !std::isalnum(static_cast<u8>(c)) && c != '_' && c != match_char && c != '\0'; |
||||
|
}); |
||||
|
if (null_chars == 0x20 || null_chars == 0 || bad_chars != 0 || name[0x1F] != '\0') { |
||||
|
LOG_ERROR(Service_BCAT, "Name passed was invalid!"); |
||||
|
return ResultInvalidArgument; |
||||
|
} |
||||
|
|
||||
|
return ResultSuccess; |
||||
|
} |
||||
|
|
||||
|
constexpr Result VerifyNameValidDir(DirectoryName name) { |
||||
|
return VerifyNameValidInternal(name, '-'); |
||||
|
} |
||||
|
|
||||
|
constexpr Result VerifyNameValidFile(FileName name) { |
||||
|
return VerifyNameValidInternal(name, '.'); |
||||
|
} |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
@ -0,0 +1,81 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project
|
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later
|
||||
|
|
||||
|
#include "common/string_util.h"
|
||||
|
#include "core/file_sys/vfs/vfs_types.h"
|
||||
|
#include "core/hle/service/bcat/bcat_result.h"
|
||||
|
#include "core/hle/service/bcat/bcat_util.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_directory_service.h"
|
||||
|
#include "core/hle/service/cmif_serialization.h"
|
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
// The digest is only used to determine if a file is unique compared to others of the same name.
|
||||
|
// Since the algorithm isn't ever checked in game, MD5 is safe.
|
||||
|
BcatDigest DigestFile(const FileSys::VirtualFile& file) { |
||||
|
BcatDigest out{}; |
||||
|
const auto bytes = file->ReadAllBytes(); |
||||
|
mbedtls_md5_ret(bytes.data(), bytes.size(), out.data()); |
||||
|
return out; |
||||
|
} |
||||
|
|
||||
|
IDeliveryCacheDirectoryService::IDeliveryCacheDirectoryService(Core::System& system_, |
||||
|
FileSys::VirtualDir root_) |
||||
|
: ServiceFramework{system_, "IDeliveryCacheDirectoryService"}, root(std::move(root_)) { |
||||
|
// clang-format off
|
||||
|
static const FunctionInfo functions[] = { |
||||
|
{0, C<&IDeliveryCacheDirectoryService::Open>, "Open"}, |
||||
|
{1, C<&IDeliveryCacheDirectoryService::Read>, "Read"}, |
||||
|
{2, C<&IDeliveryCacheDirectoryService::GetCount>, "GetCount"}, |
||||
|
}; |
||||
|
// clang-format on
|
||||
|
|
||||
|
RegisterHandlers(functions); |
||||
|
} |
||||
|
|
||||
|
IDeliveryCacheDirectoryService::~IDeliveryCacheDirectoryService() = default; |
||||
|
|
||||
|
Result IDeliveryCacheDirectoryService::Open(DirectoryName dir_name_raw) { |
||||
|
const auto dir_name = |
||||
|
Common::StringFromFixedZeroTerminatedBuffer(dir_name_raw.data(), dir_name_raw.size()); |
||||
|
|
||||
|
LOG_DEBUG(Service_BCAT, "called, dir_name={}", dir_name); |
||||
|
|
||||
|
// R_TRY(VerifyNameValidDir(dir_name_raw));
|
||||
|
R_UNLESS(current_dir == nullptr, ResultEntityAlreadyOpen); |
||||
|
|
||||
|
const auto dir = root->GetSubdirectory(dir_name); |
||||
|
R_UNLESS(dir != nullptr, ResultFailedOpenEntity); |
||||
|
|
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IDeliveryCacheDirectoryService::Read( |
||||
|
Out<u32> out_buffer_size, |
||||
|
OutArray<DeliveryCacheDirectoryEntry, BufferAttr_HipcMapAlias> out_buffer) { |
||||
|
LOG_DEBUG(Service_BCAT, "called, write_size={:016X}", out_buffer.size()); |
||||
|
|
||||
|
R_UNLESS(current_dir != nullptr, ResultNoOpenEntry); |
||||
|
|
||||
|
const auto files = current_dir->GetFiles(); |
||||
|
*out_buffer_size = static_cast<u32>(std::min(files.size(), out_buffer.size())); |
||||
|
std::transform(files.begin(), files.begin() + *out_buffer_size, out_buffer.begin(), |
||||
|
[](const auto& file) { |
||||
|
FileName name{}; |
||||
|
std::memcpy(name.data(), file->GetName().data(), |
||||
|
std::min(file->GetName().size(), name.size())); |
||||
|
return DeliveryCacheDirectoryEntry{name, file->GetSize(), DigestFile(file)}; |
||||
|
}); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IDeliveryCacheDirectoryService::GetCount(Out<u32> out_count) { |
||||
|
LOG_DEBUG(Service_BCAT, "called"); |
||||
|
|
||||
|
R_UNLESS(current_dir != nullptr, ResultNoOpenEntry); |
||||
|
|
||||
|
*out_count = static_cast<u32>(current_dir->GetFiles().size()); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
} // namespace Service::BCAT
|
||||
@ -0,0 +1,33 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include "core/file_sys/vfs/vfs.h" |
||||
|
#include "core/hle/service/bcat/bcat_types.h" |
||||
|
#include "core/hle/service/cmif_types.h" |
||||
|
#include "core/hle/service/service.h" |
||||
|
|
||||
|
namespace Core { |
||||
|
class System; |
||||
|
} |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
class IDeliveryCacheDirectoryService final |
||||
|
: public ServiceFramework<IDeliveryCacheDirectoryService> { |
||||
|
public: |
||||
|
explicit IDeliveryCacheDirectoryService(Core::System& system_, FileSys::VirtualDir root_); |
||||
|
~IDeliveryCacheDirectoryService() override; |
||||
|
|
||||
|
private: |
||||
|
Result Open(DirectoryName dir_name_raw); |
||||
|
Result Read(Out<u32> out_buffer_size, |
||||
|
OutArray<DeliveryCacheDirectoryEntry, BufferAttr_HipcMapAlias> out_buffer); |
||||
|
Result GetCount(Out<u32> out_count); |
||||
|
|
||||
|
FileSys::VirtualDir root; |
||||
|
FileSys::VirtualDir current_dir; |
||||
|
}; |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
@ -0,0 +1,81 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project
|
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later
|
||||
|
|
||||
|
#include "common/string_util.h"
|
||||
|
#include "core/hle/service/bcat/bcat_result.h"
|
||||
|
#include "core/hle/service/bcat/bcat_util.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_file_service.h"
|
||||
|
#include "core/hle/service/cmif_serialization.h"
|
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
IDeliveryCacheFileService::IDeliveryCacheFileService(Core::System& system_, |
||||
|
FileSys::VirtualDir root_) |
||||
|
: ServiceFramework{system_, "IDeliveryCacheFileService"}, root(std::move(root_)) { |
||||
|
// clang-format off
|
||||
|
static const FunctionInfo functions[] = { |
||||
|
{0, C<&IDeliveryCacheFileService::Open>, "Open"}, |
||||
|
{1, C<&IDeliveryCacheFileService::Read>, "Read"}, |
||||
|
{2, C<&IDeliveryCacheFileService::GetSize>, "GetSize"}, |
||||
|
{3, C<&IDeliveryCacheFileService::GetDigest>, "GetDigest"}, |
||||
|
}; |
||||
|
// clang-format on
|
||||
|
|
||||
|
RegisterHandlers(functions); |
||||
|
} |
||||
|
|
||||
|
IDeliveryCacheFileService::~IDeliveryCacheFileService() = default; |
||||
|
|
||||
|
Result IDeliveryCacheFileService::Open(DirectoryName dir_name_raw, FileName file_name_raw) { |
||||
|
const auto dir_name = |
||||
|
Common::StringFromFixedZeroTerminatedBuffer(dir_name_raw.data(), dir_name_raw.size()); |
||||
|
const auto file_name = |
||||
|
Common::StringFromFixedZeroTerminatedBuffer(file_name_raw.data(), file_name_raw.size()); |
||||
|
|
||||
|
LOG_DEBUG(Service_BCAT, "called, dir_name={}, file_name={}", dir_name, file_name); |
||||
|
|
||||
|
R_TRY(VerifyNameValidDir(dir_name_raw)); |
||||
|
R_TRY(VerifyNameValidDir(file_name_raw)); |
||||
|
R_UNLESS(current_file == nullptr, ResultEntityAlreadyOpen); |
||||
|
|
||||
|
const auto dir = root->GetSubdirectory(dir_name); |
||||
|
R_UNLESS(dir != nullptr, ResultFailedOpenEntity); |
||||
|
|
||||
|
current_file = dir->GetFile(file_name); |
||||
|
R_UNLESS(current_file != nullptr, ResultFailedOpenEntity); |
||||
|
|
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IDeliveryCacheFileService::Read(Out<u64> out_buffer_size, u64 offset, |
||||
|
OutBuffer<BufferAttr_HipcMapAlias> out_buffer) { |
||||
|
LOG_DEBUG(Service_BCAT, "called, offset={:016X}, size={:016X}", offset, out_buffer.size()); |
||||
|
|
||||
|
R_UNLESS(current_file != nullptr, ResultNoOpenEntry); |
||||
|
|
||||
|
*out_buffer_size = std::min<u64>(current_file->GetSize() - offset, out_buffer.size()); |
||||
|
const auto buffer = current_file->ReadBytes(*out_buffer_size, offset); |
||||
|
memcpy(out_buffer.data(), buffer.data(), buffer.size()); |
||||
|
|
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IDeliveryCacheFileService::GetSize(Out<u64> out_size) { |
||||
|
LOG_DEBUG(Service_BCAT, "called"); |
||||
|
|
||||
|
R_UNLESS(current_file != nullptr, ResultNoOpenEntry); |
||||
|
|
||||
|
*out_size = current_file->GetSize(); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IDeliveryCacheFileService::GetDigest(Out<BcatDigest> out_digest) { |
||||
|
LOG_DEBUG(Service_BCAT, "called"); |
||||
|
|
||||
|
R_UNLESS(current_file != nullptr, ResultNoOpenEntry); |
||||
|
|
||||
|
//*out_digest = DigestFile(current_file);
|
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
} // namespace Service::BCAT
|
||||
@ -0,0 +1,33 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include "core/file_sys/vfs/vfs.h" |
||||
|
#include "core/hle/service/bcat/bcat_types.h" |
||||
|
#include "core/hle/service/cmif_types.h" |
||||
|
#include "core/hle/service/service.h" |
||||
|
|
||||
|
namespace Core { |
||||
|
class System; |
||||
|
} |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
class IDeliveryCacheFileService final : public ServiceFramework<IDeliveryCacheFileService> { |
||||
|
public: |
||||
|
explicit IDeliveryCacheFileService(Core::System& system_, FileSys::VirtualDir root_); |
||||
|
~IDeliveryCacheFileService() override; |
||||
|
|
||||
|
private: |
||||
|
Result Open(DirectoryName dir_name_raw, FileName file_name_raw); |
||||
|
Result Read(Out<u64> out_buffer_size, u64 offset, |
||||
|
OutBuffer<BufferAttr_HipcMapAlias> out_buffer); |
||||
|
Result GetSize(Out<u64> out_size); |
||||
|
Result GetDigest(Out<BcatDigest> out_digest); |
||||
|
|
||||
|
FileSys::VirtualDir root; |
||||
|
FileSys::VirtualFile current_file; |
||||
|
}; |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
@ -0,0 +1,41 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project
|
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later
|
||||
|
|
||||
|
#include "core/hle/service/bcat/bcat_types.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_progress_service.h"
|
||||
|
#include "core/hle/service/cmif_serialization.h"
|
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
IDeliveryCacheProgressService::IDeliveryCacheProgressService(Core::System& system_, |
||||
|
Kernel::KReadableEvent& event_, |
||||
|
const DeliveryCacheProgressImpl& impl_) |
||||
|
: ServiceFramework{system_, "IDeliveryCacheProgressService"}, event{event_}, impl{impl_} { |
||||
|
// clang-format off
|
||||
|
static const FunctionInfo functions[] = { |
||||
|
{0, C<&IDeliveryCacheProgressService::GetEvent>, "Get"}, |
||||
|
{0, C<&IDeliveryCacheProgressService::GetImpl>, "Get"}, |
||||
|
}; |
||||
|
// clang-format on
|
||||
|
|
||||
|
RegisterHandlers(functions); |
||||
|
} |
||||
|
|
||||
|
IDeliveryCacheProgressService::~IDeliveryCacheProgressService() = default; |
||||
|
|
||||
|
Result IDeliveryCacheProgressService::GetEvent(OutCopyHandle<Kernel::KReadableEvent> out_event) { |
||||
|
LOG_DEBUG(Service_BCAT, "called"); |
||||
|
|
||||
|
*out_event = &event; |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IDeliveryCacheProgressService::GetImpl( |
||||
|
OutLargeData<DeliveryCacheProgressImpl, BufferAttr_HipcPointer> out_impl) { |
||||
|
LOG_DEBUG(Service_BCAT, "called"); |
||||
|
|
||||
|
*out_impl = impl; |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
} // namespace Service::BCAT
|
||||
@ -0,0 +1,35 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include "core/hle/service/cmif_types.h" |
||||
|
#include "core/hle/service/service.h" |
||||
|
|
||||
|
namespace Core { |
||||
|
class System; |
||||
|
} |
||||
|
|
||||
|
namespace Kernel { |
||||
|
class KEvent; |
||||
|
class KReadableEvent; |
||||
|
} // namespace Kernel |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
struct DeliveryCacheProgressImpl; |
||||
|
|
||||
|
class IDeliveryCacheProgressService final : public ServiceFramework<IDeliveryCacheProgressService> { |
||||
|
public: |
||||
|
explicit IDeliveryCacheProgressService(Core::System& system_, Kernel::KReadableEvent& event_, |
||||
|
const DeliveryCacheProgressImpl& impl_); |
||||
|
~IDeliveryCacheProgressService() override; |
||||
|
|
||||
|
private: |
||||
|
Result GetEvent(OutCopyHandle<Kernel::KReadableEvent> out_event); |
||||
|
Result GetImpl(OutLargeData<DeliveryCacheProgressImpl, BufferAttr_HipcPointer> out_impl); |
||||
|
|
||||
|
Kernel::KReadableEvent& event; |
||||
|
const DeliveryCacheProgressImpl& impl; |
||||
|
}; |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
@ -0,0 +1,57 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project
|
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later
|
||||
|
|
||||
|
#include "core/hle/service/bcat/bcat_result.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_directory_service.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_file_service.h"
|
||||
|
#include "core/hle/service/bcat/delivery_cache_storage_service.h"
|
||||
|
#include "core/hle/service/cmif_serialization.h"
|
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
|
||||
|
IDeliveryCacheStorageService::IDeliveryCacheStorageService(Core::System& system_, |
||||
|
FileSys::VirtualDir root_) |
||||
|
: ServiceFramework{system_, "IDeliveryCacheStorageService"}, root(std::move(root_)) { |
||||
|
// clang-format off
|
||||
|
static const FunctionInfo functions[] = { |
||||
|
{0, C<&IDeliveryCacheStorageService::CreateFileService>, "CreateFileService"}, |
||||
|
{1, C<&IDeliveryCacheStorageService::CreateDirectoryService>, "CreateDirectoryService"}, |
||||
|
{2, C<&IDeliveryCacheStorageService::EnumerateDeliveryCacheDirectory>, "EnumerateDeliveryCacheDirectory"}, |
||||
|
}; |
||||
|
// clang-format on
|
||||
|
|
||||
|
RegisterHandlers(functions); |
||||
|
} |
||||
|
|
||||
|
IDeliveryCacheStorageService::~IDeliveryCacheStorageService() = default; |
||||
|
|
||||
|
Result IDeliveryCacheStorageService::CreateFileService( |
||||
|
OutInterface<IDeliveryCacheFileService> out_interface) { |
||||
|
LOG_DEBUG(Service_BCAT, "called"); |
||||
|
|
||||
|
*out_interface = std::make_shared<IDeliveryCacheFileService>(system, root); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IDeliveryCacheStorageService::CreateDirectoryService( |
||||
|
OutInterface<IDeliveryCacheDirectoryService> out_interface) { |
||||
|
LOG_DEBUG(Service_BCAT, "called"); |
||||
|
|
||||
|
*out_interface = std::make_shared<IDeliveryCacheDirectoryService>(system, root); |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
Result IDeliveryCacheStorageService::EnumerateDeliveryCacheDirectory( |
||||
|
Out<u32> out_directories_size, |
||||
|
OutArray<DirectoryName, BufferAttr_HipcMapAlias> out_directories) { |
||||
|
LOG_DEBUG(Service_BCAT, "called, size={:016X}", out_directories.size()); |
||||
|
|
||||
|
*out_directories_size = |
||||
|
static_cast<u32>(std::min(out_directories.size(), entries.size() - next_read_index)); |
||||
|
memcpy(out_directories.data(), entries.data() + next_read_index, |
||||
|
*out_directories_size * sizeof(DirectoryName)); |
||||
|
next_read_index += *out_directories_size; |
||||
|
R_SUCCEED(); |
||||
|
} |
||||
|
|
||||
|
} // namespace Service::BCAT
|
||||
@ -0,0 +1,36 @@ |
|||||
|
// SPDX-FileCopyrightText: Copyright 2024 yuzu Emulator Project |
||||
|
// SPDX-License-Identifier: GPL-3.0-or-later |
||||
|
|
||||
|
#pragma once |
||||
|
|
||||
|
#include "core/file_sys/vfs/vfs.h" |
||||
|
#include "core/hle/service/bcat/bcat_types.h" |
||||
|
#include "core/hle/service/cmif_types.h" |
||||
|
#include "core/hle/service/service.h" |
||||
|
|
||||
|
namespace Core { |
||||
|
class System; |
||||
|
} |
||||
|
|
||||
|
namespace Service::BCAT { |
||||
|
class IDeliveryCacheFileService; |
||||
|
class IDeliveryCacheDirectoryService; |
||||
|
|
||||
|
class IDeliveryCacheStorageService final : public ServiceFramework<IDeliveryCacheStorageService> { |
||||
|
public: |
||||
|
explicit IDeliveryCacheStorageService(Core::System& system_, FileSys::VirtualDir root_); |
||||
|
~IDeliveryCacheStorageService() override; |
||||
|
|
||||
|
private: |
||||
|
Result CreateFileService(OutInterface<IDeliveryCacheFileService> out_interface); |
||||
|
Result CreateDirectoryService(OutInterface<IDeliveryCacheDirectoryService> out_interface); |
||||
|
Result EnumerateDeliveryCacheDirectory( |
||||
|
Out<u32> out_directories_size, |
||||
|
OutArray<DirectoryName, BufferAttr_HipcMapAlias> out_directories); |
||||
|
|
||||
|
FileSys::VirtualDir root; |
||||
|
std::vector<DirectoryName> entries; |
||||
|
u64 next_read_index = 0; |
||||
|
}; |
||||
|
|
||||
|
} // namespace Service::BCAT |
||||
Write
Preview
Loading…
Cancel
Save
Reference in new issue