aboutsummaryrefslogtreecommitdiffstats
path: root/isdb-t/br-pe-BuenosAires
blob: 12e227a4d1024cca3928b988ce89ec4c1eb3c616 (plain) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177

# Channel table for Buenos Aires - PE - Brazil
# Source: http://portalbsd.com.br/novo/terrestres_channels.php?channels=3306

# Physical channel 20
[TV Tribuna]
	DELIVERY_SYSTEM = ISDBT
	BANDWIDTH_HZ = 6000000
	FREQUENCY = 509142857
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	ISDBT_LAYER_ENABLED = 7
	ISDBT_SOUND_BROADCASTING = 0
	ISDBT_SB_SUBCHANNEL_ID = 0
	ISDBT_SB_SEGMENT_IDX = 0
	ISDBT_SB_SEGMENT_COUNT = 0
	ISDBT_LAYERA_FEC = AUTO
	ISDBT_LAYERA_MODULATION = QAM/AUTO
	ISDBT_LAYERA_SEGMENT_COUNT = 0
	ISDBT_LAYERA_TIME_INTERLEAVING = 0
	ISDBT_LAYERB_FEC = AUTO
	ISDBT_LAYERB_MODULATION = QAM/AUTO
	ISDBT_LAYERB_SEGMENT_COUNT = 0
	ISDBT_LAYERB_TIME_INTERLEAVING = 0
	ISDBT_LAYERC_FEC = AUTO
	ISDBT_LAYERC_MODULATION = QAM/AUTO
	ISDBT_LAYERC_SEGMENT_COUNT = 0
	ISDBT_LAYERC_TIME_INTERLEAVING = 0

# Physical channel 34
[Globo Nordeste]
	DELIVERY_SYSTEM = ISDBT
	BANDWIDTH_HZ = 6000000
	FREQUENCY = 593142857
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	ISDBT_LAYER_ENABLED = 7
	ISDBT_SOUND_BROADCASTING = 0
	ISDBT_SB_SUBCHANNEL_ID = 0
	ISDBT_SB_SEGMENT_IDX = 0
	ISDBT_SB_SEGMENT_COUNT = 0
	ISDBT_LAYERA_FEC = AUTO
	ISDBT_LAYERA_MODULATION = QAM/AUTO
	ISDBT_LAYERA_SEGMENT_COUNT = 0
	ISDBT_LAYERA_TIME_INTERLEAVING = 0
	ISDBT_LAYERB_FEC = AUTO
	ISDBT_LAYERB_MODULATION = QAM/AUTO
	ISDBT_LAYERB_SEGMENT_COUNT = 0
	ISDBT_LAYERB_TIME_INTERLEAVING = 0
	ISDBT_LAYERC_FEC = AUTO
	ISDBT_LAYERC_MODULATION = QAM/AUTO
	ISDBT_LAYERC_SEGMENT_COUNT = 0
	ISDBT_LAYERC_TIME_INTERLEAVING = 0

# Physical channel 35
[TV Jornal]
	DELIVERY_SYSTEM = ISDBT
	BANDWIDTH_HZ = 6000000
	FREQUENCY = 599142857
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	ISDBT_LAYER_ENABLED = 7
	ISDBT_SOUND_BROADCASTING = 0
	ISDBT_SB_SUBCHANNEL_ID = 0
	ISDBT_SB_SEGMENT_IDX = 0
	ISDBT_SB_SEGMENT_COUNT = 0
	ISDBT_LAYERA_FEC = AUTO
	ISDBT_LAYERA_MODULATION = QAM/AUTO
	ISDBT_LAYERA_SEGMENT_COUNT = 0
	ISDBT_LAYERA_TIME_INTERLEAVING = 0
	ISDBT_LAYERB_FEC = AUTO
	ISDBT_LAYERB_MODULATION = QAM/AUTO
	ISDBT_LAYERB_SEGMENT_COUNT = 0
	ISDBT_LAYERB_TIME_INTERLEAVING = 0
	ISDBT_LAYERC_FEC = AUTO
	ISDBT_LAYERC_MODULATION = QAM/AUTO
	ISDBT_LAYERC_SEGMENT_COUNT = 0
	ISDBT_LAYERC_TIME_INTERLEAVING = 0

