Skip to content

Feature/hud message queue #1189

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
lozatto wants to merge 3 commits into
base: master
Choose a base branch
from
Open

Feature/hud message queue #1189

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
48795f9
feat: Native HUD Messages Queue to prevent overflow & overlapping
lozatto Sep 1, 2026
92aef80
feat: implement HUD message queue system to manage prioritized UI not…
lozatto Sep 1, 2026
ff5632d
fix: Restore UTIL_HudMessage to fix CPlayingEngExtInterceptor unit test
lozatto Sep 1, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 15 additions & 0 deletions regamedll/dlls/API/CAPI_Impl.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -402,4 +402,19 @@ bool CReGameApi::BGetIGameRules(const char *pchVersion) const
return false;
}

void CReGameApi::QueueHudMessage(int client, const struct hudtextparms_s &textparms, const char *pMessage)
{
if (client == 0)
{
for (int i = 1; i <= gpGlobals->maxClients; i++)
{
g_HudQueue.QueueMessage(i, textparms, pMessage);
}
}
else
{
g_HudQueue.QueueMessage(client, textparms, pMessage);
}
}

EXPOSE_SINGLE_INTERFACE(CReGameApi, IReGameApi, VRE_GAMEDLL_API_VERSION);
1 change: 1 addition & 0 deletions regamedll/dlls/API/CAPI_Impl.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1116,4 +1116,5 @@ class CReGameApi: public IReGameApi {
EXT_FUNC virtual AmmoInfoStruct *GetAmmoInfoEx(const char *ammoName);
EXT_FUNC virtual bool BGetICSEntity(const char *pchVersion) const;
EXT_FUNC virtual bool BGetIGameRules(const char *pchVersion) const;
EXT_FUNC virtual void QueueHudMessage(int client, const struct hudtextparms_s &textparms, const char *pMessage);
};
3 changes: 2 additions & 1 deletion regamedll/dlls/client.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3910,7 +3910,7 @@ void EXT_FUNC PlayerPostThink(edict_t *pEntity)

void EXT_FUNC ParmsNewLevel()
{
;
g_HudQueue.Reset();
}

void EXT_FUNC ParmsChangeLevel()
Expand All @@ -3933,6 +3933,7 @@ void EXT_FUNC StartFrame()
return;
}

g_HudQueue.Think();
CLocalNav::Think();

gpGlobals->teamplay = 1.0f;
Expand Down
Empty file added regamedll/dlls/hud_queue.cpp
View file
Open in desktop
Empty file.
145 changes: 113 additions & 32 deletions regamedll/dlls/util.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -592,47 +592,128 @@ void UTIL_ScreenFade(CBaseEntity *pEntity, const Vector &color, float fadeTime,
UTIL_ScreenFadeWrite(fade, pEntity);
}

CHudMessageQueue g_HudQueue;

CHudMessageQueue::CHudMessageQueue() {
Reset();
}

void CHudMessageQueue::Reset() {
for (int i = 0; i < 33; i++) {
for (int j = 0; j < NUM_HUD_CHANNELS; j++) {
m_players[i].channelFreeTime[j] = 0.0f;
}
for (int j = 0; j < MAX_HUD_QUEUE; j++) {
m_players[i].messages[j].inUse = false;
}
}
}

void CHudMessageQueue::QueueMessage(int client, const hudtextparms_t &textparms, const char *pMessage) {
if (client < 1 || client >= 33) return;

int freeSlot = -1;
for (int i = 0; i < MAX_HUD_QUEUE; i++) {
if (!m_players[client].messages[i].inUse) {
freeSlot = i;
break;
}
}

if (freeSlot == -1) {
return;
}

m_players[client].messages[freeSlot].textparms = textparms;
Q_strlcpy(m_players[client].messages[freeSlot].message, pMessage, sizeof(m_players[client].messages[freeSlot].message));
m_players[client].messages[freeSlot].inUse = true;
}

void CHudMessageQueue::Think() {
float currentTime = gpGlobals->time;

for (int i = 1; i <= gpGlobals->maxClients; i++) {
CBaseEntity *pPlayer = UTIL_PlayerByIndex(i);
if (!pPlayer || !pPlayer->IsNetClient())
continue;

for (int j = 0; j < MAX_HUD_QUEUE; j++) {
if (!m_players[i].messages[j].inUse)
continue;

hudtextparms_t parms = m_players[i].messages[j].textparms;

int targetChannel = parms.channel - 1;
if (parms.channel <= 0 || parms.channel > NUM_HUD_CHANNELS) {
int bestChannel = 0;
float oldestTime = m_players[i].channelFreeTime[0];
for (int c = 1; c < NUM_HUD_CHANNELS; c++) {
if (m_players[i].channelFreeTime[c] < oldestTime) {
oldestTime = m_players[i].channelFreeTime[c];
bestChannel = c;
}
}
targetChannel = bestChannel;
parms.channel = bestChannel + 1;
}

if (currentTime >= m_players[i].channelFreeTime[targetChannel]) {
UTIL_HudMessage(pPlayer, parms, m_players[i].messages[j].message);
m_players[i].channelFreeTime[targetChannel] = currentTime + parms.fadeinTime + parms.holdTime + parms.fadeoutTime + 0.2f;

m_players[i].messages[j].inUse = false;
}
}
}
}

