Init commit. b1.7.3 vanilla server
This commit is contained in:
commit
ee3d133a31
451 changed files with 50531 additions and 0 deletions
54
src/net/minecraft/network/NetworkReaderThread.java
Normal file
54
src/net/minecraft/network/NetworkReaderThread.java
Normal file
|
|
@ -0,0 +1,54 @@
|
|||
package net.minecraft.network;
|
||||
|
||||
class NetworkReaderThread extends Thread {
|
||||
final NetworkManager netManager;
|
||||
|
||||
NetworkReaderThread(NetworkManager var1, String var2) {
|
||||
super(var2);
|
||||
this.netManager = var1;
|
||||
}
|
||||
|
||||
public void run() {
|
||||
Object var1 = NetworkManager.threadSyncObject;
|
||||
synchronized(var1) {
|
||||
++NetworkManager.numReadThreads;
|
||||
}
|
||||
|
||||
while(true) {
|
||||
boolean var12 = false;
|
||||
|
||||
try {
|
||||
var12 = true;
|
||||
if(!NetworkManager.isRunning(this.netManager)) {
|
||||
var12 = false;
|
||||
break;
|
||||
}
|
||||
|
||||
if(NetworkManager.isServerTerminating(this.netManager)) {
|
||||
var12 = false;
|
||||
break;
|
||||
}
|
||||
|
||||
while(NetworkManager.readNetworkPacket(this.netManager)) {
|
||||
}
|
||||
|
||||
try {
|
||||
sleep(100L);
|
||||
} catch (InterruptedException var15) {
|
||||
}
|
||||
} finally {
|
||||
if(var12) {
|
||||
Object var5 = NetworkManager.threadSyncObject;
|
||||
synchronized(var5) {
|
||||
--NetworkManager.numReadThreads;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
var1 = NetworkManager.threadSyncObject;
|
||||
synchronized(var1) {
|
||||
--NetworkManager.numReadThreads;
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue