if( p_sys->p_mux != NULL )
{
sout_stream_id_t *id = p_sys->es[0];
- id->rtsp_id = RtspAddId( p_sys->rtsp, id, 0, GetDWBE( id->ssrc ),
+ id->rtsp_id = RtspAddId( p_sys->rtsp, id, GetDWBE( id->ssrc ),
p_sys->psz_destination, p_sys->i_ttl,
id->i_port, id->i_port + 1 );
}
id->i_ts_offset = rtp_compute_ts( id, p_sys->i_pts_offset );
if( p_sys->rtsp != NULL )
- id->rtsp_id = RtspAddId( p_sys->rtsp, id, p_sys->i_es,
+ id->rtsp_id = RtspAddId( p_sys->rtsp, id,
GetDWBE( id->ssrc ),
p_sys->psz_destination,
p_sys->i_ttl, id->i_port, id->i_port + 1 );
return p_sys->i_pts_zero + (now - i_npt_zero);
}
-/* FIXME: this is pretty bad - if we remove and then insert an ES
- * the number will get unsynched from inside RTSP */
-unsigned rtp_get_num( const sout_stream_id_t *id )
-{
- sout_stream_sys_t *p_sys = id->p_stream->p_sys;
- int i;
-
- vlc_mutex_lock( &p_sys->lock_es );
- for( i = 0; i < p_sys->i_es; i++ )
- {
- if( id == p_sys->es[i] )
- break;
- }
- vlc_mutex_unlock( &p_sys->lock_es );
-
- return i;
-}
-
-
void rtp_packetize_common( sout_stream_id_t *id, block_t *out,
int b_marker, int64_t i_pts )
{
void RtspUnsetup( rtsp_stream_t *rtsp );
rtsp_stream_id_t *RtspAddId( rtsp_stream_t *rtsp, sout_stream_id_t *sid,
- unsigned i, uint32_t ssrc,
+ uint32_t ssrc,
const char *dst, int ttl,
unsigned loport, unsigned hiport );
void RtspDelId( rtsp_stream_t *rtsp, rtsp_stream_id_t * );
void rtp_del_sink( sout_stream_id_t *id, int fd );
uint16_t rtp_get_seq( sout_stream_id_t *id );
int64_t rtp_get_ts( const sout_stream_t *p_stream );
-unsigned rtp_get_num( const sout_stream_id_t *id );
/* RTP packetization */
void rtp_packetize_common (sout_stream_id_t *id, block_t *out,
httpd_url_t *url;
char *psz_path;
const char *track_fmt;
+ unsigned track_id;
unsigned port;
int sessionc;
rtsp->host = NULL;
rtsp->url = NULL;
rtsp->psz_path = NULL;
+ rtsp->track_id = 0;
vlc_mutex_init( &rtsp->lock );
rtsp->port = (url->i_port > 0) ? url->i_port : 554;
httpd_url_t *url;
const char *dst;
int ttl;
+ unsigned track_id;
uint32_t ssrc;
uint16_t loport, hiport;
};
/* Unicast session track */
struct rtsp_strack_t
{
- sout_stream_id_t *id;
+ rtsp_stream_id_t *id;
int fd;
bool playing;
};
rtsp_stream_id_t *RtspAddId( rtsp_stream_t *rtsp, sout_stream_id_t *sid,
- unsigned num, uint32_t ssrc,
+ uint32_t ssrc,
/* Multicast stuff - TODO: cleanup */
const char *dst, int ttl,
unsigned loport, unsigned hiport )
id->stream = rtsp;
id->sout_id = sid;
+ id->track_id = rtsp->track_id;
id->ssrc = ssrc;
/* TODO: can we assume that this need not be strdup'd? */
id->dst = dst;
id->hiport = hiport;
}
- /* FIXME: num screws up if any ES has been removed and re-added */
snprintf( urlbuf, sizeof( urlbuf ), rtsp->track_fmt, rtsp->psz_path,
- num );
+ id->track_id );
msg_Dbg( rtsp->owner, "RTSP: adding %s", urlbuf );
url = id->url = httpd_UrlNewUnique( rtsp->host, urlbuf, NULL, NULL, NULL );
httpd_UrlCatch( url, HTTPD_MSG_GETPARAMETER, RtspCallbackId, (void *)id );
httpd_UrlCatch( url, HTTPD_MSG_TEARDOWN, RtspCallbackId, (void *)id );
+ rtsp->track_id++;
+
return id;
}
for( int j = 0; j < ses->trackc; j++ )
{
- if( ses->trackv[j].id == id->sout_id )
+ if( ses->trackv[j].id == id )
{
rtsp_strack_t *tr = ses->trackv + j;
net_Close( tr->fd );
TAB_REMOVE( rtsp->sessionc, rtsp->sessionv, session );
for( i = 0; i < session->trackc; i++ )
- rtp_del_sink( session->trackv[i].id, session->trackv[i].fd );
+ rtp_del_sink( session->trackv[i].id->sout_id, session->trackv[i].fd );
free( session->trackv );
free( session );
{
char ip[NI_MAXNUMERICHOST], src[NI_MAXNUMERICHOST];
rtsp_session_t *ses = NULL;
- rtsp_strack_t track = { id->sout_id, -1, false };
+ rtsp_strack_t track = { id, -1, false };
int sport;
if( httpd_ClientIP( cl, ip ) == NULL )
for( int i = 0; i < ses->trackc; i++ )
{
rtsp_strack_t *tr = ses->trackv + i;
- if( ( id == NULL ) || ( tr->id == id->sout_id ) )
+ if( ( id == NULL ) || ( tr->id == id ) )
{
uint16_t seq;
if( !tr->playing )
{
tr->playing = true;
- rtp_add_sink( tr->id, tr->fd, false, &seq );
+ rtp_add_sink( tr->id->sout_id, tr->fd, false,
+ &seq );
}
else
- seq = rtp_get_seq( tr->id );
+ seq = rtp_get_seq( tr->id->sout_id );
infolen += sprintf( info + infolen,
"url=%s/trackID=%u;seq=%u;rtptime=%u, ",
- control,
- rtp_get_num( tr->id ),
- seq,
- rtp_compute_ts( tr->id, ts ) );
+ control, tr->id->track_id, seq,
+ rtp_compute_ts( tr->id->sout_id, ts ) );
}
}
if( infolen > 0 )
else /* Delete one track from the session */
for( int i = 0; i < ses->trackc; i++ )
{
- if( ses->trackv[i].id == id->sout_id )
+ if( ses->trackv[i].id == id )
{
rtp_del_sink( id->sout_id, ses->trackv[i].fd );
REMOVE_ELEM( ses->trackv, ses->trackc, i );