minor format updating
This commit is contained in:
@@ -128,7 +128,7 @@ public class ClientApi
|
||||
|
||||
/** Holds any levels that were loaded before the {@link ClientApi#onClientOnlyConnected} was fired. */
|
||||
public final HashSet<IClientLevelWrapper> waitingClientLevels = new HashSet<>();
|
||||
/** Holds any chunks that were loaded before the {@link ClientApi#clientLevelLoadEvent(IClientLevelWrapper)} was fired. */
|
||||
/** Holds any chunks that were found before the client levels are loaded. */
|
||||
public final Map<Pair<IClientLevelWrapper, DhChunkPos>, IChunkWrapper> waitingChunkByClientLevelAndPos = new ConcurrentHashMap<>();
|
||||
|
||||
/** publicly available so {@link F3Screen} can display the error */
|
||||
@@ -168,7 +168,7 @@ public class ClientApi
|
||||
|
||||
/**
|
||||
* May be fired slightly before or after the associated
|
||||
* {@link ClientApi#clientLevelLoadEvent(IClientLevelWrapper)} event
|
||||
* level is loaded
|
||||
* depending on how the host mod loader functions. <br><br>
|
||||
*
|
||||
* Synchronized shouldn't be necessary, but is present to match {@see onClientOnlyDisconnected} and prevent any unforeseen issues.
|
||||
|
||||
+2
-1
@@ -98,7 +98,8 @@ public class ClientPluginChannelApi
|
||||
LOGGER.info("Loading level with key: [" + msg.levelKey + "].");
|
||||
IServerKeyedClientLevel keyedLevel = KEYED_CLIENT_LEVEL_MANAGER.setServerKeyedLevel(clientLevel, msg.serverKey, msg.levelKey);
|
||||
AbstractDhWorld world = SharedApi.getAbstractDhWorld();
|
||||
if (world != null) {
|
||||
if (world != null)
|
||||
{
|
||||
world.getOrLoadLevel(keyedLevel);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -167,13 +167,15 @@ public class DhClientLevel extends AbstractDhLevel implements IDhClientLevel
|
||||
}
|
||||
|
||||
|
||||
// Check this before decoding data to prevent errors if multiple client levels are receiving data at once (Immersive Portals compatibility).
|
||||
// Check this before decoding data to prevent errors if multiple client levels
|
||||
// are receiving data at once (Immersive Portals compatibility).
|
||||
boolean isSameLevel = message.isSameLevelAs(this.levelWrapper);
|
||||
NETWORK_LOGGER.debug("Buffer ["+message.payload.dtoBufferId+"] isSameLevel: ["+isSameLevel+"]");
|
||||
//NETWORK_LOGGER.debug("Buffer ["+message.payload.dtoBufferId+"] isSameLevel: ["+isSameLevel+"]");
|
||||
if (!isSameLevel)
|
||||
{
|
||||
return;
|
||||
}
|
||||
|
||||
try (FullDataSourceV2DTO dataSourceDto = this.networkState.fullDataPayloadReceiver.decodeDataSource(message.payload))
|
||||
{
|
||||
|
||||
|
||||
+2
-3
@@ -165,9 +165,8 @@ public class ClientNetworkState implements Closeable
|
||||
// send message //
|
||||
//==============//
|
||||
|
||||
public void sendLevelInitRequest(String clientLevelKey) {
|
||||
this.getSession().sendMessage(new RequestLevelInitMessage(clientLevelKey));
|
||||
}
|
||||
public void sendLevelInitRequest(String clientLevelKey)
|
||||
{ this.getSession().sendMessage(new RequestLevelInitMessage(clientLevelKey)); }
|
||||
|
||||
public void sendConfigMessage() { this.sendConfigMessage(true); }
|
||||
public void sendConfigMessage(boolean blocking)
|
||||
|
||||
+16
-11
@@ -27,6 +27,8 @@ import java.util.function.Supplier;
|
||||
|
||||
public class ServerPlayerState implements Closeable
|
||||
{
|
||||
private final IMinecraftSharedWrapper MC_SHARED = SingletonInjector.INSTANCE.get(IMinecraftSharedWrapper.class);
|
||||
|
||||
private final ConfigChangeListener<String> levelKeyPrefixChangeListener
|
||||
= new ConfigChangeListener<>(Config.Server.levelKeyPrefix, this::onLevelKeyPrefixConfigChanged);
|
||||
private final SessionConfig.AnyChangeListener configAnyChangeListener = new SessionConfig.AnyChangeListener(this::sendConfigMessage);
|
||||
@@ -96,6 +98,20 @@ public class ServerPlayerState implements Closeable
|
||||
|
||||
private void onLevelKeyPrefixConfigChanged(String newLevelKey) { this.sendLevelKey(); }
|
||||
|
||||
private void sendLevelKey(String clientLevelKey)
|
||||
{
|
||||
sendLevelKey(() ->
|
||||
MC_SHARED
|
||||
.getWrappedServerLevel(clientLevelKey)
|
||||
.getKeyedLevelDimensionName());
|
||||
}
|
||||
private void sendLevelKey()
|
||||
{
|
||||
sendLevelKey(() ->
|
||||
this.getServerPlayer()
|
||||
.getLevel()
|
||||
.getKeyedLevelDimensionName());
|
||||
}
|
||||
private void sendLevelKey(Supplier<String> levelKeySupplier)
|
||||
{
|
||||
if (Config.Server.sendLevelKeys.get())
|
||||
@@ -110,17 +126,6 @@ public class ServerPlayerState implements Closeable
|
||||
}
|
||||
}
|
||||
|
||||
private void sendLevelKey(String clientLevelKey)
|
||||
{
|
||||
sendLevelKey(() -> SingletonInjector.INSTANCE.get(IMinecraftSharedWrapper.class)
|
||||
.getWrappedServerLevel(clientLevelKey).getKeyedLevelDimensionName());
|
||||
}
|
||||
|
||||
private void sendLevelKey()
|
||||
{
|
||||
sendLevelKey(() -> this.getServerPlayer().getLevel().getKeyedLevelDimensionName());
|
||||
}
|
||||
|
||||
private void sendConfigMessage()
|
||||
{
|
||||
double coordinateScale = this.getServerPlayer().getLevel().getDimensionType().getCoordinateScale();
|
||||
|
||||
@@ -92,9 +92,11 @@ public class DhClientWorld extends AbstractDhWorld implements IDhClientWorld
|
||||
{
|
||||
try
|
||||
{
|
||||
if (!ClientApi.INSTANCE.canLoadAlready(clientLevelWrapper)) {
|
||||
if (!ClientApi.INSTANCE.canLoadClientLevel(clientLevelWrapper))
|
||||
{
|
||||
return null;
|
||||
}
|
||||
|
||||
DhClientLevel level = new DhClientLevel(this.saveStructure, clientLevelWrapper, this.networkState);
|
||||
ApiEventInjector.INSTANCE.fireAllEvents(DhApiLevelLoadEvent.class, new DhApiLevelLoadEvent.EventParam(wrapper));
|
||||
ClientApi.INSTANCE.loadWaitingChunksForLevel(clientLevelWrapper);
|
||||
|
||||
@@ -94,7 +94,6 @@ public class DhServerWorld extends AbstractDhServerWorld<DhServerLevel>
|
||||
|
||||
if (this.dhLevelByLevelWrapper.containsKey(wrapper))
|
||||
{
|
||||
DhServerLevel level = this.dhLevelByLevelWrapper.get(wrapper);
|
||||
wrapper.onUnload();
|
||||
this.dhLevelByLevelWrapper.remove(wrapper).close();
|
||||
ApiEventInjector.INSTANCE.fireAllEvents(DhApiLevelUnloadEvent.class, new DhApiLevelUnloadEvent.EventParam(wrapper));
|
||||
|
||||
+1
@@ -29,6 +29,7 @@ import java.awt.*;
|
||||
public interface IClientLevelWrapper extends ILevelWrapper
|
||||
{
|
||||
|
||||
/** used to track when this level was last used for Immersive portals support */
|
||||
void markAccessed();
|
||||
|
||||
@Nullable
|
||||
|
||||
Reference in New Issue
Block a user