multiplexes.c

linux下的dvb收看解析软件代码； 带参考程序

/* 
Copyright (C) 2006  Adam Charrett

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., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA

multiplexes.c

Manage multiplexes and tuning parameters.

*/
#include <stdlib.h>
#include <string.h>

#include "dbase.h"
#include "multiplexes.h"
#include "logging.h"

int OFDMParametersGet(int freq, struct dvb_frontend_parameters *feparams);
int OFDMParametersAdd(struct dvb_frontend_parameters *feparams);
int QPSKParametersGet(int freq, struct dvb_frontend_parameters *feparams);
int QPSKParametersAdd(struct dvb_frontend_parameters *feparams);
int QAMParametersGet(int freq, struct dvb_frontend_parameters *feparams);
int QAMParametersAdd(struct dvb_frontend_parameters *feparams);

int MultiplexCount()
{
	STATEMENT_INIT;
	int result = -1;

	STATEMENT_PREPARE("SELECT count() FROM " MULTIPLEXES_TABLE ";");
	RETURN_ON_ERROR(-1);

	STATEMENT_STEP();
	if (rc == SQLITE_ROW)
	{
		result = STATEMENT_COLUMN_INT( 0);
		rc = 0;
	}
	STATEMENT_FINALIZE();
	return result;
}

Multiplex_t *MultiplexFind(int freq)
{
	Multiplex_t *result = NULL;
	STATEMENT_INIT;
	
	STATEMENT_PREPAREVA("SELECT "	MULTIPLEX_FREQ ","
						MULTIPLEX_ID ","
						MULTIPLEX_TYPE ","
						MULTIPLEX_PATVERSION " "
						"FROM " MULTIPLEXES_TABLE " WHERE " MULTIPLEX_FREQ "=%d;",freq);
	RETURN_ON_ERROR(NULL);

	result = MultiplexGetNext((MultiplexEnumerator_t)stmt);

	STATEMENT_FINALIZE();
	return result;
}

MultiplexEnumerator_t MultiplexEnumeratorGet()
{
	STATEMENT_INIT;
	STATEMENT_PREPARE("SELECT "	MULTIPLEX_FREQ ","
					  MULTIPLEX_ID ","
					  MULTIPLEX_TYPE ","
					  MULTIPLEX_PATVERSION " "
					  "FROM " MULTIPLEXES_TABLE ";");
	RETURN_ON_ERROR(NULL);
	return stmt;
}

void MultiplexEnumeratorDestroy(MultiplexEnumerator_t enumerator)
{
	int rc;
	sqlite3_stmt *stmt = (sqlite3_stmt *)enumerator;
	STATEMENT_FINALIZE();
}

Multiplex_t *MultiplexGetNext(MultiplexEnumerator_t enumerator)
{
	int rc;
	sqlite3_stmt *stmt = (sqlite3_stmt *)enumerator;

	STATEMENT_STEP();
	if (rc == SQLITE_ROW)
	{
		Multiplex_t *multiplex;
		multiplex = calloc(1, sizeof(Multiplex_t));
		multiplex->freq = STATEMENT_COLUMN_INT( 0);
		multiplex->tsid = STATEMENT_COLUMN_INT( 1);
		multiplex->type = STATEMENT_COLUMN_INT( 2);
		multiplex->patversion = STATEMENT_COLUMN_INT( 4);
		
		printlog(LOG_DEBUGV,"Multiplex: %d, 0x%04x %d %d\n", multiplex->freq ,
		multiplex->tsid,
		multiplex->type,
		multiplex->patversion);
		
		return multiplex;
	}
    if (rc != SQLITE_DONE)
    {
        PRINTLOG_SQLITE3ERROR();
    }
	return NULL;
}

int MultiplexFrontendParametersGet(Multiplex_t *multiplex, struct dvb_frontend_parameters *feparams)
{
	int result = -1;
	switch(multiplex->type)
	{
		case FE_QPSK:
		result = QPSKParametersGet(multiplex->freq, feparams);
		break;
		case FE_QAM:
		result = QAMParametersGet(multiplex->freq, feparams);
		break;
		case FE_OFDM:
		result = OFDMParametersGet(multiplex->freq, feparams);
		break;
		default:
		break;
	}
	return result;
}

