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

project: Rev 182

Browse Source
This commit is contained in:
Owain van Brakel
2019-08-29 16:04:20 +02:00
parent 0c1dd644d8
commit 6485eb9bed
349 changed files with 51857 additions and 50740 deletions
Download Patch File Download Diff File Expand all files Collapse all files

359
runescape-client/src/main/java/NetSocket.java
View File

@@ -12,63 +12,63 @@ import net.runelite.mapping.ObfuscatedSignature;
@ObfuscatedName("fp")
@Implements("NetSocket")
public final class NetSocket extends AbstractSocket implements Runnable {
@ObfuscatedName("q")
@ObfuscatedName("s")
@Export("inputStream")
InputStream inputStream;
@ObfuscatedName("w")
@ObfuscatedName("j")
@Export("outputStream")
OutputStream outputStream;
@ObfuscatedName("e")
@ObfuscatedName("i")
@Export("socket")
Socket socket;
@ObfuscatedName("p")
@ObfuscatedName("k")
@Export("isClosed")
boolean isClosed;
@ObfuscatedName("k")
@ObfuscatedName("u")
@ObfuscatedSignature(
signature = "Lfs;"
signature = "Lfu;"
)
@Export("taskHandler")
TaskHandler taskHandler;
@ObfuscatedName("l")
@ObfuscatedName("n")
@ObfuscatedSignature(
signature = "Lfa;"
signature = "Lft;"
)
@Export("task")
Task task;
@ObfuscatedName("b")
@ObfuscatedName("t")
@Export("outBuffer")
byte[] outBuffer;
@ObfuscatedName("i")
@ObfuscatedName("q")
@ObfuscatedGetter(
intValue = 2008977937
intValue = -2034750073
)
@Export("outLength")
int outLength;
@ObfuscatedName("c")
@ObfuscatedName("x")
@ObfuscatedGetter(
intValue = 1864141069
intValue = 944271121
)
@Export("outOffset")
int outOffset;
@ObfuscatedName("f")
@ObfuscatedName("d")
@Export("exceptionWriting")
boolean exceptionWriting;
@ObfuscatedName("m")
@ObfuscatedName("f")
@ObfuscatedGetter(
intValue = 772976519
intValue = -1855971629
)
@Export("bufferLength")
final int bufferLength;
@ObfuscatedName("u")
@ObfuscatedName("c")
@ObfuscatedGetter(
intValue = -1242990043
intValue = 234092539
)
@Export("maxPacketLength")
final int maxPacketLength;
@ObfuscatedSignature(
signature = "(Ljava/net/Socket;Lfs;I)V"
signature = "(Ljava/net/Socket;Lfu;I)V"
)
public NetSocket(Socket var1, TaskHandler var2, int var3) throws IOException {
this.isClosed = false;
@@ -87,10 +87,10 @@ public final class NetSocket extends AbstractSocket implements Runnable {
this.outputStream = this.socket.getOutputStream();
}
@ObfuscatedName("q")
@ObfuscatedName("s")
@ObfuscatedSignature(
signature = "(I)V",
garbageValue = "-1144636612"
garbageValue = "-1798752769"
)
@Export("close")
public void close() {
@@ -102,7 +102,7 @@ public final class NetSocket extends AbstractSocket implements Runnable {
if (this.task != null) {
while (this.task.status == 0) {
EnumDefinition.sleepMillis(1L);
UserList.sleepMillis(1L);
}
if (this.task.status == 1) {
@@ -117,67 +117,69 @@ public final class NetSocket extends AbstractSocket implements Runnable {
}
}
@ObfuscatedName("w")
@ObfuscatedName("j")
@ObfuscatedSignature(
signature = "(B)I",
garbageValue = "2"
signature = "(I)I",
garbageValue = "547465689"
)
@Export("readUnsignedByte")
public int readUnsignedByte() throws IOException {
return this.isClosed ? 0 : this.inputStream.read();
}
@ObfuscatedName("e")
@ObfuscatedName("i")
@ObfuscatedSignature(
signature = "(B)I",
garbageValue = "55"
garbageValue = "83"
)
@Export("available")
public int available() throws IOException {
return this.isClosed ? 0 : this.inputStream.available();
}
@ObfuscatedName("p")
@ObfuscatedName("k")
@ObfuscatedSignature(
signature = "(II)Z",
garbageValue = "1948150862"
garbageValue = "156087109"
)
@Export("isAvailable")
public boolean isAvailable(int var1) throws IOException {
if (this.isClosed) {
return false;
} else {
return this.inputStream.available() >= var1;
}
return this.inputStream.available() >= var1;
}
@ObfuscatedName("k")
@ObfuscatedName("u")
@ObfuscatedSignature(
signature = "([BIIB)I",
garbageValue = "26"
garbageValue = "100"
)
@Export("read")
public int read(byte[] var1, int var2, int var3) throws IOException {
if (this.isClosed) {
return 0;
}
int var4;
int var5;
for (var4 = var3; var3 > 0; var3 -= var5) {
var5 = this.inputStream.read(var1, var2, var3);
if (var5 <= 0) {
throw new EOFException();
} else {
int var4;
int var5;
for (var4 = var3; var3 > 0; var3 -= var5) {
var5 = this.inputStream.read(var1, var2, var3);
if (var5 <= 0) {
throw new EOFException();
}
var2 += var5;
}
var2 += var5;
return var4;
}
return var4;
}
@ObfuscatedName("l")
@ObfuscatedName("n")
@ObfuscatedSignature(
signature = "([BIII)V",
garbageValue = "-338727961"
garbageValue = "-1945962644"
)
@Export("write0")
void write0(byte[] var1, int var2, int var3) throws IOException {
@@ -185,33 +187,34 @@ public final class NetSocket extends AbstractSocket implements Runnable {
if (this.exceptionWriting) {
this.exceptionWriting = false;
throw new IOException();
}
if (this.outBuffer == null) {
this.outBuffer = new byte[this.bufferLength];
}
} else {
if (this.outBuffer == null) {
this.outBuffer = new byte[this.bufferLength];
}
synchronized(this) {
for (int var5 = 0; var5 < var3; ++var5) {
this.outBuffer[this.outOffset] = var1[var5 + var2];
this.outOffset = (this.outOffset + 1) % this.bufferLength;
if ((this.outLength + this.maxPacketLength) % this.bufferLength == this.outOffset) {
throw new IOException();
synchronized(this) {
for (int var5 = 0; var5 < var3; ++var5) {
this.outBuffer[this.outOffset] = var1[var5 + var2];
this.outOffset = (this.outOffset + 1) % this.bufferLength;
if ((this.outLength + this.maxPacketLength) % this.bufferLength == this.outOffset) {
throw new IOException();
}
}
}
if (this.task == null) {
this.task = this.taskHandler.newThreadTask(this, 3);
}
if (this.task == null) {
this.task = this.taskHandler.newThreadTask(this, 3);
}
this.notifyAll();
this.notifyAll();
}
}
}
}
@ObfuscatedName("b")
@ObfuscatedName("t")
@ObfuscatedSignature(
signature = "([BIII)V",
garbageValue = "-1696227994"
garbageValue = "638463675"
)
@Export("write")
public void write(byte[] var1, int var2, int var3) throws IOException {
@@ -222,152 +225,148 @@ public final class NetSocket extends AbstractSocket implements Runnable {
this.close();
}
protected void abt() {
this.close();
}
public void run() {
try {
while (true) {
int var1;
int var2;
synchronized(this) {
if (this.outOffset == this.outLength) {
if (this.isClosed) {
break;
label84: {
int var1;
int var2;
synchronized(this) {
if (this.outOffset == this.outLength) {
if (this.isClosed) {
break label84;
}
try {
this.wait();
} catch (InterruptedException var10) {
}
}
try {
this.wait();
} catch (InterruptedException var10) {
var2 = this.outLength;
if (this.outOffset >= this.outLength) {
var1 = this.outOffset - this.outLength;
} else {
var1 = this.bufferLength - this.outLength;
}
}
var2 = this.outLength;
if (this.outOffset >= this.outLength) {
var1 = this.outOffset - this.outLength;
} else {
var1 = this.bufferLength - this.outLength;
if (var1 <= 0) {
continue;
}
}
if (var1 <= 0) {
try {
this.outputStream.write(this.outBuffer, var2, var1);
} catch (IOException var9) {
this.exceptionWriting = true;
}
this.outLength = (var1 + this.outLength) % this.bufferLength;
try {
if (this.outLength == this.outOffset) {
this.outputStream.flush();
}
} catch (IOException var8) {
this.exceptionWriting = true;
}
continue;
}
try {
this.outputStream.write(this.outBuffer, var2, var1);
} catch (IOException var9) {
this.exceptionWriting = true;
}
this.outLength = (var1 + this.outLength) % this.bufferLength;
try {
if (this.outOffset == this.outLength) {
this.outputStream.flush();
if (this.inputStream != null) {
this.inputStream.close();
}
} catch (IOException var8) {
this.exceptionWriting = true;
if (this.outputStream != null) {
this.outputStream.close();
}
if (this.socket != null) {
this.socket.close();
}
} catch (IOException var7) {
}
this.outBuffer = null;
break;
}
} catch (Exception var12) {
HitSplatDefinition.RunException_sendStackTrace((String)null, var12);
}
try {
if (this.inputStream != null) {
this.inputStream.close();
}
if (this.outputStream != null) {
this.outputStream.close();
}
if (this.socket != null) {
this.socket.close();
}
} catch (IOException var7) {
class3.RunException_sendStackTrace((String)null, var12);
}
this.outBuffer = null;
}
@ObfuscatedName("w")
protected void abi() {
this.close();
}
@ObfuscatedName("ii")
@ObfuscatedSignature(
signature = "(II)Lkl;",
garbageValue = "939071894"
signature = "(Lhp;IIZB)V",
garbageValue = "-62"
)
@Export("ChatMode_find")
public static PrivateChatMode ChatMode_find(int var0) {
PrivateChatMode[] var1 = UserComparator9.ChatMode_values();
@Export("alignWidgetSize")
static void alignWidgetSize(Widget var0, int var1, int var2, boolean var3) {
int var4 = var0.width;
int var5 = var0.height;
if (var0.widthAlignment == 0) {
var0.width = var0.rawWidth;
} else if (var0.widthAlignment == 1) {
var0.width = var1 - var0.rawWidth;
} else if (var0.widthAlignment == 2) {
var0.width = var0.rawWidth * var1 >> 14;
}
if (var0.heightAlignment == 0) {
var0.height = var0.rawHeight;
} else if (var0.heightAlignment == 1) {
var0.height = var2 - var0.rawHeight;
} else if (var0.heightAlignment == 2) {
var0.height = var2 * var0.rawHeight >> 14;
}
if (var0.widthAlignment == 4) {
var0.width = var0.field2538 * var0.height / var0.field2612;
}
if (var0.heightAlignment == 4) {
var0.height = var0.width * var0.field2612 / var0.field2538;
}
if (var0.contentType == 1337) {
Client.viewportWidget = var0;
}
if (var3 && var0.onResize != null && (var4 != var0.width || var5 != var0.height)) {
ScriptEvent var6 = new ScriptEvent();
var6.widget = var0;
var6.args = var0.onResize;
Client.scriptEvents.addFirst(var6);
}
}
@ObfuscatedName("ln")
@ObfuscatedSignature(
signature = "(Ljava/lang/String;I)Ljava/lang/String;",
garbageValue = "549032388"
)
static String method3489(String var0) {
PlayerType[] var1 = class191.PlayerType_values();
for (int var2 = 0; var2 < var1.length; ++var2) {
PrivateChatMode var3 = var1[var2];
if (var0 == var3.field3815) {
return var3;
PlayerType var3 = var1[var2];
if (var3.modIcon * 714577229 != -1 && var0.startsWith(AbstractWorldMapData.method278(var3.modIcon * 714577229))) {
var0 = var0.substring(6 + Integer.toString(var3.modIcon * 714577229).length());
break;
}
}
return null;
}
@ObfuscatedName("w")
@ObfuscatedSignature(
signature = "(III)V",
garbageValue = "691418621"
)
public static void method3554(int var0, int var1) {
VarbitDefinition var3 = (VarbitDefinition)VarbitDefinition.VarbitDefinition_cached.get((long)var0);
VarbitDefinition var2;
if (var3 != null) {
var2 = var3;
} else {
byte[] var8 = VarbitDefinition.VarbitDefinition_archive.takeFile(14, var0);
var3 = new VarbitDefinition();
if (var8 != null) {
var3.decode(new Buffer(var8));
}
VarbitDefinition.VarbitDefinition_cached.put(var3, (long)var0);
var2 = var3;
}
int var4 = var2.baseVar;
int var5 = var2.startBit;
int var6 = var2.endBit;
int var7 = Varps.Varps_masks[var6 - var5];
if (var1 < 0 || var1 > var7) {
var1 = 0;
}
var7 <<= var5;
Varps.Varps_main[var4] = Varps.Varps_main[var4] & ~var7 | var1 << var5 & var7;
}
@ObfuscatedName("w")
@ObfuscatedSignature(
signature = "(II)Lig;",
garbageValue = "-1252480817"
)
@Export("getInvDefinition")
public static InvDefinition getInvDefinition(int var0) {
InvDefinition var1 = (InvDefinition)InvDefinition.InvDefinition_cached.get((long)var0);
if (var1 != null) {
return var1;
}
byte[] var2 = InvDefinition.InvDefinition_archive.takeFile(5, var0);
var1 = new InvDefinition();
if (var2 != null) {
var1.decode(new Buffer(var2));
}
InvDefinition.InvDefinition_cached.put(var1, (long)var0);
return var1;
}
@ObfuscatedName("p")
@ObfuscatedSignature(
signature = "(I)V",
garbageValue = "2054009362"
)
public static void method3553() {
Interpreter.midiPcmStream.clear();
class197.field2402 = 1;
GrandExchangeOfferNameComparator.musicTrackArchive = null;
return var0;
}
}