summaryrefslogtreecommitdiff
path: root/bin/stream
blob: c1833de32d2d8b514df3721b2aa6feb2301da3fc (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. [ "$AINPUT$VINPUT$XINPUT" = "1" ] || TWOSOURCES=1
  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. HEIGHTS_WEBM="$HEIGHT"
  109. HEIGHTS_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. VBITRATE=145000
  144. SPEED_X264=fast; SPEED_X264_ALONE=fast
  145. SPEED_VP8=3; SPEED_VP8_ALONE=2
  146. if [ $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" ] || HEIGHTS_MPEG=
  172. [ -n "$HEIGHTS_MPEG" ] || SPEED_VP8="$SPEED_VP8_ALONE"
  173. [ -n "$HEIGHTS_WEBM" ] || SPEED_X264="$SPEED_X264_ALONE"
  174. HEIGHTS=$(uniqwords "$HEIGHTS_WEBM $HEIGHTS_MPEG")
  175. [ -z "${SAVEDIR:-}" ] || SAVESTEM="${SAVEDIR:-}/$(date +%Y%m%d-%H%M%S)"
  176. [ -z "${SAVEDIR:-}" ] || export FFREPORT=file="$SAVESTEM.log"
  177. filter_split_height() {
  178. heightcount=$(echo "$HEIGHTS" | wc --words)
  179. echo_n "[$VSTREAMINDEX:v]${DEINT:+$DEINT,}${VFRAMERATE:+framerate=$VFRAMERATE,}format=pix_fmts=yuv420p,split=$heightcount"
  180. printf_each '[s%s]' "$HEIGHTS"
  181. }
  182. filter_scale() { outstem=${1:-v};
  183. for height in $HEIGHTS; do
  184. echo_n "[s$height]scale=iw*sar*$height/ih:$height,setsar=1[$outstem$height]"
  185. done
  186. }
  187. filter_watermark() {
  188. for height in $HEIGHTS; do
  189. echo_n "[bg$height][$((VSTREAMINDEX+1)):v]overlay=main_w-overlay_w-20:main_h-overlay_h-20[v$height]"
  190. done
  191. }
  192. filter_split_codec() { heights_webm=$1; heights_mpeg=$2;
  193. codeccount=$(valuedargcount "$@")
  194. printf_each "[v%s]split=$codeccount$(printf_each '[v%swebm]' "$heights_webm")$(printf_each '[v%smpeg]' "$heights_mpeg")" "$HEIGHTS"
  195. }
  196. encode_opus() {
  197. echo_n "-codec:a libopus -ac $ACHANNELS -ar $AFRAMERATE_OPUS -b:a $ABITRATE_OPUS"
  198. }
  199. encode_aac() {
  200. echo_n "-codec:a aac -strict experimental -ac $ACHANNELS -ar $AFRAMERATE_AAC -b:a $((ACHANNELS*ABITRATE_AAC))"
  201. }
  202. encode_vp8() { bitrate=$1; speed=$2;
  203. echo_n "-codec:v vp8 -quality realtime -deadline 1000000 -cpu-used $speed \
  204. -b:v $bitrate -minrate $bitrate -maxrate $bitrate \
  205. -undershoot-pct 95 -bufsize $((6000*bitrate/1000)) -rc_init_occupancy $((4000*bitrate/1000)) \
  206. -max-intra-rate 0 \
  207. -qmin 4 -qmax 56 \
  208. -force_key_frames expr:gte(t,n_forced*2)"
  209. }
  210. encode_x264() { bitrate=$1; speed=$2;
  211. echo_n "-codec:v libx264 -preset $speed -tune zerolatency \
  212. -maxrate $bitrate -bufsize $((bitrate*2)) -crf 23 \
  213. -force_key_frames expr:gte(t,n_forced*2)"
  214. }
  215. tee_rtp() { stream=$1; pt=$2; port=$3;
  216. echo_n "[select=\'$stream\':f=rtp:payload_type=$pt]rtp://$IP:$port?pkt_size=1440"
  217. }
  218. # * scale+watermark trick based on http://stackoverflow.com/a/10937357
  219. # + scale to square pixels as needed
  220. # * routing based on http://trac.ffmpeg.org/wiki/Creating%20multiple%20outputs#Teepseudo-muxer
  221. # * VP8 encoding based on http://www.webmproject.org/docs/encoder-parameters/#real-time-cbr-encoding-and-streaming
  222. # + Add 1s latency (deadline)
  223. # * Predictive GOP size preserving scene-change GOP based on https://superuser.com/a/1098329
  224. # * Use same RTP payload types as GStreamer
  225. ffmpeg -hide_banner -threads auto \
  226. ${ALSA:+-f alsa -sample_rate "$AFRAMERATE_SRC" -channels "$ACHANNELS" -thread_queue_size 2048 -i "$ALSA"} \
  227. ${DVCAM:+-f iec61883 -thread_queue_size 64 -i $DVCAM} \
  228. ${AVISTREAM:-} \
  229. ${XFILE:+-re${SEEK:+ -ss $SEEK} -i "$XFILE"} \
  230. ${IIDC:+-f libdc1394 -video_size 640x480 -framerate 15 -thread_queue_size 256 -i "$IIDC"} \
  231. ${VFILE:+-re${SEEK:+ -ss $SEEK} -i "$VFILE"} \
  232. ${LOGO:+-i "$LOGO"} \
  233. ${HASVIDEO:+-filter_complex \
  234. "$(filter_split_height);
  235. $(filter_scale "${WINPUT:+bg}")${WINPUT:+${LOGO:+;
  236. $(filter_watermark)}};
  237. $(filter_split_codec "$HEIGHTS_WEBM" "$HEIGHTS_MPEG")" } \
  238. ${SAVEDIR:+\
  239. ${DVCAM:+-map $((0${ALSA:++1})) \
  240. -codec copy -f dv "$SAVESTEM.dv" }} \
  241. ${HEIGHTS_WEBM:+\
  242. ${HASAUDIO:+-map '0:a' }${HASVIDEO:+$(printf_each ' -map [v%swebm]' "$HEIGHTS_WEBM") } -shortest \
  243. ${HASAUDIO:+\
  244. $(encode_opus) } \
  245. ${HASVIDEO:+\
  246. $(encode_vp8 "$VBITRATE" "$SPEED_VP8") } \
  247. -f tee \
  248. "${HASAUDIO:+\
  249. $(tee_rtp a 111 "$FIRSTPORT")|\
  250. }${HASVIDEO:+\
  251. $(tee_rtp v 100 $((FIRSTPORT+2)))}" } \
  252. ${HEIGHTS_MPEG:+\
  253. ${HASAUDIO:+-map '0:a' }${HASVIDEO:+$(printf_each ' -map [v%smpeg]' "$HEIGHTS_MPEG") } -shortest \
  254. ${HASAUDIO:+\
  255. $(encode_aac) } \
  256. ${HASVIDEO:+\
  257. $(encode_x264 "$VBITRATE" "$SPEED_X264") } \
  258. -f rtp_mpegts rtp://$IP:10000 }