Jump to content
MaxCheaters Official Group on Discord
Top.MaxCheaters.com is now OPEN – Lineage 2 Top Listing
L2JForge.live Interlude Premium Emulator
  • 0

CLOSE LOGINSERVER

giwrgos_

Asked by giwrgos_,

 Share

Question

giwrgos_ Apprentice

giwrgos_

Posted
Posted

kalhspera antimetopizw ena problima me to login server enw einai ok kai ton exw valei na kanei auto restart mono o login server ana 12 wres kai enw ola ok meta apo kana 2 meres peytei to login apo mono toy den katalavainw to logo kai sto log toy gameserver kanei sinexeia

https://prnt.sc/1mhrgu1   einai apo to log toy gameserver

to pack poy exw einai fandc  h5

kai o server trexei local gia test

episeis exw ton idio se live kai kanei to idio 

mhpws kapoios mpwrei na me bohthisei na to lisw?

 

tha valw kai to java 

 

 

package l2r.gameserver.network.loginservercon;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.nio.channels.CancelledKeyException;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.ArrayDeque;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import l2r.gameserver.ThreadPoolManager;
import l2r.gameserver.config.templates.HostInfo;
import l2r.gameserver.config.xml.holder.HostsConfigHolder;
import l2r.gameserver.network.GameClient;
import l2r.gameserver.network.loginservercon.gspackets.AuthRequest;

public class AuthServerCommunication extends Thread
{
    private static final Logger _log = LoggerFactory.getLogger(AuthServerCommunication.class);
    
    private static final AuthServerCommunication instance = new AuthServerCommunication();
    
    public static final AuthServerCommunication getInstance()
    {
        return instance;
    }
    
    private final Map<String, GameClient> waitingClients = new HashMap<>();
    private final Map<String, GameClient> authedClients = new HashMap<>();
    
    private final ReadWriteLock lock = new ReentrantReadWriteLock();
    private final Lock readLock = lock.readLock();
    private final Lock writeLock = lock.writeLock();
    
    private final ByteBuffer readBuffer = ByteBuffer.allocate(64 * 1024).order(ByteOrder.LITTLE_ENDIAN);
    private final ByteBuffer writeBuffer = ByteBuffer.allocate(64 * 1024).order(ByteOrder.LITTLE_ENDIAN);
    
    private final Queue<SendablePacket> sendQueue = new ArrayDeque<>();
    private final Lock sendLock = new ReentrantLock();
    
    private final AtomicBoolean isPengingWrite = new AtomicBoolean();
    
    private SelectionKey key;
    private Selector selector;
    
    private boolean shutdown;
    private boolean restart;
    
    private AuthServerCommunication()
    {
        try
        {
            selector = Selector.open();
        }
        catch (IOException e)
        {
            _log.error("Error while creating Auth Server Communication!", e);
        }
    }
    
    
    
    
    
    
    
    
    
    private void connect() throws IOException
    {
        HostInfo hostInfo = HostsConfigHolder.getInstance().getAuthServerHost();
        
        _log.info("Connecting to authserver on " + hostInfo.getIP() + ":" + hostInfo.getPort());
        
        // _log.info("Connecting to authserver on " + Config.GAME_SERVER_LOGIN_HOST + ":" + Config.GAME_SERVER_LOGIN_PORT);
        
        SocketChannel channel = SocketChannel.open();
        channel.configureBlocking(false);
        
        key = channel.register(selector, SelectionKey.OP_CONNECT);
        channel.connect(new InetSocketAddress(hostInfo.getIP(), hostInfo.getPort()));
        // channel.connect(new InetSocketAddress(Config.GAME_SERVER_LOGIN_HOST, Config.GAME_SERVER_LOGIN_PORT));
    }
    
