summaryrefslogtreecommitdiff
path: root/bin/stream
blob: 44374d6648037a738a65fb42e2ce2e6108e1e0e6 (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. VSTREAMINDEX=1
  98. [ -n "$AINPUT" ] || VSTREAMINDEX=0
  99. FIRSTPORT=${FIRSTPORT:-5002} # even number - next 7 ports used too
  100. ACHANNELS=1
  101. AFRAMERATE_SRC=48000
  102. AFRAMERATE_OPUS=48000
  103. AFRAMERATE_AAC=44100
  104. ABITRATE_OPUS=48000
  105. ABITRATE_AAC=64000
  106. # FIXME: support multiple heights
  107. HEIGHT=288
  108. ENCODINGS_WEBM="$HEIGHT"
  109. ENCODINGS_MPEG="$HEIGHT"
  110. videosize() { height=$1; width_or_ratio=$2;
  111. case $width_or_ratio in
  112. *:*) num=${width_or_ratio%:*}; den=${width_or_ratio#*:}; width=$((height*num/den));;
  113. *) width=$width_or_ratio;;
  114. esac
  115. echo_n $((height*width))
  116. }
  117. BITS=$(videosize "$HEIGHT" "$RATIO")
  118. # * bitrates and bits in parens based on https://developer.apple.com/library/content/documentation/General/Reference/HLSAuthoringSpec/Requirements.html
  119. # + bits rounded up to include nearby modulo 16 formats
  120. # * Recommended sizes (highest modulo 16 or 8 (or 4) size not "pumping"
  121. # in bridge scene 20s into Tears of Steel):
  122. # + 4:3: (105 210) 288 312 384 480 624 816
  123. # + 16:9: (72 180) 216 288 360 432 576 720
  124. # + 2.40:1: (60 160) 200 240 320 360 480 600
  125. # resolved using http://aarmstrong.org/content/aspect_ratio_calc.php
  126. # with ratio as modulo 4 integers, and size a multiplum of that
  127. # * speeds tuned to just below 100% cpu usage for each combination on a multi-core computer
  128. # TODO: Externalize speeds to site-specific configfile
  129. if [ $BITS -le 15360 ]; then # 192x80 → 15360
  130. AFRAMERATE_AAC=22050
  131. ABITRATE_OPUS=16000
  132. ABITRATE_AAC=32000
  133. VFRAMERATE=10
  134. VBITRATE=32000
  135. SPEED_X264=fast; SPEED_X264_ALONE=fast
  136. SPEED_VP8=3; SPEED_VP8_ALONE=2
  137. elif [ $BITS -le 61440 ]; then # 384x160 → 61440
  138. AFRAMERATE_AAC=22050
  139. ABITRATE_OPUS=16000
  140. ABITRATE_AAC=32000
  141. VFRAMERATE=10
  142. VBITRATE=64000
  143. SPEED_X264=fast; SPEED_X264_ALONE=fast
  144. SPEED_VP8=3; SPEED_VP8_ALONE=2
  145. elif [ $BITS -le 110592 ]; then # 234p → 97344
  146. VBITRATE=145000
  147. SPEED_X264=fast; SPEED_X264_ALONE=fast
  148. SPEED_VP8=3; SPEED_VP8_ALONE=2
  149. elif [ $BITS -le 150528 ]; then # 270p → 129600
  150. VBITRATE=365000
  151. SPEED_X264=faster; SPEED_X264_ALONE=fast
  152. SPEED_VP8=4; SPEED_VP8_ALONE=2
  153. elif [ $BITS -le 196608 ]; then # 360p → 172800
  154. VBITRATE=730000
  155. SPEED_X264=veryfast; SPEED_X264_ALONE=fast
  156. SPEED_VP8=5; SPEED_VP8_ALONE=3
  157. elif [ $BITS -le 331776 ]; then # 432p → 331776
  158. VBITRATE=1100000
  159. SPEED_X264=ultrafast; SPEED_X264_ALONE=fast
  160. SPEED_VP8=8; SPEED_VP8_ALONE=4
  161. elif [ $BITS -le 589824 ]; then # 540p → 518400
  162. VBITRATE=2000000
  163. SPEED_X264=toofast; SPEED_X264_ALONE=veryfast
  164. SPEED_VP8_ALONE=5
  165. elif [ $BITS -le 921600 ]; then # 720p → 921600
  166. VBITRATE=3000000
  167. SPEED_X264=toofast; SPEED_X264_ALONE=ultrafast
  168. SPEED_VP8_ALONE=15
  169. fi
  170. [ toofast != "$SPEED_X264" ] || ENCODINGS_MPEG=
  171. [ -n "$ENCODINGS_MPEG" ] || SPEED_VP8="$SPEED_VP8_ALONE"
  172. [ -n "$ENCODINGS_WEBM" ] || SPEED_X264="$SPEED_X264_ALONE"
  173. ENCODINGS=$(uniqwords "$ENCODINGS_WEBM $ENCODINGS_MPEG")
  174. [ -z "${SAVEDIR:-}" ] || SAVESTEM="${SAVEDIR:-}/$(date +%Y%m%d-%H%M%S)"
  175. [ -z "${SAVEDIR:-}" ] || export FFREPORT=file="$SAVESTEM.log"
  176. # * scale+watermark trick based on http://stackoverflow.com/a/10937357
  177. # + scale to square pixels as needed
  178. filters_compose() { logo=$1;
  179. heightcount=$(echo "$ENCODINGS" | wc --words)
  180. echo_n "[$VSTREAMINDEX:v]${DEINT:+$DEINT,}${VFRAMERATE:+framerate=$VFRAMERATE,}format=pix_fmts=yuv420p,split=$heightcount"
  181. printf_each '[s%s]' "$ENCODINGS"
  182. echo_n ';'
  183. for height in $ENCODINGS; do
  184. echo_n "[s$height]scale=trunc(iw*sar*$height/ih/2)*2:$height,setsar=1"
  185. [ -z "$logo" ] || echo_n "[bg$height];[bg$height][$logo:v]overlay=main_w-overlay_w-20:main_h-overlay_h-20"
  186. echo_n "[v$height]"
  187. done
  188. }
  189. filter_split_codec() { heights_webm=$1; heights_mpeg=$2;
  190. codeccount=$(valuedargcount "$@")
  191. for height in $ENCODINGS; do
  192. echo_n "[v$height]split=$codeccount"
  193. printf_each '[v%swebm]' "$heights_webm"
  194. printf_each '[v%smpeg]' "$heights_mpeg"
  195. done
  196. }
  197. # * VP8 encoding based on http://www.webmproject.org/docs/encoder-parameters/#real-time-cbr-encoding-and-streaming
  198. # + Add 1s latency (deadline)
  199. # * Predictive GOP size preserving scene-change GOP based on https://superuser.com/a/1098329
  200. encode_opus() {
  201. echo_n "-codec:a libopus -ac $ACHANNELS -ar $AFRAMERATE_OPUS -b:a $ABITRATE_OPUS"
  202. }
  203. encode_aac() {
  204. echo_n "-codec:a aac -strict experimental -ac $ACHANNELS -ar $AFRAMERATE_AAC -b:a $((ACHANNELS*ABITRATE_AAC))"
  205. }
  206. encode_vp8() { bitrate=$1; speed=$2;
  207. echo_n "-codec:v vp8 -quality realtime -deadline 1000000 -cpu-used $speed \
  208. -b:v $bitrate -minrate $bitrate -maxrate $bitrate \
  209. -undershoot-pct 95 -bufsize $((6000*bitrate/1000)) -rc_init_occupancy $((4000*bitrate/1000)) \
  210. -max-intra-rate 0 \
  211. -qmin 4 -qmax 56 \
  212. -force_key_frames expr:gte(t,n_forced*2)"
  213. }
  214. encode_x264() { bitrate=$1; speed=$2;
  215. echo_n "-codec:v libx264 -preset $speed -tune zerolatency \
  216. -maxrate $bitrate -bufsize $((bitrate*2)) -crf 23 \
  217. -force_key_frames expr:gte(t,n_forced*2)"
  218. }
  219. # * routing based on http://trac.ffmpeg.org/wiki/Creating%20multiple%20outputs#Teepseudo-muxer
  220. # * Use same RTP payload types as GStreamer
  221. mux() { targets="$1";
  222. targetcount=$(echo "$targets" | wc --words)
  223. if [ $targetcount -lt 2 ]; then
  224. case "$targets" in
  225. rtp_opus) echo_n "-f rtp -payload_type 111 rtp://$IP:$FIRSTPORT?pkt_size=1440";;
  226. rtp_vp8) echo_n "-f rtp -payload_type 100 rtp://$IP:$((FIRSTPORT+2))?pkt_size=1440";;
  227. *) exit1 "Unknown target $targets";;
  228. esac
  229. else
  230. echo_n "-f tee "
  231. for target in $targets; do
  232. case "$target" in
  233. rtp_opus) echo_n "[select=\'a\':f=rtp:payload_type=111]rtp://$IP:$FIRSTPORT?pkt_size=1440";;
  234. rtp_vp8) echo_n "[select=\'v\':f=rtp:payload_type=100]rtp://$IP:$((FIRSTPORT+2))?pkt_size=1440";;
  235. *) exit1 "Unknown target $target";;
  236. esac
  237. targetcount=$((targetcount-1))
  238. [ $targetcount -lt 1 ] || echo_n '|'
  239. done
  240. fi
  241. }
  242. ffmpeg -hide_banner -threads auto \
  243. ${ALSA:+-f alsa -sample_rate "$AFRAMERATE_SRC" -channels "$ACHANNELS" -thread_queue_size 2048 -i "$ALSA"} \
  244. ${DVCAM:+-f iec61883 -thread_queue_size 64 -i $DVCAM} \
  245. ${AVISTREAM:-} \
  246. ${XFILE:+-re${SEEK:+ -ss $SEEK} -i "$XFILE"} \
  247. ${IIDC:+-f libdc1394 -video_size 640x480 -framerate 15 -thread_queue_size 256 -i "$IIDC"} \
  248. ${VFILE:+-re${SEEK:+ -ss $SEEK} -i "$VFILE"} \
  249. ${LOGO:+-i "$LOGO"} \
  250. ${ENCODINGS:+-filter_complex "\
  251. ${HASVIDEO:+
  252. $(filters_compose "${LOGO:+$((VSTREAMINDEX+1))}");
  253. $(filter_split_codec "$ENCODINGS_WEBM" "$ENCODINGS_MPEG") }"} \
  254. ${SAVEDIR:+\
  255. ${DVCAM:+-map $((0${ALSA:++1})) \
  256. -codec copy -f dv "$SAVESTEM.dv" }} \
  257. ${ENCODINGS_WEBM:+\
  258. ${HASAUDIO:+-map '0:a' }${HASVIDEO:+$(printf_each ' -map [v%swebm]' "$ENCODINGS_WEBM") } -shortest \
  259. ${HASAUDIO:+\
  260. $(encode_opus) } \
  261. ${HASVIDEO:+\
  262. $(encode_vp8 "$VBITRATE" "$SPEED_VP8") } \
  263. $(mux "$TARGETS_WEBM") } \
  264. ${ENCODINGS_MPEG:+\
  265. ${HASAUDIO:+-map '0:a' }${HASVIDEO:+$(printf_each ' -map [v%smpeg]' "$ENCODINGS_MPEG") } -shortest \
  266. ${HASAUDIO:+\
  267. $(encode_aac) } \
  268. ${HASVIDEO:+\
  269. $(encode_x264 "$VBITRATE" "$SPEED_X264") } \
  270. -f rtp_mpegts rtp://$IP:10000 }