Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
V
vlc
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Redmine
Redmine
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Operations
Operations
Metrics
Environments
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
videolan
vlc
Commits
f5957ea5
Commit
f5957ea5
authored
Jul 02, 2012
by
Jean-Baptiste Kempf
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Remove the RTMP output too
parent
71ef5f54
Changes
5
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
1 addition
and
430 deletions
+1
-430
NEWS
NEWS
+1
-0
modules/LIST
modules/LIST
+0
-1
modules/access_output/Modules.am
modules/access_output/Modules.am
+0
-12
modules/access_output/rtmp.c
modules/access_output/rtmp.c
+0
-416
po/POTFILES.in
po/POTFILES.in
+0
-1
No files found.
NEWS
View file @
f5957ea5
...
@@ -64,6 +64,7 @@ Removed modules:
...
@@ -64,6 +64,7 @@ Removed modules:
* X11 On Screen Display notifications (xosd)
* X11 On Screen Display notifications (xosd)
* Linux Framebuffer On Screen Display interface (fbosd)
* Linux Framebuffer On Screen Display interface (fbosd)
* RTMP access: use libavformat avio instead
* RTMP access: use libavformat avio instead
* RTMP access_output: use libavformat avio instead
Changes between 2.0.1 and 2.0.2:
Changes between 2.0.1 and 2.0.2:
...
...
modules/LIST
View file @
f5957ea5
...
@@ -22,7 +22,6 @@ $Id$
...
@@ -22,7 +22,6 @@ $Id$
* access_output_file: File access_output module
* access_output_file: File access_output module
* access_output_http: HTTP Network access module
* access_output_http: HTTP Network access module
* access_output_livehttp: Live HTTP stream output
* access_output_livehttp: Live HTTP stream output
* access_output_rtmp: RTMP stream output
* access_output_shout: Shoutcast access output
* access_output_shout: Shoutcast access output
* access_output_udp: UDP Network access_output module
* access_output_udp: UDP Network access_output module
* access_rar: RAR access
* access_rar: RAR access
...
...
modules/access_output/Modules.am
View file @
f5957ea5
...
@@ -5,15 +5,6 @@ SOURCES_access_output_udp = udp.c
...
@@ -5,15 +5,6 @@ SOURCES_access_output_udp = udp.c
SOURCES_access_output_http = http.c bonjour.c bonjour.h
SOURCES_access_output_http = http.c bonjour.c bonjour.h
SOURCES_access_output_shout = shout.c
SOURCES_access_output_shout = shout.c
libaccess_output_rtmp_plugin_la_SOURCES = \
rtmp.c \
../access/rtmp/rtmp_amf_flv.c \
../access/rtmp/rtmp_amf_flv.h
libaccess_output_rtmp_plugin_la_CFLAGS = $(AM_CFLAGS) \
-fno-strict-aliasing
libaccess_output_rtmp_plugin_la_LIBADD = $(AM_LIBADD)
libaccess_output_rtmp_plugin_la_DEPENDENCIES =
libvlc_LTLIBRARIES += \
libvlc_LTLIBRARIES += \
libaccess_output_dummy_plugin.la \
libaccess_output_dummy_plugin.la \
libaccess_output_file_plugin.la \
libaccess_output_file_plugin.la \
...
@@ -21,6 +12,3 @@ libvlc_LTLIBRARIES += \
...
@@ -21,6 +12,3 @@ libvlc_LTLIBRARIES += \
libaccess_output_udp_plugin.la \
libaccess_output_udp_plugin.la \
libaccess_output_http_plugin.la \
libaccess_output_http_plugin.la \
$(NULL)
$(NULL)
EXTRA_LTLIBRARIES += \
libaccess_output_rtmp_plugin.la \
$(NULL)
modules/access_output/rtmp.c
deleted
100644 → 0
View file @
71ef5f54
/*****************************************************************************
* rtmp.c: RTMP output.
*****************************************************************************
* Copyright (C) URJC - LADyR - Luis Lopez Fernandez
*
* Author: Miguel Angel Cabrera Moya
*
* 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.
*****************************************************************************/
/*****************************************************************************
* Preamble
*****************************************************************************/
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif
#include <vlc_common.h>
#include <vlc_plugin.h>
#include <vlc_sout.h>
#include <vlc_network.h>
/* DOWN: #include <network.h> */
#include <vlc_url.h>
#include <vlc_block.h>
#include "../access/rtmp/rtmp_amf_flv.h"
/*****************************************************************************
* Module descriptor
*****************************************************************************/
#define RTMP_CONNECT_TEXT N_( "Active TCP connection" )
#define RTMP_CONNECT_LONGTEXT N_( \
"If enabled, VLC will connect to a remote destination instead of " \
"waiting for an incoming connection." )
static
int
Open
(
vlc_object_t
*
);
static
void
Close
(
vlc_object_t
*
);
#define SOUT_CFG_PREFIX "sout-rtmp-"
vlc_module_begin
()
set_description
(
N_
(
"RTMP stream output"
)
)
set_shortname
(
N_
(
"RTMP"
)
)
set_capability
(
"sout access"
,
0
)
set_category
(
CAT_SOUT
)
set_subcategory
(
SUBCAT_SOUT_STREAM
)
add_shortcut
(
"rtmp"
)
set_callbacks
(
Open
,
Close
)
add_bool
(
"rtmp-connect"
,
false
,
RTMP_CONNECT_TEXT
,
RTMP_CONNECT_LONGTEXT
,
false
)
vlc_module_end
()
/*****************************************************************************
* Local prototypes
*****************************************************************************/
static
ssize_t
Write
(
sout_access_out_t
*
,
block_t
*
);
static
int
Seek
(
sout_access_out_t
*
,
off_t
);
static
void
*
ThreadControl
(
void
*
);
struct
sout_access_out_sys_t
{
int
active
;
/* thread for filtering and handling control messages */
rtmp_control_thread_t
*
p_thread
;
};
/*****************************************************************************
* Open: open the rtmp connection
*****************************************************************************/
static
int
Open
(
vlc_object_t
*
p_this
)
{
sout_access_out_t
*
p_access
=
(
sout_access_out_t
*
)
p_this
;
sout_access_out_sys_t
*
p_sys
;
char
*
psz
,
*
p
;
int
length_path
,
length_media_name
;
int
i
;
if
(
!
(
p_sys
=
calloc
(
1
,
sizeof
(
sout_access_out_sys_t
)
)
)
)
return
VLC_ENOMEM
;
p_access
->
p_sys
=
p_sys
;
p_sys
->
p_thread
=
vlc_object_create
(
p_access
,
sizeof
(
rtmp_control_thread_t
)
);
if
(
!
p_sys
->
p_thread
)
{
free
(
p_sys
);
return
VLC_ENOMEM
;
}
/* Parse URI - remove spaces */
p
=
psz
=
strdup
(
p_access
->
psz_path
);
while
(
(
p
=
strchr
(
p
,
' '
)
)
!=
NULL
)
*
p
=
'+'
;
vlc_UrlParse
(
&
p_sys
->
p_thread
->
url
,
psz
,
0
);
free
(
psz
);
if
(
p_sys
->
p_thread
->
url
.
psz_host
==
NULL
||
*
p_sys
->
p_thread
->
url
.
psz_host
==
'\0'
)
{
msg_Warn
(
p_access
,
"invalid host"
);
goto
error
;
}
if
(
p_sys
->
p_thread
->
url
.
i_port
<=
0
)
p_sys
->
p_thread
->
url
.
i_port
=
1935
;
if
(
p_sys
->
p_thread
->
url
.
psz_path
==
NULL
)
{
msg_Warn
(
p_access
,
"invalid path"
);
goto
error
;
}
length_path
=
strlen
(
p_sys
->
p_thread
->
url
.
psz_path
);
char
*
psz_tmp
=
strrchr
(
p_sys
->
p_thread
->
url
.
psz_path
,
'/'
);
if
(
!
psz_tmp
)
goto
error
;
length_media_name
=
strlen
(
psz_tmp
)
-
1
;
p_sys
->
p_thread
->
psz_application
=
strndup
(
p_sys
->
p_thread
->
url
.
psz_path
+
1
,
length_path
-
length_media_name
-
2
);
p_sys
->
p_thread
->
psz_media
=
strdup
(
p_sys
->
p_thread
->
url
.
psz_path
+
(
length_path
-
length_media_name
)
);
msg_Dbg
(
p_access
,
"rtmp: host='%s' port=%d path='%s'"
,
p_sys
->
p_thread
->
url
.
psz_host
,
p_sys
->
p_thread
->
url
.
i_port
,
p_sys
->
p_thread
->
url
.
psz_path
);
if
(
p_sys
->
p_thread
->
url
.
psz_username
&&
*
p_sys
->
p_thread
->
url
.
psz_username
)
{
msg_Dbg
(
p_access
,
" user='%s'"
,
p_sys
->
p_thread
->
url
.
psz_username
);
}
/* Initialize thread variables */
p_sys
->
p_thread
->
b_error
=
0
;
p_sys
->
p_thread
->
p_fifo_input
=
block_FifoNew
();
p_sys
->
p_thread
->
p_empty_blocks
=
block_FifoNew
();
p_sys
->
p_thread
->
has_audio
=
0
;
p_sys
->
p_thread
->
has_video
=
0
;
p_sys
->
p_thread
->
metadata_received
=
0
;
p_sys
->
p_thread
->
first_media_packet
=
1
;
p_sys
->
p_thread
->
flv_tag_previous_tag_size
=
0x00000000
;
/* FLV_TAG_FIRST_PREVIOUS_TAG_SIZE */
p_sys
->
p_thread
->
flv_body
=
rtmp_body_new
(
-
1
);
p_sys
->
p_thread
->
flv_length_body
=
0
;
p_sys
->
p_thread
->
chunk_size_recv
=
128
;
/* RTMP_DEFAULT_CHUNK_SIZE */
p_sys
->
p_thread
->
chunk_size_send
=
128
;
/* RTMP_DEFAULT_CHUNK_SIZE */
for
(
i
=
0
;
i
<
64
;
i
++
)
{
memset
(
&
p_sys
->
p_thread
->
rtmp_headers_recv
[
i
],
0
,
sizeof
(
rtmp_packet_t
)
);
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
length_header
=
-
1
;
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
stream_index
=
-
1
;
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
timestamp
=
-
1
;
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
timestamp_relative
=
-
1
;
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
length_encoded
=
-
1
;
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
length_body
=
-
1
;
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
content_type
=
-
1
;
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
src_dst
=
-
1
;
p_sys
->
p_thread
->
rtmp_headers_send
[
i
].
body
=
NULL
;
}
vlc_cond_init
(
&
p_sys
->
p_thread
->
wait
);
vlc_mutex_init
(
&
p_sys
->
p_thread
->
lock
);
p_sys
->
p_thread
->
result_connect
=
1
;
/* p_sys->p_thread->result_publish = only used on access */
p_sys
->
p_thread
->
result_play
=
1
;
p_sys
->
p_thread
->
result_stop
=
0
;
p_sys
->
p_thread
->
fd
=
-
1
;
/* Open connection */
if
(
var_CreateGetBool
(
p_access
,
"rtmp-connect"
)
>
0
)
{
#if 0
p_sys->p_thread->fd = net_ConnectTCP( p_access,
p_sys->p_thread->url.psz_host,
p_sys->p_thread->url.i_port );
#endif
msg_Err
(
p_access
,
"to be implemented"
);
goto
error2
;
}
else
{
int
*
p_fd_listen
;
p_sys
->
active
=
0
;
p_fd_listen
=
net_ListenTCP
(
p_access
,
p_sys
->
p_thread
->
url
.
psz_host
,
p_sys
->
p_thread
->
url
.
i_port
);
if
(
p_fd_listen
==
NULL
)
{
msg_Warn
(
p_access
,
"cannot listen to %s port %i"
,
p_sys
->
p_thread
->
url
.
psz_host
,
p_sys
->
p_thread
->
url
.
i_port
);
goto
error2
;
}
do
p_sys
->
p_thread
->
fd
=
net_Accept
(
p_access
,
p_fd_listen
);
while
(
p_sys
->
p_thread
->
fd
==
-
1
);
net_ListenClose
(
p_fd_listen
);
if
(
rtmp_handshake_passive
(
p_this
,
p_sys
->
p_thread
->
fd
)
<
0
)
{
msg_Err
(
p_access
,
"handshake passive failed"
);
goto
error2
;
}
}
if
(
vlc_clone
(
&
p_sys
->
p_thread
->
thread
,
ThreadControl
,
p_sys
->
p_thread
,
VLC_THREAD_PRIORITY_INPUT
)
)
{
msg_Err
(
p_access
,
"cannot spawn rtmp control thread"
);
goto
error2
;
}
if
(
!
p_sys
->
active
)
{
if
(
rtmp_connect_passive
(
p_sys
->
p_thread
)
<
0
)
{
msg_Err
(
p_access
,
"connect passive failed"
);
vlc_cancel
(
p_sys
->
p_thread
->
thread
);
vlc_join
(
p_sys
->
p_thread
->
thread
,
NULL
);
goto
error2
;
}
}
p_access
->
pf_write
=
Write
;
p_access
->
pf_seek
=
Seek
;
return
VLC_SUCCESS
;
error2:
vlc_cond_destroy
(
&
p_sys
->
p_thread
->
wait
);
vlc_mutex_destroy
(
&
p_sys
->
p_thread
->
lock
);
free
(
p_sys
->
p_thread
->
psz_application
);
free
(
p_sys
->
p_thread
->
psz_media
);
if
(
p_sys
->
p_thread
->
fd
!=
-
1
)
net_Close
(
p_sys
->
p_thread
->
fd
);
error:
vlc_UrlClean
(
&
p_sys
->
p_thread
->
url
);
vlc_object_release
(
p_sys
->
p_thread
);
free
(
p_sys
);
return
VLC_EGENERIC
;
}
/*****************************************************************************
* Close: close the target
*****************************************************************************/
static
void
Close
(
vlc_object_t
*
p_this
)
{
sout_access_out_t
*
p_access
=
(
sout_access_out_t
*
)
p_this
;
sout_access_out_sys_t
*
p_sys
=
p_access
->
p_sys
;
int
i
;
vlc_cancel
(
p_sys
->
p_thread
->
thread
);
vlc_join
(
p_sys
->
p_thread
->
thread
,
NULL
);
vlc_cond_destroy
(
&
p_sys
->
p_thread
->
wait
);
vlc_mutex_destroy
(
&
p_sys
->
p_thread
->
lock
);
block_FifoRelease
(
p_sys
->
p_thread
->
p_fifo_input
);
block_FifoRelease
(
p_sys
->
p_thread
->
p_empty_blocks
);
for
(
i
=
0
;
i
<
64
;
i
++
)
/* RTMP_HEADER_STREAM_INDEX_MASK */
{
if
(
p_sys
->
p_thread
->
rtmp_headers_recv
[
i
].
body
!=
NULL
)
{
free
(
p_sys
->
p_thread
->
rtmp_headers_recv
[
i
].
body
->
body
);
free
(
p_sys
->
p_thread
->
rtmp_headers_recv
[
i
].
body
);
}
}
net_Close
(
p_sys
->
p_thread
->
fd
);
vlc_object_release
(
p_sys
->
p_thread
);
vlc_UrlClean
(
&
p_sys
->
p_thread
->
url
);
free
(
p_sys
->
p_thread
->
psz_application
);
free
(
p_sys
->
p_thread
->
psz_media
);
free
(
p_sys
);
}
/*****************************************************************************
* Write: standard write on a file descriptor.
*****************************************************************************/
static
ssize_t
Write
(
sout_access_out_t
*
p_access
,
block_t
*
p_buffer
)
{
rtmp_packet_t
*
rtmp_packet
;
uint8_t
*
tmp_buffer
;
ssize_t
i_ret
;
ssize_t
i_write
=
0
;
if
(
p_access
->
p_sys
->
p_thread
->
first_media_packet
)
{
/* 13 == FLV_HEADER_SIZE + PreviousTagSize*/
memmove
(
p_buffer
->
p_buffer
,
p_buffer
->
p_buffer
+
13
,
p_buffer
->
i_buffer
-
13
);
p_buffer
=
block_Realloc
(
p_buffer
,
0
,
p_buffer
->
i_buffer
-
13
);
p_access
->
p_sys
->
p_thread
->
first_media_packet
=
0
;
}
while
(
p_buffer
)
{
block_t
*
p_next
=
p_buffer
->
p_next
;
//////////////////////////////
/*msg_Warn(p_access, "XXXXXXXXXXXXXXXXX");
int i;
for(i = 0; i < p_buffer->i_buffer; i += 16)
{
msg_Warn(p_access,"%.2x%.2x %.2x%.2x %.2x%.2x %.2x%.2x %.2x%.2x %.2x%.2x %.2x%.2x %.2x%.2x",
p_buffer->p_buffer[i], p_buffer->p_buffer[i+1], p_buffer->p_buffer[i+2], p_buffer->p_buffer[i+3], p_buffer->p_buffer[i+4], p_buffer->p_buffer[i+5], p_buffer->p_buffer[i+6], p_buffer->p_buffer[i+7],
p_buffer->p_buffer[i+8], p_buffer->p_buffer[i+9], p_buffer->p_buffer[i+10], p_buffer->p_buffer[i+11], p_buffer->p_buffer[i+12], p_buffer->p_buffer[i+13], p_buffer->p_buffer[i+14], p_buffer->p_buffer[i+15]);
}*/
////////////////////////
msg_Warn
(
p_access
,
"rtmp.c:360 i_dts %"
PRIu64
" i_pts %"
PRIu64
,
p_buffer
->
i_dts
,
p_buffer
->
i_pts
);
rtmp_packet
=
rtmp_build_flv_over_rtmp
(
p_access
->
p_sys
->
p_thread
,
p_buffer
);
if
(
rtmp_packet
)
{
tmp_buffer
=
rtmp_encode_packet
(
p_access
->
p_sys
->
p_thread
,
rtmp_packet
);
i_ret
=
net_Write
(
p_access
->
p_sys
->
p_thread
,
p_access
->
p_sys
->
p_thread
->
fd
,
NULL
,
tmp_buffer
,
rtmp_packet
->
length_encoded
);
if
(
i_ret
!=
rtmp_packet
->
length_encoded
)
{
free
(
rtmp_packet
->
body
->
body
);
free
(
rtmp_packet
->
body
);
free
(
rtmp_packet
);
free
(
tmp_buffer
);
msg_Err
(
p_access
->
p_sys
->
p_thread
,
"failed send flv packet"
);
return
-
1
;
}
free
(
rtmp_packet
->
body
->
body
);
free
(
rtmp_packet
->
body
);
free
(
rtmp_packet
);
free
(
tmp_buffer
);
}
i_write
+=
p_buffer
->
i_buffer
;
p_buffer
=
p_next
;
}
return
i_write
;
}
/********************a*********************************************************
* Seek: seek to a specific location in a file
*****************************************************************************/
static
int
Seek
(
sout_access_out_t
*
p_access
,
off_t
i_pos
)
{
(
void
)
i_pos
;
msg_Err
(
p_access
,
"RTMP sout access cannot seek"
);
return
-
1
;
}
/*****************************************************************************
* ThreadControl: manage control messages and pipe media to Read
*****************************************************************************/
static
void
*
ThreadControl
(
void
*
p_this
)
{
rtmp_control_thread_t
*
p_thread
=
p_this
;
rtmp_packet_t
*
rtmp_packet
;
int
canc
=
vlc_savecancel
();
rtmp_init_handler
(
p_thread
->
rtmp_handler
);
for
(
;;
)
{
vlc_restorecancel
(
canc
);
rtmp_packet
=
rtmp_read_net_packet
(
p_thread
);
canc
=
vlc_savecancel
(
);
if
(
rtmp_packet
!=
NULL
)
{
if
(
rtmp_packet
->
content_type
<
0x01
/* RTMP_CONTENT_TYPE_CHUNK_SIZE */
||
rtmp_packet
->
content_type
>
0x14
)
/* RTMP_CONTENT_TYPE_INVOKE */
{
free
(
rtmp_packet
->
body
->
body
);
free
(
rtmp_packet
->
body
);
free
(
rtmp_packet
);
msg_Warn
(
p_thread
,
"unknown content type received"
);
}
else
p_thread
->
rtmp_handler
[
rtmp_packet
->
content_type
](
p_thread
,
rtmp_packet
);
}
else
{
/* Sometimes server close connection too soon */
#warning Locking bug here.
if
(
p_thread
->
result_connect
)
{
vlc_mutex_lock
(
&
p_thread
->
lock
);
vlc_cond_signal
(
&
p_thread
->
wait
);
vlc_mutex_unlock
(
&
p_thread
->
lock
);
}
break
;
}
}
vlc_restorecancel
(
canc
);
return
NULL
;
}
po/POTFILES.in
View file @
f5957ea5
...
@@ -232,7 +232,6 @@ modules/access_output/dummy.c
...
@@ -232,7 +232,6 @@ modules/access_output/dummy.c
modules/access_output/file.c
modules/access_output/file.c
modules/access_output/http.c
modules/access_output/http.c
modules/access_output/livehttp.c
modules/access_output/livehttp.c
modules/access_output/rtmp.c
modules/access_output/shout.c
modules/access_output/shout.c
modules/access_output/udp.c
modules/access_output/udp.c
modules/access/pulse.c
modules/access/pulse.c
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment