pa/eqemu-server
2
0
Fork 0
mirror of https://github.com/EQEmu/Server.git synced 2026-03-26 01:12:26 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

[Telnet] Automatically prune connections

Browse Source
This commit is contained in:
Akkadius 2024-12-14 21:16:14 -06:00
parent 4493ebebab
commit aa8b0570d6
2 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
common/net/console_server_connection.cpp
View File

@ -4,6 +4,7 @@
#include "../eqemu_logsys.h" #include "../eqemu_logsys.h"
#include "../servertalk.h" #include "../servertalk.h"
#include "../rulesys.h" #include "../rulesys.h"
#include "../event/timer.h"
#include <fmt/format.h> #include <fmt/format.h>
EQ::Net::ConsoleServerConnection::ConsoleServerConnection(ConsoleServer *parent, std::shared_ptr<TCPConnection> connection) EQ::Net::ConsoleServerConnection::ConsoleServerConnection(ConsoleServer *parent, std::shared_ptr<TCPConnection> connection)
@ -21,7 +22,13 @@ EQ::Net::ConsoleServerConnection::ConsoleServerConnection(ConsoleServer *parent,
m_connection->OnDisconnect(std::bind(&ConsoleServerConnection::OnDisconnect, this, std::placeholders::_1)); m_connection->OnDisconnect(std::bind(&ConsoleServerConnection::OnDisconnect, this, std::placeholders::_1));
m_connection->Start(); m_connection->Start();
ClearBuffer(); ClearBuffer();
m_keepalive = std::make_unique<EQ::Timer>(1000, true, [this](EQ::Timer *t) {
EQ::Net::DynamicPacket clear;
clear.PutUInt8(0, 0);
m_connection->Write((const char*)clear.Data(), clear.Length());
});
auto addr = m_connection->RemoteIP(); auto addr = m_connection->RemoteIP();
SendLine(fmt::format("Establishing connection from: {0}:{1}", addr, m_connection->RemotePort())); SendLine(fmt::format("Establishing connection from: {0}:{1}", addr, m_connection->RemotePort()));
@ -85,12 +92,12 @@ void EQ::Net::ConsoleServerConnection::QueueMessage(const std::string &msg)
} }
else { else {
std::string cmd(m_line, m_line + m_cursor); std::string cmd(m_line, m_line + m_cursor);
size_t len = m_user.length() + 2 + cmd.length(); size_t len = m_user.length() + 2 + cmd.length();
for (size_t i = 0; i < len; ++i) { for (size_t i = 0; i < len; ++i) {
Send("\x08"); Send("\x08");
} }
if (msg.length() < cmd.length()) { if (msg.length() < cmd.length()) {
Send(msg); Send(msg);
size_t blank_spaces = 2 + cmd.length() - msg.length(); size_t blank_spaces = 2 + cmd.length() - msg.length();
@ -227,6 +234,8 @@ void EQ::Net::ConsoleServerConnection::OnRead(TCPConnection *c, const unsigned c
void EQ::Net::ConsoleServerConnection::OnDisconnect(TCPConnection *c) void EQ::Net::ConsoleServerConnection::OnDisconnect(TCPConnection *c)
{ {
LogInfo("Console connection disconnected");
m_parent->ConnectionDisconnected(this); m_parent->ConnectionDisconnected(this);
} }

2
common/net/console_server_connection.h
View File

@ -1,6 +1,7 @@
#pragma once #pragma once
#include "tcp_server.h" #include "tcp_server.h"
#include "../event/timer.h"
#include <memory> #include <memory>
#include <map> #include <map>
@ -58,6 +59,7 @@ namespace EQ
int m_user_id; int m_user_id;
int m_admin; int m_admin;
bool m_accept_messages; bool m_accept_messages;
std::unique_ptr<EQ::Timer> m_keepalive;
size_t m_cursor; size_t m_cursor;
char m_line[MaxConsoleLineLength]; char m_line[MaxConsoleLineLength];