    public void sendPacket(SendablePacket packet)
    {
        if (isShutdown())
        {
            return;
        }
        
        boolean wakeUp;
        
        sendLock.lock();
        try
        {
            sendQueue.add(packet);
            wakeUp = enableWriteInterest();
        }
        catch (CancelledKeyException e)
        {
            return;
        }
        finally
        {
            sendLock.unlock();
        }
        
        if (wakeUp)
        {
            selector.wakeup();
        }
    }
    
    private boolean disableWriteInterest() throws CancelledKeyException
    {
        if (isPengingWrite.compareAndSet(true, false))
        {
            key.interestOps(key.interestOps() & ~SelectionKey.OP_WRITE);
            return true;
        }
        return false;
    }
    
    private boolean enableWriteInterest() throws CancelledKeyException
    {
        if (isPengingWrite.getAndSet(true) == false)
        {
            key.interestOps(key.interestOps() | SelectionKey.OP_WRITE);
            return true;
        }
        return false;
    }
    
    protected ByteBuffer getReadBuffer()
    {
        return readBuffer;
    }
    
    protected ByteBuffer getWriteBuffer()
    {
        return writeBuffer;
    }
    
    @Override
    public void run()
    {
        Set<SelectionKey> keys;
        Iterator<SelectionKey> iterator;
        SelectionKey key;
        int opts;
        
        while (!shutdown)
        {
            restart = false;
            
            try
            {
                loop: while (!isShutdown())
                {
                    connect();
                    
                    selector.select(5000L);
                    keys = selector.selectedKeys();
                    if (keys.isEmpty())
                    {
                        throw new IOException("Connection timeout.");
                    }
                    
                    iterator = keys.iterator();
                    
                    try
                    {
                        while (iterator.hasNext())
                        {
                            key = iterator.next();
                            iterator.remove();
                            
                            opts = key.readyOps();
                            
                            switch (opts)
                            {
                                case SelectionKey.OP_CONNECT:
                                    connect(key);
                                    break loop;
                            }
                        }
                    }
                    catch (CancelledKeyException e)
                    {
                        // Exit selector loop
                        break;
                    }
                }
                
                loop: while (!isShutdown())
                {
                    selector.select();
                    keys = selector.selectedKeys();
                    iterator = keys.iterator();
                    
                    try
                    {
                        while (iterator.hasNext())
                        {
                            key = iterator.next();
                            iterator.remove();
                            
                            opts = key.readyOps();
                            
                            switch (opts)
                            {
                                case SelectionKey.OP_WRITE:
                                    write(key);
                                    break;
                                case SelectionKey.OP_READ:
                                    read(key);
                                    break;
                                case SelectionKey.OP_READ | SelectionKey.OP_WRITE:
                                    write(key);
                                    read(key);
                                    break;
                            }
                        }
                    }
                    catch (CancelledKeyException e)
                    {
                        // Exit selector loop
                        break loop;
                    }
                }
            }
            catch(IOException e)
            {
                _log.info("Loginserver Restart Ore Down Not available, trying to reconnect...");
                
            }

            close();
            try
            {
                Thread.sleep(5000L);
            }
            catch (InterruptedException e)
            {

            }
        }
    }

    
    private void read(SelectionKey key) throws IOException
    {
        SocketChannel channel = (SocketChannel) key.channel();
        ByteBuffer buf = getReadBuffer();
        
        int count;
        
        count = channel.read(buf);
        
        if (count == -1)
        {
            throw new IOException("End of stream.");
        }
        
        if (count == 0)
        {
            return;
        }
        
        buf.flip();
        
        while (tryReadPacket(key, buf))
        {
            
        }
    }
    