# Physical channel 36
[Globo Nordeste]
	DELIVERY_SYSTEM = ISDBT
	BANDWIDTH_HZ = 6000000
	FREQUENCY = 605142857
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	ISDBT_LAYER_ENABLED = 7
	ISDBT_SOUND_BROADCASTING = 0
	ISDBT_SB_SUBCHANNEL_ID = 0
	ISDBT_SB_SEGMENT_IDX = 0
	ISDBT_SB_SEGMENT_COUNT = 0
	ISDBT_LAYERA_FEC = AUTO
	ISDBT_LAYERA_MODULATION = QAM/AUTO
	ISDBT_LAYERA_SEGMENT_COUNT = 0
	ISDBT_LAYERA_TIME_INTERLEAVING = 0
	ISDBT_LAYERB_FEC = AUTO
	ISDBT_LAYERB_MODULATION = QAM/AUTO
	ISDBT_LAYERB_SEGMENT_COUNT = 0
	ISDBT_LAYERB_TIME_INTERLEAVING = 0
	ISDBT_LAYERC_FEC = AUTO
	ISDBT_LAYERC_MODULATION = QAM/AUTO
	ISDBT_LAYERC_SEGMENT_COUNT = 0
	ISDBT_LAYERC_TIME_INTERLEAVING = 0

# Physical channel 39
[TV Clube]
	DELIVERY_SYSTEM = ISDBT
	BANDWIDTH_HZ = 6000000
	FREQUENCY = 623142857
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	ISDBT_LAYER_ENABLED = 7
	ISDBT_SOUND_BROADCASTING = 0
	ISDBT_SB_SUBCHANNEL_ID = 0
	ISDBT_SB_SEGMENT_IDX = 0
	ISDBT_SB_SEGMENT_COUNT = 0
	ISDBT_LAYERA_FEC = AUTO
	ISDBT_LAYERA_MODULATION = QAM/AUTO
	ISDBT_LAYERA_SEGMENT_COUNT = 0
	ISDBT_LAYERA_TIME_INTERLEAVING = 0
	ISDBT_LAYERB_FEC = AUTO
	ISDBT_LAYERB_MODULATION = QAM/AUTO
	ISDBT_LAYERB_SEGMENT_COUNT = 0
	ISDBT_LAYERB_TIME_INTERLEAVING = 0
	ISDBT_LAYERC_FEC = AUTO
	ISDBT_LAYERC_MODULATION = QAM/AUTO
	ISDBT_LAYERC_SEGMENT_COUNT = 0
	ISDBT_LAYERC_TIME_INTERLEAVING = 0

# Physical channel 52
[Rede Vida]
	DELIVERY_SYSTEM = ISDBT
	BANDWIDTH_HZ = 6000000
	FREQUENCY = 701142857
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	INVERSION = AUTO
	GUARD_INTERVAL = AUTO
	TRANSMISSION_MODE = AUTO
	ISDBT_LAYER_ENABLED = 7
	ISDBT_SOUND_BROADCASTING = 0
	ISDBT_SB_SUBCHANNEL_ID = 0
	ISDBT_SB_SEGMENT_IDX = 0
	ISDBT_SB_SEGMENT_COUNT = 0
	ISDBT_LAYERA_FEC = AUTO
	ISDBT_LAYERA_MODULATION = QAM/AUTO
	ISDBT_LAYERA_SEGMENT_COUNT = 0
	ISDBT_LAYERA_TIME_INTERLEAVING = 0
	ISDBT_LAYERB_FEC = AUTO
	ISDBT_LAYERB_MODULATION = QAM/AUTO
	ISDBT_LAYERB_SEGMENT_COUNT = 0
	ISDBT_LAYERB_TIME_INTERLEAVING = 0
	ISDBT_LAYERC_FEC = AUTO
	ISDBT_LAYERC_MODULATION = QAM/AUTO
	ISDBT_LAYERC_SEGMENT_COUNT = 0
	ISDBT_LAYERC_TIME_INTERLEAVING = 0
