您最多选择25个主题
主题必须以中文或者字母或数字开头，可以包含连字符 (-)，并且长度不得超过35个字符
250 行
14 KiB
250 行
14 KiB
using Unity.Burst;
|
|
using Unity.Collections;
|
|
using Unity.Collections.LowLevel.Unsafe;
|
|
using Unity.Jobs;
|
|
using Unity.Jobs.LowLevel.Unsafe;
|
|
using Unity.Networking.Transport.Utilities;
|
|
using Unity.NetCode;
|
|
using Unity.Entities;
|
|
using Unity.Transforms;
|
|
|
|
[UpdateInGroup(typeof(GhostUpdateSystemGroup))]
|
|
public class TeleporterGhostUpdateSystem : JobComponentSystem
|
|
{
|
|
[BurstCompile]
|
|
struct UpdateInterpolatedJob : IJobChunk
|
|
{
|
|
[ReadOnly] public NativeHashMap<int, GhostEntity> GhostMap;
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
[NativeDisableContainerSafetyRestriction] public NativeArray<uint> minMaxSnapshotTick;
|
|
#pragma warning disable 649
|
|
[NativeSetThreadIndex]
|
|
public int ThreadIndex;
|
|
#pragma warning restore 649
|
|
#endif
|
|
[ReadOnly] public ArchetypeChunkBufferType<TeleporterSnapshotData> ghostSnapshotDataType;
|
|
[ReadOnly] public ArchetypeChunkEntityType ghostEntityType;
|
|
public ArchetypeChunkComponentType<TeleporterPresentationData> ghostTeleporterPresentationDataType;
|
|
[ReadOnly] public ArchetypeChunkBufferType<LinkedEntityGroup> ghostLinkedEntityGroupType;
|
|
[NativeDisableParallelForRestriction] public ComponentDataFromEntity<Translation> ghostTranslationFromEntity;
|
|
|
|
public uint targetTick;
|
|
public float targetTickFraction;
|
|
public void Execute(ArchetypeChunk chunk, int chunkIndex, int firstEntityIndex)
|
|
{
|
|
var deserializerState = new GhostDeserializerState
|
|
{
|
|
GhostMap = GhostMap
|
|
};
|
|
var ghostEntityArray = chunk.GetNativeArray(ghostEntityType);
|
|
var ghostSnapshotDataArray = chunk.GetBufferAccessor(ghostSnapshotDataType);
|
|
var ghostTeleporterPresentationDataArray = chunk.GetNativeArray(ghostTeleporterPresentationDataType);
|
|
var ghostLinkedEntityGroupArray = chunk.GetBufferAccessor(ghostLinkedEntityGroupType);
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
var minMaxOffset = ThreadIndex * (JobsUtility.CacheLineSize/4);
|
|
#endif
|
|
for (int entityIndex = 0; entityIndex < ghostEntityArray.Length; ++entityIndex)
|
|
{
|
|
var snapshot = ghostSnapshotDataArray[entityIndex];
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
var latestTick = snapshot.GetLatestTick();
|
|
if (latestTick != 0)
|
|
{
|
|
if (minMaxSnapshotTick[minMaxOffset] == 0 || SequenceHelpers.IsNewer(minMaxSnapshotTick[minMaxOffset], latestTick))
|
|
minMaxSnapshotTick[minMaxOffset] = latestTick;
|
|
if (minMaxSnapshotTick[minMaxOffset + 1] == 0 || SequenceHelpers.IsNewer(latestTick, minMaxSnapshotTick[minMaxOffset + 1]))
|
|
minMaxSnapshotTick[minMaxOffset + 1] = latestTick;
|
|
}
|
|
#endif
|
|
TeleporterSnapshotData snapshotData;
|
|
snapshot.GetDataAtTick(targetTick, targetTickFraction, out snapshotData);
|
|
|
|
var ghostTeleporterPresentationData = ghostTeleporterPresentationDataArray[entityIndex];
|
|
var ghostTranslation = ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][0].Value];
|
|
var ghostChild0Translation = ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][1].Value];
|
|
var ghostChild1Translation = ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][2].Value];
|
|
ghostTeleporterPresentationData.effectTick = snapshotData.GetTeleporterPresentationDataeffectTick(deserializerState);
|
|
ghostTranslation.Value = snapshotData.GetTranslationValue(deserializerState);
|
|
ghostChild0Translation.Value = snapshotData.GetChild0TranslationValue(deserializerState);
|
|
ghostChild1Translation.Value = snapshotData.GetChild1TranslationValue(deserializerState);
|
|
ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][0].Value] = ghostTranslation;
|
|
ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][1].Value] = ghostChild0Translation;
|
|
ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][2].Value] = ghostChild1Translation;
|
|
ghostTeleporterPresentationDataArray[entityIndex] = ghostTeleporterPresentationData;
|
|
}
|
|
}
|
|
}
|
|
[BurstCompile]
|
|
struct UpdatePredictedJob : IJobChunk
|
|
{
|
|
[ReadOnly] public NativeHashMap<int, GhostEntity> GhostMap;
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
[NativeDisableContainerSafetyRestriction] public NativeArray<uint> minMaxSnapshotTick;
|
|
#endif
|
|
#pragma warning disable 649
|
|
[NativeSetThreadIndex]
|
|
public int ThreadIndex;
|
|
#pragma warning restore 649
|
|
[NativeDisableParallelForRestriction] public NativeArray<uint> minPredictedTick;
|
|
[ReadOnly] public ArchetypeChunkBufferType<TeleporterSnapshotData> ghostSnapshotDataType;
|
|
[ReadOnly] public ArchetypeChunkEntityType ghostEntityType;
|
|
public ArchetypeChunkComponentType<PredictedGhostComponent> predictedGhostComponentType;
|
|
public ArchetypeChunkComponentType<TeleporterPresentationData> ghostTeleporterPresentationDataType;
|
|
public ArchetypeChunkComponentType<Translation> ghostTranslationType;
|
|
[ReadOnly] public ArchetypeChunkBufferType<LinkedEntityGroup> ghostLinkedEntityGroupType;
|
|
[NativeDisableParallelForRestriction] public ComponentDataFromEntity<Translation> ghostTranslationFromEntity;
|
|
public uint targetTick;
|
|
public uint lastPredictedTick;
|
|
public void Execute(ArchetypeChunk chunk, int chunkIndex, int firstEntityIndex)
|
|
{
|
|
var deserializerState = new GhostDeserializerState
|
|
{
|
|
GhostMap = GhostMap
|
|
};
|
|
var ghostEntityArray = chunk.GetNativeArray(ghostEntityType);
|
|
var ghostSnapshotDataArray = chunk.GetBufferAccessor(ghostSnapshotDataType);
|
|
var predictedGhostComponentArray = chunk.GetNativeArray(predictedGhostComponentType);
|
|
var ghostTeleporterPresentationDataArray = chunk.GetNativeArray(ghostTeleporterPresentationDataType);
|
|
var ghostTranslationArray = chunk.GetNativeArray(ghostTranslationType);
|
|
var ghostLinkedEntityGroupArray = chunk.GetBufferAccessor(ghostLinkedEntityGroupType);
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
var minMaxOffset = ThreadIndex * (JobsUtility.CacheLineSize/4);
|
|
#endif
|
|
for (int entityIndex = 0; entityIndex < ghostEntityArray.Length; ++entityIndex)
|
|
{
|
|
var snapshot = ghostSnapshotDataArray[entityIndex];
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
var latestTick = snapshot.GetLatestTick();
|
|
if (latestTick != 0)
|
|
{
|
|
if (minMaxSnapshotTick[minMaxOffset] == 0 || SequenceHelpers.IsNewer(minMaxSnapshotTick[minMaxOffset], latestTick))
|
|
minMaxSnapshotTick[minMaxOffset] = latestTick;
|
|
if (minMaxSnapshotTick[minMaxOffset + 1] == 0 || SequenceHelpers.IsNewer(latestTick, minMaxSnapshotTick[minMaxOffset + 1]))
|
|
minMaxSnapshotTick[minMaxOffset + 1] = latestTick;
|
|
}
|
|
#endif
|
|
TeleporterSnapshotData snapshotData;
|
|
snapshot.GetDataAtTick(targetTick, out snapshotData);
|
|
|
|
var predictedData = predictedGhostComponentArray[entityIndex];
|
|
var lastPredictedTickInst = lastPredictedTick;
|
|
if (lastPredictedTickInst == 0 || predictedData.AppliedTick != snapshotData.Tick)
|
|
lastPredictedTickInst = snapshotData.Tick;
|
|
else if (!SequenceHelpers.IsNewer(lastPredictedTickInst, snapshotData.Tick))
|
|
lastPredictedTickInst = snapshotData.Tick;
|
|
if (minPredictedTick[ThreadIndex] == 0 || SequenceHelpers.IsNewer(minPredictedTick[ThreadIndex], lastPredictedTickInst))
|
|
minPredictedTick[ThreadIndex] = lastPredictedTickInst;
|
|
predictedGhostComponentArray[entityIndex] = new PredictedGhostComponent{AppliedTick = snapshotData.Tick, PredictionStartTick = lastPredictedTickInst};
|
|
if (lastPredictedTickInst != snapshotData.Tick)
|
|
continue;
|
|
|
|
var ghostTeleporterPresentationData = ghostTeleporterPresentationDataArray[entityIndex];
|
|
var ghostTranslation = ghostTranslationArray[entityIndex];
|
|
var ghostChild0Translation = ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][1].Value];
|
|
var ghostChild1Translation = ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][2].Value];
|
|
ghostTeleporterPresentationData.effectTick = snapshotData.GetTeleporterPresentationDataeffectTick(deserializerState);
|
|
ghostTranslation.Value = snapshotData.GetTranslationValue(deserializerState);
|
|
ghostChild0Translation.Value = snapshotData.GetChild0TranslationValue(deserializerState);
|
|
ghostChild1Translation.Value = snapshotData.GetChild1TranslationValue(deserializerState);
|
|
ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][1].Value] = ghostChild0Translation;
|
|
ghostTranslationFromEntity[ghostLinkedEntityGroupArray[entityIndex][2].Value] = ghostChild1Translation;
|
|
ghostTeleporterPresentationDataArray[entityIndex] = ghostTeleporterPresentationData;
|
|
ghostTranslationArray[entityIndex] = ghostTranslation;
|
|
}
|
|
}
|
|
}
|
|
private ClientSimulationSystemGroup m_ClientSimulationSystemGroup;
|
|
private GhostPredictionSystemGroup m_GhostPredictionSystemGroup;
|
|
private EntityQuery m_interpolatedQuery;
|
|
private EntityQuery m_predictedQuery;
|
|
private NativeHashMap<int, GhostEntity> m_ghostEntityMap;
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
private NativeArray<uint> m_ghostMinMaxSnapshotTick;
|
|
#endif
|
|
private GhostUpdateSystemGroup m_GhostUpdateSystemGroup;
|
|
private uint m_LastPredictedTick;
|
|
protected override void OnCreate()
|
|
{
|
|
m_GhostUpdateSystemGroup = World.GetOrCreateSystem<GhostUpdateSystemGroup>();
|
|
m_ghostEntityMap = m_GhostUpdateSystemGroup.GhostEntityMap;
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
m_ghostMinMaxSnapshotTick = m_GhostUpdateSystemGroup.GhostSnapshotTickMinMax;
|
|
#endif
|
|
m_ClientSimulationSystemGroup = World.GetOrCreateSystem<ClientSimulationSystemGroup>();
|
|
m_GhostPredictionSystemGroup = World.GetOrCreateSystem<GhostPredictionSystemGroup>();
|
|
m_interpolatedQuery = GetEntityQuery(new EntityQueryDesc
|
|
{
|
|
All = new []{
|
|
ComponentType.ReadWrite<TeleporterSnapshotData>(),
|
|
ComponentType.ReadOnly<GhostComponent>(),
|
|
ComponentType.ReadWrite<TeleporterPresentationData>(),
|
|
ComponentType.ReadOnly<LinkedEntityGroup>(),
|
|
},
|
|
None = new []{ComponentType.ReadWrite<PredictedGhostComponent>()}
|
|
});
|
|
m_predictedQuery = GetEntityQuery(new EntityQueryDesc
|
|
{
|
|
All = new []{
|
|
ComponentType.ReadOnly<TeleporterSnapshotData>(),
|
|
ComponentType.ReadOnly<GhostComponent>(),
|
|
ComponentType.ReadOnly<PredictedGhostComponent>(),
|
|
ComponentType.ReadWrite<TeleporterPresentationData>(),
|
|
ComponentType.ReadWrite<Translation>(),
|
|
ComponentType.ReadOnly<LinkedEntityGroup>(),
|
|
}
|
|
});
|
|
RequireForUpdate(GetEntityQuery(ComponentType.ReadWrite<TeleporterSnapshotData>(),
|
|
ComponentType.ReadOnly<GhostComponent>()));
|
|
}
|
|
protected override JobHandle OnUpdate(JobHandle inputDeps)
|
|
{
|
|
if (!m_predictedQuery.IsEmptyIgnoreFilter)
|
|
{
|
|
var updatePredictedJob = new UpdatePredictedJob
|
|
{
|
|
GhostMap = m_ghostEntityMap,
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
minMaxSnapshotTick = m_ghostMinMaxSnapshotTick,
|
|
#endif
|
|
minPredictedTick = m_GhostPredictionSystemGroup.OldestPredictedTick,
|
|
ghostSnapshotDataType = GetArchetypeChunkBufferType<TeleporterSnapshotData>(true),
|
|
ghostEntityType = GetArchetypeChunkEntityType(),
|
|
predictedGhostComponentType = GetArchetypeChunkComponentType<PredictedGhostComponent>(),
|
|
ghostTeleporterPresentationDataType = GetArchetypeChunkComponentType<TeleporterPresentationData>(),
|
|
ghostTranslationType = GetArchetypeChunkComponentType<Translation>(),
|
|
ghostLinkedEntityGroupType = GetArchetypeChunkBufferType<LinkedEntityGroup>(true),
|
|
ghostTranslationFromEntity = GetComponentDataFromEntity<Translation>(),
|
|
|
|
targetTick = m_ClientSimulationSystemGroup.ServerTick,
|
|
lastPredictedTick = m_LastPredictedTick
|
|
};
|
|
m_LastPredictedTick = m_ClientSimulationSystemGroup.ServerTick;
|
|
if (m_ClientSimulationSystemGroup.ServerTickFraction < 1)
|
|
m_LastPredictedTick = 0;
|
|
inputDeps = updatePredictedJob.Schedule(m_predictedQuery, JobHandle.CombineDependencies(inputDeps, m_GhostUpdateSystemGroup.LastGhostMapWriter));
|
|
m_GhostPredictionSystemGroup.AddPredictedTickWriter(inputDeps);
|
|
}
|
|
if (!m_interpolatedQuery.IsEmptyIgnoreFilter)
|
|
{
|
|
var updateInterpolatedJob = new UpdateInterpolatedJob
|
|
{
|
|
GhostMap = m_ghostEntityMap,
|
|
#if UNITY_EDITOR || DEVELOPMENT_BUILD
|
|
minMaxSnapshotTick = m_ghostMinMaxSnapshotTick,
|
|
#endif
|
|
ghostSnapshotDataType = GetArchetypeChunkBufferType<TeleporterSnapshotData>(true),
|
|
ghostEntityType = GetArchetypeChunkEntityType(),
|
|
ghostTeleporterPresentationDataType = GetArchetypeChunkComponentType<TeleporterPresentationData>(),
|
|
ghostLinkedEntityGroupType = GetArchetypeChunkBufferType<LinkedEntityGroup>(true),
|
|
ghostTranslationFromEntity = GetComponentDataFromEntity<Translation>(),
|
|
targetTick = m_ClientSimulationSystemGroup.InterpolationTick,
|
|
targetTickFraction = m_ClientSimulationSystemGroup.InterpolationTickFraction
|
|
};
|
|
inputDeps = updateInterpolatedJob.Schedule(m_interpolatedQuery, JobHandle.CombineDependencies(inputDeps, m_GhostUpdateSystemGroup.LastGhostMapWriter));
|
|
}
|
|
return inputDeps;
|
|
}
|
|
}
|
|
public partial class TeleporterGhostSpawnSystem : DefaultGhostSpawnSystem<TeleporterSnapshotData>
|
|
{
|
|
}
|