108 lines
3.6 KiB
Java
108 lines
3.6 KiB
Java
import net.runelite.mapping.Export;
|
|
import net.runelite.mapping.Implements;
|
|
import net.runelite.mapping.ObfuscatedGetter;
|
|
import net.runelite.mapping.ObfuscatedName;
|
|
import net.runelite.mapping.ObfuscatedSignature;
|
|
|
|
@ObfuscatedName("iv")
|
|
@Implements("IndexStoreActionHandler")
|
|
public class IndexStoreActionHandler implements Runnable {
|
|
@ObfuscatedName("m")
|
|
@ObfuscatedSignature(
|
|
signature = "Lje;"
|
|
)
|
|
@Export("IndexStoreActionHandler_requestQueue")
|
|
static NodeDeque IndexStoreActionHandler_requestQueue;
|
|
@ObfuscatedName("f")
|
|
@ObfuscatedSignature(
|
|
signature = "Lje;"
|
|
)
|
|
@Export("IndexStoreActionHandler_responseQueue")
|
|
static NodeDeque IndexStoreActionHandler_responseQueue;
|
|
@ObfuscatedName("q")
|
|
@ObfuscatedGetter(
|
|
intValue = -1282224505
|
|
)
|
|
static int __iv_q;
|
|
@ObfuscatedName("w")
|
|
@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;
|
|
synchronized(IndexStoreActionHandler_requestQueue) {
|
|
var1 = (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;
|
|
synchronized(IndexStoreActionHandler_requestQueue) {
|
|
var1.remove();
|
|
}
|
|
} else if(var1.type == 1) {
|
|
var1.data = var1.indexStore.read((int)var1.key);
|
|
var2 = IndexStoreActionHandler_requestQueue;
|
|
synchronized(IndexStoreActionHandler_requestQueue) {
|
|
IndexStoreActionHandler_responseQueue.addFirst(var1);
|
|
}
|
|
}
|
|
|
|
var14 = IndexStoreActionHandler_lock;
|
|
synchronized(IndexStoreActionHandler_lock) {
|
|
if(__iv_q <= 1) {
|
|
__iv_q = 0;
|
|
IndexStoreActionHandler_lock.notifyAll();
|
|
return;
|
|
}
|
|
|
|
__iv_q = 600;
|
|
}
|
|
} else {
|
|
class203.method4010(100L);
|
|
var14 = IndexStoreActionHandler_lock;
|
|
synchronized(IndexStoreActionHandler_lock) {
|
|
if(__iv_q <= 1) {
|
|
__iv_q = 0;
|
|
IndexStoreActionHandler_lock.notifyAll();
|
|
return;
|
|
}
|
|
|
|
--__iv_q;
|
|
}
|
|
}
|
|
}
|
|
} catch (Exception var13) {
|
|
NpcDefinition.sendStackTrace((String)null, var13);
|
|
}
|
|
}
|
|
|
|
@ObfuscatedName("ky")
|
|
@ObfuscatedSignature(
|
|
signature = "(Ljava/lang/String;B)V",
|
|
garbageValue = "67"
|
|
)
|
|
static final void method4655(String var0) {
|
|
if(PacketWriter.clanChat != null) {
|
|
PacketBufferNode var1 = Interpreter.method1915(ClientPacket.__gs_i, Client.packetWriter.isaacCipher);
|
|
var1.packetBuffer.writeByte(WorldMapRegion.method550(var0));
|
|
var1.packetBuffer.writeStringCp1252NullTerminated(var0);
|
|
Client.packetWriter.__q_167(var1);
|
|
}
|
|
}
|
|
}
|