generated by cgit v1.2.3 (git 2.39.1) at 2025-11-25 06:58:08 +0000
.Doc */ .highlight .s2 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Double */ .highlight .se { color: #0044dd; background-color: #fff0f0 } /* Literal.String.Escape */ .highlight .sh { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Heredoc */ .highlight .si { color: #3333bb; background-color: #fff0f0 } /* Literal.String.Interpol */ .highlight .sx { color: #22bb22; background-color: #f0fff0 } /* Literal.String.Other */ .highlight .sr { color: #008800; background-color: #fff0ff } /* Literal.String.Regex */ .highlight .s1 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Single */ .highlight .ss { color: #aa6600; background-color: #fff0f0 } /* Literal.String.Symbol */ .highlight .bp { color: #003388 } /* Name.Builtin.Pseudo */ .highlight .fm { color: #0066bb; font-weight: bold } /* Name.Function.Magic */ .highlight .vc { color: #336699 } /* Name.Variable.Class */ .highlight .vg { color: #dd7700 } /* Name.Variable.Global */ .highlight .vi { color: #3333bb } /* Name.Variable.Instance */ .highlight .vm { color: #336699 } /* Name.Variable.Magic */ .highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */
/* 
 * modbuslog
 *
 * Copyright (C) 2011 Jonathan McCrohan
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.

 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.

 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

// gcc modbuslog.c -o modbuslog `pkg-config --libs --cflags libmodbus libconfig`

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <errno.h>
#include <time.h>
#include <unistd.h>
#include <sys/select.h>
#include <signal.h>
#include <fcntl.h>

#include <libconfig.h>
#include <modbus.h>

#include <sys/ioctl.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <net/if.h>
#include <string.h>

#include <syslog.h>

// handle SIGALRM by resetting it
void minute_check(int signum) {
	alarm(60);
}

// get mac address of primary interface eth0
char *mac_address() {
	int s;
	struct ifreq ifr;

	s = socket(PF_INET, SOCK_DGRAM, 0);
	memset(&ifr, 0x00, sizeof(ifr));
	strcpy(ifr.ifr_name, "eth0");
	ioctl(s, SIOCGIFHWADDR, &ifr);
	close(s);

	static char mac_address[12];
	sprintf(mac_address, "%.2X%.2X%.2X%.2X%.2X%.2X",
			(unsigned char) ifr.ifr_hwaddr.sa_data[0],
			(unsigned char) ifr.ifr_hwaddr.sa_data[1],
			(unsigned char) ifr.ifr_hwaddr.sa_data[2],
			(unsigned char) ifr.ifr_hwaddr.sa_data[3],
			(unsigned char) ifr.ifr_hwaddr.sa_data[4],
			(unsigned char) ifr.ifr_hwaddr.sa_data[5]);

	return mac_address;
}

int main(int argc, char *argv[]) {

	int DEBUG = 0;
	int SYSLOG_CONSOLE_OUTPUT = 0;
	int k;

	// check the argv array for strings matching -d
	for (k = 1; k < argc; k++) {
		if (strcmp(argv[k], "-d") == 0) {
			DEBUG = 1;
			SYSLOG_CONSOLE_OUTPUT = LOG_PERROR;
		}
	}

	openlog("modbuslog", SYSLOG_CONSOLE_OUTPUT | LOG_PID | LOG_CONS, LOG_USER);
	syslog(LOG_INFO, "modbuslog starting");

	const char *configfile = "/etc/modbuslog.cfg";
	config_t cfg;
	//config_setting_t *setting;

	const char *modbus_device_address;
	int modbus_baud_rate;
	int modbus_data_bits;
	const char *modbus_parity;
	int modbus_stop_bits;
	int modbus_retry;

	config_init(&cfg);

	// attempt to read config
	// loads entire file to memory and destroys file descriptor
	if (!config_read_file(&cfg, configfile)) {
		fprintf(stderr, "%s:%d - %s\n", config_error_file(&cfg),
				config_error_line(&cfg), config_error_text(&cfg));
		config_destroy(&cfg);
		syslog(LOG_ERR, "Unable to find configfile");
		return -1;
	} else {
		syslog(LOG_INFO, "configfile found successfully");
	}

	// die if core config file options aren't there
	if (!(config_lookup_string(&cfg, "modbus.device", &modbus_device_address)
			&& config_lookup_int(&cfg, "modbus.baud", &modbus_baud_rate)
			&& config_lookup_int(&cfg, "modbus.data_bits", &modbus_data_bits)
			&& config_lookup_string(&cfg, "modbus.parity", &modbus_parity)
			&& config_lookup_int(&cfg, "modbus.stop_bits", &modbus_stop_bits)
			&& config_lookup_int(&cfg, "modbus.retry", &modbus_retry))) {
		syslog(LOG_ERR,
				"Incomplete modbus configuration. Check configuration file");
		closelog();
		return -1;
	}

	syslog(LOG_INFO, "%s %s %d %d %c %d", mac_address(), modbus_device_address,
			modbus_baud_rate, modbus_data_bits, modbus_parity[0],
			modbus_stop_bits);

	modbus_t *ctx;
	uint16_t tab_reg[4];
	uint8_t byte[8];
	int rc;
	int i;

	// SIGALRM used to wake for loop up every 60 secs
	// sleep puts whole thread to sleep which isn't what we want
	// other methods involve CPU spinlocks which are inefficient
	signal(SIGALRM, minute_check);
	alarm(60);

	for (;;) {
		// block until SIGARLM
		select(0, NULL, NULL, NULL, NULL);

		time_t t = time(NULL);
		time_t unixtime_min = (((int) t) / 60 * 60);
		//int unixtime = (int) t;
		//printf("%d\n", unixtime);

		config_setting_t *readings;

		readings = config_lookup(&cfg, "reading");

		// find number of required readings
		unsigned int num_readings = config_setting_length(readings);

		int i;

		// cycle through each reading and pull info from config file
		for (i = 0; i < num_readings; ++i) {
			config_setting_t *register_element = config_setting_get_elem(
					readings, i);
			int slaveid;
			config_setting_lookup_int(register_element, "slaveid", &slaveid);
			int intervalvalue;
			config_setting_lookup_int(register_element, "intervalvalue",
					&intervalvalue);
			//printf("%d", intervalvalue);

			int registertype;
			config_setting_lookup_int(register_element, "registertype",
					&registertype);

			int startaddress;
			config_setting_lookup_int(register_element, "startaddress",
					&startaddress);

			int numregisters;
			config_setting_lookup_int(register_element, "numregisters",
					&numregisters);

			const char *intervalunit;
			config_setting_lookup_string(register_element, "intervalunit",
					&intervalunit);

			//printf("%c", intervalunit[0]);

			int intervalduration;

			if (intervalunit[0] == 'h')
				intervalduration = intervalvalue * 3600;
			else
				intervalduration = intervalvalue * 60;

			// if we match the required time for the reading
			if (unixtime_min % intervalduration == 0) {
				//printf("specified minute.  %d %d\n", unixtime_min,
				//              intervalduration);

				// attempt to create new modbus connection
				ctx = modbus_new_rtu(modbus_device_address, modbus_baud_rate,
						modbus_parity[0], modbus_data_bits, modbus_stop_bits);

				modbus_set_slave(ctx, slaveid);
				modbus_set_debug(ctx, DEBUG);

				if (ctx == NULL) {
					syslog(LOG_ERR, "Unable to create libmodbus object");
				}

				if (modbus_connect(ctx) == -1) {
					syslog(LOG_ERR, "libmodbus: Connection failed: %s",
							modbus_strerror(errno));
					modbus_free(ctx);
				}

				int retry = 0;

				// handle timeouts and retries
				do {
					switch (registertype) {

					case 3:
						rc = modbus_read_registers(ctx, startaddress,
								numregisters, tab_reg);
						break;

					case 4:
						rc = modbus_read_input_registers(ctx, startaddress,
								numregisters, tab_reg);
						break;

					default:
						rc = modbus_read_registers(ctx, startaddress,
								numregisters, tab_reg);
						break;
					}
					if (rc == -1) {
						syslog(LOG_ERR, "libmodbus error: %s",
								modbus_strerror(errno));
					}
					retry++;
				} while ((rc != -1) && (retry < (modbus_retry + 1)));

				//MODBUS_GET_HIGH_BYTE(data);
				//MODBUS_GET_LOW_BYTE(data);
				//MODBUS_SET_INT16_TO_INT8(tab_int8, index, value);

				// round forward to next midnight
				time_t unixtime_day = ((((int) t) / 86400 * 86400) + 86400);

				struct tm midnight = *localtime(&unixtime_day);

				char filename[50];

				//<mac address>_YYYY_MM_DD_HH_MM_SS.log
				sprintf(filename,
						"/var/modbuslog/%s_%04i_%02i_%02i_%02i_%02i_%02i.log",
						mac_address(), midnight.tm_year + 1900,
						midnight.tm_mon + 1, midnight.tm_mday, midnight.tm_hour,
						midnight.tm_min, midnight.tm_sec);

				//printf("%s\n",filename);

				FILE *fp = fopen(filename, "r");
				if (fp) {
					fclose(fp);
				} else {
					// file doesn't exist. create it.
					syslog(LOG_NOTICE, "logfile does not exist");
					syslog(LOG_INFO, "creating file: %s", filename);
					FILE *fp = fopen(filename, "w");
					fprintf(
							fp,
							"IntervalID|UTCDate|UTCTime|LOCALDate|LOCALTime|SensorID|RegisterID|Reading\n");
					fclose(fp);
				}

				FILE *filehandle = fopen(filename, "a+");

				syslog(LOG_DEBUG, "opening file for append: %s", filename);

				int16_t registervalue = 0;

				int p;

				// data arrives in words, split into bytes
				for (p = 0; p < numregisters; p++) {
					MODBUS_SET_INT16_TO_INT8(byte, p * 2, tab_reg[p]);
					//registervalue += tab_reg[i] + tab_reg[i + 1];
				}

				// bitshifting magic
				switch (numregisters) {
				case 1:
					registervalue = byte[0];
					break;
				case 2:
					registervalue = ((byte[0]) << 8) + byte[1];
					break;
				case 4:
					registervalue = ((byte[0]) << 24) + ((byte[1]) << 16)
							+ ((byte[2]) << 8) + byte[3];
					break;
				default:
					registervalue = byte[0];
					break;
				}

				struct tm utc = *gmtime(&unixtime_min);
				struct tm lc = *localtime(&unixtime_min);

				int intervalid;
				FILE *intervalfile = fopen(
						"/var/modbuslog/interval/interval.txt", "r+");

				if (intervalfile) {
					fclose(intervalfile);
				} else {
					// file doesn't exist. create it.
					syslog(LOG_NOTICE, "interval file does not exist");
					syslog(LOG_INFO, "attempting to create file: %s",
							intervalfile);
					FILE *intervalfile = fopen(filename, "w");
					fprintf(intervalfile, "0\n");
					fclose(intervalfile);
				}

				fscanf(intervalfile, "%d", &intervalid);
				//handle 32bit signed overflow
				if (intervalid == 2147483647) {
					intervalid = 0;
				} else {
					intervalid++;
				}
				rewind(intervalfile);
				fprintf(intervalfile, "%d", intervalid);
				fclose(intervalfile);

				fprintf(
						filehandle,
						"%i|%04i%02i%02i|%02i%02i%02i|%04i%02i%02i|%02i%02i%02i|%i|%i|%i\n",
						intervalid, utc.tm_year + 1900, utc.tm_mon + 1,
						utc.tm_mday, utc.tm_hour, utc.tm_min, utc.tm_sec,
						lc.tm_year + 1900, lc.tm_mon + 1, lc.tm_mday,
						lc.tm_hour, lc.tm_min, lc.tm_sec, slaveid, startaddress,
						registervalue);
				fclose(filehandle);

				syslog(
						LOG_DEBUG,
						"%i|%04i%02i%02i|%02i%02i%02i|%04i%02i%02i|%02i%02i%02i|%i|%i|%i\n",
						intervalid, utc.tm_year + 1900, utc.tm_mon + 1,
						utc.tm_mday, utc.tm_hour, utc.tm_min, utc.tm_sec,
						lc.tm_year + 1900, lc.tm_mon + 1, lc.tm_mday,
						lc.tm_hour, lc.tm_min, lc.tm_sec, slaveid, startaddress,
						registervalue);

				modbus_close(ctx);
				modbus_free(ctx);

				sleep(1);
				//return 0;

			}
			//printf("%d ", slaveid);
		}
		//printf("%d\n", unixtime_min);
	}
}
generated by cgit v1.2.3 (git 2.39.1) at 2025-11-25 06:58:08 +0000