edg-l/ddnet
1
0
Fork 0
mirror of https://github.com/ddnet/ddnet.git synced 2024-09-20 01:24:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename variables and use class in crapnet tool

Browse source
This commit is contained in:
Robert Müller 2022-06-04 10:02:45 +02:00
parent 7fa3bb0842
commit fda98a3ef4
1 changed files with 36 additions and 36 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

72
src/tools/crapnet.cpp
View file

@ -8,10 +8,10 @@
#include <thread>
struct CPacket
struct SPacket
{
CPacket *m_pPrev;
CPacket *m_pNext;
SPacket *m_pPrev;
SPacket *m_pNext;
NETADDR m_SendTo;
int64_t m_Timestamp;
@ -20,11 +20,11 @@ struct CPacket
char m_aData[1];
};
static CPacket *m_pFirst = (CPacket *)0;
static CPacket *m_pLast = (CPacket *)0;
static int m_CurrentLatency = 0;
static SPacket *g_pFirst = (SPacket *)0;
static SPacket *g_pLast = (SPacket *)0;
static int g_CurrentLatency = 0;
struct CPingConfig
struct SPingConfig
{
int m_Base;
int m_Flux;
@ -34,17 +34,17 @@ struct CPingConfig
int m_DelayFreq;
};
static CPingConfig m_aConfigPings[] = {
static SPingConfig g_aConfigPings[] = {
// base flux spike loss delay delayfreq
{0, 0, 0, 0, 0, 0},
{40, 20, 100, 0, 0, 0},
{140, 40, 200, 0, 0, 0},
};
static int m_ConfigNumpingconfs = std::size(m_aConfigPings);
static int m_ConfigInterval = 10; // seconds between different pingconfigs
static int m_ConfigLog = 0;
static int m_ConfigReorder = 0;
static int g_ConfigNumpingconfs = std::size(g_aConfigPings);
static int g_ConfigInterval = 10; // seconds between different pingconfigs
static int g_ConfigLog = 0;
static int g_ConfigReorder = 0;
void Run(unsigned short Port, NETADDR Dest)
{
@ -56,13 +56,13 @@ void Run(unsigned short Port, NETADDR Dest)
while(true)
{
static int Lastcfg = 0;
int n = ((time_get() / time_freq()) / m_ConfigInterval) % m_ConfigNumpingconfs;
CPingConfig Ping = m_aConfigPings[n];
static int s_Lastcfg = 0;
int n = ((time_get() / time_freq()) / g_ConfigInterval) % g_ConfigNumpingconfs;
SPingConfig Ping = g_aConfigPings[n];
if(n != Lastcfg)
if(n != s_Lastcfg)
dbg_msg("crapnet", "cfg = %d", n);
Lastcfg = n;
s_Lastcfg = n;
// handle incoming packets
while(true)
@ -77,13 +77,13 @@ void Run(unsigned short Port, NETADDR Dest)
if((rand() % 100) < Ping.m_Loss) // drop the packet
{
if(m_ConfigLog)
if(g_ConfigLog)
dbg_msg("crapnet", "dropped packet");
continue;
}
// create new packet
CPacket *p = (CPacket *)malloc(sizeof(CPacket) + Bytes);
SPacket *p = (SPacket *)malloc(sizeof(SPacket) + Bytes);
if(net_addr_comp(&From, &Dest) == 0)
p->m_SendTo = Src; // from the server
@ -94,16 +94,16 @@ void Run(unsigned short Port, NETADDR Dest)
}
// queue packet
p->m_pPrev = m_pLast;
p->m_pPrev = g_pLast;
p->m_pNext = 0;
if(m_pLast)
m_pLast->m_pNext = p;
if(g_pLast)
g_pLast->m_pNext = p;
else
{
m_pFirst = p;
m_pLast = p;
g_pFirst = p;
g_pLast = p;
}
m_pLast = p;
g_pLast = p;
// set data in packet
p->m_Timestamp = time_get();
@ -130,7 +130,7 @@ void Run(unsigned short Port, NETADDR Dest)
}
Delaycounter--;
if(m_ConfigLog)
if(g_ConfigLog)
{
char aAddrStr[NETADDR_MAXSTRSIZE];
net_addr_str(&From, aAddrStr, sizeof(aAddrStr), true);
@ -138,8 +138,8 @@ void Run(unsigned short Port, NETADDR Dest)
}
}
CPacket *p = 0;
CPacket *pNext = m_pFirst;
SPacket *p = 0;
SPacket *pNext = g_pFirst;
while(true)
{
p = pNext;
@ -147,25 +147,25 @@ void Run(unsigned short Port, NETADDR Dest)
break;
pNext = p->m_pNext;
if((time_get() - p->m_Timestamp) > m_CurrentLatency)
if((time_get() - p->m_Timestamp) > g_CurrentLatency)
{
char aFlags[] = " ";
if(m_ConfigReorder && (rand() % 2) == 0 && p->m_pNext)
if(g_ConfigReorder && (rand() % 2) == 0 && p->m_pNext)
{
aFlags[0] = 'R';
p = m_pFirst->m_pNext;
p = g_pFirst->m_pNext;
}
if(p->m_pNext)
p->m_pNext->m_pPrev = p->m_pPrev;
else
m_pLast = p->m_pPrev;
g_pLast = p->m_pPrev;
if(p->m_pPrev)
p->m_pPrev->m_pNext = p->m_pNext;
else
m_pFirst = p->m_pNext;
g_pFirst = p->m_pNext;
// send and remove packet
net_udp_send(Socket, &p->m_SendTo, p->m_aData, p->m_DataSize);
@ -175,15 +175,15 @@ void Run(unsigned short Port, NETADDR Dest)
int MsSpike = Ping.m_Spike;
int MsFlux = Ping.m_Flux;
int MsPing = Ping.m_Base;
m_CurrentLatency = ((time_freq() * MsPing) / 1000) + (int64_t)(((time_freq() * MsFlux) / 1000) * Flux); // 50ms
g_CurrentLatency = ((time_freq() * MsPing) / 1000) + (int64_t)(((time_freq() * MsFlux) / 1000) * Flux); // 50ms
if(MsSpike && (p->m_ID % 100) == 0)
{
m_CurrentLatency += (time_freq() * MsSpike) / 1000;
g_CurrentLatency += (time_freq() * MsSpike) / 1000;
aFlags[1] = 'S';
}
if(m_ConfigLog)
if(g_ConfigLog)
{
char aAddrStr[NETADDR_MAXSTRSIZE];
net_addr_str(&p->m_SendTo, aAddrStr, sizeof(aAddrStr), true);