int MultiplexAdd(fe_type_t type, struct dvb_frontend_parameters *feparams)
{
	STATEMENT_INIT;
	switch(type)
	{
		case FE_QPSK:
		rc = QPSKParametersAdd(feparams);
		break;
		case FE_QAM:
		rc = QAMParametersAdd(feparams);
		break;
		case FE_OFDM:
		rc = OFDMParametersAdd(feparams);
		break;
		default:
		return -1;
	}
	RETURN_RC_ON_ERROR;
	STATEMENT_PREPAREVA("INSERT INTO " MULTIPLEXES_TABLE "("
						MULTIPLEX_FREQ ","
						MULTIPLEX_TYPE ","
						MULTIPLEX_PATVERSION ")"
						"VALUES (%d,%d,-1);", feparams->frequency, type);
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();
	
	STATEMENT_FINALIZE();
	return rc;
}

int MultiplexPATVersionSet(Multiplex_t *multiplex, int patversion)
{
	STATEMENT_INIT;
	STATEMENT_PREPAREVA("UPDATE "	MULTIPLEXES_TABLE " "
						"SET " MULTIPLEX_PATVERSION "=%d "
						"WHERE " MULTIPLEX_FREQ "=%d;", patversion, multiplex->freq);
	multiplex->patversion = patversion;
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();

	STATEMENT_FINALIZE();	
	return rc;
}

int MultiplexTSIdSet(Multiplex_t *multiplex, int tsid)
{
	STATEMENT_INIT;
	STATEMENT_PREPAREVA("UPDATE "	MULTIPLEXES_TABLE " "
						"SET " MULTIPLEX_ID "=%d "
						"WHERE " MULTIPLEX_FREQ "=%d;", tsid, multiplex->freq);
	multiplex->tsid = tsid;
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();

	STATEMENT_FINALIZE();	
	return rc;
}

int OFDMParametersGet(int freq, struct dvb_frontend_parameters *feparams)
{
	STATEMENT_INIT;
	STATEMENT_PREPAREVA("SELECT "	OFDMPARAM_FREQ ","
						OFDMPARAM_INVERSION ","
						OFDMPARAM_BW ","
						OFDMPARAM_FEC_HP ","
						OFDMPARAM_FEC_LP ","
						OFDMPARAM_QAM ","
						OFDMPARAM_TRANSMISSIONM ","
						OFDMPARAM_GUARDLIST ","
						OFDMPARAM_HIERARCHINFO " "
						"FROM " OFDMPARAMS_TABLE " WHERE " OFDMPARAM_FREQ "=%d;"
						,freq);
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();
	if (rc == SQLITE_ROW)
	{
		feparams->frequency                    = STATEMENT_COLUMN_INT( 0);
		feparams->inversion                    = STATEMENT_COLUMN_INT( 1);
		feparams->u.ofdm.bandwidth             = STATEMENT_COLUMN_INT( 2);
		feparams->u.ofdm.code_rate_HP          = STATEMENT_COLUMN_INT( 3);
		feparams->u.ofdm.code_rate_LP          = STATEMENT_COLUMN_INT( 4);
		feparams->u.ofdm.constellation         = STATEMENT_COLUMN_INT( 5);
		feparams->u.ofdm.transmission_mode     = STATEMENT_COLUMN_INT( 6);
		feparams->u.ofdm.guard_interval        = STATEMENT_COLUMN_INT( 7);
		feparams->u.ofdm.hierarchy_information = STATEMENT_COLUMN_INT( 8);
		rc = 0;
	}
	STATEMENT_FINALIZE();
	return rc;
}

int OFDMParametersAdd(struct dvb_frontend_parameters *feparams)
{
	STATEMENT_INIT;
	STATEMENT_PREPAREVA("INSERT INTO " OFDMPARAMS_TABLE " "
						"VALUES (" 
						"%d," /* OFDMPARAM_FREQ */
						"%d," /* OFDMPARAM_INVERSION */
						"%d," /* OFDMPARAM_BW */
						"%d," /* OFDMPARAM_FEC_HP */
						"%d," /* OFDMPARAM_FEC_LP */
						"%d," /* OFDMPARAM_QAM */
						"%d," /* OFDMPARAM_TRANSMISSIONM */
						"%d," /* OFDMPARAM_GUARDLIST */
						"%d"  /* OFDMPARAM_HIERARCHINFO */
						");",
						feparams->frequency,
						feparams->inversion,
						feparams->u.ofdm.bandwidth,
						feparams->u.ofdm.code_rate_HP,
						feparams->u.ofdm.code_rate_LP,
						feparams->u.ofdm.constellation,
						feparams->u.ofdm.transmission_mode,
						feparams->u.ofdm.guard_interval,
						feparams->u.ofdm.hierarchy_information);
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();
	
	STATEMENT_FINALIZE();
	return rc;
}

