Package com.hypixel.hytale.server.core.entity

Class InteractionManager

java.lang.Object

com.hypixel.hytale.server.core.entity.InteractionManager

All Implemented Interfaces:

Component<EntityStore>, Cloneable

public class InteractionManager
extends Object
implements Component<EntityStore>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	InteractionManager.ChainCancelledException

Field Summary

Fields

Modifier and Type	Field	Description
private final Predicate<InteractionChain>	cachedTickChain
private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<InteractionChain>	chains
private final it.unimi.dsi.fastutil.objects.ObjectList<InteractionChain>	chainStartQueue
protected CommandBuffer<EntityStore>	commandBuffer
private final CooldownHandler	cooldownHandler
static final float[]	DEFAULT_CHARGE_TIMES
private final LivingEntity	entity
private final float[]	globalTimeShift
private final boolean[]	globalTimeShiftDirty
private boolean	hasRemoteClient
private final IInteractionSimulationHandler	interactionSimulationHandler
private int	lastClientChainId
private int	lastServerChainId
private static final com.hypixel.hytale.logger.HytaleLogger	LOGGER
static final double	MAX_REACH_DISTANCE
private long	packetQueueTime
private final PlayerRef	playerRef
private final it.unimi.dsi.fastutil.objects.ObjectList<SyncInteractionChain>	syncPackets
private final it.unimi.dsi.fastutil.objects.ObjectList<InteractionSyncData>	tempSyncDataList
private boolean	timeShiftsDirty
private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<InteractionChain>	unmodifiableChains

Fields inherited from interface com.hypixel.hytale.component.Component

EMPTY_ARRAY

Constructor Summary

Constructors

Constructor	Description
InteractionManager(LivingEntity entity, PlayerRef playerRef, IInteractionSimulationHandler simulationHandler)

Method Summary

