Fix transaction state vacuum in MQTT transport

feymartynov · feymartynov · commit e3c0993f99f9 · 2020-09-14T15:48:41.000+03:00
diff --git a/transports/janus_mqtt.c b/transports/janus_mqtt.c
@@ -1612,7 +1612,8 @@ static gboolean janus_mqtt_vacuum(gpointer context) {
 
 	while (g_hash_table_iter_next(&iter, NULL, &value)) {
 		janus_mqtt_transaction_state* state = value;
-		if(janus_get_monotonic_time() - state->created_at > ctx->vacuum_interval) {
+		gint64 diff = (janus_get_monotonic_time() - state->created_at) / G_USEC_PER_SEC;
+		if(diff > ctx->vacuum_interval) {
 			g_hash_table_iter_remove(&iter);
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -1612,7 +1612,8 @@ static gboolean janus_mqtt_vacuum(gpointer context) {`
`1612`	`1612`
`1613`	`1613`	`while (g_hash_table_iter_next(&iter, NULL, &value)) {`
`1614`	`1614`	`janus_mqtt_transaction_state* state = value;`
`1615`		`- if(janus_get_monotonic_time() - state->created_at > ctx->vacuum_interval) {`
	`1615`	`+ gint64 diff = (janus_get_monotonic_time() - state->created_at) / G_USEC_PER_SEC;`
	`1616`	`+ if(diff > ctx->vacuum_interval) {`
`1616`	`1617`	`g_hash_table_iter_remove(&iter);`
`1617`	`1618`	`}`
`1618`	`1619`	`}`