From 8090bf9f1d91c31265093529726fef506ff7420a Mon Sep 17 00:00:00 2001
From: Jesse Boyd <jessepaleg@gmail.com>
Date: Tue, 27 Sep 2016 02:58:16 +1000
Subject: [PATCH] Various

Increase chunk-wait
Sync packet sending
Allow up outside region
---
 .../java/com/boydti/fawe/config/Settings.java |  2 +-
 .../fawe/example/NMSMappedFaweQueue.java      | 17 +++++++++++++---
 .../com/boydti/fawe/jnbt/anvil/MCAQueue.java  |  2 +-
 .../com/boydti/fawe/util/TaskManager.java     |  8 ++++++++
 .../boydti/fawe/wrappers/PlayerWrapper.java   | 20 +++++++++++++------
 5 files changed, 38 insertions(+), 11 deletions(-)

diff --git a/core/src/main/java/com/boydti/fawe/config/Settings.java b/core/src/main/java/com/boydti/fawe/config/Settings.java
index 58826768..4dd29ab8 100644
--- a/core/src/main/java/com/boydti/fawe/config/Settings.java
+++ b/core/src/main/java/com/boydti/fawe/config/Settings.java
@@ -142,7 +142,7 @@ public class Settings extends Config {
                 " or increase chunk-wait-ms.",
                 "A value of 0 is faster simply because it doesn't bother loading the chunks or waiting.",
         })
-        public static int CHUNK_WAIT_MS = 100;
+        public static int CHUNK_WAIT_MS = 1000;
         @Comment("Delete history on disk after a number of days")
         public static int DELETE_AFTER_DAYS = 7;
         @Comment("Delete history in memory on logout (does not effect disk) (BROKEN, USE DISK INSTEAD)")
diff --git a/core/src/main/java/com/boydti/fawe/example/NMSMappedFaweQueue.java b/core/src/main/java/com/boydti/fawe/example/NMSMappedFaweQueue.java
index b860519e..9be3ee08 100644
--- a/core/src/main/java/com/boydti/fawe/example/NMSMappedFaweQueue.java
+++ b/core/src/main/java/com/boydti/fawe/example/NMSMappedFaweQueue.java
@@ -1,9 +1,11 @@
 package com.boydti.fawe.example;
 
+import com.boydti.fawe.Fawe;
 import com.boydti.fawe.FaweCache;
 import com.boydti.fawe.config.Settings;
 import com.boydti.fawe.object.FaweChunk;
 import com.boydti.fawe.object.exception.FaweException;
+import com.boydti.fawe.util.SetQueue;
 import com.boydti.fawe.util.TaskManager;
 import com.sk89q.jnbt.CompoundTag;
 import com.sk89q.worldedit.world.World;
@@ -56,7 +58,7 @@ public abstract class NMSMappedFaweQueue<WORLD, CHUNK, CHUNKSECTION, SECTION> ex
     public void end(FaweChunk chunk) {
         super.end(chunk);
         if (Settings.LIGHTING.MODE == 0) {
-            refreshChunk(chunk);
+            sendChunk(chunk);
             return;
         }
         if (relighter == null) {
@@ -79,13 +81,22 @@ public abstract class NMSMappedFaweQueue<WORLD, CHUNK, CHUNKSECTION, SECTION> ex
         if (relight) {
             relighter.addChunk(chunk.getX(), chunk.getZ(), fix, chunk.getBitMask());
         } else {
-            refreshChunk(chunk);
+            sendChunk(chunk);
         }
     }
 
     @Override
     public void sendChunk(final FaweChunk fc) {
-        refreshChunk(fc);
+        if (Fawe.get().isMainThread()) {
+            refreshChunk(fc);
+        } else {
+            SetQueue.IMP.addTask(new Runnable() {
+                @Override
+                public void run() {
+                    refreshChunk(fc);
+                }
+            });
+        }
     }
 
     public abstract void setFullbright(CHUNKSECTION sections);
diff --git a/core/src/main/java/com/boydti/fawe/jnbt/anvil/MCAQueue.java b/core/src/main/java/com/boydti/fawe/jnbt/anvil/MCAQueue.java
index 41f5c958..05b3ec1f 100644
--- a/core/src/main/java/com/boydti/fawe/jnbt/anvil/MCAQueue.java
+++ b/core/src/main/java/com/boydti/fawe/jnbt/anvil/MCAQueue.java
@@ -210,7 +210,7 @@ public class MCAQueue extends NMSMappedFaweQueue<FaweQueue, FaweChunk, FaweChunk
     @Override
     public void refreshChunk(FaweChunk fs) {
         if (fs.getClass() != MCAChunk.class) {
-            parentNMS.refreshChunk(fs);
+            parentNMS.sendChunk(fs);
         }
     }
 
diff --git a/core/src/main/java/com/boydti/fawe/util/TaskManager.java b/core/src/main/java/com/boydti/fawe/util/TaskManager.java
index 0df85240..8a78ab80 100644
--- a/core/src/main/java/com/boydti/fawe/util/TaskManager.java
+++ b/core/src/main/java/com/boydti/fawe/util/TaskManager.java
@@ -295,6 +295,14 @@ public abstract class TaskManager {
         return syncWhenFree(function, Integer.MAX_VALUE);
     }
 
+    public void taskWhenFree(Runnable run) {
+        if (Fawe.get().isMainThread()) {
+            run.run();
+        } else {
+            SetQueue.IMP.addTask(run);
+        }
+    }
+
     /**
      * Run a task on the main thread when the TPS is high enough, and wait for execution to finish:<br>
      *     - Useful if you need to access something from the Bukkit API from another thread<br>
diff --git a/core/src/main/java/com/boydti/fawe/wrappers/PlayerWrapper.java b/core/src/main/java/com/boydti/fawe/wrappers/PlayerWrapper.java
index 3911721e..116f9e9f 100644
--- a/core/src/main/java/com/boydti/fawe/wrappers/PlayerWrapper.java
+++ b/core/src/main/java/com/boydti/fawe/wrappers/PlayerWrapper.java
@@ -199,19 +199,27 @@ public class PlayerWrapper implements Player {
     @Override
     public void floatAt(final int x, final int y, final int z, final boolean alwaysGlass) {
         EditSessionFactory factory = WorldEdit.getInstance().getEditSessionFactory();
-        final EditSession edit = factory.getEditSession(parent.getWorld(), -1, null, this);
-        edit.setBlockFast(new Vector(x, y - 1, z), new BaseBlock( BlockType.GLASS.getID()));
-        LocalSession session = Fawe.get().getWorldEdit().getSession(this);
-        if (session != null) {
-            session.remember(edit, true, false, FawePlayer.wrap(this).getLimit().MAX_HISTORY);
+        RuntimeException caught = null;
+        try {
+            final EditSession edit = factory.getEditSession(parent.getWorld(), -1, null, this);
+            edit.setBlockFast(new Vector(x, y - 1, z), new BaseBlock(BlockType.GLASS.getID()));
+            edit.flushQueue();
+            LocalSession session = Fawe.get().getWorldEdit().getSession(this);
+            if (session != null) {
+                session.remember(edit, true, false, FawePlayer.wrap(this).getLimit().MAX_HISTORY);
+            }
+        } catch (RuntimeException e) {
+            caught = e;
         }
         TaskManager.IMP.sync(new RunnableVal<Object>() {
             @Override
             public void run(Object value) {
-                edit.getQueue().flush();
                 setPosition(new Vector(x + 0.5, y, z + 0.5));
             }
         });
+        if (caught != null) {
+            throw caught;
+        }
     }
 
     @Override