Modifier and Type	Method	Description
private static boolean	applyRules(InteractionChainData data, InteractionType type, int heldItemSlot, RootInteraction rootInteraction, Map<?,InteractionChain> chains, List<InteractionChain> chainsToCancel)
boolean	applyRules(InteractionContext context, InteractionChainData data, InteractionType type, RootInteraction rootInteraction)
void	cancelChains(InteractionChain chain)
boolean	canRun(InteractionType type, short equipSlot, RootInteraction rootInteraction)
boolean	canRun(InteractionType type, RootInteraction rootInteraction)
void	clear()
void	clearAllGlobalTimeShift(float dt)
Component<EntityStore>	clone()
void	copyFrom(InteractionManager interactionManager)	Deprecated.
private void	doTickChain(Ref<EntityStore> ref, InteractionChain chain)
void	executeChain(Ref<EntityStore> ref, CommandBuffer<EntityStore> commandBuffer, InteractionChain chain)
private void	executeChain0(Ref<EntityStore> ref, InteractionChain chain)
<T> T	forEachInteraction(TriFunction<InteractionChain,Interaction,T,T> func, T val)
private static <T> T	forEachInteraction(Map<?,InteractionChain> chains, TriFunction<InteractionChain,Interaction,T,T> func, T val)
private InteractionChain	getChain(int chainId, ForkedChainId forkedChainId)
it.unimi.dsi.fastutil.ints.Int2ObjectMap<InteractionChain>	getChains()
float	getGlobalTimeShift(InteractionType type)
IInteractionSimulationHandler	getInteractionSimulationHandler()
private long	getOperationTimeoutThreshold()
it.unimi.dsi.fastutil.objects.ObjectList<SyncInteractionChain>	getSyncPackets()
private void	handleCancelledChain(Ref<EntityStore> ref, InteractionChain chain)
InteractionChain	initChain(InteractionChainData data, InteractionType type, InteractionContext context, RootInteraction rootInteraction, Runnable onCompletion, boolean forceRemoteSync)
InteractionChain	initChain(InteractionType type, InteractionContext context, RootInteraction rootInteraction, boolean forceRemoteSync)
InteractionChain	initChain(InteractionType type, InteractionContext context, RootInteraction rootInteraction, int entityId, BlockPosition blockPosition, boolean forceRemoteSync)
private boolean	isOnCooldown(Ref<EntityStore> ref, InteractionType type, RootInteraction root, boolean remote)
private static SyncInteractionChain	makeSyncPacket(InteractionChain chain, int operationBaseIndex, List<InteractionSyncData> interactionData)
void	queueExecuteChain(InteractionChain chain)
private void	removeInteractionIfFinished(Ref<EntityStore> ref, InteractionChain chain, InteractionEntry entry)
void	sendCancelPacket(int chainId, ForkedChainId forkedChainId)
private void	sendCancelPacket(InteractionChain chain)
void	sendSyncPacket(InteractionChain chain, int operationBaseIndex, List<InteractionSyncData> interactionData)
private InteractionSyncData	serverTick(Ref<EntityStore> ref, InteractionChain chain, long tickTime)
void	setGlobalTimeShift(InteractionType type, float shift)
void	setHasRemoteClient(boolean hasRemoteClient)	Deprecated, for removal: This API element is subject to removal in a future version.
private void	simulationTick(Ref<EntityStore> ref, InteractionChain chain, long tickTime)
void	startChain(Ref<EntityStore> ref, CommandBuffer<EntityStore> commandBuffer, InteractionType type, InteractionContext context, RootInteraction rootInteraction)
void	sync(Ref<EntityStore> ref, ChainSyncStorage chainSyncStorage, SyncInteractionChain packet)
private boolean	syncStart(Ref<EntityStore> ref, SyncInteractionChain packet)
void	tick(Ref<EntityStore> ref, CommandBuffer<EntityStore> commandBuffer, float dt)
private boolean	tickChain(InteractionChain chain)
private boolean	tryConsumePacketQueue(Ref<EntityStore> ref, Deque<SyncInteractionChain> packetQueue)
void	tryRunHeldInteraction(Ref<EntityStore> ref, CommandBuffer<EntityStore> commandBuffer, InteractionType type)
void	tryRunHeldInteraction(Ref<EntityStore> ref, CommandBuffer<EntityStore> commandBuffer, InteractionType type, short equipSlot)
boolean	tryStartChain(Ref<EntityStore> ref, CommandBuffer<EntityStore> commandBuffer, InteractionType type, InteractionContext context, RootInteraction rootInteraction)
private boolean	waitingForClient(Ref<EntityStore> ref)
void	walkChain(Ref<EntityStore> ref, Collector collector, InteractionType type, ComponentAccessor<EntityStore> componentAccessor)
void	walkChain(Ref<EntityStore> ref, Collector collector, InteractionType type, RootInteraction rootInteraction, ComponentAccessor<EntityStore> componentAccessor)
static void	walkChain(Collector collector, InteractionType type, InteractionContext context, RootInteraction rootInteraction)
static boolean	walkInteraction(Collector collector, InteractionContext context, CollectorTag tag, String id)
static boolean	walkInteractions(Collector collector, InteractionContext context, CollectorTag tag, String[] interactionIds)

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.hypixel.hytale.component.Component

cloneSerializable

Field Details

MAX_REACH_DISTANCE

public static final double MAX_REACH_DISTANCE

See Also:

• Constant Field Values

DEFAULT_CHARGE_TIMES

public static final float[] DEFAULT_CHARGE_TIMES

LOGGER

private static final com.hypixel.hytale.logger.HytaleLogger LOGGER

chains

@Nonnull
private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<InteractionChain> chains

unmodifiableChains

@Nonnull
private final it.unimi.dsi.fastutil.ints.Int2ObjectMap<InteractionChain> unmodifiableChains

cooldownHandler

@Nonnull
private final CooldownHandler cooldownHandler

entity

@Nonnull
private final LivingEntity entity

playerRef

@Nullable
private final PlayerRef playerRef

hasRemoteClient

private boolean hasRemoteClient

interactionSimulationHandler

@Nonnull
private final IInteractionSimulationHandler interactionSimulationHandler

tempSyncDataList

@Nonnull
private final it.unimi.dsi.fastutil.objects.ObjectList<InteractionSyncData> tempSyncDataList

lastServerChainId

private int lastServerChainId

lastClientChainId

private int lastClientChainId

packetQueueTime

private long packetQueueTime

globalTimeShift

private final float[] globalTimeShift

globalTimeShiftDirty

private final boolean[] globalTimeShiftDirty