    private boolean tryReadPacket(SelectionKey key, ByteBuffer buf) throws IOException
    {
        int pos = buf.position();
        // проверÑ�ем, хватает ли нам байт длÑ� чтениÑ� заголовка и не пуÑ�того тела пакета
        if (buf.remaining() > 2)
        {
            // получаем ожидаемый размер пакета
            int size = buf.getShort() & 0xffff;
            
            // проверÑ�ем корректноÑ�Ñ‚ÑŒ размера
            if (size <= 2)
            {
                throw new IOException("Incorrect packet size: <= 2");
            }
            
            // ожидаемый размер тела пакета
            size -= 2;
            
            // проверÑ�ем, хватает ли байт на чтение тела
            if (size <= buf.remaining())
            {
                // apply limit
                int limit = buf.limit();
                buf.limit(pos + size + 2);
                
                ReceivablePacket rp = PacketHandler.handlePacket(buf);
                
                if (rp != null)
                {
                    if (rp.read())
                    {
                        ThreadPoolManager.getInstance().execute(rp);
                    }
                }
                
                buf.limit(limit);
                buf.position(pos + size + 2);
                
                // закончили чтение из буфера, почиÑ�тим
                if (!buf.hasRemaining())
                {
                    buf.clear();
                    return false;
                }
                
                return true;
            }
            
            // не хватает данных на чтение тела пакета, Ñ�браÑ�ываем позицию
            buf.position(pos);
        }
        
        buf.compact();
        
        return false;
    }
    
    private void write(SelectionKey key) throws IOException
    {
        SocketChannel channel = (SocketChannel) key.channel();
        ByteBuffer buf = getWriteBuffer();
        
        boolean done;
        
        sendLock.lock();
        try
        {
            int i = 0;
            SendablePacket sp;
            while ((i++ < 64) && ((sp = sendQueue.poll()) != null))
            {
                int headerPos = buf.position();
                buf.position(headerPos + 2);
                
                sp.write();
                
                int dataSize = buf.position() - headerPos - 2;
                if (dataSize == 0)
                {
                    buf.position(headerPos);
                    continue;
                }
                
                // prepend header
                buf.position(headerPos);
                buf.putShort((short) (dataSize + 2));
                buf.position(headerPos + dataSize + 2);
            }
            
            done = sendQueue.isEmpty();
            if (done)
            {
                disableWriteInterest();
            }
        }
        finally
        {
            sendLock.unlock();
        }
        buf.flip();
        
        channel.write(buf);
        
        if (buf.remaining() > 0)
        {
            buf.compact();
            done = false;
        }
        else
        {
            buf.clear();
        }
        
        if (!done)
        {
            if (enableWriteInterest())
            {
                selector.wakeup();
            }
        }
    }
    
    private void connect(SelectionKey key) throws IOException
    {
        SocketChannel channel = (SocketChannel) key.channel();
        channel.finishConnect();
        
        key.interestOps(key.interestOps() & ~SelectionKey.OP_CONNECT);
        key.interestOps(key.interestOps() | SelectionKey.OP_READ);
        
        sendPacket(new AuthRequest());
    }
    
