mirror of
https://github.com/thunderbrewhq/thunderbrew
synced 2025-08-08 08:20:42 +03:00
Compare commits
No commits in common. "d1fbb06d839c7d719449d158193a6553f8dc620b" and "41dc426db3ae4289cb15c483a21024e6267fe88b" have entirely different histories.
d1fbb06d83
...
41dc426db3
@ -142,12 +142,6 @@ const char* ClientServices::GetErrorToken(uint32_t token) {
|
||||
}
|
||||
}
|
||||
|
||||
bool ClientServices::ValidDisconnect(const void* client) {
|
||||
STORM_ASSERT(client);
|
||||
STORM_ASSERT(ClientServices::s_currentConnection);
|
||||
return client == ClientServices::s_currentConnection;
|
||||
}
|
||||
|
||||
void ClientServices::ConnectToSelectedServer() {
|
||||
if (!ClientServices::s_selectRealmInfoValid && !ClientServices::SetSelectedRealmInfo(0)) {
|
||||
ClientServices::Connection()->Complete(0, 39);
|
||||
|
@ -33,7 +33,6 @@ class ClientServices : public LoginResponse {
|
||||
|
||||
// Static functions
|
||||
static const char* GetErrorToken(uint32_t token);
|
||||
static bool ValidDisconnect(const void* client);
|
||||
static void ConnectToSelectedServer();
|
||||
static ClientConnection* Connection();
|
||||
static ClientServices* GetInstance();
|
||||
|
@ -171,19 +171,6 @@ void ConsoleWriteA(const char* str, COLOR_T color, ...) {
|
||||
}
|
||||
}
|
||||
|
||||
void ConsolePrintf(char const* str, ...) {
|
||||
char buffer[4096] = { 0 };
|
||||
|
||||
if (str != nullptr && str[0] != '\0') {
|
||||
va_list list;
|
||||
va_start(list, str);
|
||||
vsnprintf(buffer, sizeof(buffer), str, list);
|
||||
va_end(list);
|
||||
|
||||
ConsoleWrite(buffer, DEFAULT_COLOR);
|
||||
}
|
||||
}
|
||||
|
||||
void MoveLinePtr(int32_t direction, int32_t modifier) {
|
||||
CONSOLELINE* lineptr = s_currlineptr;
|
||||
|
||||
|
@ -11,7 +11,6 @@
|
||||
|
||||
void ConsoleWrite(const char* str, COLOR_T color);
|
||||
void ConsoleWriteA(const char* str, COLOR_T color, ...);
|
||||
void ConsolePrintf(char const* str, ...);
|
||||
|
||||
void PasteInInputLine(char* characters);
|
||||
|
||||
|
@ -1,7 +1,6 @@
|
||||
#include "glue/CGlueMgr.hpp"
|
||||
#include "glue/CRealmList.hpp"
|
||||
#include "glue/CCharacterSelection.hpp"
|
||||
#include "console/Console.hpp"
|
||||
#include "client/Client.hpp"
|
||||
#include "client/ClientServices.hpp"
|
||||
#include "gx/Coordinate.hpp"
|
||||
@ -68,7 +67,6 @@ int32_t CGlueMgr::m_reload;
|
||||
int32_t CGlueMgr::m_scandllOkayToLogIn = 1; // TODO
|
||||
float CGlueMgr::m_screenHeight;
|
||||
float CGlueMgr::m_screenWidth;
|
||||
int32_t CGlueMgr::m_clientKickReason;
|
||||
int32_t CGlueMgr::m_showedDisconnect;
|
||||
CSimpleTop* CGlueMgr::m_simpleTop;
|
||||
int32_t CGlueMgr::m_suspended;
|
||||
@ -231,63 +229,6 @@ void CGlueMgr::GetCharacterList() {
|
||||
}
|
||||
}
|
||||
|
||||
int32_t CGlueMgr::NetDisconnectHandler(const void* eventData, void*) {
|
||||
bool v11 = CGlueMgr::m_idleState != IDLE_ACCOUNT_LOGIN;
|
||||
|
||||
CGlueMgr::m_idleState = IDLE_NONE;
|
||||
CGlueMgr::m_showedDisconnect = 0;
|
||||
|
||||
if (CGlueMgr::m_disconnectPending) {
|
||||
ConsolePrintf("CGlueMgr::NetDisconnectHandler: Disconnect pending");
|
||||
CGlueMgr::m_disconnectPending = 0;
|
||||
|
||||
if (CGlueMgr::m_reconnect) {
|
||||
CGlueMgr::m_reconnect = 0;
|
||||
CGlueMgr::m_idleState = IDLE_ACCOUNT_LOGIN;
|
||||
CGlueMgr::m_showedDisconnect = 0;
|
||||
auto text = FrameScript_GetText("GAME_SERVER_LOGIN", -1, GENDER_NOT_APPLICABLE);
|
||||
FrameScript_SignalEvent(3u, "%s%s", "CANCEL", text);
|
||||
ClientServices::Connection()->Connect();
|
||||
return 1;
|
||||
}
|
||||
return 1;
|
||||
}
|
||||
if (!ClientServices::ValidDisconnect(eventData)) {
|
||||
ConsolePrintf("CGlueMgr::NetDisconnectHandler: Invalid disconnect");
|
||||
return 1;
|
||||
}
|
||||
// TODO: ClientDestroyGame(0, 1, 0);
|
||||
// TODO: EventSetMouseMode(0, 0);
|
||||
|
||||
if (CGlueMgr::m_suspended) {
|
||||
CGlueMgr::Resume();
|
||||
}
|
||||
|
||||
if (v11) {
|
||||
ConsolePrintf("CGlueMgr::NetDisconnectHandler: Displaying script");
|
||||
LABEL_14:
|
||||
FrameScript_SignalEvent(2u, "%d", CGlueMgr::m_clientKickReason);
|
||||
goto LABEL_15;
|
||||
}
|
||||
ConsolePrintf("CGlueMgr::NetDisconnectHandler: NOT displaying script");
|
||||
|
||||
WOWCS_OPS op;
|
||||
const char* msg;
|
||||
int32_t result;
|
||||
int32_t errorCode;
|
||||
int32_t complete = ClientServices::Connection()->PollStatus(op, &msg, result, errorCode);
|
||||
|
||||
if (!complete || result) {
|
||||
ClientServices::SelectRealm("");
|
||||
goto LABEL_14;
|
||||
}
|
||||
FrameScript_SignalEvent(3u, "%s%s", "OKAY", msg);
|
||||
|
||||
LABEL_15:
|
||||
ClientServices::LoginConnection()->Logoff();
|
||||
return 1;
|
||||
}
|
||||
|
||||
// TODO a1: const EVENT_DATA_IDLE*
|
||||
int32_t CGlueMgr::Idle(const void* a1, void* a2) {
|
||||
// TODO:
|
||||
|
@ -59,7 +59,6 @@ class CGlueMgr {
|
||||
static int32_t m_scandllOkayToLogIn;
|
||||
static float m_screenHeight;
|
||||
static float m_screenWidth;
|
||||
static int32_t m_clientKickReason;
|
||||
static int32_t m_showedDisconnect;
|
||||
static CSimpleTop* m_simpleTop;
|
||||
static int32_t m_suspended;
|
||||
@ -79,7 +78,6 @@ class CGlueMgr {
|
||||
static int32_t HandleDisplaySizeChanged(const CSizeEvent& event);
|
||||
static void GetRealmList(bool showProgress);
|
||||
static void GetCharacterList();
|
||||
static int32_t NetDisconnectHandler(const void* eventData, void*);
|
||||
static int32_t Idle(const void* a1, void* a2);
|
||||
static void Initialize();
|
||||
static void InitCursor();
|
||||
|
@ -32,7 +32,6 @@ target_include_directories(net
|
||||
target_link_libraries(net
|
||||
PRIVATE
|
||||
client
|
||||
console
|
||||
event
|
||||
PUBLIC
|
||||
bc
|
||||
|
@ -1,7 +1,5 @@
|
||||
#include "net/connection/NetClient.hpp"
|
||||
#include "net/connection/WowConnection.hpp"
|
||||
#include "glue/CGlueMgr.hpp"
|
||||
#include "console/Line.hpp"
|
||||
#include <cstdlib>
|
||||
#include <cstring>
|
||||
#include <new>
|
||||
@ -234,17 +232,17 @@ int32_t NetClient::HandleCantConnect() {
|
||||
}
|
||||
|
||||
int32_t NetClient::HandleConnect() {
|
||||
this->PushObjMgr();
|
||||
// TODO push obj mgr
|
||||
|
||||
this->m_netState = NS_CONNECTED;
|
||||
|
||||
this->PopObjMgr();
|
||||
// TODO pop obj mgr
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
int32_t NetClient::HandleData(uint32_t timeReceived, void* data, int32_t size) {
|
||||
this->PushObjMgr();
|
||||
// TODO push obj mgr
|
||||
|
||||
CDataStore msg;
|
||||
msg.m_data = static_cast<uint8_t*>(data);
|
||||
@ -254,21 +252,13 @@ int32_t NetClient::HandleData(uint32_t timeReceived, void* data, int32_t size) {
|
||||
|
||||
this->ProcessMessage(timeReceived, &msg, 0);
|
||||
|
||||
this->PopObjMgr();
|
||||
// TODO pop obj mgr
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
int32_t NetClient::HandleDisconnect() {
|
||||
this->PushObjMgr();
|
||||
|
||||
STORM_ASSERT(this->m_netState == NS_CONNECTED || this->m_netState == NS_DISCONNECTING);
|
||||
|
||||
this->m_netState = NS_INITIALIZED;
|
||||
ConsolePrintf("NetClient::HandleDisconnect()");
|
||||
CGlueMgr::NetDisconnectHandler(this, nullptr);
|
||||
|
||||
this->PopObjMgr();
|
||||
// TODO
|
||||
return 1;
|
||||
}
|
||||
|
||||
@ -368,59 +358,6 @@ void NetClient::SetLoginData(LoginData* loginData) {
|
||||
memcpy(&this->m_loginData, loginData, sizeof(this->m_loginData));
|
||||
}
|
||||
|
||||
void NetClient::DisplayNetworkStats() {
|
||||
this->m_pingLock.Enter();
|
||||
OsGetAsyncTimeMs();
|
||||
|
||||
float bandwidthIn;
|
||||
float bandwidthOut;
|
||||
uint32_t latency;
|
||||
this->GetNetStats(bandwidthIn, bandwidthOut, latency);
|
||||
|
||||
this->m_pingLock.Leave();
|
||||
}
|
||||
|
||||
void NetClient::GetNetStats(float& bandwidthIn, float& bandwidthOut, uint32_t& latency) {
|
||||
this->m_pingLock.Enter();
|
||||
|
||||
double v5 = (double)(OsGetAsyncTimeMs() - this->m_connectedTimestamp) * 0.001;
|
||||
bandwidthIn = (double)this->m_bytesReceived * 0.0009765625 / v5;
|
||||
bandwidthOut = (double)this->m_bytesSent * 0.0009765625 / v5;
|
||||
|
||||
uint32_t latencyStart = this->m_latencyStart;
|
||||
uint32_t latencyEnd = this->m_latencyEnd;
|
||||
|
||||
uint32_t v6 = 0;
|
||||
uint32_t v9 = 0;
|
||||
|
||||
while (latencyStart != latencyEnd) {
|
||||
if (latencyStart >= 16) {
|
||||
latencyStart = 0;
|
||||
if (!latencyEnd)
|
||||
break;
|
||||
}
|
||||
v9 += this->m_latency[latencyStart];
|
||||
++v6;
|
||||
++latencyStart;
|
||||
} ;
|
||||
|
||||
if (!v6) {
|
||||
latency = 0;
|
||||
} else {
|
||||
latency = v9 / v6;
|
||||
}
|
||||
|
||||
this->m_pingLock.Leave();
|
||||
}
|
||||
|
||||
void NetClient::PushObjMgr() {
|
||||
// TODO
|
||||
}
|
||||
|
||||
void NetClient::PopObjMgr() {
|
||||
// TODO
|
||||
}
|
||||
|
||||
void NetClient::SetMessageHandler(NETMESSAGE msgId, MESSAGE_HANDLER handler, void* param) {
|
||||
this->m_handlers[msgId] = handler;
|
||||
this->m_handlerParams[msgId] = param;
|
||||
@ -450,10 +387,7 @@ void NetClient::WCConnected(WowConnection* conn, WowConnection* inbound, uint32_
|
||||
}
|
||||
|
||||
void NetClient::WCDisconnected(WowConnection* conn, uint32_t timeStamp, NETCONNADDR* addr) {
|
||||
this->DisplayNetworkStats();
|
||||
if (this->m_netEventQueue) {
|
||||
this->m_netEventQueue->AddEvent(EVENT_ID_NET_DISCONNECT, conn, this, nullptr, 0);
|
||||
}
|
||||
// TODO
|
||||
}
|
||||
|
||||
void NetClient::WCMessageReady(WowConnection* conn, uint32_t timeStamp, CDataStore* msg) {
|
||||
|
@ -79,10 +79,6 @@ class NetClient : public WowConnectionResponse {
|
||||
void SetDelete();
|
||||
void SetLoginData(LoginData* loginData);
|
||||
void SetMessageHandler(NETMESSAGE msgId, MESSAGE_HANDLER handler, void* param);
|
||||
void DisplayNetworkStats();
|
||||
void GetNetStats(float& bandwidthIn, float& bandwidthOut, uint32_t& latency);
|
||||
void PushObjMgr();
|
||||
void PopObjMgr();
|
||||
|
||||
private:
|
||||
// Static variables
|
||||
|
@ -341,7 +341,8 @@ void WowConnection::DoDisconnect() {
|
||||
this->m_lock.Leave();
|
||||
|
||||
if (this->m_response && this->m_sock >= 0) {
|
||||
this->m_response->WCDisconnected(this, OsGetAsyncTimeMsPrecise(), &this->m_peer);
|
||||
// TODO
|
||||
// this->m_response->Vfunc4(this, OsGetAsyncTimeMsPrecise());
|
||||
}
|
||||
|
||||
this->m_lock.Enter();
|
||||
|
@ -72,62 +72,7 @@ void LoginResponse::HandleRealmData(uint32_t a2, CDataStore* msg) {
|
||||
realm.flags |= 0x80;
|
||||
}
|
||||
|
||||
if (realm.name[0] == '\0') {
|
||||
continue;
|
||||
}
|
||||
|
||||
int32_t j = 0;
|
||||
while (realm.name[j]) {
|
||||
switch (realm.name[j]) {
|
||||
case '"':
|
||||
case '*':
|
||||
case '/':
|
||||
case ':':
|
||||
case '<':
|
||||
case '>':
|
||||
case '?':
|
||||
case '\\':
|
||||
case '|': {
|
||||
realm.name[j] = ' ';
|
||||
break;
|
||||
}
|
||||
|
||||
default: {
|
||||
break;
|
||||
}
|
||||
}
|
||||
++j;
|
||||
}
|
||||
|
||||
while (j > 0) {
|
||||
bool stop = false;
|
||||
switch (realm.name[j - 1]) {
|
||||
case ' ':
|
||||
case '"':
|
||||
case '*':
|
||||
case '.':
|
||||
case '/':
|
||||
case ':':
|
||||
case '<':
|
||||
case '>':
|
||||
case '?':
|
||||
case '\\':
|
||||
case '|': {
|
||||
--j;
|
||||
break;
|
||||
}
|
||||
|
||||
default: {
|
||||
stop = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
if (stop) {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
realm.name[j] = '\0';
|
||||
// TODO name manipulation
|
||||
}
|
||||
|
||||
msg->Get(reinterpret_cast<uint16_t&>(this->uint10));
|
||||
|
Loading…
Reference in New Issue
Block a user