ra/runelite
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
zeruth
2019-06-16 22:31:48 -04:00
parent 2e873af898
commit 39a9ae35ab
218 changed files with 16857 additions and 16879 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
runescape-client/src/main/java/IndexStoreActionHandler.java
View File

@@ -29,41 +29,40 @@ public class IndexStoreActionHandler implements Runnable {
@Export("IndexStoreActionHandler_lock")
static Object IndexStoreActionHandler_lock;
static {
IndexStoreActionHandler_requestQueue = new NodeDeque();
IndexStoreActionHandler_responseQueue = new NodeDeque();
__iv_q = 0;
IndexStoreActionHandler_lock = new Object();
}
@Export("run")
@ObfuscatedName("run")
public void run() {
try {
while(true) {
NodeDeque var2 = IndexStoreActionHandler_requestQueue;
IndexStoreAction var1;
NodeDeque var1 = IndexStoreActionHandler_requestQueue;
NodeDeque var3 = IndexStoreActionHandler_requestQueue;
IndexStoreAction var2;
synchronized(IndexStoreActionHandler_requestQueue) {
var1 = (IndexStoreAction)IndexStoreActionHandler_requestQueue.last();
var2 = (IndexStoreAction)IndexStoreActionHandler_requestQueue.last();
}
Object var14;
if(var1 != null) {
if(var1.type == 0) {
var1.indexStore.write((int)var1.key, var1.data, var1.data.length);
var2 = IndexStoreActionHandler_requestQueue;
Object var4;
Object var15;
if(var2 != null) {
NodeDeque var16;
if(var2.type == 0) {
var2.indexStore.write((int)var2.key, var2.data, var2.data.length);
var1 = IndexStoreActionHandler_requestQueue;
var16 = IndexStoreActionHandler_requestQueue;
synchronized(IndexStoreActionHandler_requestQueue) {
var1.remove();
var2.remove();
}
} else if(var1.type == 1) {
var1.data = var1.indexStore.read((int)var1.key);
var2 = IndexStoreActionHandler_requestQueue;
} else if(var2.type == 1) {
var2.data = var2.indexStore.read((int)var2.key);
var1 = IndexStoreActionHandler_requestQueue;
var16 = IndexStoreActionHandler_requestQueue;
synchronized(IndexStoreActionHandler_requestQueue) {
IndexStoreActionHandler_responseQueue.addFirst(var1);
IndexStoreActionHandler_responseQueue.addFirst(var2);
}
}
var14 = IndexStoreActionHandler_lock;
var15 = IndexStoreActionHandler_lock;
var4 = IndexStoreActionHandler_lock;
synchronized(IndexStoreActionHandler_lock) {
if(__iv_q <= 1) {
__iv_q = 0;
@@ -75,7 +74,8 @@ public class IndexStoreActionHandler implements Runnable {
}
} else {
class203.method4010(100L);
var14 = IndexStoreActionHandler_lock;
var15 = IndexStoreActionHandler_lock;
var4 = IndexStoreActionHandler_lock;
synchronized(IndexStoreActionHandler_lock) {
if(__iv_q <= 1) {
__iv_q = 0;
@@ -87,8 +87,8 @@ public class IndexStoreActionHandler implements Runnable {
}
}
}
} catch (Exception var13) {
NpcDefinition.sendStackTrace((String)null, var13);
} catch (Exception var14) {
NPCDefinition.sendStackTrace((String)null, var14);
}
}
@@ -104,5 +104,13 @@ public class IndexStoreActionHandler implements Runnable {
var1.packetBuffer.writeStringCp1252NullTerminated(var0);
Client.packetWriter.__q_167(var1);
}
}
static {
IndexStoreActionHandler_requestQueue = new NodeDeque();
IndexStoreActionHandler_responseQueue = new NodeDeque();
__iv_q = 0;
IndexStoreActionHandler_lock = new Object();
}
}