mirror of
https://github.com/2006-Scape/2006Scape.git
synced 2026-07-03 16:49:03 +00:00
Make project setup easier with Maven (#411)
* Remove a bunch of .ideas and class files to see if it makes the setup easier * remove some .idea's and imkls * Remove a ton of .class files * [TASK] Switched to maven instead of gradle * [TASK] Added target to gitignore * Remove ignored files * [TASK] Fixed file_server source * [TASK] Fixed client source * [BUGFIX] Main Class * [BUGFIX] Fixed SLF4J * [TASK] Server Libs cleanup * Update setup guide/debug * Maven cli compile instructions * [TASK] Jar building * Update runServer and runFileServer.sh Co-authored-by: Sandro Coutinho <sandro@farrelltech.org>
This commit is contained in:
Daniel Ginovker
@@ -0,0 +1,682 @@
|
||||
// Decompiled by Jad v1.5.8f. Copyright 2001 Pavel Kouznetsov.
|
||||
// Jad home page: http://www.kpdus.com/jad.html
|
||||
// Decompiler options: packimports(3)
|
||||
|
||||
import java.io.ByteArrayInputStream;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.io.OutputStream;
|
||||
import java.net.Socket;
|
||||
import java.util.zip.CRC32;
|
||||
import java.util.zip.GZIPInputStream;
|
||||
|
||||
public final class OnDemandFetcher extends OnDemandFetcherParent implements Runnable {
|
||||
|
||||
/* private boolean crcMatches(int i, int j, byte abyte0[])
|
||||
{
|
||||
//if(abyte0 == null || abyte0.length < 2)
|
||||
//return false;
|
||||
int k = abyte0.length - 2;
|
||||
int l = ((abyte0[k] & 0xff) << 8) + (abyte0[k + 1] & 0xff);
|
||||
crc32.reset();
|
||||
crc32.update(abyte0, 0, k);
|
||||
int i1 = (int) crc32.getValue();
|
||||
//return l == i && i1 == j;
|
||||
return true;
|
||||
|
||||
}*/
|
||||
|
||||
// XXX: Fixed and refactored the crcMatches method. - Ryley
|
||||
private boolean crcMatches(int type, int id, byte[] data) {
|
||||
if (data == null || data.length < 2) {
|
||||
return false;
|
||||
}
|
||||
int length = data.length - 2;
|
||||
int hash = ((data[length] & 0xFF) << 8) + (data[length + 1] & 0xFF);
|
||||
crc32.reset();
|
||||
crc32.update(data, 0, length);
|
||||
int crc = (int) crc32.getValue();
|
||||
return hash == type && crc == id;
|
||||
}
|
||||
|
||||
private void readData() {
|
||||
try {
|
||||
int available = inputStream.available();
|
||||
if (expectedSize == 0 && available >= 6) {
|
||||
waiting = true;
|
||||
for (int k = 0; k < 6; k += inputStream.read(ioBuffer, k, 6 - k)) {
|
||||
;
|
||||
}
|
||||
int l = ioBuffer[0] & 0xff;
|
||||
int j1 = ((ioBuffer[1] & 0xff) << 8) + (ioBuffer[2] & 0xff);
|
||||
int l1 = ((ioBuffer[3] & 0xff) << 8) + (ioBuffer[4] & 0xff);
|
||||
int i2 = ioBuffer[5] & 0xff;
|
||||
current = null;
|
||||
for (OnDemandData onDemandData = (OnDemandData) requested.reverseGetFirst(); onDemandData != null; onDemandData = (OnDemandData) requested.reverseGetNext()) {
|
||||
if (onDemandData.dataType == l && onDemandData.ID == j1) {
|
||||
current = onDemandData;
|
||||
}
|
||||
if (current != null) {
|
||||
onDemandData.loopCycle = 0;
|
||||
}
|
||||
}
|
||||
|
||||
if (current != null) {
|
||||
loopCycle = 0;
|
||||
if (l1 == 0) {
|
||||
Signlink.reporterror("Rej: " + l + "," + j1);
|
||||
current.buffer = null;
|
||||
if (current.incomplete) {
|
||||
synchronized (aClass19_1358) {
|
||||
aClass19_1358.insertHead(current);
|
||||
}
|
||||
} else {
|
||||
current.unlink();
|
||||
}
|
||||
current = null;
|
||||
} else {
|
||||
if (current.buffer == null && i2 == 0) {
|
||||
current.buffer = new byte[l1];
|
||||
}
|
||||
if (current.buffer == null && i2 != 0) {
|
||||
throw new IOException("missing start of file");
|
||||
}
|
||||
}
|
||||
}
|
||||
completedSize = i2 * 500;
|
||||
expectedSize = 500;
|
||||
if (expectedSize > l1 - i2 * 500) {
|
||||
expectedSize = l1 - i2 * 500;
|
||||
}
|
||||
}
|
||||
if (expectedSize > 0 && available >= expectedSize) {
|
||||
waiting = true;
|
||||
byte abyte0[] = ioBuffer;
|
||||
int i1 = 0;
|
||||
if (current != null) {
|
||||
abyte0 = current.buffer;
|
||||
i1 = completedSize;
|
||||
}
|
||||
for (int k1 = 0; k1 < expectedSize; k1 += inputStream.read(abyte0, k1 + i1, expectedSize - k1)) {
|
||||
;
|
||||
}
|
||||
if (expectedSize + completedSize >= abyte0.length && current != null) {
|
||||
if (clientInstance.decompressors[0] != null) {
|
||||
clientInstance.decompressors[current.dataType + 1].method234(abyte0.length, abyte0, current.ID);
|
||||
}
|
||||
if (!current.incomplete && current.dataType == 3) {
|
||||
current.incomplete = true;
|
||||
current.dataType = 93;
|
||||
}
|
||||
if (current.incomplete) {
|
||||
synchronized (aClass19_1358) {
|
||||
aClass19_1358.insertHead(current);
|
||||
}
|
||||
} else {
|
||||
current.unlink();
|
||||
}
|
||||
}
|
||||
expectedSize = 0;
|
||||
}
|
||||
} catch (IOException ioexception) {
|
||||
try {
|
||||
socket.close();
|
||||
} catch (Exception _ex) {
|
||||
}
|
||||
socket = null;
|
||||
inputStream = null;
|
||||
outputStream = null;
|
||||
expectedSize = 0;
|
||||
}
|
||||
}
|
||||
|
||||
public void start(StreamLoader streamLoader, Game client1) {
|
||||
String as[] = {"model_version", "anim_version", "midi_version", "map_version"};
|
||||
for (int i = 0; i < 4; i++) {
|
||||
byte abyte0[] = streamLoader.getDataForName(as[i]);
|
||||
int j = abyte0.length / 2;
|
||||
Stream stream = new Stream(abyte0);
|
||||
versions[i] = new int[j];
|
||||
fileStatus[i] = new byte[j];
|
||||
for (int l = 0; l < j; l++) {
|
||||
versions[i][l] = stream.readUnsignedWord();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
String as1[] = {"model_crc", "anim_crc", "midi_crc", "map_crc"};
|
||||
for (int k = 0; k < 4; k++) {
|
||||
byte abyte1[] = streamLoader.getDataForName(as1[k]);
|
||||
int i1 = abyte1.length / 4;
|
||||
Stream stream_1 = new Stream(abyte1);
|
||||
crcs[k] = new int[i1];
|
||||
for (int l1 = 0; l1 < i1; l1++) {
|
||||
crcs[k][l1] = stream_1.readDWord();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
byte abyte2[] = streamLoader.getDataForName("model_index");
|
||||
int j1 = versions[0].length;
|
||||
modelIndices = new byte[j1];
|
||||
for (int k1 = 0; k1 < j1; k1++) {
|
||||
if (k1 < abyte2.length) {
|
||||
modelIndices[k1] = abyte2[k1];
|
||||
} else {
|
||||
modelIndices[k1] = 0;
|
||||
}
|
||||
}
|
||||
|
||||
abyte2 = streamLoader.getDataForName("map_index");
|
||||
Stream stream2 = new Stream(abyte2);
|
||||
j1 = abyte2.length / 7;
|
||||
mapIndices1 = new int[j1];
|
||||
mapIndices2 = new int[j1];
|
||||
mapIndices3 = new int[j1];
|
||||
mapIndices4 = new int[j1];
|
||||
for (int i2 = 0; i2 < j1; i2++) {
|
||||
mapIndices1[i2] = stream2.readUnsignedWord();
|
||||
mapIndices2[i2] = stream2.readUnsignedWord();
|
||||
mapIndices3[i2] = stream2.readUnsignedWord();
|
||||
mapIndices4[i2] = stream2.readUnsignedByte();
|
||||
}
|
||||
|
||||
abyte2 = streamLoader.getDataForName("anim_index");
|
||||
stream2 = new Stream(abyte2);
|
||||
j1 = abyte2.length / 2;
|
||||
anIntArray1360 = new int[j1];
|
||||
for (int j2 = 0; j2 < j1; j2++) {
|
||||
anIntArray1360[j2] = stream2.readUnsignedWord();
|
||||
}
|
||||
|
||||
abyte2 = streamLoader.getDataForName("midi_index");
|
||||
stream2 = new Stream(abyte2);
|
||||
j1 = abyte2.length;
|
||||
anIntArray1348 = new int[j1];
|
||||
for (int k2 = 0; k2 < j1; k2++) {
|
||||
anIntArray1348[k2] = stream2.readUnsignedByte();
|
||||
}
|
||||
|
||||
clientInstance = client1;
|
||||
running = true;
|
||||
clientInstance.startRunnable(this, 2);
|
||||
}
|
||||
|
||||
public int getNodeCount() {
|
||||
synchronized (nodeSubList) {
|
||||
return nodeSubList.getNodeCount();
|
||||
}
|
||||
}
|
||||
|
||||
public void disable() {
|
||||
running = false;
|
||||
}
|
||||
|
||||
public void method554(boolean flag) {
|
||||
int j = mapIndices1.length;
|
||||
for (int k = 0; k < j; k++) {
|
||||
if (flag || mapIndices4[k] != 0) {
|
||||
method563((byte) 2, 3, mapIndices3[k]);
|
||||
method563((byte) 2, 3, mapIndices2[k]);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public int getVersionCount(int j) {
|
||||
return versions[j].length;
|
||||
}
|
||||
|
||||
private void closeRequest(OnDemandData onDemandData) {
|
||||
try {
|
||||
if (socket == null) {
|
||||
long l = System.currentTimeMillis();
|
||||
if (l - openSocketTime < 4000L) {
|
||||
return;
|
||||
}
|
||||
openSocketTime = l;
|
||||
socket = clientInstance.openSocket(43596 + Game.portOff);
|
||||
inputStream = socket.getInputStream();
|
||||
outputStream = socket.getOutputStream();
|
||||
outputStream.write(15);
|
||||
for (int j = 0; j < 8; j++) {
|
||||
inputStream.read();
|
||||
}
|
||||
|
||||
loopCycle = 0;
|
||||
}
|
||||
ioBuffer[0] = (byte) onDemandData.dataType;
|
||||
ioBuffer[1] = (byte) (onDemandData.ID >> 8);
|
||||
ioBuffer[2] = (byte) onDemandData.ID;
|
||||
if (onDemandData.incomplete) {
|
||||
ioBuffer[3] = 2;
|
||||
} else if (!clientInstance.loggedIn) {
|
||||
ioBuffer[3] = 1;
|
||||
} else {
|
||||
ioBuffer[3] = 0;
|
||||
}
|
||||
outputStream.write(ioBuffer, 0, 4);
|
||||
writeLoopCycle = 0;
|
||||
anInt1349 = -10000;
|
||||
return;
|
||||
} catch (IOException ioexception) {
|
||||
}
|
||||
try {
|
||||
socket.close();
|
||||
} catch (Exception _ex) {
|
||||
}
|
||||
socket = null;
|
||||
inputStream = null;
|
||||
outputStream = null;
|
||||
expectedSize = 0;
|
||||
anInt1349++;
|
||||
}
|
||||
|
||||
public int getAnimCount() {
|
||||
return anIntArray1360.length;
|
||||
}
|
||||
|
||||
public void method558(int i, int j) {
|
||||
if (i < 0 || i > versions.length || j < 0 || j > versions[i].length) {
|
||||
return;
|
||||
}
|
||||
if (versions[i][j] == 0) {
|
||||
return;
|
||||
}
|
||||
synchronized (nodeSubList) {
|
||||
for (OnDemandData onDemandData = (OnDemandData) nodeSubList.reverseGetFirst(); onDemandData != null; onDemandData = (OnDemandData) nodeSubList.reverseGetNext()) {
|
||||
if (onDemandData.dataType == i && onDemandData.ID == j) {
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
OnDemandData onDemandData_1 = new OnDemandData();
|
||||
onDemandData_1.dataType = i;
|
||||
onDemandData_1.ID = j;
|
||||
onDemandData_1.incomplete = true;
|
||||
synchronized (aClass19_1370) {
|
||||
aClass19_1370.insertHead(onDemandData_1);
|
||||
}
|
||||
nodeSubList.insertHead(onDemandData_1);
|
||||
}
|
||||
}
|
||||
|
||||
public int getModelIndex(int i) {
|
||||
return modelIndices[i] & 0xff;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
try {
|
||||
while (running) {
|
||||
onDemandCycle++;
|
||||
int i = 20;
|
||||
if (anInt1332 == 0 && clientInstance.decompressors[0] != null) {
|
||||
i = 50;
|
||||
}
|
||||
try {
|
||||
Thread.sleep(i);
|
||||
} catch (Exception _ex) {
|
||||
}
|
||||
waiting = true;
|
||||
for (int j = 0; j < 100; j++) {
|
||||
if (!waiting) {
|
||||
break;
|
||||
}
|
||||
waiting = false;
|
||||
checkReceived();
|
||||
handleFailed();
|
||||
if (uncompletedCount == 0 && j >= 5) {
|
||||
break;
|
||||
}
|
||||
method568();
|
||||
if (inputStream != null) {
|
||||
readData();
|
||||
}
|
||||
}
|
||||
|
||||
boolean flag = false;
|
||||
for (OnDemandData onDemandData = (OnDemandData) requested.reverseGetFirst(); onDemandData != null; onDemandData = (OnDemandData) requested.reverseGetNext()) {
|
||||
if (onDemandData.incomplete) {
|
||||
flag = true;
|
||||
onDemandData.loopCycle++;
|
||||
if (onDemandData.loopCycle > 50) {
|
||||
onDemandData.loopCycle = 0;
|
||||
closeRequest(onDemandData);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (!flag) {
|
||||
for (OnDemandData onDemandData_1 = (OnDemandData) requested.reverseGetFirst(); onDemandData_1 != null; onDemandData_1 = (OnDemandData) requested.reverseGetNext()) {
|
||||
flag = true;
|
||||
onDemandData_1.loopCycle++;
|
||||
if (onDemandData_1.loopCycle > 50) {
|
||||
onDemandData_1.loopCycle = 0;
|
||||
closeRequest(onDemandData_1);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
if (flag) {
|
||||
loopCycle++;
|
||||
if (loopCycle > 750) {
|
||||
try {
|
||||
socket.close();
|
||||
} catch (Exception _ex) {
|
||||
}
|
||||
socket = null;
|
||||
inputStream = null;
|
||||
outputStream = null;
|
||||
expectedSize = 0;
|
||||
}
|
||||
} else {
|
||||
loopCycle = 0;
|
||||
statusString = "";
|
||||
}
|
||||
if (clientInstance.loggedIn && socket != null && outputStream != null && (anInt1332 > 0 || clientInstance.decompressors[0] == null)) {
|
||||
writeLoopCycle++;
|
||||
if (writeLoopCycle > 500) {
|
||||
writeLoopCycle = 0;
|
||||
ioBuffer[0] = 0;
|
||||
ioBuffer[1] = 0;
|
||||
ioBuffer[2] = 0;
|
||||
ioBuffer[3] = 10;
|
||||
try {
|
||||
outputStream.write(ioBuffer, 0, 4);
|
||||
} catch (IOException _ex) {
|
||||
loopCycle = 5000;
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (Exception exception) {
|
||||
Signlink.reporterror("od_ex " + exception.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
public void method560(int i, int j) {
|
||||
if (clientInstance.decompressors[0] == null) {
|
||||
return;
|
||||
}
|
||||
if (versions[j][i] == 0) {
|
||||
return;
|
||||
}
|
||||
if (fileStatus[j][i] == 0) {
|
||||
return;
|
||||
}
|
||||
if (anInt1332 == 0) {
|
||||
return;
|
||||
}
|
||||
OnDemandData onDemandData = new OnDemandData();
|
||||
onDemandData.dataType = j;
|
||||
onDemandData.ID = i;
|
||||
onDemandData.incomplete = false;
|
||||
synchronized (aClass19_1344) {
|
||||
aClass19_1344.insertHead(onDemandData);
|
||||
}
|
||||
}
|
||||
|
||||
public OnDemandData getNextNode() {
|
||||
OnDemandData onDemandData;
|
||||
synchronized (aClass19_1358) {
|
||||
onDemandData = (OnDemandData) aClass19_1358.popHead();
|
||||
}
|
||||
if (onDemandData == null) {
|
||||
return null;
|
||||
}
|
||||
synchronized (nodeSubList) {
|
||||
onDemandData.unlinkSub();
|
||||
}
|
||||
if (onDemandData.buffer == null) {
|
||||
return onDemandData;
|
||||
}
|
||||
int i = 0;
|
||||
try {
|
||||
GZIPInputStream gzipinputstream = new GZIPInputStream(new ByteArrayInputStream(onDemandData.buffer));
|
||||
do {
|
||||
if (i == gzipInputBuffer.length) {
|
||||
throw new RuntimeException("buffer overflow!");
|
||||
}
|
||||
int k = gzipinputstream.read(gzipInputBuffer, i, gzipInputBuffer.length - i);
|
||||
if (k == -1) {
|
||||
break;
|
||||
}
|
||||
i += k;
|
||||
} while (true);
|
||||
} catch (IOException _ex) {
|
||||
throw new RuntimeException("error unzipping");
|
||||
}
|
||||
onDemandData.buffer = new byte[i];
|
||||
System.arraycopy(gzipInputBuffer, 0, onDemandData.buffer, 0, i);
|
||||
|
||||
return onDemandData;
|
||||
}
|
||||
|
||||
public int method562(int i, int k, int l) {
|
||||
int i1 = (l << 8) + k;
|
||||
for (int j1 = 0; j1 < mapIndices1.length; j1++) {
|
||||
if (mapIndices1[j1] == i1) {
|
||||
if (i == 0) {
|
||||
return mapIndices2[j1];
|
||||
} else {
|
||||
return mapIndices3[j1];
|
||||
}
|
||||
}
|
||||
}
|
||||
return -1;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void method548(int i) {
|
||||
method558(0, i);
|
||||
}
|
||||
|
||||
public void method563(byte byte0, int i, int j) {
|
||||
if (clientInstance.decompressors[0] == null) {
|
||||
return;
|
||||
}
|
||||
if (versions[i][j] == 0) {
|
||||
return;
|
||||
}
|
||||
byte abyte0[] = clientInstance.decompressors[i + 1].decompress(j);
|
||||
if (crcMatches(versions[i][j], crcs[i][j], abyte0)) {
|
||||
return;
|
||||
}
|
||||
fileStatus[i][j] = byte0;
|
||||
if (byte0 > anInt1332) {
|
||||
anInt1332 = byte0;
|
||||
}
|
||||
totalFiles++;
|
||||
}
|
||||
|
||||
public boolean method564(int i) {
|
||||
for (int k = 0; k < mapIndices1.length; k++) {
|
||||
if (mapIndices3[k] == i) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
private void handleFailed() {
|
||||
uncompletedCount = 0;
|
||||
completedCount = 0;
|
||||
for (OnDemandData onDemandData = (OnDemandData) requested.reverseGetFirst(); onDemandData != null; onDemandData = (OnDemandData) requested.reverseGetNext()) {
|
||||
if (onDemandData.incomplete) {
|
||||
uncompletedCount++;
|
||||
} else {
|
||||
completedCount++;
|
||||
}
|
||||
}
|
||||
|
||||
while (uncompletedCount < 10) {
|
||||
OnDemandData onDemandData_1 = (OnDemandData) aClass19_1368.popHead();
|
||||
if (onDemandData_1 == null) {
|
||||
break;
|
||||
}
|
||||
if (fileStatus[onDemandData_1.dataType][onDemandData_1.ID] != 0) {
|
||||
filesLoaded++;
|
||||
}
|
||||
fileStatus[onDemandData_1.dataType][onDemandData_1.ID] = 0;
|
||||
requested.insertHead(onDemandData_1);
|
||||
uncompletedCount++;
|
||||
closeRequest(onDemandData_1);
|
||||
waiting = true;
|
||||
}
|
||||
}
|
||||
|
||||
public void method566() {
|
||||
synchronized (aClass19_1344) {
|
||||
aClass19_1344.removeAll();
|
||||
}
|
||||
}
|
||||
|
||||
private void checkReceived() {
|
||||
OnDemandData onDemandData;
|
||||
synchronized (aClass19_1370) {
|
||||
onDemandData = (OnDemandData) aClass19_1370.popHead();
|
||||
}
|
||||
while (onDemandData != null) {
|
||||
waiting = true;
|
||||
byte abyte0[] = null;
|
||||
if (clientInstance.decompressors[0] != null) {
|
||||
abyte0 = clientInstance.decompressors[onDemandData.dataType + 1].decompress(onDemandData.ID);
|
||||
}
|
||||
if (!crcMatches(versions[onDemandData.dataType][onDemandData.ID], crcs[onDemandData.dataType][onDemandData.ID], abyte0)) {
|
||||
abyte0 = null;
|
||||
}
|
||||
synchronized (aClass19_1370) {
|
||||
if (abyte0 == null) {
|
||||
aClass19_1368.insertHead(onDemandData);
|
||||
} else {
|
||||
onDemandData.buffer = abyte0;
|
||||
synchronized (aClass19_1358) {
|
||||
aClass19_1358.insertHead(onDemandData);
|
||||
}
|
||||
}
|
||||
onDemandData = (OnDemandData) aClass19_1370.popHead();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private void method568() {
|
||||
while (uncompletedCount == 0 && completedCount < 10) {
|
||||
if (anInt1332 == 0) {
|
||||
break;
|
||||
}
|
||||
OnDemandData onDemandData;
|
||||
synchronized (aClass19_1344) {
|
||||
onDemandData = (OnDemandData) aClass19_1344.popHead();
|
||||
}
|
||||
while (onDemandData != null) {
|
||||
if (fileStatus[onDemandData.dataType][onDemandData.ID] != 0) {
|
||||
fileStatus[onDemandData.dataType][onDemandData.ID] = 0;
|
||||
requested.insertHead(onDemandData);
|
||||
closeRequest(onDemandData);
|
||||
waiting = true;
|
||||
if (filesLoaded < totalFiles) {
|
||||
filesLoaded++;
|
||||
}
|
||||
statusString = "Loading extra files - " + filesLoaded * 100 / totalFiles + "%";
|
||||
completedCount++;
|
||||
if (completedCount == 10) {
|
||||
return;
|
||||
}
|
||||
}
|
||||
synchronized (aClass19_1344) {
|
||||
onDemandData = (OnDemandData) aClass19_1344.popHead();
|
||||
}
|
||||
}
|
||||
for (int j = 0; j < 4; j++) {
|
||||
byte abyte0[] = fileStatus[j];
|
||||
int k = abyte0.length;
|
||||
for (int l = 0; l < k; l++) {
|
||||
if (abyte0[l] == anInt1332) {
|
||||
abyte0[l] = 0;
|
||||
OnDemandData onDemandData_1 = new OnDemandData();
|
||||
onDemandData_1.dataType = j;
|
||||
onDemandData_1.ID = l;
|
||||
onDemandData_1.incomplete = false;
|
||||
requested.insertHead(onDemandData_1);
|
||||
closeRequest(onDemandData_1);
|
||||
waiting = true;
|
||||
if (filesLoaded < totalFiles) {
|
||||
filesLoaded++;
|
||||
}
|
||||
statusString = "Loading extra files - " + filesLoaded * 100 / totalFiles + "%";
|
||||
completedCount++;
|
||||
if (completedCount == 10) {
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
anInt1332--;
|
||||
}
|
||||
}
|
||||
|
||||
public boolean method569(int i) {
|
||||
return anIntArray1348[i] == 1;
|
||||
}
|
||||
|
||||
public OnDemandFetcher() {
|
||||
requested = new NodeList();
|
||||
statusString = "";
|
||||
crc32 = new CRC32();
|
||||
ioBuffer = new byte[500];
|
||||
fileStatus = new byte[4][];
|
||||
aClass19_1344 = new NodeList();
|
||||
running = true;
|
||||
waiting = false;
|
||||
aClass19_1358 = new NodeList();
|
||||
gzipInputBuffer = new byte[65000];
|
||||
nodeSubList = new NodeSubList();
|
||||
versions = new int[4][];
|
||||
crcs = new int[4][];
|
||||
aClass19_1368 = new NodeList();
|
||||
aClass19_1370 = new NodeList();
|
||||
}
|
||||
|
||||
private int totalFiles;
|
||||
private final NodeList requested;
|
||||
private int anInt1332;
|
||||
public String statusString;
|
||||
private int writeLoopCycle;
|
||||
private long openSocketTime;
|
||||
private int[] mapIndices3;
|
||||
private final CRC32 crc32;
|
||||
private final byte[] ioBuffer;
|
||||
public int onDemandCycle;
|
||||
private final byte[][] fileStatus;
|
||||
private Game clientInstance;
|
||||
private final NodeList aClass19_1344;
|
||||
private int completedSize;
|
||||
private int expectedSize;
|
||||
int[] anIntArray1348;
|
||||
public int anInt1349;
|
||||
private int[] mapIndices2;
|
||||
private int filesLoaded;
|
||||
private boolean running;
|
||||
private OutputStream outputStream;
|
||||
private int[] mapIndices4;
|
||||
private boolean waiting;
|
||||
private final NodeList aClass19_1358;
|
||||
private final byte[] gzipInputBuffer;
|
||||
private int[] anIntArray1360;
|
||||
private final NodeSubList nodeSubList;
|
||||
private InputStream inputStream;
|
||||
private Socket socket;
|
||||
public final int[][] versions;
|
||||
public final int[][] crcs;
|
||||
private int uncompletedCount;
|
||||
private int completedCount;
|
||||
private final NodeList aClass19_1368;
|
||||
private OnDemandData current;
|
||||
private final NodeList aClass19_1370;
|
||||
private int[] mapIndices1;
|
||||
private byte[] modelIndices;
|
||||
private int loopCycle;
|
||||
}
|
||||
Reference in New Issue
Block a user