lcd4linux.git - lcd4linux

diff options

author	michael <michael@3ae390bd-cb1e-0410-b409-cd5a39f66f1f>	2011-01-05 03:49:07 +0000
committer	michael <michael@3ae390bd-cb1e-0410-b409-cd5a39f66f1f>	2011-01-05 03:49:07 +0000
commit	72e1f7501bd6806022b7a33e1424ea2cc7fa4059 (patch)
tree	d9f61ce9a56caf4cc81f50c76e1052f4939e633d /contrib/picoLCD/mrtg.py
parent	f95cad51ea998c6febe30b9da74bd2852449d3c1 (diff)
download	lcd4linux-72e1f7501bd6806022b7a33e1424ea2cc7fa4059.tar.gz

fix for a bug introduced in the DE-LD021 driver

git-svn-id: https://ssl.bulix.org/svn/lcd4linux/trunk@1140 3ae390bd-cb1e-0410-b409-cd5a39f66f1f

Diffstat (limited to 'contrib/picoLCD/mrtg.py')

0 files changed, 0 insertions, 0 deletions

/* gnutv utility Copyright (C) 2004, 2005 Manu Abraham <abraham.manu@gmail.com> Copyright (C) 2006 Andrew de Quincey (adq_dvb@lidskialf.net) 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 2 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, write to the Free Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */ #include <stdio.h> #include <unistd.h> #include <limits.h> #include <string.h> #include <signal.h> #include <pthread.h> #include <errno.h> #include <sys/poll.h> #include <libdvbapi/dvbdemux.h> #include <libucsi/section.h> #include <libucsi/mpeg/section.h> #include <libucsi/dvb/section.h> #include "gnutv.h" #include "gnutv_dvb.h" #include "gnutv_data.h" #include "gnutv_ca.h" #define FE_STATUS_PARAMS (DVBFE_INFO_LOCKSTATUS|DVBFE_INFO_SIGNAL_STRENGTH|DVBFE_INFO_BER|DVBFE_INFO_SNR|DVBFE_INFO_UNCORRECTED_BLOCKS) static int dvbthread_shutdown = 0; static pthread_t dvbthread; static int tune_state = 0; static int pat_version = -1; static int ca_pmt_version = -1; static int data_pmt_version = -1; static void *dvbthread_func(void* arg); static void process_pat(int pat_fd, struct gnutv_dvb_params *params, int *pmt_fd, struct pollfd *pollfd); static void process_tdt(int tdt_fd); static void process_pmt(int pmt_fd, struct gnutv_dvb_params *params); static int create_section_filter(int adapter, int demux, uint16_t pid, uint8_t table_id); int gnutv_dvb_start(struct gnutv_dvb_params *params) { pthread_create(&dvbthread, NULL, dvbthread_func, (void*) params); return 0; } void gnutv_dvb_stop(void) { dvbthread_shutdown = 1; pthread_join(dvbthread, NULL); } int gnutv_dvb_locked(void) { return tune_state == 2; } static void *dvbthread_func(void* arg) { int pat_fd = -1; int pmt_fd = -1; int tdt_fd = -1; struct pollfd pollfds[3]; struct gnutv_dvb_params *params = (struct gnutv_dvb_params *) arg; tune_state = 0; // create PAT filter if ((pat_fd = create_section_filter(params->adapter_id, params->demux_id, TRANSPORT_PAT_PID, stag_mpeg_program_association)) < 0) { fprintf(stderr, "Failed to create PAT section filter\n"); exit(1); } pollfds[0].fd = pat_fd; pollfds[0].events = POLLIN|POLLPRI|POLLERR; // create TDT filter if ((tdt_fd = create_section_filter(params->adapter_id, params->demux_id, TRANSPORT_TDT_PID, stag_dvb_time_date)) < 0) { fprintf(stderr, "Failed to create TDT section filter\n"); exit(1); } pollfds[1].fd = tdt_fd; pollfds[1].events = POLLIN|POLLPRI|POLLERR; // zero PMT filter pollfds[2].fd = 0; pollfds[2].events = 0; // the DVB loop while(!dvbthread_shutdown) { // tune frontend + monitor lock status if (tune_state == 0) { // get the type of frontend struct dvbfe_info result; char *types; memset(&result, 0, sizeof(result)); dvbfe_get_info(params->fe, 0, &result, DVBFE_INFO_QUERYTYPE_IMMEDIATE, 0); switch(result.type) { case DVBFE_TYPE_DVBS: types = "DVB-S"; break; case DVBFE_TYPE_DVBC: types = "DVB-C"; break; case DVBFE_TYPE_DVBT: types = "DVB-T"; break; case DVBFE_TYPE_ATSC: types = "ATSC"; break; default: types = "Unknown"; } fprintf(stderr, "Using frontend \"%s\", type %s\n", result.name, types); // do we have a valid SEC configuration? struct dvbsec_config *sec = NULL; if (params->valid_sec) sec = &params->sec; // tune! if (dvbsec_set(params->fe, sec, params->channel.polarization, (params->channel.diseqc_switch & 0x01) ? DISEQC_SWITCH_B : DISEQC_SWITCH_A, (params->channel.diseqc_switch & 0x02) ? DISEQC_SWITCH_B : DISEQC_SWITCH_A, &params->channel.fe_params, 0)) { fprintf(stderr, "Failed to set frontend\n"); exit(1); } tune_state++; } else if (tune_state == 1) { struct dvbfe_info result; memset(&result, 0, sizeof(result)); dvbfe_get_info(params->fe, FE_STATUS_PARAMS, &result, DVBFE_INFO_QUERYTYPE_IMMEDIATE, 0); fprintf(stderr, "status %c%c%c%c%c | signal %04x | snr %04x | ber %08x | unc %08x | %s\r", result.signal ? 'S' : ' ', result.carrier ? 'C' : ' ', result.viterbi ? 'V' : ' ', result.sync ? 'Y' : ' ', result.lock ? 'L' : ' ', result.signal_strength, result.snr, result.ber, result.ucblocks, result.lock ? "FE_HAS_LOCK" : ""); fflush(stderr); if (result.lock) { tune_state++; fprintf(stderr, "\n"); fflush(stderr); } else { usleep(500000); } } // is there SI data? int count = poll(pollfds, 3, 100); if (count < 0) { if (errno != EINTR) fprintf(stderr, "Poll error: %m\n"); break; } if (count == 0) { continue; } // PAT if (pollfds[0].revents & (POLLIN|POLLPRI)) { process_pat(pat_fd, params, &pmt_fd, &pollfds[2]); } // TDT if (pollfds[1].revents & (POLLIN|POLLPRI)) { process_tdt(tdt_fd); } // PMT if (pollfds[2].revents & (POLLIN|POLLPRI)) { process_pmt(pmt_fd, params); } } // close demuxers if (pat_fd != -1) close(pat_fd); if (pmt_fd != -1) close(pmt_fd); if (tdt_fd != -1) close(tdt_fd); return 0; } static void process_pat(int pat_fd, struct gnutv_dvb_params *params, int *pmt_fd, struct pollfd *pollfd) { int size; uint8_t sibuf[4096]; // read the section if ((size = read(pat_fd, sibuf, sizeof(sibuf))) < 0) { return; } // parse section struct section *section = section_codec(sibuf, size); if (section == NULL) { return; } // parse section_ext struct section_ext *section_ext = section_ext_decode(section, 0); if (section_ext == NULL) { return; } if (pat_version == section_ext->version_number) { return; } // parse PAT struct mpeg_pat_section *pat = mpeg_pat_section_codec(section_ext); if (pat == NULL) { return; } // try and find the requested program struct mpeg_pat_program *cur_program; mpeg_pat_section_programs_for_each(pat, cur_program) { if (cur_program->program_number == params->channel.service_id) { // close old PMT fd if (*pmt_fd != -1) close(*pmt_fd); // create PMT filter if ((*pmt_fd = create_section_filter(params->adapter_id, params->demux_id, cur_program->pid, stag_mpeg_program_map)) < 0) { return; } pollfd->fd = *pmt_fd; pollfd->events = POLLIN|POLLPRI|POLLERR; gnutv_data_new_pat(cur_program->pid); // we have a new PMT pid data_pmt_version = -1; ca_pmt_version = -1; break; } } // remember the PAT version pat_version = section_ext->version_number; } static void process_tdt(int tdt_fd) { int size; uint8_t sibuf[4096]; // read the section if ((size = read(tdt_fd, sibuf, sizeof(sibuf))) < 0) { return; } // parse section struct section *section = section_codec(sibuf, size); if (section == NULL) { return; } // parse TDT struct dvb_tdt_section *tdt = dvb_tdt_section_codec(section); if (tdt == NULL) { return; } // done gnutv_ca_new_dvbtime(dvbdate_to_unixtime(tdt->utc_time)); } static void process_pmt(int pmt_fd, struct gnutv_dvb_params *params) { int size; uint8_t sibuf[4096]; // read the section if ((size = read(pmt_fd, sibuf, sizeof(sibuf))) < 0) { return; } // parse section struct section *section = section_codec(sibuf, size); if (section == NULL) { return; } // parse section_ext struct section_ext *section_ext = section_ext_decode(section, 0); if (section_ext == NULL) { return; } if ((section_ext->table_id_ext != params->channel.service_id) || ((section_ext->version_number == data_pmt_version) && (section_ext->version_number == ca_pmt_version))) { return; } // parse PMT struct mpeg_pmt_section *pmt = mpeg_pmt_section_codec(section_ext); if (pmt == NULL) { return; } // do data handling if (section_ext->version_number != data_pmt_version) { if (gnutv_data_new_pmt(pmt) == 1) data_pmt_version = pmt->head.version_number; } // do ca handling if (section_ext->version_number != ca_pmt_version) { if (gnutv_ca_new_pmt(pmt) == 1) ca_pmt_version = pmt->head.version_number; } } static int create_section_filter(int adapter, int demux, uint16_t pid, uint8_t table_id) { int demux_fd = -1; uint8_t filter[18]; uint8_t mask[18]; // open the demuxer if ((demux_fd = dvbdemux_open_demux(adapter, demux, 0)) < 0) { return -1; } // create a section filter memset(filter, 0, sizeof(filter)); memset(mask, 0, sizeof(mask)); filter[0] = table_id; mask[0] = 0xFF; if (dvbdemux_set_section_filter(demux_fd, pid, filter, mask, 1, 1)) { close(demux_fd); return -1; } // done return demux_fd; }


context:
space:
mode: