Plexus/Plex-FAWE
1
0
Fork 0
mirror of https://github.com/plexusorg/Plex-FAWE.git synced 2024-07-03 07:30:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix exceptions being squashed RegionVisitor preloading

Browse Source
This commit is contained in:
dordsor21 2021-09-10 14:41:15 +01:00
parent ef62f1e0d9
commit effb94623a
No known key found for this signature in database
GPG Key ID: 1E53E88969FFCF0B
1 changed files with 34 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

93
worldedit-core/src/main/java/com/sk89q/worldedit/function/visitor/RegionVisitor.java
View File

@ -108,23 +108,24 @@ public class RegionVisitor implements Operation {
int lastLeadChunkX = Integer.MIN_VALUE; int lastLeadChunkX = Integer.MIN_VALUE;
int lastLeadChunkZ = Integer.MIN_VALUE; int lastLeadChunkZ = Integer.MIN_VALUE;
int loadingTarget = Settings.IMP.QUEUE.PRELOAD_CHUNK_COUNT; int loadingTarget = Settings.IMP.QUEUE.PRELOAD_CHUNK_COUNT;
try { while (trailIter.hasNext()) {
for (; ; ) { BlockVector3 pt = trailIter.next();
BlockVector3 pt = trailIter.next(); apply(pt);
apply(pt); int cx = pt.getBlockX() >> 4;
int cx = pt.getBlockX() >> 4; int cz = pt.getBlockZ() >> 4;
int cz = pt.getBlockZ() >> 4; if (cx != lastTrailChunkX || cz != lastTrailChunkZ) {
if (cx != lastTrailChunkX || cz != lastTrailChunkZ) { lastTrailChunkX = cx;
lastTrailChunkX = cx; lastTrailChunkZ = cz;
lastTrailChunkZ = cz; int amount;
int amount; if (lastLeadChunkX == Integer.MIN_VALUE) {
if (lastLeadChunkX == Integer.MIN_VALUE) { lastLeadChunkX = cx;
lastLeadChunkX = cx; lastLeadChunkZ = cz;
lastLeadChunkZ = cz; amount = loadingTarget;
amount = loadingTarget; } else {
} else { amount = 1;
amount = 1; }
} try {
lead:
for (int count = 0; count < amount; ) { for (int count = 0; count < amount; ) {
BlockVector3 v = leadIter.next(); BlockVector3 v = leadIter.next();
int vcx = v.getBlockX() >> 4; int vcx = v.getBlockX() >> 4;
@ -136,51 +137,26 @@ public class RegionVisitor implements Operation {
count++; count++;
} }
// Skip the next 15 blocks // Skip the next 15 blocks
leadIter.next(); for (int i = 0; i < 16; i++) {
leadIter.next(); if (!leadIter.hasNext()) {
leadIter.next(); break lead;
leadIter.next(); }
leadIter.next(); leadIter.next();
leadIter.next(); }
leadIter.next();
leadIter.next();
leadIter.next();
leadIter.next();
leadIter.next();
leadIter.next();
leadIter.next();
leadIter.next();
leadIter.next();
} }
} catch (FaweException e) {
// Likely to be a low memory or cancellation exception.
throw new RuntimeException(e);
} catch (Throwable ignored) {
// Ignore as it is likely not something too important, and we can continue with the operation
}
}
for (int i = 0; i < 16; i++) {
if (!trailIter.hasNext()) {
return null;
} }
apply(trailIter.next()); apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
apply(trailIter.next());
} }
} catch (FaweException e) {
throw new RuntimeException(e);
} catch (Throwable ignore) {
}
try {
for (; ; ) {
apply(trailIter.next());
apply(trailIter.next());
}
} catch (FaweException e) {
throw new RuntimeException(e);
} catch (Throwable ignore) {
} }
} else { } else {
for (BlockVector3 pt : region) { for (BlockVector3 pt : region) {
@ -188,7 +164,6 @@ public class RegionVisitor implements Operation {
} }
} }
//FAWE end //FAWE end
return null; return null;
} }