timeShiftsDirty

private boolean timeShiftsDirty

syncPackets

private final it.unimi.dsi.fastutil.objects.ObjectList<SyncInteractionChain> syncPackets

chainStartQueue

@Nonnull
private final it.unimi.dsi.fastutil.objects.ObjectList<InteractionChain> chainStartQueue

cachedTickChain

@Nonnull
private final Predicate<InteractionChain> cachedTickChain

commandBuffer

@Nullable
protected CommandBuffer<EntityStore> commandBuffer

Constructor Details

InteractionManager

public InteractionManager(@Nonnull
 LivingEntity entity,
 @Nullable
 PlayerRef playerRef,
 @Nonnull
 IInteractionSimulationHandler simulationHandler)

Method Details

getChains

@Nonnull
public it.unimi.dsi.fastutil.ints.Int2ObjectMap<InteractionChain> getChains()

getInteractionSimulationHandler

@Nonnull
public IInteractionSimulationHandler getInteractionSimulationHandler()

getOperationTimeoutThreshold

private long getOperationTimeoutThreshold()

waitingForClient

private boolean waitingForClient(@Nonnull
 Ref<EntityStore> ref)

setHasRemoteClient

@Deprecated(forRemoval=true)
public void setHasRemoteClient(boolean hasRemoteClient)

Deprecated, for removal: This API element is subject to removal in a future version.

copyFrom

@Deprecated
public void copyFrom(@Nonnull
 InteractionManager interactionManager)

Deprecated.

tick

public void tick(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 CommandBuffer<EntityStore> commandBuffer,
 float dt)

tryConsumePacketQueue

private boolean tryConsumePacketQueue(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 Deque<SyncInteractionChain> packetQueue)

getChain

@Nullable
private InteractionChain getChain(int chainId,
 @Nullable
 ForkedChainId forkedChainId)

tickChain

private boolean tickChain(@Nonnull
 InteractionChain chain)

handleCancelledChain

private void handleCancelledChain(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 InteractionChain chain)

doTickChain

private void doTickChain(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 InteractionChain chain)

serverTick

@Nullable
private InteractionSyncData serverTick(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 InteractionChain chain,
 long tickTime)

removeInteractionIfFinished

private void removeInteractionIfFinished(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 InteractionChain chain,
 @Nonnull
 InteractionEntry entry)

simulationTick

private void simulationTick(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 InteractionChain chain,
 long tickTime)

syncStart

private boolean syncStart(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 SyncInteractionChain packet)

sync

public void sync(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 ChainSyncStorage chainSyncStorage,
 @Nonnull
 SyncInteractionChain packet)

canRun

public boolean canRun(@Nonnull
 InteractionType type,
 @Nonnull
 RootInteraction rootInteraction)

canRun

public boolean canRun(@Nonnull
 InteractionType type,
 short equipSlot,
 @Nonnull
 RootInteraction rootInteraction)

applyRules

public boolean applyRules(@Nonnull
 InteractionContext context,
 @Nonnull
 InteractionChainData data,
 @Nonnull
 InteractionType type,
 @Nonnull
 RootInteraction rootInteraction)

cancelChains

public void cancelChains(@Nonnull
 InteractionChain chain)

applyRules

private static boolean applyRules(@Nullable
 InteractionChainData data,
 @Nonnull
 InteractionType type,
 int heldItemSlot,
 @Nullable
 RootInteraction rootInteraction,
 @Nonnull
 Map<?,InteractionChain> chains,
 @Nullable
 List<InteractionChain> chainsToCancel)

tryStartChain

public boolean tryStartChain(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 CommandBuffer<EntityStore> commandBuffer,
 @Nonnull
 InteractionType type,
 @Nonnull
 InteractionContext context,
 @Nonnull
 RootInteraction rootInteraction)

startChain

public void startChain(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 CommandBuffer<EntityStore> commandBuffer,
 @Nonnull
 InteractionType type,
 @Nonnull
 InteractionContext context,
 @Nonnull
 RootInteraction rootInteraction)

initChain

@Nonnull
public InteractionChain initChain(@Nonnull
 InteractionType type,
 @Nonnull
 InteractionContext context,
 @Nonnull
 RootInteraction rootInteraction,
 boolean forceRemoteSync)

