Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
dvb: create mux - rearrange parameters for SAT>IP server
  • Loading branch information
perexg committed Mar 11, 2015
1 parent d563dc9 commit be1cc5c
Show file tree
Hide file tree
Showing 4 changed files with 17 additions and 15 deletions.
5 changes: 3 additions & 2 deletions src/input/mpegts.h
Expand Up @@ -283,7 +283,8 @@ struct mpegts_network
void (*mn_display_name) (mpegts_network_t*, char *buf, size_t len);
void (*mn_config_save) (mpegts_network_t*);
mpegts_mux_t* (*mn_create_mux)
(mpegts_mux_t*, uint16_t onid, uint16_t tsid, void *conf, int force);
(mpegts_network_t*, void *origin, uint16_t onid, uint16_t tsid,
void *conf, int force);
mpegts_service_t* (*mn_create_service)
(mpegts_mux_t*, uint16_t sid, uint16_t pmt_pid);
const idclass_t* (*mn_mux_class) (mpegts_network_t*);
Expand Down Expand Up @@ -385,7 +386,7 @@ struct mpegts_mux
MM_ORIG_AUTO ///< From NIT
} mm_dmc_origin2;
#endif
mpegts_mux_t *mm_dmc_origin;
void *mm_dmc_origin;
time_t mm_dmc_origin_expire;

char *mm_fastscan_muxes;
Expand Down
6 changes: 3 additions & 3 deletions src/input/mpegts/dvb_psi.c
Expand Up @@ -273,7 +273,7 @@ dvb_desc_sat_del
tvhdebug(mt->mt_name, " %s", buf);

/* Create */
return mm->mm_network->mn_create_mux(mm, onid, tsid, &dmc, force);
return mm->mm_network->mn_create_mux(mm->mm_network, mm, onid, tsid, &dmc, force);
}

/*
Expand Down Expand Up @@ -329,7 +329,7 @@ dvb_desc_cable_del
tvhdebug(mt->mt_name, " %s", buf);

/* Create */
return mm->mm_network->mn_create_mux(mm, onid, tsid, &dmc, 0);
return mm->mm_network->mn_create_mux(mm->mm_network, mm, onid, tsid, &dmc, 0);
}

/*
Expand Down Expand Up @@ -395,7 +395,7 @@ dvb_desc_terr_del
tvhdebug(mt->mt_name, " %s", buf);

/* Create */
return mm->mm_network->mn_create_mux(mm, onid, tsid, &dmc, 0);
return mm->mm_network->mn_create_mux(mm->mm_network, mm, onid, tsid, &dmc, 0);
}

#endif /* ENABLE_MPEGTS_DVB */
Expand Down
3 changes: 2 additions & 1 deletion src/input/mpegts/mpegts_network.c
Expand Up @@ -263,7 +263,8 @@ mpegts_network_config_save

static mpegts_mux_t *
mpegts_network_create_mux
( mpegts_mux_t *mm, uint16_t sid, uint16_t tsid, void *aux, int force )
( mpegts_network_t *mn, void *origin, uint16_t sid, uint16_t tsid,
void *aux, int force )
{
return NULL;
}
Expand Down
18 changes: 9 additions & 9 deletions src/input/mpegts/mpegts_network_dvb.c
Expand Up @@ -421,11 +421,11 @@ dvb_network_mux_class

static mpegts_mux_t *
dvb_network_create_mux
( mpegts_mux_t *mm, uint16_t onid, uint16_t tsid, void *p, int force )
( mpegts_network_t *mn, void *origin, uint16_t onid, uint16_t tsid,
void *p, int force )
{
int save = 0, satpos;
mpegts_mux_t *mmo = mm;
mpegts_network_t *mn = mm->mm_network;
dvb_mux_t *mm;
dvb_network_t *ln;
dvb_mux_conf_t *dmc = p;
const idclass_t *cls = dvb_network_mux_class(mn);
Expand All @@ -447,7 +447,7 @@ dvb_network_create_mux
}

ln = (dvb_network_t*)mn;
mm = dvb_network_find_mux(ln, dmc, onid, tsid);
mm = (dvb_mux_t *)dvb_network_find_mux(ln, dmc, onid, tsid);
if (!mm && (ln->mn_autodiscovery || force)) {
cls = dvb_network_mux_class((mpegts_network_t *)ln);
save |= cls == &dvb_mux_dvbt_class && dmc->dmc_fe_type == DVB_TYPE_T;
Expand All @@ -461,7 +461,7 @@ dvb_network_create_mux
save = 0;
}
if (save) {
mm = (mpegts_mux_t*)dvb_mux_create0(ln, onid, tsid, dmc, NULL, NULL);
mm = dvb_mux_create0(ln, onid, tsid, dmc, NULL, NULL);
#if ENABLE_TRACE
char buf[128];
dvb_mux_conf_str(&((dvb_mux_t *)mm)->lm_tuning, buf, sizeof(buf));
Expand All @@ -473,7 +473,7 @@ dvb_network_create_mux
dvb_mux_t *lm = (dvb_mux_t*)mm;
/* the nit tables may be inconsistent (like rolloff ping-pong) */
/* accept information only from one origin mux */
if (mm->mm_dmc_origin_expire > dispatch_clock && mm->mm_dmc_origin && mm->mm_dmc_origin != mmo)
if (mm->mm_dmc_origin_expire > dispatch_clock && mm->mm_dmc_origin && mm->mm_dmc_origin != origin)
goto noop;
#if ENABLE_TRACE
#define COMPARE(x) ({ \
Expand Down Expand Up @@ -565,12 +565,12 @@ dvb_network_create_mux
}
save:
if (mm && save) {
mm->mm_dmc_origin = mmo;
mm->mm_dmc_origin = origin;
mm->mm_dmc_origin_expire = dispatch_clock + 3600 * 24; /* one day */
mm->mm_config_save(mm);
mm->mm_config_save((mpegts_mux_t *)mm);
}
noop:
return mm;
return (mpegts_mux_t *)mm;
}

static mpegts_service_t *
Expand Down

0 comments on commit be1cc5c

Please sign in to comment.