#!/usr/bin/perl # Send live video/audio media as RTP streams, published via RTSP # Depends: libglib-object-introspection-perl, gir1.2-gst-rtsp-server-1.0 # Recommends: gstreamer1.0-plugins-good use v5.12; use strictures 2; use Glib qw( TRUE FALSE ); use Glib::Object::Introspection; use IPC::System::Simple qw(capturex); BEGIN { Glib::Object::Introspection->setup( basename => 'Gst', version => '1.0', package => 'Gst', ); Glib::Object::Introspection->setup( basename => 'GstRtspServer', version => '1.0', package => 'Gst', ); } my $ADDRESS = shift || $ENV{'ADDRESS'} || '127.0.0.1'; my $PORT = shift || $ENV{'PORT'} || '8554'; my $VDEVICES = shift || $ENV{'VDEVICES'} || ''; my $ADEVICES = shift || $ENV{'ADEVICES'} || ''; my $VFORMAT = shift || $ENV{'VFORMAT'} || 'VP8'; # H264 VP8 RAW - default: VP8 my $AFORMAT = shift || $ENV{'AFORMAT'} || 'OPUS'; # AMR OPUS RAW - default: OPUS my @VDEVICES = $VDEVICES ? split ' ', $VDEVICES : sort split ' ', capturex( 'find', qw(/dev -maxdepth 1 -type c -name video*) ); # FIXME: Detect/blacklist and skip faulty devices #my @ADEVICES = grep { /^hw:/ } capturex( 'arecord', qw(-L) ); my @ADEVICES = split ' ', $ADEVICES; chomp @ADEVICES; #use Data::Dump; die dd @ADEVICES; my $HEIGHT = 240; my $FRAMERATE = 25; my $AUDIORATE = 48000; my $VBITRATE; # inspired by Apple HLS recommendations if ( $HEIGHT le 234 ) { $VBITRATE = 145000 } elsif ( $HEIGHT le 270 ) { $VBITRATE = 365000 } elsif ( $HEIGHT le 360 ) { $VBITRATE = 730000 } elsif ( $HEIGHT le 432 ) { $VBITRATE = 1100000 } elsif ( $HEIGHT le 540 ) { $VBITRATE = 2000000 } elsif ( $HEIGHT le 720 ) { $VBITRATE = 3000000 } my $VCAPS = "video/x-raw,height=$HEIGHT"; my $ACAPS = "audio/x-raw,rate=$AUDIORATE,channels=2,depth=16"; # * http://stackoverflow.com/a/42237307 my $ABUFFERS = 20000; # * force threads using queues - see http://stackoverflow.com/a/30738533 # * generous queue sizes inspired by https://wiki.xiph.org/GST_cookbook my $QUEUE = "queue max-size-bytes=100000000 max-size-time=0"; my %PIPELINE = ( AMR => { AENC => [ 'amrnbenc', $QUEUE, 'rtpamrpay' ], }, H264 => { # * let x264 use low-latency sliced-threads (i.e. don't disable treads) VENC => [ "x264enc speed-preset=ultrafast tune=zerolatency bitrate=800 byte-stream=true key-int-max=15 intra-refresh=true option-string=\"slice-max-size=8192:vbv-maxrate=80:vbv-bufsize=10\"", 'video/x-h264,profile=baseline', $QUEUE, 'rtph264pay', ], }, OPUS => { AENC => [ 'opusenc', $QUEUE, 'rtpopuspay' ], }, VP8 => { VENC => [ "vp8enc threads=4 cpu-used=15 deadline=1000000 end-usage=1 target-bitrate=$VBITRATE undershoot=95 keyframe-max-dist=999999 max-quantizer=56 deadline=5000 static-threshold=500", 'video/x-vp8', $QUEUE, 'rtpvp8pay', ], }, RAW => { AENC => ['rtpL16pay'], VENC => ['rtpvrawpay'], }, ); our $nextpayload = 0; sub cam { my ( $device, $payload ) = @_; my $factory = Gst::RTSPMediaFactory->new(); my $pipeline = join( ' ! ', ( "v4l2src device=$device", $QUEUE, 'videoconvert', $VCAPS, $QUEUE, @{ $PIPELINE{$VFORMAT}{'VENC'} }, ) ); return "( $pipeline name=pay$payload )"; } sub mic { my ( $device, $payload ) = @_; my $factory = Gst::RTSPMediaFactory->new(); my $pipeline = join( ' ! ', ( "alsasrc device=$device buffer-time=$ABUFFERS", $QUEUE, 'audioconvert', $QUEUE, @{ $PIPELINE{$AFORMAT}{'AENC'} }, ) ); return "( $pipeline name=pay$payload )"; } sub factory { my @pipeline = @_; my $factory = Gst::RTSPMediaFactory->new(); $factory->set_launch( join( ' ', @pipeline ) ); $factory->set_shared(TRUE); #say "media ($device): " . $factory->get_launch(); # $factory->set_latency(5); #say "latency ($device): " . $factory->get_latency(); return $factory; } Gst::init( [ $0, @ARGV ] ); my $loop = Glib::MainLoop->new( undef, FALSE ); # create a server instance my $server = Gst::RTSPServer->new(); $server->set_address($ADDRESS); $server->set_service($PORT); # get the mount points for this server, every server has a default # object that be used to map uri mount points to media factories my $mounts = $server->get_mount_points(); # attach media to URIs my @mounts; for my $i ( 0 .. $#VDEVICES ) { my $mount = "/cam$i"; $mounts->add_factory( $mount, factory( cam( $VDEVICES[$i], $nextpayload++ ) ) ); push @mounts, $mount; } for my $i ( 0 .. $#ADEVICES ) { my $mount = "/mic$i"; $mounts->add_factory( $mount, factory( mic( $ADEVICES[$i], $nextpayload++ ) ) ); push @mounts, $mount; } if ( @ADEVICES and @VDEVICES ) { my $mount = "/main"; $mounts->add_factory( $mount, factory( mic( $ADEVICES[0], $#VDEVICES + 1 ), cam( $VDEVICES[0], 0 ) ) ); push @mounts, $mount; } # don't need the ref to the mapper anymore undef $mounts; # attach the server to the default maincontext my $retval = $server->attach(undef); # start serving say "streams ready at the following URLs:"; for (@mounts) { say "rtsp://$ADDRESS:$PORT$_"; } $loop->run;