av_free(avg->videoframe.data[0]);
free(avg);
- t->tht_status = TRANSPORT_IDLE;
+ t->tht_runstatus = TRANSPORT_IDLE;
}
t->tht_avgen = avg;
- t->tht_status = TRANSPORT_RUNNING;
+ t->tht_runstatus = TRANSPORT_RUNNING;
avg->refclock = getclock_hires();
avgen_deliver(t, avg, avg->refclock);
close(st->st_demuxer_fd);
st->st_demuxer_fd = -1;
}
- t->tht_status = TRANSPORT_IDLE;
+ t->tht_runstatus = TRANSPORT_IDLE;
}
}
LIST_INSERT_HEAD(&tda->tda_transports, t, tht_active_link);
- t->tht_status = status;
+ t->tht_runstatus = status;
dvb_tune_tdmi(tdmi, 1, TDMI_RUNNING);
return 0;
file_input_t *fi = t->tht_file_input;
dtimer_disarm(&fi->fi_timer);
- t->tht_status = TRANSPORT_IDLE;
+ t->tht_runstatus = TRANSPORT_IDLE;
}
{
file_input_t *fi = t->tht_file_input;
- t->tht_status = TRANSPORT_RUNNING;
+ t->tht_runstatus = TRANSPORT_RUNNING;
file_input_reset(t, fi);
fi->fi_refclock = getclock_hires();
}
t->tht_iptv_fd = fd;
- t->tht_status = status;
+ t->tht_runstatus = status;
syslog(LOG_ERR, "iptv: \"%s\" joined group", t->tht_name);
static void
iptv_stop_feed(th_transport_t *t)
{
- if(t->tht_status == TRANSPORT_IDLE)
+ if(t->tht_runstatus == TRANSPORT_IDLE)
return;
- t->tht_status = TRANSPORT_IDLE;
+ t->tht_runstatus = TRANSPORT_IDLE;
dispatch_delfd(t->tht_iptv_dispatch_handle);
close(t->tht_iptv_fd);
iptv_parse_pmt(struct th_transport *t, th_stream_t *st,
uint8_t *table, int table_len)
{
- if(table[0] != 2 || t->tht_status != TRANSPORT_PROBING)
+ if(table[0] != 2 || t->tht_runstatus != TRANSPORT_PROBING)
return;
psi_parse_pmt(t, table + 3, table_len - 3, 0);
iptv_parse_pat(struct th_transport *t, th_stream_t *st,
uint8_t *table, int table_len)
{
- if(table[0] != 0 || t->tht_status != TRANSPORT_PROBING)
+ if(table[0] != 0 || t->tht_runstatus != TRANSPORT_PROBING)
return;
psi_parse_pat(t, table + 3, table_len - 3, iptv_parse_pmt);
s->ths_weight = INT32_MAX;
s->ths_opaque = sp;
- if(t->tht_status != TRANSPORT_RUNNING)
+ if(t->tht_runstatus != TRANSPORT_RUNNING)
transport_start(t, INT32_MAX);
s->ths_transport = t;
AVCodec *c;
enum CodecID id;
- assert(t->tht_status != TRANSPORT_RUNNING);
+ assert(t->tht_runstatus != TRANSPORT_RUNNING);
if(t->tht_start_feed(t, weight, TRANSPORT_RUNNING))
return -1;
for(i = 0; i < cnt; i++) {
t = vec[i];
- if(t->tht_status == TRANSPORT_RUNNING)
+ if(t->tht_runstatus == TRANSPORT_RUNNING)
return t;
if(!transport_start(t, 0))
TRANSPORT_IDLE,
TRANSPORT_RUNNING,
TRANSPORT_PROBING,
- } tht_status;
+ } tht_runstatus;
th_commercial_advice_t tht_tt_commercial_advice;
t->tht_v4l_adapter = NULL;
LIST_REMOVE(t, tht_active_link);
- t->tht_status = TRANSPORT_IDLE;
+ t->tht_runstatus = TRANSPORT_IDLE;
if(LIST_FIRST(&tva->tva_transports) == NULL)
v4l_stop(tva);
LIST_INSERT_HEAD(&tva->tva_transports, t, tht_active_link);
t->tht_v4l_adapter = tva;
- t->tht_status = TRANSPORT_RUNNING;
+ t->tht_runstatus = TRANSPORT_RUNNING;
return 0;
}