Jump to content
  • 0

Question

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
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


  • Posts

    • <dailyReward days="28" autoOpen="true" minimumOnlineTimeSeconds="30" oneRewardPerIP="true" resetIfMissDay="true">   For now, I have these settings in the XML—this is the V1 version I created, though I plan to make further improvements over time. Of course, I’ll also add more protections—MAC, HWID, and perhaps others like account-based restrictions—to make it more secure. We can also implement non-tradable items to further enhance the system's security. I’ll keep posting updates and refining both the system and the interface. I might make a video tomorrow; if you look at the top, you'll see the "auto-open" feature can be toggled on or off, allowing users to rely solely on the `.daily` command. Cheers! Note: If I sell it in this state, I’ll provide support and roll out updates to users. I’m not forcing anyone to buy anything; I’d even provide the patch files so that anyone with the necessary skills can add features, modify it, or improve it further.
    • If the problem is that the target is lost, the action of aiming at another character, upon losing collision, does not allow aiming.   This one works as it should, allowing you to target characters
    • MICROTEXT AND WATERMARKS BREAK MOST RENDERINGS Microtext and watermarks aren’t just small decorative details. They are one of the most common reasons a document fails verification, even when it looks decent at first glance. The issue is that these elements are almost impossible to reproduce “by eye.” Microtext requires precise geometry and legibility at a very small size, while a watermark needs the correct density, transparency, and accurate placement relative to other security features. Any deviation becomes obvious during detailed inspection. ▪ What’s most often done wrong: - microtext is drawn too thick or blurry - the watermark is made either too visible or almost invisible - the positioning between microtext and watermark is ignored - the original printing technology isn’t taken into account when choosing density and shape - The stronger the document’s security features, the less room there is for approximation. What matters here isn’t visual similarity, but accurate reproduction of the original technical characteristics. If your document contains microtext and watermarks, this is always an area that requires extra attention. Write to us in DMs. We’ll review your case and point out exactly which details need the highest precision during rendering. › TG: @mustang_service_ms ( https:// t.me/ mustang_service_ms ) › Channel: Mustang Service ( https:// t.me/ +JPpJCETg-xM1NjNl ) #drawing #microtext #photoshop #editing #watermarks
    • GoldRush launches tomorrow! July 18 16:00 GMT+3 Europe / International Register your account in the website, connect wallet and be ready to dominate!
  • 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..