From c07d4fffb00124588c8fadf477ff568dcd75d83d Mon Sep 17 00:00:00 2001
From: Charles Daffern <seejay.11@gmail.com>
Date: Sun, 13 May 2012 00:43:04 +0100
Subject: [PATCH] Adding NetworkWriterThread for diff visibility

---
 .../minecraft/server/NetworkWriterThread.java | 68 +++++++++++++++++++
 1 file changed, 68 insertions(+)
 create mode 100644 src/main/java/net/minecraft/server/NetworkWriterThread.java

diff --git a/src/main/java/net/minecraft/server/NetworkWriterThread.java b/src/main/java/net/minecraft/server/NetworkWriterThread.java
new file mode 100644
index 0000000000..19db566355
--- /dev/null
+++ b/src/main/java/net/minecraft/server/NetworkWriterThread.java
@@ -0,0 +1,68 @@
+package net.minecraft.server;
+
+import java.io.IOException;
+
+class NetworkWriterThread extends Thread {
+
+    final NetworkManager a;
+
+    NetworkWriterThread(NetworkManager networkmanager, String s) {
+        super(s);
+        this.a = networkmanager;
+    }
+
+    public void run() {
+        Object object = NetworkManager.a;
+
+        synchronized (NetworkManager.a) {
+            ++NetworkManager.c;
+        }
+
+        while (true) {
+            boolean flag = false;
+
+            try {
+                flag = true;
+                if (!NetworkManager.a(this.a)) {
+                    flag = false;
+                    break;
+                }
+
+                while (NetworkManager.d(this.a)) {
+                    ;
+                }
+
+                try {
+                    if (NetworkManager.e(this.a) != null) {
+                        NetworkManager.e(this.a).flush();
+                    }
+                } catch (IOException ioexception) {
+                    if (!NetworkManager.f(this.a)) {
+                        NetworkManager.a(this.a, (Exception) ioexception);
+                    }
+
+                    ioexception.printStackTrace();
+                }
+
+                try {
+                    sleep(2L);
+                } catch (InterruptedException interruptedexception) {
+                    ;
+                }
+            } finally {
+                if (flag) {
+                    Object object1 = NetworkManager.a;
+
+                    synchronized (NetworkManager.a) {
+                        --NetworkManager.c;
+                    }
+                }
+            }
+        }
+
+        object = NetworkManager.a;
+        synchronized (NetworkManager.a) {
+            --NetworkManager.c;
+        }
+    }
+}