# include "config.h"
#endif
-#include <vlc/vlc.h>
+#include <vlc_common.h>
+#include <vlc_plugin.h>
#include <sys/types.h>
#include <sys/stat.h>
"of packets that will be sent at a time. It " \
"helps reducing the scheduling load on " \
"heavily-loaded systems." )
-#define AUTO_MCAST_TEXT N_("Automatic multicast streaming")
-#define AUTO_MCAST_LONGTEXT N_("Allocates an outbound multicast address " \
- "automatically.")
vlc_module_begin();
- set_description( _("UDP stream output") );
+ set_description( N_("UDP stream output") );
set_shortname( "UDP" );
set_category( CAT_SOUT );
set_subcategory( SUBCAT_SOUT_ACO );
true );
add_obsolete_integer( SOUT_CFG_PREFIX "late" );
add_obsolete_bool( SOUT_CFG_PREFIX "raw" );
- add_bool( SOUT_CFG_PREFIX "auto-mcast", false, NULL, AUTO_MCAST_TEXT,
- AUTO_MCAST_LONGTEXT, true );
set_capability( "sout access", 100 );
add_shortcut( "udp" );
*****************************************************************************/
static const char *const ppsz_sout_options[] = {
- "auto-mcast",
"caching",
"group",
NULL
static ssize_t Write ( sout_access_out_t *, block_t * );
static int Seek ( sout_access_out_t *, off_t );
-static void ThreadWrite( vlc_object_t * );
+static void* ThreadWrite( vlc_object_t * );
static block_t *NewUDPPacket( sout_access_out_t *, mtime_t );
-static const char *MakeRandMulticast (int family, char *buf, size_t buflen);
typedef struct sout_access_thread_t
{
}
if( !( p_sys = calloc ( 1, sizeof( sout_access_out_sys_t ) ) ) )
- {
- msg_Err( p_access, "not enough memory" );
return VLC_ENOMEM;
- }
p_access->p_sys = p_sys;
i_dst_port = DEFAULT_PORT;
- if (var_GetBool (p_access, SOUT_CFG_PREFIX"auto-mcast"))
+ char *psz_parser = psz_dst_addr = strdup( p_access->psz_path );
+ if( !psz_dst_addr )
{
- char buf[INET6_ADDRSTRLEN];
- if (MakeRandMulticast (AF_INET, buf, sizeof (buf)) != NULL)
- psz_dst_addr = strdup (buf);
+ free( p_sys );
+ return VLC_ENOMEM;
}
- else
- {
- char *psz_parser = psz_dst_addr = strdup( p_access->psz_path );
- if (psz_parser[0] == '[')
- psz_parser = strchr (psz_parser, ']');
+ if (psz_parser[0] == '[')
+ psz_parser = strchr (psz_parser, ']');
- psz_parser = strchr (psz_parser ?: psz_dst_addr, ':');
- if (psz_parser != NULL)
- {
- *psz_parser++ = '\0';
- i_dst_port = atoi (psz_parser);
- }
+ psz_parser = strchr (psz_parser ?: psz_dst_addr, ':');
+ if (psz_parser != NULL)
+ {
+ *psz_parser++ = '\0';
+ i_dst_port = atoi (psz_parser);
}
p_sys->p_thread =
vlc_object_create( p_access, sizeof( sout_access_thread_t ) );
if( !p_sys->p_thread )
{
- msg_Err( p_access, "out of memory" );
free (p_sys);
free (psz_dst_addr);
return VLC_ENOMEM;
p_sys->p_thread->p_sout = p_access->p_sout;
p_sys->p_thread->b_die = 0;
p_sys->p_thread->b_error= 0;
- p_sys->p_thread->p_fifo = block_FifoNew( p_access );
- p_sys->p_thread->p_empty_blocks = block_FifoNew( p_access );
+ p_sys->p_thread->p_fifo = block_FifoNew();
+ p_sys->p_thread->p_empty_blocks = block_FifoNew();
i_handle = net_ConnectDgram( p_this, psz_dst_addr, i_dst_port, -1,
IPPROTO_UDP );
{
if( p_sys->p_buffer->i_dts + p_sys->p_thread->i_caching < now )
{
- msg_Dbg( p_access, "late packet for UDP input (" I64Fd ")",
+ msg_Dbg( p_access, "late packet for UDP input (%"PRId64 ")",
now - p_sys->p_buffer->i_dts
- p_sys->p_thread->i_caching );
}
/* Flush */
if( p_sys->p_buffer->i_dts + p_sys->p_thread->i_caching < now )
{
- msg_Dbg( p_access, "late packet for udp input (" I64Fd ")",
+ msg_Dbg( p_access, "late packet for udp input (%"PRId64 ")",
mdate() - p_sys->p_buffer->i_dts
- p_sys->p_thread->i_caching );
}
/*****************************************************************************
* ThreadWrite: Write a packet on the network at the good time.
*****************************************************************************/
-static void ThreadWrite( vlc_object_t *p_this )
+static void* ThreadWrite( vlc_object_t *p_this )
{
sout_access_thread_t *p_thread = (sout_access_thread_t*)p_this;
mtime_t i_date_last = -1;
mtime_t i_to_send = p_thread->i_group;
int i_dropped_packets = 0;
- while( !p_thread->b_die )
+ while( vlc_object_alive (p_thread) )
{
block_t *p_pk;
mtime_t i_date, i_sent;
if( i_date - i_date_last > 2000000 )
{
if( !i_dropped_packets )
- msg_Dbg( p_thread, "mmh, hole ("I64Fd" > 2s) -> drop",
+ msg_Dbg( p_thread, "mmh, hole (%"PRId64" > 2s) -> drop",
i_date - i_date_last );
block_FifoPut( p_thread->p_empty_blocks, p_pk );
else if( i_date - i_date_last < -1000 )
{
if( !i_dropped_packets )
- msg_Dbg( p_thread, "mmh, packets in the past ("I64Fd")",
+ msg_Dbg( p_thread, "mmh, packets in the past (%"PRId64")",
i_date_last - i_date );
}
}
i_sent = mdate();
if ( i_sent > i_date + 20000 )
{
- msg_Dbg( p_thread, "packet has been sent too late (" I64Fd ")",
+ msg_Dbg( p_thread, "packet has been sent too late (%"PRId64 ")",
i_sent - i_date );
}
#endif
i_date_last = i_date;
}
-}
-
-
-static const char *MakeRandMulticast (int family, char *buf, size_t buflen)
-{
- uint32_t rand = (getpid() & 0xffff)
- | (uint32_t)(((mdate () >> 10) & 0xffff) << 16);
-
- switch (family)
- {
-#ifdef AF_INET6
- case AF_INET6:
- {
- struct in6_addr addr;
- memcpy (&addr, "\xff\x38\x00\x00" "\x00\x00\x00\x00"
- "\x00\x00\x00\x00", 12);
- rand |= 0x80000000;
- memcpy (addr.s6_addr + 12, &(uint32_t){ htonl (rand) }, 4);
- return inet_ntop (family, &addr, buf, buflen);
- }
-#endif
-
- case AF_INET:
- {
- struct in_addr addr;
- addr.s_addr = htonl ((rand & 0xffffff) | 0xe8000000);
- return inet_ntop (family, &addr, buf, buflen);
- }
- }
-#ifdef EAFNOSUPPORT
- errno = EAFNOSUPPORT;
-#endif
return NULL;
}