    private void close()
    {
        restart = !shutdown;
        
        sendLock.lock();
        try
        {
            sendQueue.clear();
        }
        finally
        {
            sendLock.unlock();
        }
        
        readBuffer.clear();
        writeBuffer.clear();
        
        isPengingWrite.set(false);
        
        try
        {
            if (key != null)
            {
                key.channel().close();
                key.cancel();
            }
        }
        catch (IOException e)
        {
        }
        
        writeLock.lock();
        try
        {
            waitingClients.clear();
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public void shutdown()
    {
        shutdown = true;
        selector.wakeup();
    }
    
    public boolean isShutdown()
    {
        return shutdown || restart;
    }
    
    public void restart()
    {
        restart = true;
        selector.wakeup();
    }
    
    public GameClient addWaitingClient(GameClient client)
    {
        writeLock.lock();
        try
        {
            return waitingClients.put(client.getLogin(), client);
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public GameClient removeWaitingClient(String account)
    {
        writeLock.lock();
        try
        {
            return waitingClients.remove(account);
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public GameClient addAuthedClient(GameClient client)
    {
        writeLock.lock();
        try
        {
            return authedClients.put(client.getLogin(), client);
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public GameClient removeAuthedClient(String login)
    {
        writeLock.lock();
        try
        {
            return authedClients.remove(login);
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public GameClient getAuthedClient(String login)
    {
        readLock.lock();
        try
        {
            return authedClients.get(login);
        }
        finally
        {
            readLock.unlock();
        }
    }
    
    public GameClient removeClient(GameClient client)
    {
        writeLock.lock();
        try
        {
            if (client.isAuthed())
            {
                return authedClients.remove(client.getLogin());
            }
            return waitingClients.remove(client.getSessionKey());
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public String[] getAccounts()
    {
        readLock.lock();
        try
        {
            return authedClients.keySet().toArray(new String[authedClients.size()]);
        }
        finally
        {
            readLock.unlock();
        }
    }
}
 

 

 

 

 

 

 

 

3 answers to this question

Recommended Posts

  • 0
Amenadiel Experienced

Amenadiel

Posted
Posted
On 8/11/2021 at 2:00 AM, giwrgos_ said:

kalhspera antimetopizw ena problima me to login server enw einai ok kai ton exw valei na kanei auto restart mono o login server ana 12 wres kai enw ola ok meta apo kana 2 meres peytei to login apo mono toy den katalavainw to logo kai sto log toy gameserver kanei sinexeia

https://prnt.sc/1mhrgu1   einai apo to log toy gameserver

to pack poy exw einai fandc  h5

kai o server trexei local gia test

episeis exw ton idio se live kai kanei to idio 

mhpws kapoios mpwrei na me bohthisei na to lisw?

 

tha valw kai to java 

 

 

package l2r.gameserver.network.loginservercon;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.nio.channels.CancelledKeyException;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.ArrayDeque;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import l2r.gameserver.ThreadPoolManager;
import l2r.gameserver.config.templates.HostInfo;
import l2r.gameserver.config.xml.holder.HostsConfigHolder;
import l2r.gameserver.network.GameClient;
import l2r.gameserver.network.loginservercon.gspackets.AuthRequest;

public class AuthServerCommunication extends Thread
{
    private static final Logger _log = LoggerFactory.getLogger(AuthServerCommunication.class);
    
    private static final AuthServerCommunication instance = new AuthServerCommunication();
    
    public static final AuthServerCommunication getInstance()
    {
        return instance;
    }
    
    private final Map<String, GameClient> waitingClients = new HashMap<>();
    private final Map<String, GameClient> authedClients = new HashMap<>();
    
    private final ReadWriteLock lock = new ReentrantReadWriteLock();
    private final Lock readLock = lock.readLock();
    private final Lock writeLock = lock.writeLock();
    
    private final ByteBuffer readBuffer = ByteBuffer.allocate(64 * 1024).order(ByteOrder.LITTLE_ENDIAN);
    private final ByteBuffer writeBuffer = ByteBuffer.allocate(64 * 1024).order(ByteOrder.LITTLE_ENDIAN);
    
    private final Queue<SendablePacket> sendQueue = new ArrayDeque<>();
    private final Lock sendLock = new ReentrantLock();
    
    private final AtomicBoolean isPengingWrite = new AtomicBoolean();
    
    private SelectionKey key;
    private Selector selector;
    
    private boolean shutdown;
    private boolean restart;
    
    private AuthServerCommunication()
    {
        try
        {
            selector = Selector.open();
        }
        catch (IOException e)
        {
            _log.error("Error while creating Auth Server Communication!", e);
        }
    }
    
    
    
    
    
    
    
    
    
    private void connect() throws IOException
    {
        HostInfo hostInfo = HostsConfigHolder.getInstance().getAuthServerHost();
        
        _log.info("Connecting to authserver on " + hostInfo.getIP() + ":" + hostInfo.getPort());
        
        // _log.info("Connecting to authserver on " + Config.GAME_SERVER_LOGIN_HOST + ":" + Config.GAME_SERVER_LOGIN_PORT);
        
        SocketChannel channel = SocketChannel.open();
        channel.configureBlocking(false);
        
        key = channel.register(selector, SelectionKey.OP_CONNECT);
        channel.connect(new InetSocketAddress(hostInfo.getIP(), hostInfo.getPort()));
        // channel.connect(new InetSocketAddress(Config.GAME_SERVER_LOGIN_HOST, Config.GAME_SERVER_LOGIN_PORT));
    }
    
    public void sendPacket(SendablePacket packet)
    {
        if (isShutdown())
        {
            return;
        }
        
        boolean wakeUp;
        
        sendLock.lock();
        try
        {
            sendQueue.add(packet);
            wakeUp = enableWriteInterest();
        }
        catch (CancelledKeyException e)
        {
            return;
        }
        finally
        {
            sendLock.unlock();
        }
        
        if (wakeUp)
        {
            selector.wakeup();
        }
    }
    
    private boolean disableWriteInterest() throws CancelledKeyException
    {
        if (isPengingWrite.compareAndSet(true, false))
        {
            key.interestOps(key.interestOps() & ~SelectionKey.OP_WRITE);
            return true;
        }
        return false;
    }
    
    private boolean enableWriteInterest() throws CancelledKeyException
    {
        if (isPengingWrite.getAndSet(true) == false)
        {
            key.interestOps(key.interestOps() | SelectionKey.OP_WRITE);
            return true;
        }
        return false;
    }
    
    protected ByteBuffer getReadBuffer()
    {
        return readBuffer;
    }
    
    protected ByteBuffer getWriteBuffer()
    {
        return writeBuffer;
    }
    
    @Override
    public void run()
    {
        Set<SelectionKey> keys;
        Iterator<SelectionKey> iterator;
        SelectionKey key;
        int opts;
        
        while (!shutdown)
        {
            restart = false;
            
            try
            {
                loop: while (!isShutdown())
                {
                    connect();
                    
                    selector.select(5000L);
                    keys = selector.selectedKeys();
                    if (keys.isEmpty())
                    {
                        throw new IOException("Connection timeout.");
                    }
                    
                    iterator = keys.iterator();
                    
                    try
                    {
                        while (iterator.hasNext())
                        {
                            key = iterator.next();
                            iterator.remove();
                            
                            opts = key.readyOps();
                            
                            switch (opts)
                            {
                                case SelectionKey.OP_CONNECT:
                                    connect(key);
                                    break loop;
                            }
                        }
                    }
                    catch (CancelledKeyException e)
                    {
                        // Exit selector loop
                        break;
                    }
                }
                
                loop: while (!isShutdown())
                {
                    selector.select();
                    keys = selector.selectedKeys();
                    iterator = keys.iterator();
                    
                    try
                    {
                        while (iterator.hasNext())
                        {
                            key = iterator.next();
                            iterator.remove();
                            
                            opts = key.readyOps();
                            
                            switch (opts)
                            {
                                case SelectionKey.OP_WRITE:
                                    write(key);
                                    break;
                                case SelectionKey.OP_READ:
                                    read(key);
                                    break;
                                case SelectionKey.OP_READ | SelectionKey.OP_WRITE:
                                    write(key);
                                    read(key);
                                    break;
                            }
                        }
                    }
                    catch (CancelledKeyException e)
                    {
                        // Exit selector loop
                        break loop;
                    }
                }
            }
            catch(IOException e)
            {
                _log.info("Loginserver Restart Ore Down Not available, trying to reconnect...");
                
            }

            close();
            try
            {
                Thread.sleep(5000L);
            }
            catch (InterruptedException e)
            {

            }
        }
    }

    
    private void read(SelectionKey key) throws IOException
    {
        SocketChannel channel = (SocketChannel) key.channel();
        ByteBuffer buf = getReadBuffer();
        
        int count;
        
        count = channel.read(buf);
        
        if (count == -1)
        {
            throw new IOException("End of stream.");
        }
        
        if (count == 0)
        {
            return;
        }
        
        buf.flip();
        
        while (tryReadPacket(key, buf))
        {
            
        }
    }
    
    private boolean tryReadPacket(SelectionKey key, ByteBuffer buf) throws IOException
    {
        int pos = buf.position();
        // проверÑ�ем, хватает ли нам байт длÑ� чтениÑ� заголовка и не пуÑ�того тела пакета
        if (buf.remaining() > 2)
        {
            // получаем ожидаемый размер пакета
            int size = buf.getShort() & 0xffff;
            
            // проверÑ�ем корректноÑ�Ñ‚ÑŒ размера
            if (size <= 2)
            {
                throw new IOException("Incorrect packet size: <= 2");
            }
            
            // ожидаемый размер тела пакета
            size -= 2;
            
            // проверÑ�ем, хватает ли байт на чтение тела
            if (size <= buf.remaining())
            {
                // apply limit
                int limit = buf.limit();
                buf.limit(pos + size + 2);
                
                ReceivablePacket rp = PacketHandler.handlePacket(buf);
                
                if (rp != null)
                {
                    if (rp.read())
                    {
                        ThreadPoolManager.getInstance().execute(rp);
                    }
                }
                
                buf.limit(limit);
                buf.position(pos + size + 2);
                
                // закончили чтение из буфера, почиÑ�тим
                if (!buf.hasRemaining())
                {
                    buf.clear();
                    return false;
                }
                
                return true;
            }
            
            // не хватает данных на чтение тела пакета, Ñ�браÑ�ываем позицию
            buf.position(pos);
        }
        
        buf.compact();
        
        return false;
    }
    
    private void write(SelectionKey key) throws IOException
    {
        SocketChannel channel = (SocketChannel) key.channel();
        ByteBuffer buf = getWriteBuffer();
        
        boolean done;
        
        sendLock.lock();
        try
        {
            int i = 0;
            SendablePacket sp;
            while ((i++ < 64) && ((sp = sendQueue.poll()) != null))
            {
                int headerPos = buf.position();
                buf.position(headerPos + 2);
                
                sp.write();
                
                int dataSize = buf.position() - headerPos - 2;
                if (dataSize == 0)
                {
                    buf.position(headerPos);
                    continue;
                }
                
                // prepend header
                buf.position(headerPos);
                buf.putShort((short) (dataSize + 2));
                buf.position(headerPos + dataSize + 2);
            }
            
            done = sendQueue.isEmpty();
            if (done)
            {
                disableWriteInterest();
            }
        }
        finally
        {
            sendLock.unlock();
        }
        buf.flip();
        
        channel.write(buf);
        
        if (buf.remaining() > 0)
        {
            buf.compact();
            done = false;
        }
        else
        {
            buf.clear();
        }
        
        if (!done)
        {
            if (enableWriteInterest())
            {
                selector.wakeup();
            }
        }
    }
    
    private void connect(SelectionKey key) throws IOException
    {
        SocketChannel channel = (SocketChannel) key.channel();
        channel.finishConnect();
        
        key.interestOps(key.interestOps() & ~SelectionKey.OP_CONNECT);
        key.interestOps(key.interestOps() | SelectionKey.OP_READ);
        
        sendPacket(new AuthRequest());
    }
    
    private void close()
    {
        restart = !shutdown;
        
        sendLock.lock();
        try
        {
            sendQueue.clear();
        }
        finally
        {
            sendLock.unlock();
        }
        
        readBuffer.clear();
        writeBuffer.clear();
        
        isPengingWrite.set(false);
        
        try
        {
            if (key != null)
            {
                key.channel().close();
                key.cancel();
            }
        }
        catch (IOException e)
        {
        }
        
        writeLock.lock();
        try
        {
            waitingClients.clear();
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public void shutdown()
    {
        shutdown = true;
        selector.wakeup();
    }
    
    public boolean isShutdown()
    {
        return shutdown || restart;
    }
    
    public void restart()
    {
        restart = true;
        selector.wakeup();
    }
    
    public GameClient addWaitingClient(GameClient client)
    {
        writeLock.lock();
        try
        {
            return waitingClients.put(client.getLogin(), client);
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public GameClient removeWaitingClient(String account)
    {
        writeLock.lock();
        try
        {
            return waitingClients.remove(account);
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public GameClient addAuthedClient(GameClient client)
    {
        writeLock.lock();
        try
        {
            return authedClients.put(client.getLogin(), client);
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public GameClient removeAuthedClient(String login)
    {
        writeLock.lock();
        try
        {
            return authedClients.remove(login);
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public GameClient getAuthedClient(String login)
    {
        readLock.lock();
        try
        {
            return authedClients.get(login);
        }
        finally
        {
            readLock.unlock();
        }
    }
    
    public GameClient removeClient(GameClient client)
    {
        writeLock.lock();
        try
        {
            if (client.isAuthed())
            {
                return authedClients.remove(client.getLogin());
            }
            return waitingClients.remove(client.getSessionKey());
        }
        finally
        {
            writeLock.unlock();
        }
    }
    
    public String[] getAccounts()
    {
        readLock.lock();
        try
        {
            return authedClients.keySet().toArray(new String[authedClients.size()]);
        }
        finally
        {
            readLock.unlock();
        }
    }
}
 

 

 

 

 

 

 

 

put a login from another pack

Create an account or sign in to comment

You need to be a member in order to leave a comment

Create an account

Sign up for a new account in our community. It's easy!

Register a new account

Sign in

Already have an account? Sign in here.

Sign In Now
 Share
Go to question listing


  • Posts

    • VPSLab
      — VPSLAB — Fast & Private RDP/VPS | 100% Instant Setup

      By VPSLab · Posted

      Active & Taking orders!
    • Daupz
      [L2J] GoldRush Mid-Rate

      By Daupz · Posted

      GoldRush launches tomorrow! July 18 16:00 GMT+3 Europe / International Register your account in the website, connect wallet and be ready to dominate!
    • Celestine
      [L2OFF] L2Exalta Legacy

      By Celestine · Posted

      🏰 L2EXALTA LEGACY — Interlude x45 📅 Grand Opening: 31/07/2026 — 21:30 (GMT+3) 🌐 Website: https://l2exalta.org/ 💬 Discord: https://discord.gg/zNTCZD4AcT 📌 Wiki: https://l2exalta.org/en/wiki.html#progression   ⚙️ MAIN INFO Chronicle : Interlude Rates : x45 Adena : x50 Spoil : x1 Drop : x5 Safe Enchant : +3 Files : L2OFF   💰 ECONOMY EX Coin : dynamic market currency, mined from monsters, Raid Bosses and Grand Bosses value fluctuates over time Exalta Vouchers : premium currency used for store, donations and EX Coin exchange Exchange : convert EX Coin into Exalta Vouchers Investment options : choose safer or riskier market strategies with EX Coin   ⚔️ PROGRESSION & GEAR Exalta Armors : signature top-tier gear line Forge System : upgrade weapons, armor and jewels with risk/reward mechanics Raid Boss progression tied to materials and prestige   🤖 AUTOFARM Access : Auto Hunting button, bottom-right UI Duration : controlled via tickets or in-game currency Route Mode : record custom farm routes Support Mode : healer/support builds auto-follow, heal and assist party Smart targeting logic with class-specific behavior (mage/archer/melee/support) Captcha designed not to interrupt legitimate AutoFarm sessions   🧪 BUFFER Exalta Buffer NPC/interface Scheme Buffer : save multiple buff loadouts Class presets for mage, fighter, support, PvP   🛠️ SMART GADGETS / QOL Autoloot filter Drop value tracker Boss timer tools Farm stats tracker Auto-consume system In-game server assistant   🗺️ DUNGEON FINDER / PVE Party matching with roles (Tank / Healer / DPS) Ready-check before teleport Monastery of Silence custom PvE zone Party-based reward structure   🎟️ DAILY PROGRESS / EXALTA PASS Daily and weekly tasks (farm, PvP, boss, check-in) Premium Pass track with extra rewards Monastery Daily Quest Reward boards for claiming progress   🏠 HOUSING & EXPEDITIONS Player residences with service NPCs Exalta Spirit Expeditions to themed territories Rewards vary by territory Owner-only access   🏆 PVP / TOURNAMENT Scheduled Tournament system Ranking points from wins/participation Spectator Mode for watching live matches PvP Statues for top-ranked players Anti-feed protections   🛡️ CLAN CONTENT Clan Civil War battlefield event Clan Dungeon Raid content DPS Meter for contribution tracking Support Credit system Classic siege/clan politics preserved   🏪 AUCTION / SHOPS Auction House with seller fee Black Market Dealer (limited-time special offers) Custom shops and multisells Confirmation prompts on purchases/sales   💳 DONATIONS / VIP Donation rewards linked to Exalta Vouchers VIP tiers with comfort/cosmetic bonuses Premium store Gift/promo codes for events   🎥 STREAMER / COMMUNITY Streamer Panel with visible stream links Viewer rewards system Streamer Points for cosmetics/vouchers In-game voice chat (global/party/clan/alliance/command)   🔒 FAIR PLAY Strong Anti-Bot protection Reward protection tied to valid client state Captcha on suspicious activity Staff investigation tools No bots, packet tools or modified clients allowed   👑 GRANDBOSS SPAWNS Orfen : 1 day + 1h random Core : 1 day + 1h random Queen Ant : 1 day 6h + 1h random Zaken : 2 days 12h + 1h random Baium : 5 days + 1h random Antharas : 8 days + 1h random Valakas : 11 days + 1h random   🏅 OLYMPIAD Runs Thursday, Friday, Saturday Heroes change monthly Balanced and fair matchmaking
    • 911reg
      WTB no collision characters

      By 911reg · Posted

      yup basically another one just in case https://drive.google.com/file/d/1UtccbD9e50x3WEnQBab2PTZnBHwpcGYM/view?usp=sharing LineageWarrior.FMagic (CollideActors = True; > False) LineageWarrior.FOrc (CollideActors = True; > False) LineageWarrior.FShaman (CollideActors = True; > False) LineageWarrior.MDarkElf (CollideActors = True; > False) LineageWarrior.MDwarf (CollideActors = True; > False) LineageWarrior.MElf (CollideActors = True; > False) LineageWarrior.MFighter (CollideActors = True; > False) LineageWarrior.MMagic (CollideActors = True; > False) LineageWarrior.MOrc (CollideActors = True; > False) LineageWarrior.MShaman (CollideActors = True; > False) LineageWarrior.FDwarf (CollideActors = True; > False) LineageWarrior.FElf (CollideActors = True; > False) LineageWarrior.FFighter (CollideActors = True; > False)
    • Seamless
      Sell daily reward 28 days sell

      By Seamless · Posted

      @l2naylondev Requiring a player to log in just for the sake of logging  seems exploitable. Someone could log in only to claim the reward and immediately leave, or repeatedly change their ip. So i guess  are there are additional protections in place ? such as locking the reward by account, character , and ip. It would also be useful to add a playtime requirement. For example, after logging in, the player would need to remain active for at least x playtime  before getting the reward or other parameters configurable by the xml.  I suggest improving the system before selling it. 

  • Topics

×
×
  • Create New...

Important Information

This community uses essential cookies to function properly. Non-essential cookies and third-party services are used only with your consent. Read our Privacy Policy and We have placed cookies on your device to help make this website better. You can adjust your cookie settings, otherwise we'll assume you're okay to continue..