Report each 60 seconds how many EMMs has been send

camd.c

@@ -239,15 +239,25 @@ static int camd35_send_emm(struct ts *ts, uint16_t ca_id, uint8_t *data, uint8_t
 	if (ret <= 0) {
 		ts_LOGf("EMM | Error sending packet.\n");
 		camd35_reconnect(ts);
+	} else {
+		c->emm_count++;
 	}
 	return ret;
 }
 
 static void camd_do_msg(struct camd_msg *msg) {
+	struct camd35 *c = &msg->ts->camd35;
 	if (msg->type == EMM_MSG)
 		camd35_send_emm(msg->ts, msg->ca_id, msg->data, msg->data_len);
 	if (msg->type == ECM_MSG)
 		camd35_send_ecm(msg->ts, msg->ca_id, msg->service_id, msg->idx, msg->data, msg->data_len);
+
+	if (msg->ts->emm_send && c->emm_count_last_report + c->emm_count_report_interval <= time(NULL)) {
+		ts_LOGf("EMM | Send %d messages in %d seconds.\n", c->emm_count, c->emm_count_report_interval);
+		c->emm_count = 0;
+		c->emm_count_last_report = time(NULL);
+	}
+
 	camd_msg_free(&msg);
 }
 

data.c

@@ -41,6 +41,8 @@ void data_init(struct ts *ts) {
 	ts->camd35.key          = &ts->key;
 	strcpy(ts->camd35.user, "user");
 	strcpy(ts->camd35.pass, "pass");
+	ts->camd35.emm_count_report_interval = 60;
+	ts->camd35.emm_count_last_report     = time(NULL);
 
 	// Config
 	ts->syslog_port = 514;

data.h

@@ -40,6 +40,10 @@ struct camd35 {
 	char			user[64];
 	char			pass[64];
 
+	int				emm_count;
+	int				emm_count_report_interval;
+	time_t			emm_count_last_report;
+
 	AES_KEY			aes_encrypt_key;
 	AES_KEY			aes_decrypt_key;