From 2d79655938d71025999550912dd3b554cf4a3ca7 Mon Sep 17 00:00:00 2001 From: ben Date: Fri, 4 Aug 2006 18:32:36 +0000 Subject: split rtp stack, udp input layer and rtp input layer from rtp.c git-svn-id: svn://svn.mplayerhq.hu/mplayer/trunk@19319 b3059339-0415-0410-9bf9-f77b7e298cf2 --- stream/stream_udp.c | 107 ++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 107 insertions(+) create mode 100644 stream/stream_udp.c (limited to 'stream/stream_udp.c') diff --git a/stream/stream_udp.c b/stream/stream_udp.c new file mode 100644 index 0000000000..97b0e40f6c --- /dev/null +++ b/stream/stream_udp.c @@ -0,0 +1,107 @@ +/* + * Copyright (C) 2006 Benjamin Zores + * Stream layer for MPEG over UDP, based on previous work from Dave Chapman + * + * 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 2 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, write to the Free Software Foundation, + * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA + */ + +#include "config.h" + +#include +#include + +#include "stream.h" +#include "url.h" +#include "rtp.h" + +static int +udp_streaming_start (stream_t *stream) +{ + streaming_ctrl_t *streaming_ctrl; + int fd; + + if (!stream) + return -1; + + streaming_ctrl = stream->streaming_ctrl; + fd = stream->fd; + + if (fd < 0) + { + fd = rtp_open_socket (streaming_ctrl->url); + if (fd < 0) + return -1; + stream->fd = fd; + } + + streaming_ctrl->streaming_read = nop_streaming_read; + streaming_ctrl->streaming_seek = nop_streaming_seek; + streaming_ctrl->prebuffer_size = 64 * 1024; /* 64 KBytes */ + streaming_ctrl->buffering = 0; + streaming_ctrl->status = streaming_playing_e; + + return 0; +} + +static int +udp_stream_open (stream_t *stream, int mode, void *opts, int *file_format) +{ + URL_t *url; + extern int network_bandwidth; + + mp_msg (MSGT_OPEN, MSGL_INFO, "STREAM_UDP, URL: %s\n", stream->url); + stream->streaming_ctrl = streaming_ctrl_new (); + if (!stream->streaming_ctrl) + return STREAM_ERROR; + + stream->streaming_ctrl->bandwidth = network_bandwidth; + url = url_new (stream->url); + stream->streaming_ctrl->url = check4proxies (url); + + if (url->port == 0) + { + mp_msg (MSGT_NETWORK, MSGL_ERR, + "You must enter a port number for UDP streams!\n"); + streaming_ctrl_free (stream->streaming_ctrl); + stream->streaming_ctrl = NULL; + + return STREAM_UNSUPORTED; + } + + if (udp_streaming_start (stream) < 0) + { + mp_msg (MSGT_NETWORK, MSGL_ERR, "udp_streaming_start failed\n"); + streaming_ctrl_free (stream->streaming_ctrl); + stream->streaming_ctrl = NULL; + + return STREAM_UNSUPORTED; + } + + stream->type = STREAMTYPE_STREAM; + fixup_network_stream_cache (stream); + + return STREAM_OK; +} + +stream_info_t stream_info_udp = { + "MPEG over UDP streaming", + "udp", + "Dave Chapman, Benjamin Zores", + "native udp support", + udp_stream_open, + { "udp", NULL}, + NULL, + 0 // Urls are an option string +}; -- cgit v1.2.3