mirror of
https://gitlab.com/2009scape/rt4-client.git
synced 2026-08-17 08:25:14 -06:00
Renamed JS5 fields/methods
This commit is contained in:
parent
7ffd30e31c
commit
bd10ece252
21 changed files with 539 additions and 542 deletions
|
|
@ -9,123 +9,119 @@ import org.openrs2.deob.annotation.Pc;
|
|||
public final class Js5CacheQueue implements Runnable {
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "q", descriptor = "Lclient!ce;")
|
||||
private final SecondaryLinkedList aClass16_6 = new SecondaryLinkedList();
|
||||
private final SecondaryLinkedList queue = new SecondaryLinkedList();
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "s", descriptor = "I")
|
||||
public int anInt3131 = 0;
|
||||
public int size = 0;
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "w", descriptor = "Z")
|
||||
private boolean aBoolean161 = false;
|
||||
private boolean stop = false;
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "v", descriptor = "Ljava/lang/Thread;")
|
||||
private Thread aThread2;
|
||||
private Thread thread;
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "<init>", descriptor = "()V")
|
||||
public Js5CacheQueue() {
|
||||
@Pc(20) PrivilegedRequest local20 = GameShell.signLink.startThread(5, this);
|
||||
while (local20.status == 0) {
|
||||
@Pc(20) PrivilegedRequest request = GameShell.signLink.startThread(5, this);
|
||||
while (request.status == 0) {
|
||||
ThreadUtils.sleep(10L);
|
||||
}
|
||||
if (local20.status == 2) {
|
||||
if (request.status == 2) {
|
||||
throw new RuntimeException();
|
||||
}
|
||||
this.aThread2 = (Thread) local20.result;
|
||||
this.thread = (Thread) request.result;
|
||||
}
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "a", descriptor = "(Lclient!c;I)V")
|
||||
private void method2461(@OriginalArg(0) Js5CacheRequest arg0) {
|
||||
@Pc(7) SecondaryLinkedList local7 = this.aClass16_6;
|
||||
synchronized (this.aClass16_6) {
|
||||
this.aClass16_6.addTail(arg0);
|
||||
this.anInt3131++;
|
||||
this.aClass16_6.notifyAll();
|
||||
private void enqueue(@OriginalArg(0) Js5CacheRequest arg0) {
|
||||
synchronized (this.queue) {
|
||||
this.queue.addTail(arg0);
|
||||
this.size++;
|
||||
this.queue.notifyAll();
|
||||
}
|
||||
}
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "a", descriptor = "(I)V")
|
||||
public final void quit() {
|
||||
this.aBoolean161 = true;
|
||||
@Pc(6) SecondaryLinkedList local6 = this.aClass16_6;
|
||||
synchronized (this.aClass16_6) {
|
||||
this.aClass16_6.notifyAll();
|
||||
this.stop = true;
|
||||
synchronized (this.queue) {
|
||||
this.queue.notifyAll();
|
||||
}
|
||||
try {
|
||||
this.aThread2.join();
|
||||
} catch (@Pc(23) InterruptedException local23) {
|
||||
this.thread.join();
|
||||
} catch (@Pc(23) InterruptedException ignored) {
|
||||
}
|
||||
this.aThread2 = null;
|
||||
this.thread = null;
|
||||
}
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "a", descriptor = "(Lclient!ge;I[BI)Lclient!c;")
|
||||
public final Js5CacheRequest method2467(@OriginalArg(0) Cache arg0, @OriginalArg(2) byte[] arg1, @OriginalArg(3) int arg2) {
|
||||
@Pc(7) Js5CacheRequest local7 = new Js5CacheRequest();
|
||||
local7.aByteArray11 = arg1;
|
||||
local7.aBoolean225 = false;
|
||||
local7.secondaryKey = arg2;
|
||||
local7.aClass49_3 = arg0;
|
||||
local7.anInt824 = 2;
|
||||
this.method2461(local7);
|
||||
return local7;
|
||||
public final Js5CacheRequest write(@OriginalArg(0) Cache arg0, @OriginalArg(2) byte[] arg1, @OriginalArg(3) int arg2) {
|
||||
@Pc(7) Js5CacheRequest request = new Js5CacheRequest();
|
||||
request.data = arg1;
|
||||
request.urgent = false;
|
||||
request.secondaryKey = arg2;
|
||||
request.cache = arg0;
|
||||
request.type = 2;
|
||||
this.enqueue(request);
|
||||
return request;
|
||||
}
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "a", descriptor = "(IILclient!ge;)Lclient!c;")
|
||||
public final Js5CacheRequest method2469(@OriginalArg(0) int arg0, @OriginalArg(2) Cache arg1) {
|
||||
public final Js5CacheRequest read(@OriginalArg(0) int arg0, @OriginalArg(2) Cache arg1) {
|
||||
@Pc(7) Js5CacheRequest local7 = new Js5CacheRequest();
|
||||
local7.aClass49_3 = arg1;
|
||||
local7.anInt824 = 3;
|
||||
local7.aBoolean225 = false;
|
||||
local7.cache = arg1;
|
||||
local7.type = 3;
|
||||
local7.urgent = false;
|
||||
local7.secondaryKey = arg0;
|
||||
this.method2461(local7);
|
||||
this.enqueue(local7);
|
||||
return local7;
|
||||
}
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "a", descriptor = "(Lclient!ge;BI)Lclient!c;")
|
||||
public final Js5CacheRequest method2471(@OriginalArg(0) Cache arg0, @OriginalArg(2) int arg1) {
|
||||
public final Js5CacheRequest readSynchronous(@OriginalArg(0) Cache arg0, @OriginalArg(2) int arg1) {
|
||||
@Pc(9) Js5CacheRequest local9 = new Js5CacheRequest();
|
||||
local9.anInt824 = 1;
|
||||
@Pc(16) SecondaryLinkedList local16 = this.aClass16_6;
|
||||
synchronized (this.aClass16_6) {
|
||||
@Pc(31) Js5CacheRequest local31 = (Js5CacheRequest) this.aClass16_6.method795();
|
||||
local9.type = 1;
|
||||
synchronized (this.queue) {
|
||||
@Pc(31) Js5CacheRequest local31 = (Js5CacheRequest) this.queue.head();
|
||||
while (true) {
|
||||
if (local31 == null) {
|
||||
break;
|
||||
}
|
||||
if (local31.secondaryKey == (long) arg1 && local31.aClass49_3 == arg0 && local31.anInt824 == 2) {
|
||||
local9.aByteArray11 = local31.aByteArray11;
|
||||
if (local31.secondaryKey == (long) arg1 && local31.cache == arg0 && local31.type == 2) {
|
||||
local9.data = local31.data;
|
||||
local9.incomplete = false;
|
||||
return local9;
|
||||
}
|
||||
local31 = (Js5CacheRequest) this.aClass16_6.method797();
|
||||
local31 = (Js5CacheRequest) this.queue.next();
|
||||
}
|
||||
}
|
||||
local9.aByteArray11 = arg0.read(arg1);
|
||||
local9.data = arg0.read(arg1);
|
||||
local9.incomplete = false;
|
||||
local9.aBoolean225 = true;
|
||||
local9.urgent = true;
|
||||
return local9;
|
||||
}
|
||||
|
||||
@OriginalMember(owner = "client!k", name = "run", descriptor = "()V")
|
||||
@Override
|
||||
public final void run() {
|
||||
while (!this.aBoolean161) {
|
||||
@Pc(12) SecondaryLinkedList local12 = this.aClass16_6;
|
||||
while (!this.stop) {
|
||||
@Pc(19) Js5CacheRequest local19;
|
||||
synchronized (this.aClass16_6) {
|
||||
local19 = (Js5CacheRequest) this.aClass16_6.method796();
|
||||
synchronized (this.queue) {
|
||||
local19 = (Js5CacheRequest) this.queue.removeHead();
|
||||
if (local19 == null) {
|
||||
try {
|
||||
this.aClass16_6.wait();
|
||||
} catch (@Pc(35) InterruptedException local35) {
|
||||
this.queue.wait();
|
||||
} catch (@Pc(35) InterruptedException ignored) {
|
||||
}
|
||||
continue;
|
||||
}
|
||||
this.anInt3131--;
|
||||
this.size--;
|
||||
}
|
||||
try {
|
||||
if (local19.anInt824 == 2) {
|
||||
local19.aClass49_3.write((int) local19.secondaryKey, local19.aByteArray11.length, local19.aByteArray11);
|
||||
} else if (local19.anInt824 == 3) {
|
||||
local19.aByteArray11 = local19.aClass49_3.read((int) local19.secondaryKey);
|
||||
if (local19.type == 2) {
|
||||
local19.cache.write((int) local19.secondaryKey, local19.data.length, local19.data);
|
||||
} else if (local19.type == 3) {
|
||||
local19.data = local19.cache.read((int) local19.secondaryKey);
|
||||
}
|
||||
} catch (@Pc(83) Exception local83) {
|
||||
TracingException.report(null, local83);
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue