Compare commits
2 Commits
7b90a81365
...
af0ac0ff77
| Author | SHA1 | Date | |
|---|---|---|---|
| af0ac0ff77 | |||
| 375e0eddbd |
@@ -21,7 +21,6 @@ public abstract class Connexion implements PacketVisitor {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public void sendPacket(Packet packet) {
|
public void sendPacket(Packet packet) {
|
||||||
System.out.println("Sending " + packet);
|
|
||||||
try {
|
try {
|
||||||
ByteArrayOutputStream stream = new ByteArrayOutputStream();
|
ByteArrayOutputStream stream = new ByteArrayOutputStream();
|
||||||
ObjectOutputStream oos = new ObjectOutputStream(stream);
|
ObjectOutputStream oos = new ObjectOutputStream(stream);
|
||||||
|
|||||||
@@ -39,10 +39,9 @@ public class ClientConnexion extends Connexion {
|
|||||||
private void readPackets() {
|
private void readPackets() {
|
||||||
while (!Thread.interrupted()) {
|
while (!Thread.interrupted()) {
|
||||||
try {
|
try {
|
||||||
byte[] buffer = new byte[1024 * 10];
|
byte[] buffer = new byte[65535];
|
||||||
DatagramPacket dataPacket = new DatagramPacket(buffer, buffer.length);
|
DatagramPacket dataPacket = new DatagramPacket(buffer, buffer.length);
|
||||||
this.socket.receive(dataPacket);
|
this.socket.receive(dataPacket);
|
||||||
System.out.println(dataPacket.getLength());
|
|
||||||
|
|
||||||
ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(dataPacket.getData()));
|
ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(dataPacket.getData()));
|
||||||
Packet packet = (Packet) ois.readObject();
|
Packet packet = (Packet) ois.readObject();
|
||||||
|
|||||||
Reference in New Issue
Block a user