Mirror/Erupe
1
0
Fork 0
mirror of https://github.com/Mezeporta/Erupe.git synced 2026-03-26 09:33:02 +01:00
Code Issues Packages Projects Releases Wiki Activity

test(channelserver): reduce polling interval from 10ms to 1ms

Browse Source 
LoopDelay is 0 in test servers (bare struct, no Viper defaults), so
sendLoop spins without delay and satisfies conditions in <1ms. The
10ms poll interval was the new bottleneck — dropping to 1ms cuts the
channelserver test suite from ~136s to ~5s.
This commit is contained in:
Houmgaor
2026-03-23 11:06:50 +01:00
parent d0efc4e81a
commit e1aa863a1f
3 changed files with 24 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
server/channelserver/integration_test.go
View File

@@ -89,7 +89,7 @@ func IntegrationTest_PacketQueueFlow(t *testing.T) {
if mock.PacketCount() >= tt.wantPackets { if mock.PacketCount() >= tt.wantPackets {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -186,7 +186,7 @@ done:
if mock.PacketCount() >= expectedTotal { if mock.PacketCount() >= expectedTotal {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -255,7 +255,7 @@ func IntegrationTest_AckPacketFlow(t *testing.T) {
if mock.PacketCount() >= ackCount { if mock.PacketCount() >= ackCount {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -330,7 +330,7 @@ func IntegrationTest_MixedPacketTypes(t *testing.T) {
if mock.PacketCount() >= 4 { if mock.PacketCount() >= 4 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -385,7 +385,7 @@ func IntegrationTest_PacketOrderPreservation(t *testing.T) {
if mock.PacketCount() >= packetCount { if mock.PacketCount() >= packetCount {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -456,7 +456,7 @@ func IntegrationTest_QueueBackpressure(t *testing.T) {
if mock.PacketCount() > 0 { if mock.PacketCount() > 0 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
// Some packets should have been sent // Some packets should have been sent
@@ -539,7 +539,7 @@ func IntegrationTest_GuildEnumerationFlow(t *testing.T) {
if mock.PacketCount() >= tt.guildCount { if mock.PacketCount() >= tt.guildCount {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -614,7 +614,7 @@ func IntegrationTest_ConcurrentClientAccess(t *testing.T) {
if mock.PacketCount() >= tt.packetsPerClient { if mock.PacketCount() >= tt.packetsPerClient {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
s.closed.Store(true) s.closed.Store(true)
deadline = time.Now().Add(2 * time.Second) deadline = time.Now().Add(2 * time.Second)
@@ -622,7 +622,7 @@ func IntegrationTest_ConcurrentClientAccess(t *testing.T) {
if mock.PacketCount() >= tt.packetsPerClient { if mock.PacketCount() >= tt.packetsPerClient {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentCount := mock.PacketCount() sentCount := mock.PacketCount()
@@ -693,7 +693,7 @@ func IntegrationTest_ClientVersionCompatibility(t *testing.T) {
if mock.PacketCount() >= 1 { if mock.PacketCount() >= 1 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
s.closed.Store(true) s.closed.Store(true)
deadline = time.Now().Add(2 * time.Second) deadline = time.Now().Add(2 * time.Second)
@@ -701,7 +701,7 @@ func IntegrationTest_ClientVersionCompatibility(t *testing.T) {
if mock.PacketCount() >= 1 { if mock.PacketCount() >= 1 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentCount := mock.PacketCount() sentCount := mock.PacketCount()
@@ -742,7 +742,7 @@ func IntegrationTest_PacketPrioritization(t *testing.T) {
if mock.PacketCount() >= 10 { if mock.PacketCount() >= 10 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -804,7 +804,7 @@ done:
if mock.PacketCount() >= packetCount { if mock.PacketCount() >= packetCount {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()

2
server/channelserver/sys_channel_server_test.go
View File

@@ -291,7 +291,7 @@ func TestBroadcastMHFAllSessions(t *testing.T) {
if receivedCount == sessionCount { if receivedCount == sessionCount {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
// Stop all sessions // Stop all sessions

20
server/channelserver/sys_session_test.go
View File

@@ -121,7 +121,7 @@ func TestPacketQueueIndividualSending(t *testing.T) {
if mock.PacketCount() >= tt.wantPackets { if mock.PacketCount() >= tt.wantPackets {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
// Stop the session // Stop the session
@@ -131,7 +131,7 @@ func TestPacketQueueIndividualSending(t *testing.T) {
if mock.PacketCount() >= tt.wantPackets { if mock.PacketCount() >= tt.wantPackets {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
// Verify packet count // Verify packet count
@@ -182,7 +182,7 @@ func TestPacketQueueNoConcatenation(t *testing.T) {
if mock.PacketCount() >= 3 { if mock.PacketCount() >= 3 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
s.closed.Store(true) s.closed.Store(true)
deadline = time.Now().Add(2 * time.Second) deadline = time.Now().Add(2 * time.Second)
@@ -190,7 +190,7 @@ func TestPacketQueueNoConcatenation(t *testing.T) {
if mock.PacketCount() >= 3 { if mock.PacketCount() >= 3 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -228,7 +228,7 @@ func TestQueueSendUsesQueue(t *testing.T) {
s.QueueSend(testData) s.QueueSend(testData)
// Give it a moment // Give it a moment
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
// WITHOUT sendLoop running, packets should NOT be sent yet // WITHOUT sendLoop running, packets should NOT be sent yet
if mock.PacketCount() > 0 { if mock.PacketCount() > 0 {
@@ -247,7 +247,7 @@ func TestQueueSendUsesQueue(t *testing.T) {
if mock.PacketCount() >= 1 { if mock.PacketCount() >= 1 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
if mock.PacketCount() != 1 { if mock.PacketCount() != 1 {
@@ -272,7 +272,7 @@ func TestPacketTerminatorFormat(t *testing.T) {
if mock.PacketCount() >= 1 { if mock.PacketCount() >= 1 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
s.closed.Store(true) s.closed.Store(true)
deadline = time.Now().Add(2 * time.Second) deadline = time.Now().Add(2 * time.Second)
@@ -280,7 +280,7 @@ func TestPacketTerminatorFormat(t *testing.T) {
if mock.PacketCount() >= 1 { if mock.PacketCount() >= 1 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()
@@ -360,7 +360,7 @@ func TestPacketQueueAckFormat(t *testing.T) {
if mock.PacketCount() >= 1 { if mock.PacketCount() >= 1 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
s.closed.Store(true) s.closed.Store(true)
deadline = time.Now().Add(2 * time.Second) deadline = time.Now().Add(2 * time.Second)
@@ -368,7 +368,7 @@ func TestPacketQueueAckFormat(t *testing.T) {
if mock.PacketCount() >= 1 { if mock.PacketCount() >= 1 {
break break
} }
time.Sleep(10 * time.Millisecond) time.Sleep(1 * time.Millisecond)
} }
sentPackets := mock.GetSentPackets() sentPackets := mock.GetSentPackets()