summaryrefslogtreecommitdiff
path: root/bin/stream
blob: beae9abf4fa8a31903a7871483e173a6ca3dc4e6 (plain)
  1. #!/bin/sh
  2. #
  3. # TODO: Set predictive GOP size for WebM (when tested that it works)
  4. set -eu
  5. # TODO: Externalize to site-specific configfile
  6. [ $# -gt 0 ] || set -- morla 5002 -- dvcam ../../content/icon_small.png
  7. ##
  8. ## defaults
  9. ##
  10. RATIO=4:3
  11. ##
  12. ## generic functions
  13. ##
  14. exit1() {
  15. echo >&2 "ERROR: $1"
  16. exit 1
  17. }
  18. # shellcheck disable=SC2048,SC2059
  19. echo_n() {
  20. printf -- "$*"
  21. }
  22. # shellcheck disable=SC2048,SC2059
  23. printf_each() {
  24. skel=$1; shift
  25. for string in $*; do
  26. printf -- "$skel" "$string"
  27. done
  28. }
  29. uniqwords() {
  30. echo_n "$@" | tr ' ' '\012' | sort -u
  31. }
  32. valuedargcount() {
  33. nonempty=
  34. while [ $# -gt 0 ]; do
  35. [ -z "$1" ] || nonempty=$((nonempty+1))
  36. shift
  37. done
  38. echo_n "$nonempty"
  39. }
  40. while [ $# -gt 0 ]; do
  41. case $1 in
  42. --)
  43. shift; break;;
  44. *)
  45. if [ -z "${HOST:-}" ]; then
  46. HOST=$1
  47. elif [ -z "${FIRSTPORT:-}" ]; then
  48. FIRSTPORT=$1
  49. else
  50. exit1 "Too many arguments: Max. 2 about target"
  51. fi
  52. ;;
  53. esac
  54. shift
  55. done
  56. # TODO: Externalize to site-specific configfile
  57. [ $# -gt 0 ] || set -- dvcam ../../content/icon_small.png
  58. AINPUT=
  59. VINPUT=
  60. WINPUT=
  61. XINPUT=
  62. while [ $# -gt 0 ]; do
  63. case $1 in
  64. alsa=*) ALSA=${1#*=}; AINPUT=$((AINPUT+1));;
  65. alsa) ALSA=default; AINPUT=$((AINPUT+1));;
  66. dvcam=*) DVCAM=${1#*=}; DEINT=${DEINT:-yadif}; XINPUT=$((XINPUT+1));;
  67. dvcam) DVCAM=auto; XINPUT=$((XINPUT+1));;
  68. dc=*) IIDC=${1#*=}; VINPUT=$((VINPUT+1));;
  69. dc) IIDC=/dev/fw1; VINPUT=$((VINPUT+1));;
  70. dv-stream=*) AVISTREAM="-f avi -i ${1#*=}"; XINPUT=$((XINPUT+1));;
  71. dv-stream) AVISTREAM="-f avi -i udp://localhost:10000"; XINPUT=$((XINPUT+1));;
  72. videofile=*) VFILE=${1#*=}; VINPUT=$((VINPUT+1));;
  73. *.ffv1|*.yuv|*.vp8|*.vp9) VFILE=$1; VINPUT=$((VINPUT+1));;
  74. container=*) XFILE=${1#*=}; XINPUT=$((XINPUT+1));;
  75. *.avi|*.dv|*.mkv|*.mov|*.mp4|*.nut|*.ogg|*.ogv|*.webm) XFILE=$1; XINPUT=$((XINPUT+1));;
  76. *.png) LOGO=$1; WINPUT=$((WINPUT+1));;
  77. --) shift; break;;
  78. *) exit1 "Unsupported input: $1";;
  79. esac
  80. shift
  81. done
  82. HOST=${HOST:-127.0.0.1}
  83. if [ "$HOST" = "$(hostname --short)" ]; then
  84. IP=127.0.0.1
  85. else
  86. IP=$(host "$HOST" | grep -Po 'address \K\S+')
  87. fi
  88. [ -n "$AINPUT$VINPUT$XINPUT" ] || exit1 "Too few arguments: Min. 1 A/V source"
  89. [ -z "$AINPUT" ] || [ -z "$VINPUT" ] || [ -z "$XINPUT" ] || exit1 "Too many arguments: Max. 2 A/V sources"
  90. [ -z "$AINPUT" ] || [ $AINPUT -eq 1 ] || exit1 "Too many arguments: Max. 1 audio source"
  91. [ -z "$VINPUT" ] || [ $VINPUT -eq 1 ] || exit1 "Too many arguments: Max. 1 video source"
  92. [ -z "$WINPUT" ] || [ $WINPUT -eq 1 ] || exit1 "Too many arguments: Max. 1 watermark source"
  93. [ -z "$XINPUT" ] || [ $XINPUT -eq 1 ] || exit1 "Too many arguments: Max. 1 multimedia source"
  94. [ -n "${NOAUDIO:-}" ] || [ -z "$AINPUT$XINPUT" ] || HASAUDIO=1
  95. [ -n "${NOVIDEO:-}" ] || [ -z "$VINPUT$XINPUT" ] || HASVIDEO=1
  96. TARGETS_WEBM="${HASAUDIO:+rtp_opus} ${HASVIDEO:+rtp_vp8}"
  97. TARGETS_MPEG="rtp_mpegts"
  98. VSTREAMINDEX=1
  99. [ -n "$AINPUT" ] || VSTREAMINDEX=0
  100. FIRSTPORT=${FIRSTPORT:-5002} # even number - next 7 ports used too
  101. ACHANNELS=1
  102. AFRAMERATE_SRC=48000
  103. AFRAMERATE_OPUS=48000
  104. AFRAMERATE_AAC=44100
  105. ABITRATE_OPUS=48000
  106. ABITRATE_AAC=64000
  107. # FIXME: support multiple heights
  108. HEIGHT=288
  109. ENCODINGS_WEBM="$HEIGHT"
  110. ENCODINGS_MPEG="$HEIGHT"
  111. videosize() { height=$1; width_or_ratio=$2;
  112. case $width_or_ratio in
  113. *:*) num=${width_or_ratio%:*}; den=${width_or_ratio#*:}; width=$((height*num/den));;
  114. *) width=$width_or_ratio;;
  115. esac
  116. echo_n $((height*width))
  117. }
  118. BITS=$(videosize "$HEIGHT" "$RATIO")
  119. # * bitrates and bits in parens based on https://developer.apple.com/library/content/documentation/General/Reference/HLSAuthoringSpec/Requirements.html
  120. # + bits rounded up to include nearby modulo 16 formats
  121. # * Recommended sizes (highest modulo 16 or 8 (or 4) size not "pumping"
  122. # in bridge scene 20s into Tears of Steel):
  123. # + 4:3: (105 210) 288 312 384 480 624 816
  124. # + 16:9: (72 180) 216 288 360 432 576 720
  125. # + 2.40:1: (60 160) 200 240 320 360 480 600
  126. # resolved using http://aarmstrong.org/content/aspect_ratio_calc.php
  127. # with ratio as modulo 4 integers, and size a multiplum of that
  128. # * speeds tuned to just below 100% cpu usage for each combination on a multi-core computer
  129. # TODO: Externalize speeds to site-specific configfile
  130. if [ $BITS -le 15360 ]; then # 192x80 → 15360
  131. AFRAMERATE_AAC=22050
  132. ABITRATE_OPUS=16000
  133. ABITRATE_AAC=32000
  134. VFRAMERATE=10
  135. VBITRATE=32000
  136. SPEED_X264=fast; SPEED_X264_ALONE=fast
  137. SPEED_VP8=3; SPEED_VP8_ALONE=2
  138. elif [ $BITS -le 61440 ]; then # 384x160 → 61440
  139. AFRAMERATE_AAC=22050
  140. ABITRATE_OPUS=16000
  141. ABITRATE_AAC=32000
  142. VFRAMERATE=10
  143. VBITRATE=64000
  144. SPEED_X264=fast; SPEED_X264_ALONE=fast
  145. SPEED_VP8=3; SPEED_VP8_ALONE=2
  146. elif [ $BITS -le 110592 ]; then # 234p → 97344
  147. VBITRATE=145000
  148. SPEED_X264=fast; SPEED_X264_ALONE=fast
  149. SPEED_VP8=3; SPEED_VP8_ALONE=2
  150. elif [ $BITS -le 150528 ]; then # 270p → 129600
  151. VBITRATE=365000
  152. SPEED_X264=faster; SPEED_X264_ALONE=fast
  153. SPEED_VP8=4; SPEED_VP8_ALONE=2
  154. elif [ $BITS -le 196608 ]; then # 360p → 172800
  155. VBITRATE=730000
  156. SPEED_X264=veryfast; SPEED_X264_ALONE=fast
  157. SPEED_VP8=5; SPEED_VP8_ALONE=3
  158. elif [ $BITS -le 331776 ]; then # 432p → 331776
  159. VBITRATE=1100000
  160. SPEED_X264=ultrafast; SPEED_X264_ALONE=fast
  161. SPEED_VP8=8; SPEED_VP8_ALONE=4
  162. elif [ $BITS -le 589824 ]; then # 540p → 518400
  163. VBITRATE=2000000
  164. SPEED_X264=toofast; SPEED_X264_ALONE=veryfast
  165. SPEED_VP8_ALONE=5
  166. elif [ $BITS -le 921600 ]; then # 720p → 921600
  167. VBITRATE=3000000
  168. SPEED_X264=toofast; SPEED_X264_ALONE=ultrafast
  169. SPEED_VP8_ALONE=15
  170. fi
  171. [ toofast != "$SPEED_X264" ] || ENCODINGS_MPEG=
  172. [ -n "$ENCODINGS_MPEG" ] || SPEED_VP8="$SPEED_VP8_ALONE"
  173. [ -n "$ENCODINGS_WEBM" ] || SPEED_X264="$SPEED_X264_ALONE"
  174. ENCODINGS=$(uniqwords "$ENCODINGS_WEBM $ENCODINGS_MPEG")
  175. [ -z "${SAVEDIR:-}" ] || SAVESTEM="${SAVEDIR:-}/$(date +%Y%m%d-%H%M%S)"
  176. [ -z "${SAVEDIR:-}" ] || export FFREPORT=file="$SAVESTEM.log"
  177. # * scale+watermark trick based on http://stackoverflow.com/a/10937357
  178. # + scale to square pixels as needed
  179. filters_compose() { logo=$1;
  180. heightcount=$(echo "$ENCODINGS" | wc --words)
  181. echo_n "[$VSTREAMINDEX:v]${DEINT:+$DEINT,}${VFRAMERATE:+framerate=$VFRAMERATE,}format=pix_fmts=yuv420p,split=$heightcount"
  182. printf_each '[s%s]' "$ENCODINGS"
  183. echo_n ';'
  184. for height in $ENCODINGS; do
  185. echo_n "[s$height]scale=trunc(iw*sar*$height/ih/2)*2:$height,setsar=1"
  186. [ -z "$logo" ] || echo_n "[bg$height];[bg$height][$logo:v]overlay=main_w-overlay_w-20:main_h-overlay_h-20"
  187. echo_n "[v$height]"
  188. done
  189. }
  190. filter_split_codec() { heights_webm=$1; heights_mpeg=$2;
  191. codeccount=$(valuedargcount "$@")
  192. for height in $ENCODINGS; do
  193. echo_n "[v$height]split=$codeccount"
  194. printf_each '[v%swebm]' "$heights_webm"
  195. printf_each '[v%smpeg]' "$heights_mpeg"
  196. done
  197. }
  198. # * VP8 encoding based on http://www.webmproject.org/docs/encoder-parameters/#real-time-cbr-encoding-and-streaming
  199. # + Add 1s latency (deadline)
  200. # * Predictive GOP size preserving scene-change GOP based on https://superuser.com/a/1098329
  201. encode_opus() {
  202. echo_n "-codec:a libopus -ac $ACHANNELS -ar $AFRAMERATE_OPUS -b:a $ABITRATE_OPUS"
  203. }
  204. encode_aac() {
  205. echo_n "-codec:a aac -strict experimental -ac $ACHANNELS -ar $AFRAMERATE_AAC -b:a $((ACHANNELS*ABITRATE_AAC))"
  206. }
  207. encode_vp8() { bitrate=$1; speed=$2;
  208. echo_n "-codec:v vp8 -quality realtime -deadline 1000000 -cpu-used $speed \
  209. -b:v $bitrate -minrate $bitrate -maxrate $bitrate \
  210. -undershoot-pct 95 -bufsize $((6000*bitrate/1000)) -rc_init_occupancy $((4000*bitrate/1000)) \
  211. -max-intra-rate 0 \
  212. -qmin 4 -qmax 56 \
  213. -force_key_frames expr:gte(t,n_forced*2)"
  214. }
  215. encode_x264() { bitrate=$1; speed=$2;
  216. echo_n "-codec:v libx264 -preset $speed -tune zerolatency \
  217. -maxrate $bitrate -bufsize $((bitrate*2)) -crf 23 \
  218. -force_key_frames expr:gte(t,n_forced*2)"
  219. }
  220. # * routing based on http://trac.ffmpeg.org/wiki/Creating%20multiple%20outputs#Teepseudo-muxer
  221. # * Use same RTP payload types as GStreamer
  222. mux() { targets="$1";
  223. targetcount=$(echo "$targets" | wc --words)
  224. if [ $targetcount -lt 2 ]; then
  225. case "$targets" in
  226. hls_mpeg) echo_n "-f hls -hls_time 6 -hls_flags delete_segments -hls_flags discont_start -hls_flags append_list -use_localtime 1 -hls_segment_filename file-%Y%m%d-%s.ts index.m3u8";;
  227. rtp_opus) echo_n "-f rtp -payload_type 111 rtp://$IP:$FIRSTPORT?pkt_size=1440";;
  228. rtp_vp8) echo_n "-f rtp -payload_type 100 rtp://$IP:$((FIRSTPORT+2))?pkt_size=1440";;
  229. rtp_mpegts) echo_n "-f rtp_mpegts rtp://$IP:10000?pkt_size=1440";;
  230. *) exit1 "Unknown target $targets";;
  231. esac
  232. else
  233. echo_n "-f tee "
  234. for target in $targets; do
  235. case "$target" in
  236. hls_mpeg) echo_n "[f=hls:hls_time=6:hls_flags=delete_segments:hls_flags=discont_start:hls_flags=append_list:use_localtime=1:hls_segment_filename=file-%Y%m%d-%s.ts]index.m3u8";;
  237. rtp_opus) echo_n "[select=\'a\':f=rtp:payload_type=111]rtp://$IP:$FIRSTPORT?pkt_size=1440";;
  238. rtp_vp8) echo_n "[select=\'v\':f=rtp:payload_type=100]rtp://$IP:$((FIRSTPORT+2))?pkt_size=1440";;
  239. rtp_mpegts) echo_n "[f=rtp_mpegts]rtp://$IP:$((FIRSTPORT+2))?pkt_size=1440";;
  240. *) exit1 "Unknown target $target";;
  241. esac
  242. targetcount=$((targetcount-1))
  243. [ $targetcount -lt 1 ] || echo_n '|'
  244. done
  245. fi
  246. }
  247. ffmpeg -hide_banner -threads auto \
  248. ${ALSA:+-f alsa -sample_rate "$AFRAMERATE_SRC" -channels "$ACHANNELS" -thread_queue_size 2048 -i "$ALSA"} \
  249. ${DVCAM:+-f iec61883 -thread_queue_size 64 -i $DVCAM} \
  250. ${AVISTREAM:-} \
  251. ${XFILE:+-re${SEEK:+ -ss $SEEK} -i "$XFILE"} \
  252. ${IIDC:+-f libdc1394 -video_size 640x480 -framerate 15 -thread_queue_size 256 -i "$IIDC"} \
  253. ${VFILE:+-re${SEEK:+ -ss $SEEK} -i "$VFILE"} \
  254. ${LOGO:+-i "$LOGO"} \
  255. ${ENCODINGS:+-filter_complex "\
  256. ${HASVIDEO:+
  257. $(filters_compose "${LOGO:+$((VSTREAMINDEX+1))}");
  258. $(filter_split_codec "$ENCODINGS_WEBM" "$ENCODINGS_MPEG") }"} \
  259. ${SAVEDIR:+\
  260. ${DVCAM:+-map $((0${ALSA:++1})) \
  261. -codec copy -f dv "$SAVESTEM.dv" }} \
  262. ${ENCODINGS_WEBM:+\
  263. ${HASAUDIO:+-map '0:a' }${HASVIDEO:+$(printf_each ' -map [v%swebm]' "$ENCODINGS_WEBM") } -shortest \
  264. ${HASAUDIO:+\
  265. $(encode_opus) } \
  266. ${HASVIDEO:+\
  267. $(encode_vp8 "$VBITRATE" "$SPEED_VP8") } \
  268. $(mux "$TARGETS_WEBM") } \
  269. ${ENCODINGS_MPEG:+\
  270. ${HASAUDIO:+-map '0:a' }${HASVIDEO:+$(printf_each ' -map [v%smpeg]' "$ENCODINGS_MPEG") } -shortest \
  271. ${HASAUDIO:+\
  272. $(encode_aac) } \
  273. ${HASVIDEO:+\
  274. $(encode_x264 "$VBITRATE" "$SPEED_X264") } \
  275. $(mux "$TARGETS_MPEG") }