void UTIL_HudMessage(CBaseEntity *pEntity, const hudtextparms_t &textparms, const char *pMessage)
{
if (!pEntity || !pEntity->IsNetClient())
return;

MESSAGE_BEGIN(MSG_ONE, SVC_TEMPENTITY, nullptr, pEntity->edict());
WRITE_BYTE(TE_TEXTMESSAGE);
WRITE_BYTE(textparms.channel & 0xFF);
WRITE_SHORT(FixedSigned16(textparms.x, (1<<13)));
WRITE_SHORT(FixedSigned16(textparms.y, (1<<13)));
WRITE_BYTE(textparms.effect);
WRITE_BYTE(textparms.r1);
WRITE_BYTE(textparms.g1);
WRITE_BYTE(textparms.b1);
WRITE_BYTE(textparms.a1);
WRITE_BYTE(textparms.r2);
WRITE_BYTE(textparms.g2);
WRITE_BYTE(textparms.b2);
WRITE_BYTE(textparms.a2);
WRITE_SHORT(FixedUnsigned16(textparms.fadeinTime, (1<<8)));
WRITE_SHORT(FixedUnsigned16(textparms.fadeoutTime, (1<<8)));
WRITE_SHORT(FixedUnsigned16(textparms.holdTime, (1<<8)));

if (textparms.effect == 2)
WRITE_SHORT(FixedUnsigned16(textparms.fxTime, (1<<8)));

if (!pMessage)
WRITE_STRING(" ");
WRITE_BYTE(TE_TEXTMESSAGE);
WRITE_BYTE(textparms.channel & 0xFF);

WRITE_SHORT(FixedSigned16(textparms.x, 1 << 13));
WRITE_SHORT(FixedSigned16(textparms.y, 1 << 13));
WRITE_BYTE(textparms.effect);

WRITE_BYTE(textparms.r1);
WRITE_BYTE(textparms.g1);
WRITE_BYTE(textparms.b1);
WRITE_BYTE(textparms.a1);

WRITE_BYTE(textparms.r2);
WRITE_BYTE(textparms.g2);
WRITE_BYTE(textparms.b2);
WRITE_BYTE(textparms.a2);

WRITE_SHORT(FixedUnsigned16(textparms.fadeinTime, 1 << 8));
WRITE_SHORT(FixedUnsigned16(textparms.fadeoutTime, 1 << 8));
WRITE_SHORT(FixedUnsigned16(textparms.holdTime, 1 << 8));

if (textparms.effect == 2)
WRITE_SHORT(FixedUnsigned16(textparms.fxTime, 1 << 8));

if (!pMessage)
{
WRITE_STRING(" ");
}
else
{
if (Q_strlen(pMessage) >= 512)
{
char tmp[512];
Q_strlcpy(tmp, pMessage);
WRITE_STRING(tmp);
}
else
{
if (Q_strlen(pMessage) >= 512)
{
char tmp[512];
Q_strlcpy(tmp, pMessage);
WRITE_STRING(tmp);
}
else
{
WRITE_STRING(pMessage);
}
WRITE_STRING(pMessage);
}
}
MESSAGE_END();
}

Expand Down
30 changes: 30 additions & 0 deletions regamedll/dlls/util.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -227,6 +227,36 @@ void UTIL_ScreenFadeBuild(ScreenFade &fade, const Vector &color, float fadeTime,
void UTIL_ScreenFadeWrite(const ScreenFade &fade, CBaseEntity *pEntity);
void UTIL_ScreenFadeAll(const Vector &color, float fadeTime, float fadeHold, int alpha, int flags);
void UTIL_ScreenFade(CBaseEntity *pEntity, const Vector &color, float fadeTime, float fadeHold = 0.0f, int alpha = 0, int flags = 0);
// ----------------------------------------------------
// Native HUD Messages Queue
// ----------------------------------------------------
#define MAX_HUD_QUEUE 10
#define NUM_HUD_CHANNELS 4

struct QueuedHudMessage_t {
hudtextparms_t textparms;
char message[512];
bool inUse;
};

class CHudMessageQueue {
public:
CHudMessageQueue();

void QueueMessage(int client, const hudtextparms_t &textparms, const char *pMessage);
void Think();
void Reset();

private:
struct PlayerHudQueue {
QueuedHudMessage_t messages[MAX_HUD_QUEUE];
float channelFreeTime[NUM_HUD_CHANNELS];
};
PlayerHudQueue m_players[33];
};

extern CHudMessageQueue g_HudQueue;

void UTIL_HudMessage(CBaseEntity *pEntity, const hudtextparms_t &textparms, const char *pMessage);
void UTIL_HudMessageAll(const hudtextparms_t &textparms, const char *pMessage);
void UTIL_ClientPrintAll(int msg_dest, const char *msg_name, const char *param1 = nullptr, const char *param2 = nullptr, const char *param3 = nullptr, const char *param4 = nullptr);
Expand Down
1 change: 1 addition & 0 deletions regamedll/public/regamedll/regamedll_api.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -856,6 +856,7 @@ class IReGameApi {
virtual struct AmmoInfoStruct *GetAmmoInfoEx(const char *ammoName) = 0;
virtual bool BGetICSEntity(const char *pchVersion) const = 0;
virtual bool BGetIGameRules(const char *pchVersion) const = 0;
virtual void QueueHudMessage(int client, const struct hudtextparms_s &textparms, const char *pMessage) = 0;
};

#define VRE_GAMEDLL_API_VERSION "VRE_GAMEDLL_API_VERSION001"
Loading