FlarePublic/CrossJeeves
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix race condition

Browse Source
This commit is contained in:
Flare Microsystems
2024-11-16 21:13:52 -08:00
parent 7eb283592e
commit 32203cde49
1 changed files with 13 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/com/flaremicro/crossjeeves/net/packet/Packet4FileData.java
View File

@@ -6,20 +6,21 @@ import java.io.IOException;
import com.flaremicro.crossjeeves.net.NetworkHandler; import com.flaremicro.crossjeeves.net.NetworkHandler;
public class Packet4FileData extends Packet{ public class Packet4FileData extends Packet {
private long fileId; private long fileId;
private short chunkSize; private short chunkSize;
private byte[] fileChunk; private byte[] fileChunk;
public Packet4FileData(){ public Packet4FileData() {
} }
public Packet4FileData(long fileId, short chunkSize, byte[] fileChunk){ public Packet4FileData(long fileId, short chunkSize, byte[] fileChunk) {
this.fileId = fileId; this.fileId = fileId;
this.chunkSize = chunkSize; this.chunkSize = chunkSize;
this.fileChunk = fileChunk; this.fileChunk = new byte[chunkSize];
System.arraycopy(fileChunk, 0, this.fileChunk, 0, chunkSize);
} }
public void recievePacket(DataInputStream in) throws IOException { public void recievePacket(DataInputStream in) throws IOException {
fileId = in.readLong(); fileId = in.readLong();
chunkSize = in.readShort(); chunkSize = in.readShort();
@@ -33,25 +34,22 @@ public class Packet4FileData extends Packet{
out.writeShort(chunkSize); out.writeShort(chunkSize);
out.write(fileChunk, 0, chunkSize); out.write(fileChunk, 0, chunkSize);
} }
public void processPacket(NetworkHandler networkHandler){ public void processPacket(NetworkHandler networkHandler) {
networkHandler.handlePacket(this); networkHandler.handlePacket(this);
} }
public long getFileId() public long getFileId() {
{
return fileId; return fileId;
} }
public byte[] getFileChunk() public byte[] getFileChunk() {
{
return fileChunk; return fileChunk;
} }
@Override @Override
public Packet cloneTypeOnly() { public Packet cloneTypeOnly() {
return new Packet4FileData(); return new Packet4FileData();
} }
} }