public class TcpConnection extends Object implements INetworkManager
Modifier and Type | Field and Description |
---|---|
static int[] |
field_74467_d |
int |
field_74468_e |
static AtomicInteger |
field_74469_b |
static int[] |
field_74470_c |
static AtomicInteger |
field_74471_a |
Constructor and Description |
---|
TcpConnection(ILogAgent par1ILogAgent,
Socket par2Socket,
String par3Str,
NetHandler par4NetHandler) |
TcpConnection(ILogAgent par1ILogAgent,
Socket par2Socket,
String par3Str,
NetHandler par4NetHandler,
PrivateKey par5PrivateKey) |
Modifier and Type | Method and Description |
---|---|
void |
addToSendQueue(Packet par1Packet)
Adds the packet to the correct send queue (chunk data packets go to a separate queue).
|
void |
closeConnections() |
Socket |
getSocket() |
SocketAddress |
getSocketAddress()
Return the InetSocketAddress of the remote endpoint
|
void |
networkShutdown(String par1Str,
Object... par2ArrayOfObj)
Shuts down the network with the specified reason.
|
int |
packetSize()
returns 0 for memoryConnections
|
void |
processReadPackets()
Checks timeouts and processes all pending read packets.
|
void |
serverShutdown()
Shuts down the server.
|
void |
setNetHandler(NetHandler par1NetHandler)
Sets the NetHandler for this NetworkManager.
|
void |
wakeThreads()
Wakes reader and writer threads
|
public static AtomicInteger field_74471_a
public static AtomicInteger field_74469_b
public static int[] field_74470_c
public static int[] field_74467_d
public int field_74468_e
public TcpConnection(ILogAgent par1ILogAgent, Socket par2Socket, String par3Str, NetHandler par4NetHandler) throws IOException
IOException
public TcpConnection(ILogAgent par1ILogAgent, Socket par2Socket, String par3Str, NetHandler par4NetHandler, PrivateKey par5PrivateKey) throws IOException
IOException
public void closeConnections()
closeConnections
in interface INetworkManager
public void setNetHandler(NetHandler par1NetHandler)
setNetHandler
in interface INetworkManager
public void addToSendQueue(Packet par1Packet)
addToSendQueue
in interface INetworkManager
public void wakeThreads()
wakeThreads
in interface INetworkManager
public void networkShutdown(String par1Str, Object... par2ArrayOfObj)
networkShutdown
in interface INetworkManager
public void processReadPackets()
processReadPackets
in interface INetworkManager
public SocketAddress getSocketAddress()
getSocketAddress
in interface INetworkManager
public void serverShutdown()
serverShutdown
in interface INetworkManager
public int packetSize()
packetSize
in interface INetworkManager
public Socket getSocket()