AstralTransRocketries/MCGalaxy
1
0
Fork 0
mirror of https://github.com/ClassiCube/MCGalaxy.git synced 2025-09-23 20:53:40 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add LowLatency setter to INetworkSocket

Browse Source
This commit is contained in:
UnknownShadow200 2017-07-19 17:50:56 +10:00
parent 9062dbc68f
commit 282edd2ca3
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
MCGalaxy/Network/Socket/Interfaces.cs
View File

@ -26,6 +26,9 @@ namespace MCGalaxy.Network {
/// <summary> Gets the remote IP of this socket. </summary> /// <summary> Gets the remote IP of this socket. </summary>
string RemoteIP { get; } string RemoteIP { get; }
/// <summary> Sets whether this socket operates in low-latency mode (e.g. for TCP, disabes nagle's algorithm). </summary>
bool LowLatency { set; }
/// <summary> Receives next block of received data, asynchronously. </summary> /// <summary> Receives next block of received data, asynchronously. </summary>
void ReceiveNextAsync(); void ReceiveNextAsync();

4
MCGalaxy/Network/Socket/TcpSocket.cs
View File

@ -33,6 +33,10 @@ namespace MCGalaxy.Network {
get { return ((IPEndPoint)socket.RemoteEndPoint).Address.ToString(); } get { return ((IPEndPoint)socket.RemoteEndPoint).Address.ToString(); }
} }
public bool LowLatency {
set { socket.NoDelay = value; }
}
static AsyncCallback recvCallback = new AsyncCallback(ReceiveCallback); static AsyncCallback recvCallback = new AsyncCallback(ReceiveCallback);
public void ReceiveNextAsync() { public void ReceiveNextAsync() {
socket.BeginReceive(tempbuffer, 0, tempbuffer.Length, SocketFlags.None, recvCallback, this); socket.BeginReceive(tempbuffer, 0, tempbuffer.Length, SocketFlags.None, recvCallback, this);