|
|
|
@ -2,19 +2,14 @@ package networkInterface;
|
|
|
|
|
|
|
|
|
|
|
|
import model.ClientAddress;
|
|
|
|
import model.ClientAddress;
|
|
|
|
import model.MatchTable;
|
|
|
|
import model.MatchTable;
|
|
|
|
import model.TableKey;
|
|
|
|
|
|
|
|
import network.BinaryMessageDecoder;
|
|
|
|
import network.BinaryMessageDecoder;
|
|
|
|
import network.BinaryMessageEncoder;
|
|
|
|
|
|
|
|
import network.Exceptions.InvalidMessageException;
|
|
|
|
import network.Exceptions.InvalidMessageException;
|
|
|
|
import network.MessageDecoders.HostGameMessageDecoder;
|
|
|
|
import network.MessageDecoders.HostGameMessageDecoder;
|
|
|
|
import network.MessageDecoders.HostedGamesRequestDecoder;
|
|
|
|
import network.MessageDecoders.HostedGamesRequestDecoder;
|
|
|
|
import network.MessageEncoders.HostGameMessageEncoder;
|
|
|
|
|
|
|
|
import network.MessageEncoders.HostedGamesRequestEncoder;
|
|
|
|
import network.MessageEncoders.HostedGamesRequestEncoder;
|
|
|
|
import network.Messages.Enums.MessageType;
|
|
|
|
import network.Messages.Enums.MessageType;
|
|
|
|
import network.Messages.Enums.RaceStatusEnum;
|
|
|
|
|
|
|
|
import network.Messages.HostGame;
|
|
|
|
import network.Messages.HostGame;
|
|
|
|
import network.Messages.HostGamesRequest;
|
|
|
|
import network.Messages.HostGamesRequest;
|
|
|
|
import network.Messages.RaceStatus;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import java.io.IOException;
|
|
|
|
import java.io.IOException;
|
|
|
|
import java.net.DatagramPacket;
|
|
|
|
import java.net.DatagramPacket;
|
|
|
|
@ -46,8 +41,8 @@ public class NetworkInterface {
|
|
|
|
this.groupPort = 4941;
|
|
|
|
this.groupPort = 4941;
|
|
|
|
this.serverSocket = new DatagramSocket(3779);
|
|
|
|
this.serverSocket = new DatagramSocket(3779);
|
|
|
|
|
|
|
|
|
|
|
|
startBroadcast(10000);
|
|
|
|
startBroadcast(5000);
|
|
|
|
scheduleFlush(300000);
|
|
|
|
scheduleFlush(30000);
|
|
|
|
this.run();
|
|
|
|
this.run();
|
|
|
|
} catch (IOException e) {
|
|
|
|
} catch (IOException e) {
|
|
|
|
System.err.println("Error listening on port: " + this.serverSocket.getLocalPort() + ".");
|
|
|
|
System.err.println("Error listening on port: " + this.serverSocket.getLocalPort() + ".");
|
|
|
|
|