summaryrefslogtreecommitdiffstats
path: root/src/main/java/net/minecraft/server/NetworkWriterThread.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/net/minecraft/server/NetworkWriterThread.java')
-rw-r--r--src/main/java/net/minecraft/server/NetworkWriterThread.java37
1 files changed, 8 insertions, 29 deletions
diff --git a/src/main/java/net/minecraft/server/NetworkWriterThread.java b/src/main/java/net/minecraft/server/NetworkWriterThread.java
index 140fcd2d..68d84deb 100644
--- a/src/main/java/net/minecraft/server/NetworkWriterThread.java
+++ b/src/main/java/net/minecraft/server/NetworkWriterThread.java
@@ -12,28 +12,18 @@ class NetworkWriterThread extends Thread {
}
public void run() {
- Object object = NetworkManager.a;
+ NetworkManager.b.getAndIncrement();
- synchronized (NetworkManager.a) {
- ++NetworkManager.c;
- }
-
- while (true) {
- boolean flag = false;
+ try {
+ while (NetworkManager.a(this.a)) {
+ boolean flag;
- try {
- flag = true;
- if (!NetworkManager.a(this.a)) {
- flag = false;
- break;
- }
-
- while (NetworkManager.d(this.a)) {
+ for (flag = false; NetworkManager.d(this.a); flag = true) {
;
}
try {
- if (NetworkManager.e(this.a) != null) {
+ if (flag && NetworkManager.e(this.a) != null) {
NetworkManager.e(this.a).flush();
}
} catch (IOException ioexception) {
@@ -49,20 +39,9 @@ class NetworkWriterThread extends Thread {
} catch (InterruptedException interruptedexception) {
;
}
- } finally {
- if (flag) {
- Object object1 = NetworkManager.a;
-
- synchronized (NetworkManager.a) {
- --NetworkManager.c;
- }
- }
}
- }
-
- object = NetworkManager.a;
- synchronized (NetworkManager.a) {
- --NetworkManager.c;
+ } finally {
+ NetworkManager.b.getAndDecrement();
}
}
}