Package net.minecraft.network.rcon

Class QueryThread

java.lang.Object

net.minecraft.network.rcon.RConThread

net.minecraft.network.rcon.QueryThread

All Implemented Interfaces:

Runnable

public class QueryThread
extends RConThread

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	QueryThread.Auth

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	buffer
private String	hostIp
private long	lastChallengeCheck
private long	lastRulesResponse
private static final org.apache.logging.log4j.Logger	LOGGER
private final int	maxPlayers
private final int	port
private final RConOutputStream	rulesResponse
private final IServer	serverInterface
private String	serverIp
private final String	serverName
private final int	serverPort
private DatagramSocket	socket
private final Map<SocketAddress,QueryThread.Auth>	validChallenges
private final String	worldName

Fields inherited from class net.minecraft.network.rcon.RConThread

name, running, thread

Constructor Summary

Constructors

Modifier	Constructor	Description
private	QueryThread(IServer p_i241890_1_, int p_i241890_2_)

Method Summary

Modifier and Type	Method	Description
private byte[]	buildRuleResponse(DatagramPacket p_72624_1_)
static QueryThread	create(IServer p_242129_0_)
private byte[]	getIdentBytes(SocketAddress p_72625_1_)
private boolean	initSocket()
private boolean	processPacket(DatagramPacket p_72621_1_)
private void	pruneChallenges()
private void	recoverSocketError(Exception p_72623_1_)
void	run()
private void	sendChallenge(DatagramPacket p_72622_1_)
private void	sendTo(byte[] p_72620_1_, DatagramPacket p_72620_2_)
boolean	start()
private Boolean	validChallenge(DatagramPacket p_72627_1_)

Methods inherited from class net.minecraft.network.rcon.RConThread

isRunning, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

private static final org.apache.logging.log4j.Logger LOGGER

lastChallengeCheck

private long lastChallengeCheck

port

private final int port

serverPort

private final int serverPort

maxPlayers

private final int maxPlayers

serverName

private final String serverName

worldName

private final String worldName

socket

private DatagramSocket socket

buffer

private final byte[] buffer

hostIp

private String hostIp

serverIp

private String serverIp

validChallenges

private final Map<SocketAddress,QueryThread.Auth> validChallenges

rulesResponse

private final RConOutputStream rulesResponse

lastRulesResponse

private long lastRulesResponse

serverInterface

private final IServer serverInterface

Constructor Details

QueryThread

private QueryThread(IServer p_i241890_1_,
 int p_i241890_2_)

Method Details

create

@Nullable
public static QueryThread create(IServer p_242129_0_)

sendTo

private void sendTo(byte[] p_72620_1_,
 DatagramPacket p_72620_2_)
             throws IOException

Throws:

IOException

processPacket

private boolean processPacket(DatagramPacket p_72621_1_)
                       throws IOException

Throws:

IOException

buildRuleResponse

private byte[] buildRuleResponse(DatagramPacket p_72624_1_)
                          throws IOException

Throws:

IOException

getIdentBytes

private byte[] getIdentBytes(SocketAddress p_72625_1_)

validChallenge

private Boolean validChallenge(DatagramPacket p_72627_1_)

sendChallenge

private void sendChallenge(DatagramPacket p_72622_1_)
                    throws IOException

Throws:

IOException

pruneChallenges

private void pruneChallenges()

run

public void run()

start

public boolean start()

Overrides:

start in class RConThread

recoverSocketError

private void recoverSocketError(Exception p_72623_1_)

initSocket

private boolean initSocket()