stv0g/tvheadend
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity
tvheadend/src/input/mpegts/satip/satip_frontend.c
Jaroslav Kysela 087089c204 SAT>IP: fix spelling (sattellite -> satellite)
2014-05-22 11:23:09 +02:00

1483 lines
42 KiB
C
Raw Blame History

/*
* Tvheadend - SAT>IP DVB frontend
*
* Copyright (C) 2014 Jaroslav Kysela
*
* 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/>.
*/
#include <fcntl.h>
#include "tvheadend.h"
#include "tvhpoll.h"
#include "streaming.h"
#include "http.h"
#include "satip_private.h"
static int
satip_frontend_tune1
( satip_frontend_t *lfe, mpegts_mux_instance_t *mmi );
/*
*
*/
static satip_frontend_t *
satip_frontend_find_by_number( satip_device_t *sd, int num )
{
satip_frontend_t *lfe;
TAILQ_FOREACH(lfe, &sd->sd_frontends, sf_link)
if (lfe->sf_number == num)
return lfe;
return NULL;
}
/* **************************************************************************
* Class definition
* *************************************************************************/
static void
satip_frontend_class_save ( idnode_t *in )
{
satip_device_t *la = ((satip_frontend_t*)in)->sf_device;
satip_device_save(la);
}
static int
satip_frontend_set_new_type
( satip_frontend_t *lfe, const char *type )
{
free(lfe->sf_type_override);
lfe->sf_type_override = strdup(type);
satip_device_destroy_later(lfe->sf_device, 100);
return 1;
}
static int
satip_frontend_class_override_set( void *obj, const void * p )
{
satip_frontend_t *lfe = obj;
const char *s = p;
if (lfe->sf_type_override == NULL) {
if (strlen(p) > 0)
return satip_frontend_set_new_type(lfe, s);
} else if (strcmp(lfe->sf_type_override, s))
return satip_frontend_set_new_type(lfe, s);
return 0;
}
static htsmsg_t *
satip_frontend_class_override_enum( void * p )
{
htsmsg_t *m = htsmsg_create_list();
htsmsg_add_str(m, NULL, "DVB-T");
htsmsg_add_str(m, NULL, "DVB-C");
return m;
}
const idclass_t satip_frontend_class =
{
.ic_super = &mpegts_input_class,
.ic_class = "satip_frontend",
.ic_caption = "SAT>IP DVB Frontend",
.ic_save = satip_frontend_class_save,
.ic_properties = (const property_t[]) {
{
.type = PT_INT,
.id = "fe_number",
.name = "Frontend Number",
.opts = PO_RDONLY | PO_NOSAVE,
.off = offsetof(satip_frontend_t, sf_number),
},
{
.type = PT_INT,
.id = "udp_rtp_port",
.name = "UDP RTP Port Number (2 ports)",
.off = offsetof(satip_frontend_t, sf_udp_rtp_port),
},
{
.type = PT_INT,
.id = "tdelay",
.name = "Next tune delay in ms (0-2000)",
.opts = PO_ADVANCED,
.off = offsetof(satip_frontend_t, sf_tdelay),
},
{
.type = PT_BOOL,
.id = "play2",
.name = "Send full PLAY cmd",
.opts = PO_ADVANCED,
.off = offsetof(satip_frontend_t, sf_play2),
},
{
.type = PT_BOOL,
.id = "teardown_delay",
.name = "Force teardown delay",
.opts = PO_ADVANCED,
.off = offsetof(satip_frontend_t, sf_teardown_delay),
},
{}
}
};
const idclass_t satip_frontend_dvbt_class =
{
.ic_super = &satip_frontend_class,
.ic_class = "satip_frontend_dvbt",
.ic_caption = "SAT>IP DVB-T Frontend",
.ic_properties = (const property_t[]){
{
.type = PT_STR,
.id = "fe_override",
.name = "Network Type",
.set = satip_frontend_class_override_set,
.list = satip_frontend_class_override_enum,
.off = offsetof(satip_frontend_t, sf_type_override),
},
{}
}
};
static idnode_set_t *
satip_frontend_dvbs_class_get_childs ( idnode_t *self )
{
satip_frontend_t *lfe = (satip_frontend_t*)self;
idnode_set_t *is = idnode_set_create();
satip_satconf_t *sfc;
TAILQ_FOREACH(sfc, &lfe->sf_satconf, sfc_link)
idnode_set_add(is, &sfc->sfc_id, NULL);
return is;
}
static int
satip_frontend_dvbs_class_positions_set ( void *self, const void *val )
{
satip_frontend_t *lfe = self;
int n = *(int *)val;
if (n < 0 || n > 32)
return 0;
if (n != lfe->sf_positions) {
lfe->sf_positions = n;
satip_satconf_updated_positions(lfe);
return 1;
}
return 0;
}
static int
satip_frontend_dvbs_class_master_set ( void *self, const void *val )
{
satip_frontend_t *lfe = self;
satip_frontend_t *lfe2 = NULL;
int num = *(int *)val, pos = 0;
if (num) {
TAILQ_FOREACH(lfe2, &lfe->sf_device->sd_frontends, sf_link)
if (lfe2 != lfe && lfe2->sf_type == lfe->sf_type)
if (++pos == num) {
num = lfe2->sf_number;
break;
}
}
if (lfe2 == NULL)
num = 0;
else if (lfe2->sf_master)
num = lfe2->sf_master;
if (lfe->sf_master != num) {
lfe->sf_master = num;
satip_device_destroy_later(lfe->sf_device, 100);
return 1;
}
return 0;
}
static htsmsg_t *
satip_frontend_dvbs_class_master_enum( void * self )
{
satip_frontend_t *lfe = self, *lfe2;
satip_device_t *sd = lfe->sf_device;
htsmsg_t *m = htsmsg_create_list();
htsmsg_add_str(m, NULL, "This Tuner");
TAILQ_FOREACH(lfe2, &sd->sd_frontends, sf_link)
if (lfe2 != lfe && lfe2->sf_type == lfe->sf_type)
htsmsg_add_str(m, NULL, lfe2->mi_name);
return m;
}
const idclass_t satip_frontend_dvbs_class =
{
.ic_super = &satip_frontend_class,
.ic_class = "satip_frontend_dvbs",
.ic_caption = "SAT>IP DVB-S Frontend",
.ic_get_childs = satip_frontend_dvbs_class_get_childs,
.ic_properties = (const property_t[]){
{
.type = PT_INT,
.id = "positions",
.name = "Satellite Positions",
.set = satip_frontend_dvbs_class_positions_set,
.opts = PO_NOSAVE,
.off = offsetof(satip_frontend_t, sf_positions),
.def.i = 4
},
{
.type = PT_INT,
.id = "fe_master",
.name = "Master Tuner",
.set = satip_frontend_dvbs_class_master_set,
.list = satip_frontend_dvbs_class_master_enum,
.off = offsetof(satip_frontend_t, sf_master),
},
{
.id = "networks",
.type = PT_NONE,
},
{}
}
};
const idclass_t satip_frontend_dvbs_slave_class =
{
.ic_super = &satip_frontend_class,
.ic_class = "satip_frontend_dvbs",
.ic_caption = "SAT>IP DVB-S Slave Frontend",
.ic_properties = (const property_t[]){
{
.type = PT_INT,
.id = "fe_master",
.name = "Master Tuner",
.set = satip_frontend_dvbs_class_master_set,
.list = satip_frontend_dvbs_class_master_enum,
.off = offsetof(satip_frontend_t, sf_master),
},
{
.id = "networks",
.type = PT_NONE,
},
{}
}
};
const idclass_t satip_frontend_dvbc_class =
{
.ic_super = &satip_frontend_class,
.ic_class = "satip_frontend_dvbc",
.ic_caption = "SAT>IP DVB-C Frontend",
.ic_properties = (const property_t[]){
{
.type = PT_STR,
.id = "fe_override",
.name = "Network Type",
.set = satip_frontend_class_override_set,
.list = satip_frontend_class_override_enum,
.off = offsetof(satip_frontend_t, sf_type_override),
},
{}
}
};
/* **************************************************************************
* Class methods
* *************************************************************************/
static int
satip_frontend_is_free ( mpegts_input_t *mi )
{
/* TODO: Add some RTSP live checks here */
return mpegts_input_is_free(mi);
}
static int
satip_frontend_get_weight ( mpegts_input_t *mi )
{
return mpegts_input_get_weight(mi);
}
static int
satip_frontend_get_priority ( mpegts_input_t *mi, mpegts_mux_t *mm )
{
satip_frontend_t *lfe = (satip_frontend_t*)mi;
int r = mpegts_input_get_priority(mi, mm);
if (lfe->sf_positions)
r += satip_satconf_get_priority(lfe, mm);
return r;
}
static int
satip_frontend_get_grace ( mpegts_input_t *mi, mpegts_mux_t *mm )
{
satip_frontend_t *lfe = (satip_frontend_t*)mi;
int r = 5;
if (lfe->sf_positions)
r = 10;
return r;
}
static int
satip_frontend_match_satcfg ( satip_frontend_t *lfe2, mpegts_mux_t *mm2 )
{
mpegts_mux_t *mm1;
dvb_mux_conf_t *mc1, *mc2;
int position, high1, high2;
if (lfe2->sf_mmi == NULL)
return 0;
mm1 = lfe2->sf_mmi->mmi_mux;
position = satip_satconf_get_position(lfe2, mm2);
if (position <= 0 || lfe2->sf_position != position)
return 0;
mc1 = &((dvb_mux_t *)mm1)->lm_tuning;
mc2 = &((dvb_mux_t *)mm2)->lm_tuning;
if (mc1->dmc_fe_type != DVB_TYPE_S || mc2->dmc_fe_type != DVB_TYPE_S)
return 0;
if (mc1->u.dmc_fe_qpsk.polarisation != mc2->u.dmc_fe_qpsk.polarisation)
return 0;
high1 = mc1->dmc_fe_freq > 11700000;
high2 = mc2->dmc_fe_freq > 11700000;
if (high1 != high2)
return 0;
return 1;
}
static int
satip_frontend_is_enabled ( mpegts_input_t *mi, mpegts_mux_t *mm )
{
satip_frontend_t *lfe = (satip_frontend_t*)mi;
satip_frontend_t *lfe2;
int position;
lock_assert(&global_lock);
if (!lfe->mi_enabled) return 0;
if (lfe->sf_type != DVB_TYPE_S) return 1;
/* check if the position is enabled */
position = satip_satconf_get_position(lfe, mm);
if (position <= 0)
return 0;
/* check if any "blocking" tuner is running */
TAILQ_FOREACH(lfe2, &lfe->sf_device->sd_frontends, sf_link) {
if (lfe2 == lfe) continue;
if (lfe2->sf_type != DVB_TYPE_S) continue;
if (lfe->sf_master == lfe2->sf_number) {
if (!lfe2->sf_running)
return 0; /* master must be running */
return satip_frontend_match_satcfg(lfe2, mm);
}
if (lfe2->sf_master == lfe->sf_number && lfe2->sf_running) {
if (lfe2->sf_mmi == NULL)
return 0;
return satip_frontend_match_satcfg(lfe2, mm);
}
}
return 1;
}
static void
satip_frontend_stop_mux
( mpegts_input_t *mi, mpegts_mux_instance_t *mmi )
{
satip_frontend_t *lfe = (satip_frontend_t*)mi;
char buf1[256], buf2[256];
mi->mi_display_name(mi, buf1, sizeof(buf1));
mmi->mmi_mux->mm_display_name(mmi->mmi_mux, buf2, sizeof(buf2));
tvhdebug("satip", "%s - stopping %s", buf1, buf2);
gtimer_disarm(&lfe->sf_monitor_timer);
/* Stop thread */
lfe->sf_shutdown = 1;
if (lfe->sf_dvr_pipe.wr > 0) {
tvh_write(lfe->sf_dvr_pipe.wr, "", 1);
tvhtrace("satip", "%s - waiting for dvr thread", buf1);
pthread_join(lfe->sf_dvr_thread, NULL);
tvh_pipe_close(&lfe->sf_dvr_pipe);
tvhdebug("satip", "%s - stopped dvr thread", buf1);
}
lfe->sf_shutdown = 0;
lfe->sf_running = 0;
lfe->sf_mmi = NULL;
udp_close(lfe->sf_rtp); lfe->sf_rtp = NULL;
udp_close(lfe->sf_rtcp); lfe->sf_rtcp = NULL;
free(lfe->sf_pids); lfe->sf_pids = NULL;
free(lfe->sf_pids_tuned); lfe->sf_pids_tuned = NULL;
}
static int
satip_frontend_start_mux
( mpegts_input_t *mi, mpegts_mux_instance_t *mmi )
{
satip_frontend_t *lfe = (satip_frontend_t*)mi;
if (lfe->sf_positions > 0) {
lfe->sf_position = satip_satconf_get_position(lfe, mmi->mmi_mux);
if (lfe->sf_position <= 0)
return SM_CODE_TUNING_FAILED;
}
return satip_frontend_tune1((satip_frontend_t*)mi, mmi);
}
static int
satip_frontend_add_pid( satip_frontend_t *lfe, int pid)
{
int mid, div;
if (pid < 0 || pid >= 8191)
return 0;
pthread_mutex_lock(&lfe->sf_dvr_lock);
if (lfe->sf_pids_count >= lfe->sf_pids_size) {
lfe->sf_pids_size += 64;
lfe->sf_pids = realloc(lfe->sf_pids,
lfe->sf_pids_size * sizeof(uint16_t));
lfe->sf_pids_tuned = realloc(lfe->sf_pids_tuned,
lfe->sf_pids_size * sizeof(uint16_t));
}
if (lfe->sf_pids_count == 0) {
lfe->sf_pids[lfe->sf_pids_count++] = pid;
pthread_mutex_unlock(&lfe->sf_dvr_lock);
return 1;
}
#if 0
printf("Insert PID: %i\n", pid);
if (pid == 0)
printf("HERE!!!\n");
{ int i; for (i = 0; i < lfe->sf_pids_count; i++)
printf("Bpid[%i] = %i\n", i, lfe->sf_pids[i]); }
#endif
/* insert pid to the sorted array */
mid = div = lfe->sf_pids_count / 2;
while (1) {
assert(mid >= 0 && mid < lfe->sf_pids_count);
if (div > 1)
div /= 2;
if (lfe->sf_pids[mid] == pid) {
pthread_mutex_unlock(&lfe->sf_dvr_lock);
return 0;
}
if (lfe->sf_pids[mid] < pid) {
if (mid + 1 >= lfe->sf_pids_count) {
lfe->sf_pids[lfe->sf_pids_count++] = pid;
break;
}
if (lfe->sf_pids[mid + 1] > pid) {
mid++;
if (mid < lfe->sf_pids_count)
memmove(&lfe->sf_pids[mid + 1], &lfe->sf_pids[mid],
(lfe->sf_pids_count - mid) * sizeof(uint16_t));
lfe->sf_pids[mid] = pid;
lfe->sf_pids_count++;
break;
}
mid += div;
} else {
if (mid == 0 || lfe->sf_pids[mid - 1] < pid) {
memmove(&lfe->sf_pids[mid+1], &lfe->sf_pids[mid],
(lfe->sf_pids_count - mid) * sizeof(uint16_t));
lfe->sf_pids[mid] = pid;
lfe->sf_pids_count++;
break;
}
mid -= div;
}
}
#if 0
{ int i; for (i = 0; i < lfe->sf_pids_count; i++)
printf("Apid[%i] = %i\n", i, lfe->sf_pids[i]); }
#endif
pthread_mutex_unlock(&lfe->sf_dvr_lock);
return 1;
}
static mpegts_pid_t *
satip_frontend_open_pid
( mpegts_input_t *mi, mpegts_mux_t *mm, int pid, int type, void *owner )
{
satip_frontend_t *lfe = (satip_frontend_t*)mi;
mpegts_pid_t *mp;
int change = 0;
if (!(mp = mpegts_input_open_pid(mi, mm, pid, type, owner)))
return NULL;
if (pid == MPEGTS_FULLMUX_PID) {
if (lfe->sf_device->sd_fullmux_ok) {
if (!lfe->sf_pids_any)
lfe->sf_pids_any = change = 1;
} else {
mpegts_service_t *s;
elementary_stream_t *st;
LIST_FOREACH(s, &mm->mm_services, s_dvb_mux_link) {
change |= satip_frontend_add_pid(lfe, s->s_pmt_pid);
change |= satip_frontend_add_pid(lfe, s->s_pcr_pid);
TAILQ_FOREACH(st, &s->s_components, es_link)
change |= satip_frontend_add_pid(lfe, st->es_pid);
}
}
} else {
change |= satip_frontend_add_pid(lfe, mp->mp_pid);
}
if (change) {
pthread_mutex_lock(&lfe->sf_dvr_lock);
if (!lfe->sf_pids_any_tuned ||
lfe->sf_pids_any != lfe->sf_pids_any_tuned)
tvh_write(lfe->sf_dvr_pipe.wr, "c", 1);
pthread_mutex_unlock(&lfe->sf_dvr_lock);
}
return mp;
}
static void
satip_frontend_close_pid
( mpegts_input_t *mi, mpegts_mux_t *mm, int pid, int type, void *owner )
{
satip_frontend_t *lfe = (satip_frontend_t*)mi;
int change = 0;
int mid, div, cnt;
/* remove PID */
if (pid == MPEGTS_FULLMUX_PID) {
if (lfe->sf_device->sd_fullmux_ok) {
if (lfe->sf_pids_any) {
lfe->sf_pids_any = 0;
change = 1;
}
}
goto finish;
}
pthread_mutex_lock(&lfe->sf_dvr_lock);
if (lfe->sf_pids) {
mid = div = (cnt = lfe->sf_pids_count) / 2;
while (cnt > 0) {
if (div > 1)
div /= 2;
if (lfe->sf_pids[mid] == pid) {
if (mid + 1 < lfe->sf_pids_count)
memmove(&lfe->sf_pids[mid], &lfe->sf_pids[mid+1],
(lfe->sf_pids_count - mid - 1) * sizeof(uint16_t));
lfe->sf_pids_count--;
change = 1;
break;
} else if (lfe->sf_pids[mid] < pid) {
if (mid + 1 > lfe->sf_pids_count)
break;
if (lfe->sf_pids[mid + 1] > pid)
break;
mid += div;
} else {
if (mid == 0)
break;
if (lfe->sf_pids[mid - 1] < pid)
break;
mid -= div;
}
cnt--;
}
}
pthread_mutex_unlock(&lfe->sf_dvr_lock);
finish:
mpegts_input_close_pid(mi, mm, pid, type, owner);
if (change) {
pthread_mutex_lock(&lfe->sf_dvr_lock);
if (!lfe->sf_pids_any_tuned ||
lfe->sf_pids_any != lfe->sf_pids_any_tuned)
tvh_write(lfe->sf_dvr_pipe.wr, "c", 1);
pthread_mutex_unlock(&lfe->sf_dvr_lock);
}
}
static idnode_set_t *
satip_frontend_network_list ( mpegts_input_t *mi )
{
satip_frontend_t *lfe = (satip_frontend_t*)mi;
const idclass_t *idc;
if (lfe->sf_type == DVB_TYPE_T)
idc = &dvb_network_dvbt_class;
else if (lfe->sf_type == DVB_TYPE_S)
idc = &dvb_network_dvbs_class;
else if (lfe->sf_type == DVB_TYPE_C)
idc = &dvb_network_dvbc_class;
else
return NULL;
return idnode_find_all(idc);
}
/* **************************************************************************
* Data processing
* *************************************************************************/
static void
satip_frontend_decode_rtcp( satip_frontend_t *lfe, const char *name,
mpegts_mux_instance_t *mmi,
uint8_t *rtcp, size_t len )
{
signal_state_t status;
uint16_t l, sl;
char *s;
char *argv[4];
int n;
/*
* DVB-S/S2:
* ver=<major>.<minor>;src=<srcID>;tuner=<feID>,<level>,<lock>,<quality>,\
* <frequency>,<polarisation>,<system>,<type>,<pilots>,<roll_off>,
* <symbol_rate>,<fec_inner>;pids=<pid0>,...,<pidn>
*
* DVB-T:
* ver=1.1;tuner=<feID>,<level>,<lock>,<quality>,<freq>,<bw>,<msys>,<tmode>,\
* <mtype>,<gi>,<fec>,<plp>,<t2id>,<sm>;pids=<pid0>,...,<pidn>
*
* DVB-C (OctopusNet):
* ver=0.9;tuner=<feID>,<0>,<lock>,<0>,<freq>,<bw>,<msys>,<mtype>;pids=<pid0>,...<pidn>
* example:
* ver=0.9;tuner=1,0,1,0,362.000,6900,dvbc,256qam;pids=0,1,16,17,18
*/
/* level:
* Numerical value between 0 and 255
* An incoming L-band satellite signal of
* -25dBm corresponds to 224
* -65dBm corresponds to 32
* No signal corresponds to 0
*
* lock:
* lock Set to one of the following values:
* "0" the frontend is not locked
* "1" the frontend is locked
*
* quality:
* Numerical value between 0 and 15
* Lowest value corresponds to highest error rate
* The value 15 shall correspond to
* -a BER lower than 2x10-4 after Viterbi for DVB-S
* -a PER lower than 10-7 for DVB-S2
*/
while (len >= 12) {
if ((rtcp[0] & 0xc0) != 0x80) /* protocol version: v2 */
return;
l = (((rtcp[2] << 8) | rtcp[3]) + 1) * 4; /* length of payload */
if (l > len)
return;
if (rtcp[1] == 204 && l > 20 && /* packet type */
rtcp[8] == 'S' && rtcp[9] == 'E' &&
rtcp[10] == 'S' && rtcp[11] == '1') {
sl = (rtcp[14] << 8) | rtcp[15];
if (sl > 0 && l - 16 >= sl) {
rtcp[sl + 16] = '\0';
s = (char *)rtcp + 16;
tvhtrace("satip", "Status string: '%s'", s);
status = SIGNAL_NONE;
if (strncmp(s, "ver=0.9;tuner=", 14) == 0) {
n = http_tokenize(s + 14, argv, 4, ',');
if (n < 4)
return;
if (atoi(argv[0]) != lfe->sf_number)
return;
mmi->mmi_stats.signal =
(atoi(argv[1]) * 100) / lfe->sf_device->sd_sig_scale;
if (atoi(argv[2]) > 0)
status = SIGNAL_GOOD;
mmi->mmi_stats.snr = atoi(argv[3]);
if (status == SIGNAL_GOOD &&
mmi->mmi_stats.signal == 0 && mmi->mmi_stats.snr == 0) {
/* some values that we're tuned */
mmi->mmi_stats.signal = 50;
mmi->mmi_stats.snr = 12;
}
goto ok;
} else if (strncmp(s, "ver=1.0;", 8) == 0) {
if ((s = strstr(s + 8, ";tuner=")) == NULL)
return;
s += 7;
n = http_tokenize(s, argv, 4, ',');
if (n < 4)
return;
if (atoi(argv[0]) != lfe->sf_number)
return;
mmi->mmi_stats.signal =
(atoi(argv[1]) * 100) / lfe->sf_device->sd_sig_scale;
if (atoi(argv[2]) > 0)
status = SIGNAL_GOOD;
mmi->mmi_stats.snr = atoi(argv[3]);
goto ok;
} else if (strncmp(s, "ver=1.1;tuner=", 14) == 0) {
n = http_tokenize(s + 14, argv, 4, ',');
if (n < 4)
return;
if (atoi(argv[0]) != lfe->sf_number)
return;
mmi->mmi_stats.signal =
(atoi(argv[1]) * 100) / lfe->sf_device->sd_sig_scale;
if (atoi(argv[2]) > 0)
status = SIGNAL_GOOD;
mmi->mmi_stats.snr = atoi(argv[3]);
goto ok;
}
}
}
rtcp += l;
len -= l;
}
return;
ok:
if (mmi->mmi_stats.snr < 2 && status == SIGNAL_GOOD)
status = SIGNAL_BAD;
else if (mmi->mmi_stats.snr < 4 && status == SIGNAL_GOOD)
status = SIGNAL_FAINT;
lfe->sf_status = status;
}
static void
satip_frontend_default_tables
( satip_frontend_t *lfe, mpegts_mux_t *mm )
{
psi_tables_default(mm);
psi_tables_dvb(mm);
}
static void
satip_frontend_store_pids(char *buf, uint16_t *pids, int count)
{
int first = 1;
char *s = buf;
*s = '\0';
while (count--) {
assert(*pids < 8192);
if (!first)
sprintf(s + strlen(s), ",%i", *(pids++));
else {
sprintf(s + strlen(s), "%i", *(pids++));
first = 0;
}
}
}
static int
satip_frontend_pid_changed( http_client_t *rtsp,
satip_frontend_t *lfe, const char *name )
{
char *add, *del;
int i, j, r, count, any = lfe->sf_pids_any;
int deleted;
int max_pids_len = lfe->sf_device->sd_pids_len;
if (!lfe->sf_running || lfe->sf_shutdown)
return 0;
pthread_mutex_lock(&lfe->sf_dvr_lock);
if (lfe->sf_pids_count > lfe->sf_device->sd_pids_max)
any = lfe->sf_device->sd_fullmux_ok ? 1 : 0;
if (any) {
if (lfe->sf_pids_any_tuned) {
pthread_mutex_unlock(&lfe->sf_dvr_lock);
return 0;
}
lfe->sf_pids_any_tuned = 1;
memcpy(lfe->sf_pids_tuned, lfe->sf_pids,
lfe->sf_pids_count * sizeof(uint16_t));
lfe->sf_pids_tcount = lfe->sf_pids_count;
pthread_mutex_unlock(&lfe->sf_dvr_lock);
r = satip_rtsp_play(rtsp, "all", NULL, NULL, max_pids_len);
r = r == 0 ? 1 : r;
} else if (!lfe->sf_device->sd_pids_deladd ||
lfe->sf_pids_any_tuned ||
lfe->sf_pids_tcount == 0) {
lfe->sf_pids_any_tuned = 0;
count = lfe->sf_pids_count;
if (count > lfe->sf_device->sd_pids_max)
count = lfe->sf_device->sd_pids_max;
add = alloca(count * 5);
/* prioritize higher PIDs (tables are low prio) */
satip_frontend_store_pids(add,
&lfe->sf_pids[lfe->sf_pids_count - count],
count);
memcpy(lfe->sf_pids_tuned, lfe->sf_pids,
lfe->sf_pids_count * sizeof(uint16_t));
lfe->sf_pids_tcount = lfe->sf_pids_count;
pthread_mutex_unlock(&lfe->sf_dvr_lock);
r = satip_rtsp_play(rtsp, add, NULL, NULL, max_pids_len);
r = r == 0 ? 1 : r;
} else {
add = alloca(lfe->sf_pids_count * 5);
del = alloca(lfe->sf_pids_count * 5);
add[0] = del[0] = '\0';
#if 0
for (i = 0; i < lfe->sf_pids_count; i++)
printf("pid[%i] = %i\n", i, lfe->sf_pids[i]);
for (i = 0; i < lfe->sf_pids_tcount; i++)
printf("tuned[%i] = %i\n", i, lfe->sf_pids_tuned[i]);
#endif
i = j = deleted = 0;
while (i < lfe->sf_pids_count && j < lfe->sf_pids_tcount) {
if (lfe->sf_pids[i] == lfe->sf_pids_tuned[j]) {
i++; j++;
} else if (lfe->sf_pids[i] < lfe->sf_pids_tuned[j]) {
i++;
} else {
sprintf(del + strlen(del), ",%i", lfe->sf_pids_tuned[j++]);
deleted++;
}
}
while (j < lfe->sf_pids_tcount) {
sprintf(del + strlen(del), ",%i", lfe->sf_pids_tuned[j++]);
deleted++;
}
count = lfe->sf_pids_count + (lfe->sf_pids_tcount - deleted);
if (count > lfe->sf_device->sd_pids_max)
count = lfe->sf_device->sd_pids_max;
/* prioritize higher PIDs (tables are low prio) */
/* count means "skip count" in following code */
count = lfe->sf_pids_count - count;
i = j = 0;
while (i < lfe->sf_pids_count && j < lfe->sf_pids_tcount) {
if (lfe->sf_pids[i] == lfe->sf_pids_tuned[j]) {
i++; j++;
} else if (lfe->sf_pids[i] < lfe->sf_pids_tuned[j]) {
if (count > 0) {
count--;
} else {
sprintf(add + strlen(add), ",%i", lfe->sf_pids[i]);
}
i++;
} else {
j++;
}
}
while (i < lfe->sf_pids_count) {
if (count > 0)
count--;
else
sprintf(add + strlen(add), ",%i", lfe->sf_pids[i++]);
}
memcpy(lfe->sf_pids_tuned, lfe->sf_pids,
lfe->sf_pids_count * sizeof(uint16_t));
lfe->sf_pids_tcount = lfe->sf_pids_count;
pthread_mutex_unlock(&lfe->sf_dvr_lock);
if (add[0] == '\0' && del[0] == '\0')
return 0;
r = satip_rtsp_play(rtsp, NULL, add, del, max_pids_len);
r = r == 0 ? 1 : r;
}
if (r < 0)
tvherror("satip", "%s - failed to modify pids: %s", name, strerror(-r));
return r;
}
static void *
satip_frontend_input_thread ( void *aux )
{
#define RTP_PKTS 64
#define UDP_PKT_SIZE 1472 /* this is maximum UDP payload (standard ethernet) */
#define RTP_PKT_SIZE (UDP_PKT_SIZE - 12) /* minus RTP minimal RTP header */
#define HTTP_CMD_NONE 9874
satip_frontend_t *lfe = aux, *lfe_master = lfe;
mpegts_mux_instance_t *mmi = lfe->sf_mmi;
http_client_t *rtsp;
dvb_mux_t *lm;
char buf[256];
struct iovec *iovec;
uint8_t rtcp[2048];
uint8_t *p;
sbuf_t sb;
int pos, nfds, i, r;
size_t c;
int tc;
tvhpoll_event_t ev[4];
tvhpoll_t *efd;
int changing = 0, ms = -1, fatal = 0;
uint32_t seq = -1, nseq;
udp_multirecv_t um;
int play2 = 1, position, rtsp_flags = 0;
uint64_t u64;
lfe->mi_display_name((mpegts_input_t*)lfe, buf, sizeof(buf));
if (lfe->sf_rtp == NULL || lfe->sf_rtcp == NULL || mmi == NULL)
return NULL;
lm = (dvb_mux_t *)mmi->mmi_mux;
if (lfe->sf_master) {
lfe_master = satip_frontend_find_by_number(lfe->sf_device, lfe->sf_master);
if (lfe_master == NULL)
lfe_master = lfe;
}
pthread_mutex_lock(&lfe->sf_device->sd_tune_mutex);
u64 = getmonoclock() - lfe_master->sf_last_tune;
tvhtrace("satip", "%s - last tune diff = %llu (tdelay = %u)",
buf, (unsigned long long)u64, lfe_master->sf_tdelay * 1000);
if (u64 < lfe_master->sf_tdelay * 1000) {
u64 = (lfe_master->sf_tdelay * 1000) - u64;
if (u64 >= 1000000) {
unsigned int s = u64 / 1000000;
while ((s = sleep(s)) != 0);
}
u64 %= 1000000;
while (usleep(u64));
}
lfe_master->sf_last_tune = getmonoclock();
pthread_mutex_unlock(&lfe->sf_device->sd_tune_mutex);
rtsp = http_client_connect(lfe, RTSP_VERSION_1_0, "rstp",
lfe->sf_device->sd_info.addr, 554);
if (rtsp == NULL)
return NULL;
/* Setup poll */
efd = tvhpoll_create(4);
memset(ev, 0, sizeof(ev));
ev[0].events = TVHPOLL_IN;
ev[0].fd = lfe->sf_rtp->fd;
ev[0].data.ptr = lfe->sf_rtp;
ev[1].events = TVHPOLL_IN;
ev[1].fd = lfe->sf_rtcp->fd;
ev[1].data.ptr = lfe->sf_rtcp;
ev[2].events = TVHPOLL_IN;
ev[2].fd = rtsp->hc_fd;
ev[2].data.ptr = rtsp;
ev[3].events = TVHPOLL_IN;
ev[3].fd = lfe->sf_dvr_pipe.rd;
ev[3].data.ptr = NULL;
tvhpoll_add(efd, ev, 4);
rtsp->hc_efd = efd;
position = lfe_master->sf_position;
if (lfe->sf_device->sd_pids0)
rtsp_flags |= SATIP_SETUP_PIDS0;
r = satip_rtsp_setup(rtsp,
position, lfe->sf_number,
lfe->sf_rtp_port, &lm->lm_tuning,
rtsp_flags);
if (r < 0) {
tvherror("satip", "%s - failed to tune", buf);
goto done;
}
udp_multirecv_init(&um, RTP_PKTS, RTP_PKT_SIZE);
sbuf_init_fixed(&sb, RTP_PKTS * RTP_PKT_SIZE);
while (tvheadend_running && !fatal) {
nfds = tvhpoll_wait(efd, ev, 1, ms);
if (nfds > 0 && ev[0].data.ptr == NULL) {
c = read(lfe->sf_dvr_pipe.rd, rtcp, 1);
if (c == 1 && rtcp[0] == 'c') {
ms = 20;
changing = 1;
continue;
}
tvhtrace("satip", "%s - input thread received shutdown", buf);
break;
}
if (changing && rtsp->hc_cmd == HTTP_CMD_NONE) {
ms = -1;
changing = 0;
satip_frontend_pid_changed(rtsp, lfe, buf);
continue;
}
if (nfds < 1) continue;
if (ev[0].data.ptr == rtsp) {
r = http_client_run(rtsp);
if (r < 0) {
tvhlog(LOG_ERR, "satip", "%s - RTSP error %d (%s) [%i-%i]",
buf, r, strerror(-r), rtsp->hc_cmd, rtsp->hc_code);
fatal = 1;
} else if (r == HTTP_CON_DONE) {
switch (rtsp->hc_cmd) {
case RTSP_CMD_OPTIONS:
r = rtsp_options_decode(rtsp);
if (r < 0) {
tvhlog(LOG_ERR, "satip", "%s - RTSP OPTIONS error %d (%s) [%i-%i]",
buf, r, strerror(-r), rtsp->hc_cmd, rtsp->hc_code);
fatal = 1;
}
break;
case RTSP_CMD_SETUP:
r = rtsp_setup_decode(rtsp, 1);
if (r < 0 || rtsp->hc_rtp_port != lfe->sf_rtp_port ||
rtsp->hc_rtpc_port != lfe->sf_rtp_port + 1) {
tvhlog(LOG_ERR, "satip", "%s - RTSP SETUP error %d (%s) [%i-%i]",
buf, r, strerror(-r), rtsp->hc_cmd, rtsp->hc_code);
fatal = 1;
} else {
tvhdebug("satip", "%s #%i - new session %s stream id %li",
rtsp->hc_host, lfe->sf_number,
rtsp->hc_rtsp_session, rtsp->hc_rtsp_stream_id);
pthread_mutex_lock(&global_lock);
satip_frontend_default_tables(lfe, mmi->mmi_mux);
pthread_mutex_unlock(&global_lock);
if (lfe->sf_play2) {
r = satip_rtsp_setup(rtsp, position, lfe->sf_number,
lfe->sf_rtp_port, &lm->lm_tuning,
rtsp_flags | SATIP_SETUP_PLAY);
if (r < 0) {
tvherror("satip", "%s - failed to tune2", buf);
fatal = 1;
}
continue;
} else {
if (satip_frontend_pid_changed(rtsp, lfe, buf) > 0)
continue;
}
}
break;
case RTSP_CMD_PLAY:
if (rtsp->hc_code == 200 && play2) {
play2 = 0;
if (satip_frontend_pid_changed(rtsp, lfe, buf) > 0)
continue;
}
/* fall thru */
default:
if (rtsp->hc_code >= 400) {
tvhlog(LOG_ERR, "satip", "%s - RTSP cmd error %d (%s) [%i-%i]",
buf, r, strerror(-r), rtsp->hc_cmd, rtsp->hc_code);
fatal = 1;
}
break;
}
rtsp->hc_cmd = HTTP_CMD_NONE;
}
}
/* We need to keep the session alive */
if (rtsp->hc_ping_time + rtsp->hc_rtp_timeout / 2 < dispatch_clock &&
rtsp->hc_cmd == HTTP_CMD_NONE)
rtsp_options(rtsp);
if (ev[0].data.ptr == lfe->sf_rtcp) {
c = recv(lfe->sf_rtcp->fd, rtcp, sizeof(rtcp), MSG_DONTWAIT);
if (c > 0)
satip_frontend_decode_rtcp(lfe, buf, mmi, rtcp, c);
continue;
}
if (ev[0].data.ptr != lfe->sf_rtp)
continue;
tc = udp_multirecv_read(&um, lfe->sf_rtp->fd, RTP_PKTS, &iovec);
if (tc < 0) {
if (errno == EAGAIN || errno == EINTR || errno == EWOULDBLOCK)
continue;
if (errno == EOVERFLOW) {
tvhlog(LOG_WARNING, "satip", "%s - recvmsg() EOVERFLOW", buf);
continue;
}
tvhlog(LOG_ERR, "satip", "%s - multirecv error %d (%s)",
buf, errno, strerror(errno));
break;
}
for (i = 0; i < tc; i++) {
p = iovec[i].iov_base;
c = iovec[i].iov_len;
/* Strip RTP header */
if (c < 12)
continue;
if ((p[0] & 0xc0) != 0x80)
continue;
if ((p[1] & 0x7f) != 33)
continue;
pos = ((p[0] & 0x0f) * 4) + 12;
if (p[0] & 0x10) {
if (c < pos + 4)
continue;
pos += (((p[pos+2] << 8) | p[pos+3]) + 1) * 4;
}
if (c <= pos || ((c - pos) % 188) != 0)
continue;
/* Use uncorrectable value to notify RTP delivery issues */
nseq = (p[2] << 8) | p[3];
if (seq == -1)
seq = nseq;
else if (((seq + 1) & 0xffff) != nseq)
mmi->mmi_stats.unc += ((c - pos) / 188) *
(uint32_t)((uint16_t)nseq-(uint16_t)(seq+1));
seq = nseq;
/* Process */
sbuf_append(&sb, p + pos, c - pos);
}
mpegts_input_recv_packets((mpegts_input_t*)lfe, mmi,
&sb, 0, NULL, NULL);
}
sbuf_free(&sb);
udp_multirecv_free(&um);
ev[0].events = TVHPOLL_IN;
ev[0].fd = lfe->sf_rtp->fd;
ev[0].data.ptr = lfe->sf_rtp;
ev[1].events = TVHPOLL_IN;
ev[1].fd = lfe->sf_rtcp->fd;
ev[1].data.ptr = lfe->sf_rtcp;
ev[2].events = TVHPOLL_IN;
ev[2].fd = lfe->sf_dvr_pipe.rd;
ev[2].data.ptr = NULL;
tvhpoll_rem(efd, ev, 3);
if (rtsp->hc_rtsp_stream_id >= 0) {
snprintf((char *)rtcp, sizeof(rtcp), "/stream=%li", rtsp->hc_rtsp_stream_id);
r = rtsp_teardown(rtsp, (char *)rtcp, NULL);
if (r < 0) {
tvhtrace("satip", "%s - bad teardown", buf);
} else {
while (1) {
r = http_client_run(rtsp);
if (r != HTTP_CON_RECEIVING && r != HTTP_CON_SENDING)
break;
nfds = tvhpoll_wait(efd, ev, 1, -1);
if (nfds <= 0) {
if (errno == EAGAIN || errno == EINTR || errno == EWOULDBLOCK)
continue;
break;
}
}
}
}
done:
if (lfe->sf_teardown_delay) {
pthread_mutex_lock(&lfe->sf_device->sd_tune_mutex);
lfe->sf_last_tune = lfe_master->sf_last_tune = getmonoclock();
pthread_mutex_unlock(&lfe->sf_device->sd_tune_mutex);
}
http_client_close(rtsp);
tvhpoll_destroy(efd);
return NULL;
#undef PKTS
}
/* **************************************************************************
* Tuning
* *************************************************************************/
static void
satip_frontend_signal_cb( void *aux )
{
satip_frontend_t *lfe = aux;
mpegts_mux_instance_t *mmi = LIST_FIRST(&lfe->mi_mux_active);
streaming_message_t sm;
signal_status_t sigstat;
service_t *svc;
if (mmi == NULL)
return;
sigstat.status_text = signal2str(lfe->sf_status);
sigstat.snr = mmi->mmi_stats.snr;
sigstat.signal = mmi->mmi_stats.signal;
sigstat.ber = mmi->mmi_stats.ber;
sigstat.unc = mmi->mmi_stats.unc;
sm.sm_type = SMT_SIGNAL_STATUS;
sm.sm_data = &sigstat;
LIST_FOREACH(svc, &lfe->mi_transports, s_active_link) {
pthread_mutex_lock(&svc->s_stream_mutex);
streaming_pad_deliver(&svc->s_streaming_pad, &sm);
pthread_mutex_unlock(&svc->s_stream_mutex);
}
gtimer_arm_ms(&lfe->sf_monitor_timer, satip_frontend_signal_cb, lfe, 250);
}
static int
satip_frontend_tune0
( satip_frontend_t *lfe, mpegts_mux_instance_t *mmi )
{
mpegts_mux_instance_t *cur = LIST_FIRST(&lfe->mi_mux_active);
if (cur != NULL) {
/* Already tuned */
if (mmi == cur)
return 0;
/* Stop current */
cur->mmi_mux->mm_stop(cur->mmi_mux, 1);
}
assert(LIST_FIRST(&lfe->mi_mux_active) == NULL);
if (udp_bind_double(&lfe->sf_rtp, &lfe->sf_rtcp,
"satip", "rtp", "rtpc",
lfe->sf_device->sd_info.myaddr, lfe->sf_udp_rtp_port,
NULL, SATIP_BUF_SIZE, 16384) < 0)
return SM_CODE_TUNING_FAILED;
lfe->sf_rtp_port = ntohs(IP_PORT(lfe->sf_rtp->ip));
assert(lfe->sf_pids == NULL);
assert(lfe->sf_pids_tuned == NULL);
lfe->sf_pids_count = 0;
lfe->sf_pids_tcount = 0;
lfe->sf_pids_size = 512;
lfe->sf_pids = calloc(lfe->sf_pids_size, sizeof(uint16_t));
lfe->sf_pids_tuned = calloc(lfe->sf_pids_size, sizeof(uint16_t));
lfe->sf_pids_any = 0;
lfe->sf_pids_any_tuned = 0;
lfe->sf_status = SIGNAL_NONE;
lfe->sf_mmi = mmi;
lfe->sf_running = 1;
tvhtrace("satip", "%s - local RTP port %i RTCP port %i",
lfe->mi_name,
ntohs(IP_PORT(lfe->sf_rtp->ip)),
ntohs(IP_PORT(lfe->sf_rtcp->ip)));
tvh_pipe(O_NONBLOCK, &lfe->sf_dvr_pipe);
tvhthread_create(&lfe->sf_dvr_thread, NULL,
satip_frontend_input_thread, lfe, 0);
gtimer_arm_ms(&lfe->sf_monitor_timer, satip_frontend_signal_cb, lfe, 250);
return 0;
}
static int
satip_frontend_tune1
( satip_frontend_t *lfe, mpegts_mux_instance_t *mmi )
{
char buf1[256], buf2[256];
lfe->mi_display_name((mpegts_input_t*)lfe, buf1, sizeof(buf1));
mmi->mmi_mux->mm_display_name(mmi->mmi_mux, buf2, sizeof(buf2));
tvhdebug("satip", "%s - starting %s", buf1, buf2);
/* Tune */
return satip_frontend_tune0(lfe, mmi);
}
/* **************************************************************************
* Creation/Config
* *************************************************************************/
static void
satip_frontend_hacks( satip_frontend_t *lfe )
{
lfe->sf_tdelay = 50; /* should not hurt anything */
if (strstr(lfe->sf_device->sd_info.location, ":8888/octonet.xml")) {
if (lfe->sf_type == DVB_TYPE_S)
lfe->sf_play2 = 1;
lfe->sf_tdelay = 250;
lfe->sf_teardown_delay = 1;
}
}
satip_frontend_t *
satip_frontend_create
( htsmsg_t *conf, satip_device_t *sd, dvb_fe_type_t type, int t2, int num )
{
const idclass_t *idc;
const char *uuid = NULL, *override = NULL;
char id[16], lname[256];
satip_frontend_t *lfe;
uint32_t master = 0;
int i;
/* Override type */
snprintf(id, sizeof(id), "override #%d", num);
if (conf && type != DVB_TYPE_S) {
override = htsmsg_get_str(conf, id);
if (override) {
i = dvb_str2type(override);
if ((i == DVB_TYPE_T || i == DVB_TYPE_C || DVB_TYPE_S) && i != type)
type = i;
else
override = NULL;
}
}
/* Tuner slave */
snprintf(id, sizeof(id), "master for #%d", num);
if (conf && type == DVB_TYPE_S) {
if (htsmsg_get_u32(conf, id, &master))
master = 0;
if (master == num)
master = 0;
}
/* Internal config ID */
snprintf(id, sizeof(id), "%s #%d", dvb_type2str(type), num);
if (conf)
conf = htsmsg_get_map(conf, id);
if (conf)
uuid = htsmsg_get_str(conf, "uuid");
/* Class */
if (type == DVB_TYPE_S)
idc = master ? &satip_frontend_dvbs_slave_class :
&satip_frontend_dvbs_class;
else if (type == DVB_TYPE_T)
idc = &satip_frontend_dvbt_class;
else if (type == DVB_TYPE_C)
idc = &satip_frontend_dvbc_class;
else {
tvherror("satip", "unknown FE type %d", type);
return NULL;
}
// Note: there is a bit of a chicken/egg issue below, without the
// correct "fe_type" we cannot set the network (which is done
// in mpegts_input_create()). So we must set early.
lfe = calloc(1, sizeof(satip_frontend_t));
lfe->sf_device = sd;
lfe->sf_number = num;
lfe->sf_type = type;
lfe->sf_type_t2 = t2;
lfe->sf_master = master;
lfe->sf_type_override = override ? strdup(override) : NULL;
satip_frontend_hacks(lfe);
TAILQ_INIT(&lfe->sf_satconf);
pthread_mutex_init(&lfe->sf_dvr_lock, NULL);
lfe = (satip_frontend_t*)mpegts_input_create0((mpegts_input_t*)lfe, idc, uuid, conf);
if (!lfe) return NULL;
/* Defaults */
lfe->sf_position = -1;
if (lfe->sf_tdelay > 2000)
lfe->sf_tdelay = 2000;
/* Callbacks */
lfe->mi_is_free = satip_frontend_is_free;
lfe->mi_get_weight = satip_frontend_get_weight;
lfe->mi_get_priority = satip_frontend_get_priority;
lfe->mi_get_grace = satip_frontend_get_grace;
/* Default name */
if (!lfe->mi_name ||
(strncmp(lfe->mi_name, "SAT>IP ", 7) == 0 &&
strstr(lfe->mi_name, " Tuner ") &&
strstr(lfe->mi_name, " #"))) {
snprintf(lname, sizeof(lname), "SAT>IP %s Tuner #%i (%s)",
dvb_type2str(type), num, sd->sd_info.addr);
free(lfe->mi_name);
lfe->mi_name = strdup(lname);
}
/* Input callbacks */
lfe->mi_is_enabled = satip_frontend_is_enabled;
lfe->mi_start_mux = satip_frontend_start_mux;
lfe->mi_stop_mux = satip_frontend_stop_mux;
lfe->mi_network_list = satip_frontend_network_list;
lfe->mi_open_pid = satip_frontend_open_pid;
lfe->mi_close_pid = satip_frontend_close_pid;
/* Adapter link */
lfe->sf_device = sd;
TAILQ_INSERT_TAIL(&sd->sd_frontends, lfe, sf_link);
/* Create satconf */
if (lfe->sf_type == DVB_TYPE_S && master == 0)
satip_satconf_create(lfe, conf);
/* Slave networks update */
if (master) {
satip_frontend_t *lfe2 = satip_frontend_find_by_number(sd, master);
if (lfe2) {
htsmsg_t *l = (htsmsg_t *)mpegts_input_class_network_get(lfe2);
if (l) {
mpegts_input_class_network_set(lfe, l);
htsmsg_destroy(l);
}
}
}
return lfe;
}
void
satip_frontend_save ( satip_frontend_t *lfe, htsmsg_t *fe )
{
char id[16];
htsmsg_t *m = htsmsg_create_map();
/* Save frontend */
mpegts_input_save((mpegts_input_t*)lfe, m);
htsmsg_add_str(m, "type", dvb_type2str(lfe->sf_type));
if (lfe->ti_id.in_class == &satip_frontend_dvbs_class) {
satip_satconf_save(lfe, m);
htsmsg_delete_field(m, "networks");
}
htsmsg_delete_field(m, "fe_override");
htsmsg_delete_field(m, "fe_master");
/* Add to list */
snprintf(id, sizeof(id), "%s #%d", dvb_type2str(lfe->sf_type), lfe->sf_number);
htsmsg_add_msg(fe, id, m);
if (lfe->sf_type_override) {
snprintf(id, sizeof(id), "override #%d", lfe->sf_number);
htsmsg_add_str(fe, id, lfe->sf_type_override);
}
if (lfe->sf_master) {
snprintf(id, sizeof(id), "master for #%d", lfe->sf_number);
htsmsg_add_u32(fe, id, lfe->sf_master);
}
}
void
satip_frontend_delete ( satip_frontend_t *lfe )
{
lock_assert(&global_lock);
/* Ensure we're stopped */
mpegts_input_stop_all((mpegts_input_t*)lfe);
/* Stop timer */
gtimer_disarm(&lfe->sf_monitor_timer);
/* Remove from adapter */
TAILQ_REMOVE(&lfe->sf_device->sd_frontends, lfe, sf_link);
/* Delete satconf */
satip_satconf_destroy(lfe);
free(lfe->sf_type_override);
/* Finish */
mpegts_input_delete((mpegts_input_t*)lfe, 0);
}
Reference in a new issue View git blame Copy permalink