lineage2/l2j_mobius
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Reverting latest L2jServer MMOCore changes.

Browse Source 
Other minor MMOCore improvements.
This commit is contained in:
MobiusDev
2015-12-04 20:13:14 +00:00
parent 4a2595b95a
commit 63ddbd13f6
9 changed files with 16 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
trunk/java/com/l2jserver/commons/mmocore/AbstractPacket.java
View File

@@ -27,7 +27,7 @@ public abstract class AbstractPacket<T extends MMOClient<?>>
{
protected ByteBuffer _buf;
protected T _client;
T _client;
public final T getClient()
{

12
trunk/java/com/l2jserver/commons/mmocore/MMOConnection.java
View File

@@ -20,7 +20,6 @@ package com.l2jserver.commons.mmocore;
import java.io.IOException;
import java.net.InetAddress;
import java.net.Socket;
import java.net.SocketException;
import java.nio.ByteBuffer;
import java.nio.channels.CancelledKeyException;
import java.nio.channels.ReadableByteChannel;
@@ -61,7 +60,7 @@ public class MMOConnection<T extends MMOClient<?>>
private T _client;
public MMOConnection(final SelectorThread<T> selectorThread, final Socket socket, final SelectionKey key, boolean tcpNoDelay)
public MMOConnection(final SelectorThread<T> selectorThread, final Socket socket, final SelectionKey key)
{
_selectorThread = selectorThread;
_socket = socket;
@@ -72,15 +71,6 @@ public class MMOConnection<T extends MMOClient<?>>
_selectionKey = key;
_sendQueue = new NioNetStackList<>();
try
{
_socket.setTcpNoDelay(tcpNoDelay);
}
catch (SocketException e)
{
e.printStackTrace();
}
}
final void setClient(final T client)

10
trunk/java/com/l2jserver/commons/mmocore/SelectorConfig.java
View File

@@ -51,14 +51,4 @@ public final class SelectorConfig
* 10-30 for an latency/troughput trade-off based on your needs.<BR>
*/
public int SLEEP_TIME = 10;
/**
* Used to enable/disable TCP_NODELAY which disable/enable Nagle's algorithm.<BR>
* <BR>
* Nagle's algorithm try to conserve bandwidth by minimizing the number of segments that are sent. When applications wish to decrease network latency and increase performance, they can disable Nagle's algorithm (that is enable TCP_NODELAY). Data will be sent earlier, at the cost of an increase
* in bandwidth consumption. The Nagle's algorithm is described in RFC 896.<BR>
* <BR>
* Summary, data will be sent earlier, thus lowering the ping, at the cost of a small increase in bandwidth consumption.
*/
public boolean TCP_NODELAY = false;
}

33
trunk/java/com/l2jserver/commons/mmocore/SelectorThread.java
View File

@@ -28,8 +28,7 @@ import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.LinkedList;
/**
* Parts of design based on network core from WoodenGil
@@ -55,7 +54,6 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
private final int MAX_SEND_PER_PASS;
private final int MAX_READ_PER_PASS;
private final long SLEEP_TIME;
public boolean TCP_NODELAY;
// Main Buffers
private final ByteBuffer DIRECT_WRITE_BUFFER;
private final ByteBuffer WRITE_BUFFER;
@@ -63,7 +61,7 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
// String Buffer
private final NioNetStringBuffer STRING_BUFFER;
// ByteBuffers General Purpose Pool
private final Queue<ByteBuffer> _bufferPool;
private final LinkedList<ByteBuffer> _bufferPool;
// Pending Close
private final NioNetStackList<MMOConnection<T>> _pendingClose;
@@ -78,7 +76,6 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
MAX_SEND_PER_PASS = sc.MAX_SEND_PER_PASS;
MAX_READ_PER_PASS = sc.MAX_READ_PER_PASS;
SLEEP_TIME = sc.SLEEP_TIME;
TCP_NODELAY = sc.TCP_NODELAY;
DIRECT_WRITE_BUFFER = ByteBuffer.allocateDirect(sc.WRITE_BUFFER_SIZE).order(BYTE_ORDER);
WRITE_BUFFER = ByteBuffer.wrap(new byte[sc.WRITE_BUFFER_SIZE]).order(BYTE_ORDER);
@@ -87,11 +84,11 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
STRING_BUFFER = new NioNetStringBuffer(64 * 1024);
_pendingClose = new NioNetStackList<>();
_bufferPool = new ConcurrentLinkedQueue<>();
_bufferPool = new LinkedList<>();
for (int i = 0; i < HELPER_BUFFER_COUNT; i++)
{
_bufferPool.add(ByteBuffer.wrap(new byte[HELPER_BUFFER_SIZE]).order(BYTE_ORDER));
_bufferPool.addLast(ByteBuffer.wrap(new byte[HELPER_BUFFER_SIZE]).order(BYTE_ORDER));
}
_acceptFilter = acceptFilter;
@@ -127,7 +124,7 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
return ByteBuffer.wrap(new byte[HELPER_BUFFER_SIZE]).order(BYTE_ORDER);
}
return _bufferPool.remove();
return _bufferPool.removeFirst();
}
final void recycleBuffer(ByteBuffer buf)
@@ -135,7 +132,7 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
if (_bufferPool.size() < HELPER_BUFFER_COUNT)
{
buf.clear();
_bufferPool.add(buf);
_bufferPool.addLast(buf);
}
}
@@ -201,16 +198,9 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
{
while (!_pendingClose.isEmpty())
{
try
{
con = _pendingClose.removeFirst();
writeClosePacket(con);
closeConnectionImpl(con.getSelectionKey(), con);
}
catch (Exception e)
{
e.printStackTrace();
}
con = _pendingClose.removeFirst();
writeClosePacket(con);
closeConnectionImpl(con.getSelectionKey(), con);
}
}
@@ -259,7 +249,7 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
{
sc.configureBlocking(false);
SelectionKey clientKey = sc.register(_selector, SelectionKey.OP_READ);
con = new MMOConnection<>(this, sc.socket(), clientKey, TCP_NODELAY);
con = new MMOConnection<>(this, sc.socket(), clientKey);
con.setClient(_clientFactory.create(con));
clientKey.attach(con);
}
@@ -408,7 +398,6 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
}
return true;
}
// we don`t have enough bytes for the dataPacket so we need
// to read
key.interestOps(key.interestOps() | SelectionKey.OP_READ);
@@ -615,8 +604,6 @@ public final class SelectorThread<T extends MMOClient<?>> extends Thread
// set the write buffer
sp._buf = WRITE_BUFFER;
// set the client.
sp._client = client;
// write content to buffer
sp.write();
// delete the write buffer

6
trunk/java/com/l2jserver/commons/mmocore/SendablePacket.java
View File

@@ -45,8 +45,7 @@ public abstract class SendablePacket<T extends MMOClient<?>> extends AbstractPac
*/
protected final void writeC(final boolean data)
{
int value = data ? 0x01 : 0x00;
_buf.put((byte) value);
_buf.put((byte) (data ? 0x01 : 0x00));
}
/**
@@ -96,8 +95,7 @@ public abstract class SendablePacket<T extends MMOClient<?>> extends AbstractPac
*/
protected final void writeD(final boolean value)
{
int val = value ? 0x01 : 0x00;
_buf.putInt(val);
_buf.putInt(value ? 0x01 : 0x00);
}
/**