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

rs-client/apis

Browse Source
This commit is contained in:
Lucwousin
2019-07-18 15:21:46 +02:00
parent aa5098aff5
commit 25ce6c2ee9
346 changed files with 78952 additions and 84408 deletions
Download Patch File Download Diff File Expand all files Collapse all files

213
runescape-client/src/main/java/ArchiveDiskActionHandler.java
View File

@@ -1,107 +1,140 @@
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
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")
@ObfuscatedName("ir")
@Implements("ArchiveDiskActionHandler")
public class ArchiveDiskActionHandler implements Runnable {
@ObfuscatedName("m")
@ObfuscatedSignature(
signature = "Lje;"
)
@Export("ArchiveDiskActionHandler_requestQueue")
static NodeDeque ArchiveDiskActionHandler_requestQueue;
@ObfuscatedName("f")
@ObfuscatedSignature(
signature = "Lje;"
)
@Export("ArchiveDiskActionHandler_responseQueue")
static NodeDeque ArchiveDiskActionHandler_responseQueue;
@ObfuscatedName("q")
@ObfuscatedGetter(
intValue = -1282224505
)
static int field412;
@ObfuscatedName("w")
@Export("ArchiveDiskActionHandler_lock")
static Object ArchiveDiskActionHandler_lock;
@ObfuscatedName("q")
@ObfuscatedSignature(
signature = "Ljh;"
)
@Export("ArchiveDiskActionHandler_requestQueue")
public static NodeDeque ArchiveDiskActionHandler_requestQueue;
@ObfuscatedName("w")
@ObfuscatedSignature(
signature = "Ljh;"
)
@Export("ArchiveDiskActionHandler_responseQueue")
public static NodeDeque ArchiveDiskActionHandler_responseQueue;
@ObfuscatedName("e")
@ObfuscatedGetter(
intValue = -1331634311
)
static int field3144;
@ObfuscatedName("p")
@Export("ArchiveDiskActionHandler_lock")
static Object ArchiveDiskActionHandler_lock;
@ObfuscatedName("k")
@Export("ArchiveDiskActionHandler_thread")
static Thread ArchiveDiskActionHandler_thread;
public void run() {
try {
while (true) {
NodeDeque var1 = ArchiveDiskActionHandler_requestQueue;
ArchiveDiskAction var2;
synchronized(ArchiveDiskActionHandler_requestQueue) {
var2 = (ArchiveDiskAction)ArchiveDiskActionHandler_requestQueue.last();
}
static {
ArchiveDiskActionHandler_requestQueue = new NodeDeque();
ArchiveDiskActionHandler_responseQueue = new NodeDeque();
field3144 = 0;
ArchiveDiskActionHandler_lock = new Object();
}
Object var3;
if (var2 != null) {
if (var2.type == 0) {
var2.archiveDisk.write((int)var2.key, var2.data, var2.data.length);
var1 = ArchiveDiskActionHandler_requestQueue;
synchronized(ArchiveDiskActionHandler_requestQueue) {
var2.remove();
}
} else if (var2.type == 1) {
var2.data = var2.archiveDisk.read((int)var2.key);
var1 = ArchiveDiskActionHandler_requestQueue;
synchronized(ArchiveDiskActionHandler_requestQueue) {
ArchiveDiskActionHandler_responseQueue.addFirst(var2);
}
}
ArchiveDiskActionHandler() {
}
var3 = ArchiveDiskActionHandler_lock;
synchronized(ArchiveDiskActionHandler_lock) {
if (field412 <= 1) {
field412 = 0;
ArchiveDiskActionHandler_lock.notifyAll();
return;
}
public void run() {
try {
while (true) {
ArchiveDiskAction var1;
synchronized(ArchiveDiskActionHandler_requestQueue) {
var1 = (ArchiveDiskAction)ArchiveDiskActionHandler_requestQueue.last();
}
field412 = 600;
}
} else {
class203.method4010(100L);
var3 = ArchiveDiskActionHandler_lock;
synchronized(ArchiveDiskActionHandler_lock) {
if (field412 <= 1) {
field412 = 0;
ArchiveDiskActionHandler_lock.notifyAll();
return;
}
if (var1 != null) {
if (var1.type == 0) {
var1.archiveDisk.write((int)var1.key, var1.data, var1.data.length);
synchronized(ArchiveDiskActionHandler_requestQueue) {
var1.remove();
}
} else if (var1.type == 1) {
var1.data = var1.archiveDisk.read((int)var1.key);
synchronized(ArchiveDiskActionHandler_requestQueue) {
ArchiveDiskActionHandler_responseQueue.addFirst(var1);
}
}
--field412;
}
}
}
} catch (Exception var14) {
NPCDefinition.sendStackTrace((String)null, var14);
}
}
synchronized(ArchiveDiskActionHandler_lock) {
if (field3144 <= 1) {
field3144 = 0;
ArchiveDiskActionHandler_lock.notifyAll();
return;
}
@ObfuscatedName("ky")
@ObfuscatedSignature(
signature = "(Ljava/lang/String;B)V",
garbageValue = "67"
)
@Export("clanKickUser")
static final void clanKickUser(String var0) {
if (PacketWriter.clanChat != null) {
PacketBufferNode var1 = Interpreter.method1915(ClientPacket.field235, Client.packetWriter.isaacCipher);
var1.packetBuffer.writeByte(WorldMapRegion.stringCp1252NullTerminatedByteSize(var0));
var1.packetBuffer.writeStringCp1252NullTerminated(var0);
Client.packetWriter.method241(var1);
}
field3144 = 600;
}
} else {
EnumDefinition.method4550(100L);
synchronized(ArchiveDiskActionHandler_lock) {
if (field3144 <= 1) {
field3144 = 0;
ArchiveDiskActionHandler_lock.notifyAll();
return;
}
}
--field3144;
}
}
}
} catch (Exception var13) {
HitSplatDefinition.sendStackTrace((String)null, var13);
}
}
static {
ArchiveDiskActionHandler_requestQueue = new NodeDeque();
ArchiveDiskActionHandler_responseQueue = new NodeDeque();
field412 = 0;
ArchiveDiskActionHandler_lock = new Object();
}
@ObfuscatedName("al")
@ObfuscatedSignature(
signature = "(Lfs;III)Ldn;",
garbageValue = "2015059645"
)
public static final PcmPlayer method4256(TaskHandler var0, int var1, int var2) {
if (CollisionMap.PcmPlayer_sampleRate == 0) {
throw new IllegalStateException();
} else if (var1 >= 0 && var1 < 2) {
if (var2 < 256) {
var2 = 256;
}
try {
PcmPlayer var3 = class32.pcmPlayerProvider.player();
var3.samples = new int[256 * (class169.isStereo ? 2 : 1)];
var3.field1414 = var2;
var3.init();
var3.capacity = (var2 & -1024) + 1024;
if (var3.capacity > 16384) {
var3.capacity = 16384;
}
var3.open(var3.capacity);
if (PcmPlayer.pcmPlayerCount > 0 && SecureRandomFuture.soundSystem == null) {
SecureRandomFuture.soundSystem = new SoundSystem();
class14.soundSystemExecutor = Executors.newScheduledThreadPool(1);
class14.soundSystemExecutor.scheduleAtFixedRate(SecureRandomFuture.soundSystem, 0L, 10L, TimeUnit.MILLISECONDS);
}
if (SecureRandomFuture.soundSystem != null) {
if (SecureRandomFuture.soundSystem.players[var1] != null) {
throw new IllegalArgumentException();
}
SecureRandomFuture.soundSystem.players[var1] = var3;
}
return var3;
} catch (Throwable var4) {
return new PcmPlayer();
}
} else {
throw new IllegalArgumentException();
}
}
}