feat: make retransmit timer use setTimeout instead of setInterval #…

…96

This is so that it only runs when packets are inflight, and lowers idle cpu usage

src/lib/atemSocketChild.ts

@@ -46,7 +46,7 @@ export class AtemSocketChild {
 
 	private _connectionState = ConnectionState.Closed
 	private _reconnectTimer: NodeJS.Timer | undefined
-	private _retransmitTimer: NodeJS.Timer | undefined
+	private _retransmitTimer: NodeJS.Timeout | undefined
 
 	private _nextSendPacketId = 1
 	private _sessionId = 0
@@ -98,14 +98,6 @@ export class AtemSocketChild {
 				})
 			}, CONNECTION_RETRY_INTERVAL)
 		}
-		// Check for retransmits every 10 milliseconds
-		if (!this._retransmitTimer) {
-			this._retransmitTimer = setInterval(() => {
-				this._checkForRetransmit().catch((e) => {
-					this.log(`Failed to retransmit: ${e?.message ?? e}`)
-				})
-			}, RETRANSMIT_INTERVAL)
-		}
 	}
 
 	public async connect(address: string, port: number): Promise<void> {
@@ -126,7 +118,7 @@ export class AtemSocketChild {
 
 	private _clearTimers() {
 		if (this._retransmitTimer) {
-			clearInterval(this._retransmitTimer)
+			clearTimeout(this._retransmitTimer)
 			this._retransmitTimer = undefined
 		}
 		if (this._reconnectTimer) {
@@ -197,6 +189,7 @@ export class AtemSocketChild {
 			payload: buffer,
 			resent: 0,
 		})
+		this._triggerRetransmitTimer()
 	}
 
 	private _recreateSocket(): Socket {
@@ -305,6 +298,8 @@ export class AtemSocketChild {
 						return true
 					}
 				})
+				this._triggerRetransmitTimer()
+
 				ps.push(this.onCommandsAcknowledged(ackedCommands))
 				// this.log(`${Date.now()} Got ack ${ackPacketId} Remaining=${this._inFlight.length}`)
 			}
@@ -378,8 +373,28 @@ export class AtemSocketChild {
 		}
 	}
 
+	private _triggerRetransmitTimer(): void {
+		if (!this._inFlight.length && this._retransmitTimer) {
+			clearTimeout(this._retransmitTimer)
+			delete this._retransmitTimer
+			return
+		}
+
+		if (!this._retransmitTimer) {
+			this._retransmitTimer = setTimeout(() => {
+				delete this._retransmitTimer
+				this._checkForRetransmit().catch((e) => {
+					this.log(`Failed to retransmit: ${e?.message ?? e}`)
+				})
+			}, RETRANSMIT_INTERVAL)
+		}
+	}
+
 	private async _checkForRetransmit(): Promise<void> {
 		if (!this._inFlight.length) return
+
+		this._triggerRetransmitTimer()
+
 		const now = performance.now()
 		for (const sentPacket of this._inFlight) {
 			if (sentPacket.lastSent + IN_FLIGHT_TIMEOUT < now) {