int QPSKParametersGet(int freq, struct dvb_frontend_parameters *feparams)
{
	STATEMENT_INIT;
	STATEMENT_PREPAREVA("SELECT "	
                        QPSKPARAM_FREQ ","
						QPSKPARAM_INVERSION ","
						QPSKPARAM_SYMBOL_RATE ","
						QPSKPARAM_FEC_INNER " "
						"FROM " QPSKPARAMS_TABLE " WHERE " QPSKPARAM_FREQ "=%d;"
						,freq);
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();
	if (rc == SQLITE_ROW)
	{
		feparams->frequency           = STATEMENT_COLUMN_INT( 0);
		feparams->inversion           = STATEMENT_COLUMN_INT( 1);
		feparams->u.qpsk.symbol_rate  = STATEMENT_COLUMN_INT( 2);
		feparams->u.qpsk.fec_inner    = STATEMENT_COLUMN_INT( 3);
		rc = 0;
	}
	STATEMENT_FINALIZE();
	return rc;
}

int QPSKParametersAdd(struct dvb_frontend_parameters *feparams)
{
	STATEMENT_INIT;
	STATEMENT_PREPAREVA("INSERT INTO " QPSKPARAMS_TABLE " "
						"VALUES (" 
						"%d," /* QPSKPARAM_FREQ */
						"%d," /* QPSKPARAM_INVERSION */
						"%d," /* QPSKPARAM_SYMBOL_RATE */
						"%d" /* QPSKPARAM_FEC_INNER */
						");",
						feparams->frequency,
						feparams->inversion,
						feparams->u.qpsk.symbol_rate,
						feparams->u.qpsk.fec_inner);
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();
	
	STATEMENT_FINALIZE();
	return rc;
}

int QAMParametersGet(int freq, struct dvb_frontend_parameters *feparams)
{
	STATEMENT_INIT;
	STATEMENT_PREPAREVA("SELECT "	
						QAMPARAM_FREQ ","
	                    QAMPARAM_INVERSION ","
	                    QAMPARAM_SYMBOL_RATE ","
	                    QAMPARAM_FEC_INNER ","
	                    QAMPARAM_MODULATION " "
						"FROM " QAMPARAMS_TABLE " WHERE " QAMPARAM_FREQ "=%d;"
						,freq);
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();
	if (rc == SQLITE_ROW)
	{
		feparams->frequency           = STATEMENT_COLUMN_INT( 0);
		feparams->inversion           = STATEMENT_COLUMN_INT( 1);
		feparams->u.qam.symbol_rate   = STATEMENT_COLUMN_INT( 2);
		feparams->u.qam.fec_inner     = STATEMENT_COLUMN_INT( 3);
		feparams->u.qam.modulation    = STATEMENT_COLUMN_INT( 4);
		rc = 0;
	}
	STATEMENT_FINALIZE();
	return rc;
}

int QAMParametersAdd(struct dvb_frontend_parameters *feparams)
{
	STATEMENT_INIT;
	STATEMENT_PREPAREVA("INSERT INTO " QAMPARAMS_TABLE " "
						"VALUES (" 
						"%d," /* QAMPARAM_FREQ */
						"%d," /* QAMPARAM_INVERSION */
						"%d," /* QAMPARAM_SYMBOL_RATE */
						"%d," /* QAMPARAM_FEC_INNER */
						"%d" /* QAMPARAM_MODULATION */
						");",
						feparams->frequency,
						feparams->inversion,
						feparams->u.qam.symbol_rate,
						feparams->u.qam.fec_inner,
						feparams->u.qam.modulation);
	RETURN_RC_ON_ERROR;
	
	STATEMENT_STEP();
	
	STATEMENT_FINALIZE();
	return rc;
}