initChain

@Nonnull
public InteractionChain initChain(@Nonnull
 InteractionType type,
 @Nonnull
 InteractionContext context,
 @Nonnull
 RootInteraction rootInteraction,
 int entityId,
 @Nullable
 BlockPosition blockPosition,
 boolean forceRemoteSync)

initChain

@Nonnull
public InteractionChain initChain(@Nonnull
 InteractionChainData data,
 @Nonnull
 InteractionType type,
 @Nonnull
 InteractionContext context,
 @Nonnull
 RootInteraction rootInteraction,
 @Nullable
 Runnable onCompletion,
 boolean forceRemoteSync)

queueExecuteChain

public void queueExecuteChain(@Nonnull
 InteractionChain chain)

executeChain

public void executeChain(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 CommandBuffer<EntityStore> commandBuffer,
 @Nonnull
 InteractionChain chain)

executeChain0

private void executeChain0(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 InteractionChain chain)

isOnCooldown

private boolean isOnCooldown(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 InteractionType type,
 @Nonnull
 RootInteraction root,
 boolean remote)

tryRunHeldInteraction

public void tryRunHeldInteraction(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 CommandBuffer<EntityStore> commandBuffer,
 @Nonnull
 InteractionType type)

tryRunHeldInteraction

public void tryRunHeldInteraction(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 CommandBuffer<EntityStore> commandBuffer,
 @Nonnull
 InteractionType type,
 short equipSlot)

sendSyncPacket

public void sendSyncPacket(@Nonnull
 InteractionChain chain,
 int operationBaseIndex,
 @Nullable
 List<InteractionSyncData> interactionData)

makeSyncPacket

@Nonnull
private static SyncInteractionChain makeSyncPacket(@Nonnull
 InteractionChain chain,
 int operationBaseIndex,
 @Nullable
 List<InteractionSyncData> interactionData)

sendCancelPacket

private void sendCancelPacket(@Nonnull
 InteractionChain chain)

sendCancelPacket

public void sendCancelPacket(int chainId,
 @Nonnull
 ForkedChainId forkedChainId)

clear

public void clear()

clearAllGlobalTimeShift

public void clearAllGlobalTimeShift(float dt)

setGlobalTimeShift

public void setGlobalTimeShift(@Nonnull
 InteractionType type,
 float shift)

getGlobalTimeShift

public float getGlobalTimeShift(@Nonnull
 InteractionType type)

forEachInteraction

public <T> T forEachInteraction(@Nonnull
 TriFunction<InteractionChain,Interaction,T,T> func,
 @Nonnull
 T val)

forEachInteraction

private static <T> T forEachInteraction(@Nonnull
 Map<?,InteractionChain> chains,
 @Nonnull
 TriFunction<InteractionChain,Interaction,T,T> func,
 @Nonnull
 T val)

walkChain

public void walkChain(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 Collector collector,
 @Nonnull
 InteractionType type,
 @Nonnull
 ComponentAccessor<EntityStore> componentAccessor)

walkChain

public void walkChain(@Nonnull
 Ref<EntityStore> ref,
 @Nonnull
 Collector collector,
 @Nonnull
 InteractionType type,
 @Nullable
 RootInteraction rootInteraction,
 @Nonnull
 ComponentAccessor<EntityStore> componentAccessor)

walkChain

public static void walkChain(@Nonnull
 Collector collector,
 @Nonnull
 InteractionType type,
 @Nonnull
 InteractionContext context,
 @Nullable
 RootInteraction rootInteraction)

walkInteractions

public static boolean walkInteractions(@Nonnull
 Collector collector,
 @Nonnull
 InteractionContext context,
 @Nonnull
 CollectorTag tag,
 @Nonnull
 String[] interactionIds)

walkInteraction

public static boolean walkInteraction(@Nonnull
 Collector collector,
 @Nonnull
 InteractionContext context,
 @Nonnull
 CollectorTag tag,
 @Nullable
 String id)

getSyncPackets

public it.unimi.dsi.fastutil.objects.ObjectList<SyncInteractionChain> getSyncPackets()

clone

@Nonnull
public Component<EntityStore> clone()

Specified by:

clone in interface Component<EntityStore>

Overrides:

clone in class Object