DrSocalkwe3n/LuaVox
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

*

Browse Source
This commit is contained in:
DrSocalkwe3n
2025-08-29 17:21:03 +06:00
parent 28b7e8fe91
commit 5b02fec75e
4 changed files with 228 additions and 121 deletions
Download Patch File Download Diff File Expand all files Collapse all files

246
Src/Client/ServerSession.cpp
View File

@@ -6,6 +6,7 @@
#include "TOSLib.hpp"
#include "glm/ext/quaternion_geometric.hpp"
#include <GLFW/glfw3.h>
#include <algorithm>
#include <boost/asio/deadline_timer.hpp>
#include <boost/asio/this_coro.hpp>
#include <boost/date_time/posix_time/posix_time_duration.hpp>
@@ -320,37 +321,170 @@ void ServerSession::onJoystick() {
}
void ServerSession::atFreeDrawTime(GlobalTime gTime, float dTime) {
void ServerSession::update(GlobalTime gTime, float dTime) {
// Если были получены ресурсы, отправим их на запись в кеш
if(!AsyncContext.LoadedAssets.get_read().empty()) {
std::vector<AssetEntry> assets = std::move(*AsyncContext.LoadedAssets.lock());
std::vector<Resource> resources;
resources.reserve(assets.size());
for(AssetEntry& entry : assets) {
resources.push_back(entry.Res);
AsyncContext.ReceivedResources[entry.Type].push_back(entry);
// // Проверяем используется ли сейчас ресурс
// auto iter = Assets.ExistBinds[(int) entry.Type].find(entry.Id);
// if(iter == Assets.ExistBinds[(int) entry.Type].end()) {
// // Не используется
// Assets.NotInUse[(int) entry.Type][entry.Domain + ':' + entry.Key] = {entry, TIME_BEFORE_UNLOAD_RESOURCE+time(nullptr)};
// } else {
// // Используется
// Assets.InUse[(int) entry.Type][entry.Id] = entry;
// changedResources[entry.Type].insert({entry.Id, entry});
// }
}
AM->pushResources(std::move(resources));
}
// Разбираемся с полученными меж тактами привязками ресурсов
if(!AsyncContext.AssetsBinds.get_read().empty()) {
AssetsBindsChange abc;
// Нужно объеденить изменения в один AssetsBindsChange (abc)
{
std::vector<AssetsBindsChange> list = std::move(*AsyncContext.AssetsBinds.lock());
for(AssetsBindsChange entry : list) {
for(int type = 0; type < (int) EnumAssets::MAX_ENUM; type++)
std::sort(entry.Lost[type].begin(), entry.Lost[type].end());
// Если до этого была объявлена привязка, а теперь она потеряна, то просто сокращаем значения.
// Иначе дописываем в lost
for(ssize_t iter = abc.Binds.size()-1; iter >= 0; iter--) {
const AssetBindEntry& abe = abc.Binds[iter];
auto& lost = entry.Lost[(int) abe.Type];
auto iterator = std::lower_bound(lost.begin(), lost.end(), abe.Id);
if(iterator != lost.end()) {
// Привязка будет удалена
lost.erase(iterator);
abc.Binds.erase(abc.Binds.begin()+iter);
}
}
for(int type = 0; type < (int) EnumAssets::MAX_ENUM; type++) {
abc.Lost[type].append_range(entry.Lost[type]);
entry.Lost[type].clear();
std::sort(abc.Lost[type].begin(), abc.Lost[type].end());
}
for(AssetBindEntry& abe : entry.Binds) {
auto iterator = std::lower_bound(entry.Lost[(int) abe.Type].begin(), entry.Lost[(int) abe.Type].end(), abe.Id);
if(iterator != entry.Lost[(int) abe.Type].end()) {
// Получили новую привязку, которая была удалена в предыдущем такте
entry.Lost[(int) abe.Type].erase(iterator);
} else {
// Данная привязка не удалялась, может она была изменена?
bool hasChanged = false;
for(AssetBindEntry& abe2 : abc.Binds) {
if(abe2.Type == abe.Type && abe2.Id == abe.Id) {
// Привязка была изменена
abe2 = std::move(abe);
hasChanged = true;
break;
}
}
if(!hasChanged)
// Изменения не было, это просто новая привязка
abc.Binds.emplace_back(std::move(abe));
}
}
entry.Binds.clear();
}
}
// Запрос к дисковому кешу новых ресурсов
std::vector<AssetsManager::ResourceKey> needToLoad;
for(const AssetBindEntry& bind : abc.Binds) {
bool needQuery = false;
// Проверить in memory кеш по домену+ключу
{
std::string dk = bind.Domain + ':' + bind.Key;
auto &niubdk = Assets.NotInUse[(int) bind.Type];
auto iter = niubdk.find(dk);
if(iter != niubdk.end()) {
// Есть ресурс
needQuery = true;
}
}
// Проверить если такой запрос уже был отправлен в AssetsManager и ожидает ответа
if(!needQuery) {
auto& list = AsyncContext.ResourceWait[(int) bind.Type];
auto iterDomain = list.find(bind.Domain);
if(iterDomain != list.end()) {
for(const auto& [key, hash] : iterDomain->second) {
if(key == bind.Key && hash == bind.Hash) {
needQuery = true;
break;
}
}
}
}
// Assets.ExistBinds[(int) bind.Type].insert(bind.Id);
// Под рукой нет ресурса, отправим на проверку в AssetsManager
if(needQuery) {
AsyncContext.ResourceWait[(int) bind.Type][bind.Domain].emplace_back(bind.Key, bind.Hash);
needToLoad.emplace_back(bind.Hash, bind.Type, bind.Domain, bind.Key, bind.Id);
}
}
// Отправляем запрос на получение ресурсов
if(!needToLoad.empty())
AM->pushReads(std::move(needToLoad));
}
if(!AsyncContext.TickSequence.get_read().empty()) {
// Есть такты с сервера
// Оповещаем о подготовке к обработке тактов
if(RS)
RS->prepareTickSync();
IRenderSession::TickSyncData result;
// Перевариваем данные по тактам
if(RS)
RS->pushStageTickSync();
// Применяем изменения по ресурсам, профилям и контенту
if(RS)
RS->tickSync(result);
}
// Здесь нужно обработать управляющие пакеты
// Оповещение модуля рендера об изменениях ресурсов
std::unordered_map<EnumAssets, std::unordered_map<ResourceId, AssetEntry>> changedResources;
std::unordered_map<EnumAssets, std::unordered_set<ResourceId>> lostResources;
// Обработка полученных ресурсов
if(!AsyncContext.LoadedAssets.get_read().empty()) {
std::vector<AssetEntry> assets = std::move(*AsyncContext.LoadedAssets.lock());
// Для сохранения ресурсов в кеше
std::vector<Resource> resources;
resources.reserve(assets.size());
for(AssetEntry& entry : assets) {
resources.push_back(entry.Res);
// Проверяем используется ли сейчас ресурс
auto iter = Assets.ExistBinds[(int) entry.Type].find(entry.Id);
if(iter == Assets.ExistBinds[(int) entry.Type].end()) {
// Не используется
Assets.NotInUse[(int) entry.Type][entry.Domain + ':' + entry.Key] = {entry, TIME_BEFORE_UNLOAD_RESOURCE+time(nullptr)};
} else {
// Используется
Assets.InUse[(int) entry.Type][entry.Id] = entry;
changedResources[entry.Type].insert({entry.Id, entry});
}
}
// Сохраняем в кеш
AM->pushResources(std::move(resources));
}
// Обработка полученных тактов
while(!AsyncContext.TickSequence.get_read().empty()) {
@@ -372,69 +506,9 @@ void ServerSession::atFreeDrawTime(GlobalTime gTime, float dTime) {
lostResources[(EnumAssets) type].insert_range(tick.AssetsLost[type]);
}
// Запрос к дисковому кешу
std::vector<AssetsManager::ResourceKey> needToLoad;
// Новые привязки ресурсов
for(const AssetBindEntry& bind : tick.AssetsBinds) {
Assets.ExistBinds[(int) bind.Type].insert(bind.Id);
// Проверить in memory кеш по домену+ключу
{
std::string dk = bind.Domain + ':' + bind.Key;
auto &niubdk = Assets.NotInUse[(int) bind.Type];
auto iter = niubdk.find(dk);
if(iter != niubdk.end()) {
// Есть ресурс
Assets.InUse[(int) bind.Type][bind.Id] = std::get<0>(iter->second);
changedResources[bind.Type].insert({bind.Id, std::get<0>(iter->second)});
lostResources[bind.Type].erase(bind.Id);
continue;
}
}
// Под рукой нет ресурса, отправим на проверку в AssetsManager
needToLoad.emplace_back(bind.Hash, bind.Type, bind.Domain, bind.Key, bind.Id);
}
if(!needToLoad.empty())
AM->pushReads(std::move(needToLoad));
}
// Получаем ресурсы, загруженные с дискового кеша
{
std::vector<Hash_t> request;
std::vector<std::pair<AssetsManager::ResourceKey, std::optional<Resource>>> resources = AM->pullReads();
for(auto& [key, res] : resources) {
if(!res) {
// Нужно запросить ресурс с сервера
request.push_back(key.Hash);
} else {
auto& a = Assets.ExistBinds[(int) key.Type];
AssetEntry entry = {key.Type, key.Id, key.Domain, key.Key, *res};
if(a.contains(key.Id)) {
// Ресурс ещё нужен
Assets.InUse[(int) key.Type][key.Id] = entry;
changedResources[key.Type].insert({key.Id, entry});
} else {
// Ресурс уже не нужен
Assets.NotInUse[(int) key.Type][key.Domain + ':' + key.Key] = {entry, TIME_BEFORE_UNLOAD_RESOURCE+time(nullptr)};
}
}
}
if(!request.empty()) {
assert(request.size() < (1 << 16));
Net::Packet p;
p << (uint8_t) ToServer::L1::System << (uint8_t) ToServer::L2System::ResourceRequest
<< uint16_t(request.size());
for(Hash_t& hash : request)
p.write((const std::byte*) hash.data(), 32);
Socket->pushPacket(std::move(p));
}
}
if(RS) {
// Уведомляем рендер опотерянных и изменённых ресурсах