您最多选择25个主题
主题必须以中文或者字母或数字开头，可以包含连字符 (-)，并且长度不得超过35个字符
253 行
15 KiB
253 行
15 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;
|
|
|
|
[UpdateInGroup(typeof(GhostUpdateSystemGroup))]
|
|
public class PlayerStateGhostUpdateSystem : 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<PlayerStateSnapshotData> ghostSnapshotDataType;
|
|
[ReadOnly] public ArchetypeChunkEntityType ghostEntityType;
|
|
public ArchetypeChunkComponentType<Player.State> ghostPlayerStateType;
|
|
|
|
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 ghostPlayerStateArray = chunk.GetNativeArray(ghostPlayerStateType);
|
|
#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
|
|
PlayerStateSnapshotData snapshotData;
|
|
snapshot.GetDataAtTick(targetTick, targetTickFraction, out snapshotData);
|
|
|
|
var ghostPlayerState = ghostPlayerStateArray[entityIndex];
|
|
ghostPlayerState.playerId = snapshotData.GetPlayerStateplayerId(deserializerState);
|
|
ghostPlayerState.playerName = snapshotData.GetPlayerStateplayerName(deserializerState);
|
|
ghostPlayerState.teamIndex = snapshotData.GetPlayerStateteamIndex(deserializerState);
|
|
ghostPlayerState.score = snapshotData.GetPlayerStatescore(deserializerState);
|
|
ghostPlayerState.gameModeSystemInitialized = snapshotData.GetPlayerStategameModeSystemInitialized(deserializerState);
|
|
ghostPlayerState.displayCountDown = snapshotData.GetPlayerStatedisplayCountDown(deserializerState);
|
|
ghostPlayerState.countDown = snapshotData.GetPlayerStatecountDown(deserializerState);
|
|
ghostPlayerState.displayScoreBoard = snapshotData.GetPlayerStatedisplayScoreBoard(deserializerState);
|
|
ghostPlayerState.displayGameScore = snapshotData.GetPlayerStatedisplayGameScore(deserializerState);
|
|
ghostPlayerState.displayGameResult = snapshotData.GetPlayerStatedisplayGameResult(deserializerState);
|
|
ghostPlayerState.gameResult = snapshotData.GetPlayerStategameResult(deserializerState);
|
|
ghostPlayerState.displayGoal = snapshotData.GetPlayerStatedisplayGoal(deserializerState);
|
|
ghostPlayerState.goalPosition = snapshotData.GetPlayerStategoalPosition(deserializerState);
|
|
ghostPlayerState.goalDefendersColor = snapshotData.GetPlayerStategoalDefendersColor(deserializerState);
|
|
ghostPlayerState.goalAttackersColor = snapshotData.GetPlayerStategoalAttackersColor(deserializerState);
|
|
ghostPlayerState.goalAttackers = snapshotData.GetPlayerStategoalAttackers(deserializerState);
|
|
ghostPlayerState.goalDefenders = snapshotData.GetPlayerStategoalDefenders(deserializerState);
|
|
ghostPlayerState.goalString = snapshotData.GetPlayerStategoalString(deserializerState);
|
|
ghostPlayerState.actionString = snapshotData.GetPlayerStateactionString(deserializerState);
|
|
ghostPlayerState.goalCompletion = snapshotData.GetPlayerStategoalCompletion(deserializerState);
|
|
ghostPlayerStateArray[entityIndex] = ghostPlayerState;
|
|
}
|
|
}
|
|
}
|
|
[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<PlayerStateSnapshotData> ghostSnapshotDataType;
|
|
[ReadOnly] public ArchetypeChunkEntityType ghostEntityType;
|
|
public ArchetypeChunkComponentType<PredictedGhostComponent> predictedGhostComponentType;
|
|
public ArchetypeChunkComponentType<Player.State> ghostPlayerStateType;
|
|
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 ghostPlayerStateArray = chunk.GetNativeArray(ghostPlayerStateType);
|
|
#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
|
|
PlayerStateSnapshotData 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 ghostPlayerState = ghostPlayerStateArray[entityIndex];
|
|
ghostPlayerState.playerId = snapshotData.GetPlayerStateplayerId(deserializerState);
|
|
ghostPlayerState.playerName = snapshotData.GetPlayerStateplayerName(deserializerState);
|
|
ghostPlayerState.teamIndex = snapshotData.GetPlayerStateteamIndex(deserializerState);
|
|
ghostPlayerState.score = snapshotData.GetPlayerStatescore(deserializerState);
|
|
ghostPlayerState.gameModeSystemInitialized = snapshotData.GetPlayerStategameModeSystemInitialized(deserializerState);
|
|
ghostPlayerState.displayCountDown = snapshotData.GetPlayerStatedisplayCountDown(deserializerState);
|
|
ghostPlayerState.countDown = snapshotData.GetPlayerStatecountDown(deserializerState);
|
|
ghostPlayerState.displayScoreBoard = snapshotData.GetPlayerStatedisplayScoreBoard(deserializerState);
|
|
ghostPlayerState.displayGameScore = snapshotData.GetPlayerStatedisplayGameScore(deserializerState);
|
|
ghostPlayerState.displayGameResult = snapshotData.GetPlayerStatedisplayGameResult(deserializerState);
|
|
ghostPlayerState.gameResult = snapshotData.GetPlayerStategameResult(deserializerState);
|
|
ghostPlayerState.displayGoal = snapshotData.GetPlayerStatedisplayGoal(deserializerState);
|
|
ghostPlayerState.goalPosition = snapshotData.GetPlayerStategoalPosition(deserializerState);
|
|
ghostPlayerState.goalDefendersColor = snapshotData.GetPlayerStategoalDefendersColor(deserializerState);
|
|
ghostPlayerState.goalAttackersColor = snapshotData.GetPlayerStategoalAttackersColor(deserializerState);
|
|
ghostPlayerState.goalAttackers = snapshotData.GetPlayerStategoalAttackers(deserializerState);
|
|
ghostPlayerState.goalDefenders = snapshotData.GetPlayerStategoalDefenders(deserializerState);
|
|
ghostPlayerState.goalString = snapshotData.GetPlayerStategoalString(deserializerState);
|
|
ghostPlayerState.actionString = snapshotData.GetPlayerStateactionString(deserializerState);
|
|
ghostPlayerState.goalCompletion = snapshotData.GetPlayerStategoalCompletion(deserializerState);
|
|
ghostPlayerStateArray[entityIndex] = ghostPlayerState;
|
|
}
|
|
}
|
|
}
|
|
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<PlayerStateSnapshotData>(),
|
|
ComponentType.ReadOnly<GhostComponent>(),
|
|
ComponentType.ReadWrite<Player.State>(),
|
|
},
|
|
None = new []{ComponentType.ReadWrite<PredictedGhostComponent>()}
|
|
});
|
|
m_predictedQuery = GetEntityQuery(new EntityQueryDesc
|
|
{
|
|
All = new []{
|
|
ComponentType.ReadOnly<PlayerStateSnapshotData>(),
|
|
ComponentType.ReadOnly<GhostComponent>(),
|
|
ComponentType.ReadOnly<PredictedGhostComponent>(),
|
|
ComponentType.ReadWrite<Player.State>(),
|
|
}
|
|
});
|
|
RequireForUpdate(GetEntityQuery(ComponentType.ReadWrite<PlayerStateSnapshotData>(),
|
|
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<PlayerStateSnapshotData>(true),
|
|
ghostEntityType = GetArchetypeChunkEntityType(),
|
|
predictedGhostComponentType = GetArchetypeChunkComponentType<PredictedGhostComponent>(),
|
|
ghostPlayerStateType = GetArchetypeChunkComponentType<Player.State>(),
|
|
|
|
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<PlayerStateSnapshotData>(true),
|
|
ghostEntityType = GetArchetypeChunkEntityType(),
|
|
ghostPlayerStateType = GetArchetypeChunkComponentType<Player.State>(),
|
|
targetTick = m_ClientSimulationSystemGroup.InterpolationTick,
|
|
targetTickFraction = m_ClientSimulationSystemGroup.InterpolationTickFraction
|
|
};
|
|
inputDeps = updateInterpolatedJob.Schedule(m_interpolatedQuery, JobHandle.CombineDependencies(inputDeps, m_GhostUpdateSystemGroup.LastGhostMapWriter));
|
|
}
|
|
return inputDeps;
|
|
}
|
|
}
|
|
public partial class PlayerStateGhostSpawnSystem : DefaultGhostSpawnSystem<PlayerStateSnapshotData>
|
|
{
|
|
}
|