Fix anti-interupt transmission delay

dharmab · dharmab · commit 12e6830519de · 2024-08-24T16:14:18.000-06:00
diff --git a/pkg/simpleradio/audio/transmit.go b/pkg/simpleradio/audio/transmit.go
@@ -29,8 +29,8 @@ func (c *audioClient) transmit(ctx context.Context, packetCh <-chan []voice.Voic
 }
 
 func (c *audioClient) tx(packets []voice.VoicePacket) {
-	if c.lastRx.deadline.After(time.Now()) {
-		delay := 250 * time.Millisecond
+	for c.lastRx.deadline.After(time.Now()) {
+		delay := time.Until(c.lastRx.deadline) + 250*time.Millisecond
 		log.Info().Dur("delay", delay).Msg("delaying outgoing transmission to avoid interrupting incoming transmission")
 		time.Sleep(delay)
 	}

Original file line number	Diff line number	Diff line change
`@@ -29,8 +29,8 @@ func (c *audioClient) transmit(ctx context.Context, packetCh <-chan []voice.Voic`
`29`	`29`	`}`
`30`	`30`
`31`	`31`	`func (c *audioClient) tx(packets []voice.VoicePacket) {`
`32`		`- if c.lastRx.deadline.After(time.Now()) {`
`33`		`- delay := 250 * time.Millisecond`
	`32`	`+ for c.lastRx.deadline.After(time.Now()) {`
	`33`	`+ delay := time.Until(c.lastRx.deadline) + 250*time.Millisecond`
`34`	`34`	`log.Info().Dur("delay", delay).Msg("delaying outgoing transmission to avoid interrupting incoming transmission")`
`35`	`35`	`time.Sleep(delay)`
`36`	`36`	`}`