From 65cc7ba4d760b4420c073c19cf645fb2688b348a Mon Sep 17 00:00:00 2001
From: Cursor Agent <cursoragent@cursor.com>
Date: Sun, 21 Dec 2025 01:10:37 +0000
Subject: [PATCH] feat: Add adaptive bitrate HLS and concurrency controls

Co-authored-by: mathieumoran1 <mathieumoran1@gmail.com>
---
 README.md                                |  24 ++++
 __pycache__/video_server.cpython-312.pyc | Bin 21972 -> 27473 bytes
 video_server.py                          | 172 ++++++++++++++++++++---
 3 files changed, 175 insertions(+), 21 deletions(-)

diff --git a/README.md b/README.md
index c9328ab..266ab5e 100644
--- a/README.md
+++ b/README.md
@@ -47,6 +47,30 @@ Example:
 - Source: `http://localhost:8001/media/MyMovie.mkv`
 - The player will request: `http://localhost:8001/api/hls?source=MyMovie.mkv` and then play the returned `.m3u8`.
 
+### Multi-stream / adaptive bitrate
+HLS is generated as **multi-rendition adaptive bitrate** by default (a master playlist `index.m3u8` pointing to multiple variant streams).
+
+You can configure variants with:
+
+```bash
+export HLS_VARIANTS="1080:5500,720:3000,480:1500,360:900"
+```
+
+### Concurrency (many viewers at once)
+- **Serving** multiple viewers is handled by Uvicorn/FastAPI; for heavy traffic run with more workers:
+
+```bash
+export VIDEO_SERVER_RELOAD=0
+export VIDEO_SERVER_WORKERS=4
+python3 video_server.py
+```
+
+- **Transcoding** is CPU-heavy; it is throttled with:
+
+```bash
+export HLS_MAX_JOBS=2
+```
+
 ### Install
 
 ```bash
diff --git a/__pycache__/video_server.cpython-312.pyc b/__pycache__/video_server.cpython-312.pyc
index bf420e154bcdb206ccb605195fb96c0c7f7f7ab2..5fddb13a1e258d67403f77cd0588b53131b27851 100644
GIT binary patch
delta 10716
zcmbVy3s75Emf(B(3w=RCLVSfV24S!PV{FR?n?L@60TbIwY*}z0AS@yLp1@cmMNV(J
zR!-a-+;3)0lFmfQOz+ZVZ;xx3nqq3YdYn$D)1RttVH{iYhN?-=rg}EpGrQQG+UYn`
zy?f4+1lZ&4t=boJbndz5oO|xMzjN-*{af_P16uzxoi2xh?|=37_$CH!=nEtdlsBs9
zCIcq7DPVS+1NrWJnj#dT{T8=H{I$BR@GJKh1Z-|wpwL|yC~_ACirvM55_gHntMHcw
z%G_lluJqdj<?ix;!|i~w%3UF$7#*|i7LBb^)Z{V#m9oN`$>ZtbR_Lx`s)#zQp(uAX
z3c(*eImoZ*OjS96*FdcXYqP3uNz&5Ua$0qhdxskB*ZOM%b?!Qv0?|4U)om38%k;!B
zA#v}5TFK-EY$Vs1Rpf5iY?}X)*3t~x%-bb$<?bytha@?<O;FxL@&Pt)*61w6nl)}x
zl#R{NoCF%RW}C=XyZ3^aWpa9}AJRCpH_PkZPYReCVq<h;GE(@e%<UpYOfi(rOpOhg
zfm#gI0~zW;D3?IFg_JTn;HrUgtPBXP#13l8nPyQmpJ`^A$0VpgRH7gb;5kHI6vZll
zYa9Gkirl%(VL}snOe%8bknOL^-ECXcSAk^vmU1<eJ2GV>44fgBZU`)KLRBYuiPV5?
zJ5V{ORghXx*d@}iEF*Qm)lGJ8*uM+PJ)|DYZ^(E;K^lS9OLjxKNu<?)o;^T2LYkkV
z?FE|cD7e|iRNUUT;nZVW#%n)uWd|fZUe)g7%yHtnSWQu^mbk`g_X#F1?QN!y95@J0
zn`&i_Pri#2hd#*vPFe($<k7)0DV0{xcSCZ$QbvtRq7;Z8n|v=ls9PaZ1{Mr3C$bii
zmT`)-zE5Lww-4Qtr+H}#q`!^Llpo&Uv@r+AB&6+C*{zI1_fVFrvVDUqJxR*JogG^^
zPh~k<I<uT$M-k~F-M4$PUKpdr$<!-4wj3OL<W>1bTf?B?zo12Xj*?^K__*ZuiLBhl
z5T)BL8B>wIEp4C9N_O@C8_AQ<R#r+u2DV6@Va}34aVXvr_anF4y*YN)A#y6)y8A_-
zZ&`;$!{mi*UAC|8mo{Z}r%7J6K0R!>#x>`j)}lM}ESEjAn)5c4o@dUn5|Zye52EhL
z@1t{C&N44DFEQts^S9lbgL#F%LRV1C&TSMcqp7phy!5*1GBqbXOI@Z%VTZs8bD46U
z<Nry~Ql%86ZBthSS*LF_B&d6sDTeiif~=rA5&~?*&j_;PJ}$I$NLfW&KF1AK(Doi5
z@|<Wp<2l;jJ|xhMOJl0Pk<dndyXGvtoxiH_$PWQq?b2tOHzX3af}hbl=>7bH-d=wg
z#pz3e%sUgB;G|Hp+wE*CQuQ8YF2s6AL!MCZA~VJI0kLc8zv=TNbS?jtaaMx_)`-Bt
zM{-*V4kOx*pasCDGJYl3BtHwJ!KKf0V>DgJ`%I0BeaN_<f6wG7bpt9$p*2B18oDyg
z2(*Wj0S!z6Tlim^Y;p#Qg#X{BV|4%0F|$#ss73J#-fML!jv;E~-?Lg3V~CFP-?ttt
z5c{C@OnX_5@vz>hafY3R+Q3p?!FF2HkBlJ%GfN$|2HI7DI36udxgZNpGgE?$W0;GA
zjAgup4MK$=^)pjWC5zT(L=n5pf48vGBDR*}@xc&z#(aK;eFf_NXzBC91$xg*$aW5a
z7r>UDK}pE<O!zs^XmBdTOo6AN_w3h!{vQ9A#lteRlAkZKELD~i(~3P%Vt4aBrG5L;
z9%C85AmKuS^dfWRxoUmHGZth$0fzXz>>q;oE&k`Fml{#+C{CR0rv(JZ{x^95Z$cD6
zBt%MNL{1b$NmNA5w>6t(<2g~9f49tTiO?hm|GTZZg~J42R1%T!c9S_LvqrR&YB)TL
ztWsi}qoazbl9(dWS&FSyQxWN;30KO1iI}s?5LPD@RYldI{IoiXim0-yYzs}DrA3ud
z#fFjjV59|%v}TRWK_l&v98&O%k(v;mWa1am{9AJi`MYNIxHh6-B@rd33+b}Va9kDM
zHe`+c8XZwYlo2f{`j&Kvs-Qw*WQDx2yiHNr7C9Z!Z^}hvUy~4HRQ9s$G98leuNliK
z_C;k8*(5HZXTGQ17?VGxGdCj7ZbffX??|5CLUwxr`z%@IV4o7gk<5^srLKRrh3oh9
zBKCjlMpoQe93IZW)jG(8X4omtKH}wkqjulaSkUer3C@J<p$P_x(}2xzzNvBh*w{21
z9ARAcKe+58p^4fF#y36@s-5t19`6kC1*1DfeS#7hW55}f)XfTVhGm0n*igqYeg-xs
zE(EJHz=fr=uKKX9j++Qx_P{b?eGC^ir7K&u>JLlnf@5LLC^y?O-BR!3TINnUrLgHt
zFrya*{it^utY<u6FBmGwLb(4;g7aeR0Kjm5#%TLgFa(|9LSDb0AuR4hePLs^a?A_M
zpSbK{U6vvmEzol;?lEDh7i`sLjPp$qW-hGE7}U+yBS+Qn6gM+H9b`icvE$l}d0qB^
zj}sj?>my9io)$;j#qJ4;wEqP4h69~C_5vsqa=4ihaP=s|ae|bcnGzISh(Hfn+%<*V
zZZNhl80rqrOpz{huDGEKc^zWkPNoI<lXd#oQQ&8%P)OZ1H_A+hd_mYFM}k2=G?m_u
zMgv5krv=I73GoDA{}e^Oh2R~OlV0|K4HE$5!0GV{64;#o7-~3NX*hj0zU&DkP7-mL
zV=&I_cY*KEQQ$|gdtIg0b0~FQN~KMy3@Mc@rP8HT)|9G5MDo{Ent12y>h*k$Msc-c
zy+A1s&}&-D8-3UM7Ir7da?@RMUwbT0r}Tz5Caz7qHnre*sH<4fRjleN<C1kfWhqR`
zY*)MD-6>^Gd?fbDm34_s?MPW|H|K85C8UXgRcqC?-gw8nX|1>{A$_~|Pe&Ik{$ygl
zIo|br!z`j<xtoUR6j!^}3uN*a=rx`7jq}&eFLW*DFNc1-?Y^!*E?F}dEI8hEzUh2x
zSAu;Qv(>NI>Q`-ztLEKt^&=If&3#j`rY~BQCY#RP*Pl<S&VQO;m>65$zoO|%%DR60
zMGsABOCD1+s!#JByRSc<92`!nhQC_V<UiC@uV|_tQxb4YDlh+L&5fFSd5(nSVXku}
z*SVUzBc9RU+<kZUUaaRra^OO;+na0}xvw8h`us_i|EqO5N`Li59%ZyaQ{bMG@}#yr
z-u2Dybtx3T`eNJfF#=e?xF;M25;ymD?4mxf?&z{oKPYIUx@xEocd5I~(hv9PI~CF&
zDt20+@WbNWT?Xk#207p#S#@1i(vP;&2y4{c3h76?_1(1eN3<O9rH-<XC3KwEIBM*;
zK*!+^zT_dN9u~GQzzC8c$A*E#Uf_ovJIOZyg?Z@@a*SZWRnavEK^C`VO~^Sv!%RD6
z?4P039pqQS9)PP<kc^RM4q%<fJ9=rx2iu81IC_!&KCu6K=^q_0)3xlk0e8}(8V*n4
zOuVJ@z<JJiAzBe7egHMU<8N+zNrUHucsf7H;XMZnmMoQrBm-6;ieF?SGluhX^L$ei
z9TqlD%$!hBMu3W_iT<fN4KYNud}Mo>)ELq7f4sd?tsAGJ`iO3_1W)Rs+^m*P>J7uF
zWE|qvbFi014H3gPYl;;decdc#_Koz%&`F&;4ID<27ctJ#EPY)SF{ZV}@`x#Wl#1tm
zZZuC#ZLxf#wWw(ebtCGInj;W7Tr7lLKprutG0=Y~Vv6L5RQh^XL_b-c?d|3-aG1v=
zv215(>iSt37148s5N^!kNAe>%S>uRhOfpVK^`XjaZKx`XMfBi`{87mSx&mULXnrLB
zo097aG55>Qwm__}QbcmQ;1-S^e4xuo#nL!5oMnqzh;4F5hP>q`RF^G8ELmP?)|wds
z6)3cl!ie>4iWI#g1>fh0&2QW`L<^p$A+|+@d5enTh(2P)X+g{gL1|ib$va9=ZIMw?
z8#GrMvAj)13ZS;^9T_Qmp4kyw)>vF#(L!P;<-|cM$Tm_L+O^sLjk!s-M+(Q)(W2*B
z3-btOdej;zB2^m(NyjB&I5MI|5e>|}T(Pb?OS^7^K`kOqQj?{Ga<hJ%%!7FPwe7jm
z9i$fLd8|0pkgeMs4`}l|MTv9MD#DUz>6V#TO6tP$Ei0?+sk)s{)!D(4T{uGTNJu?t
zh^R<oL`in1DUs3`_^}D9_GAcUnR0WcY|oVUl6~X)EnPkdYWHW<y2ybHck#F^&2#;N
z=z@c!C87Wgt?z6)tcV;Uhe=yRLE1?NiFM)y01Qgzi^xgO)(bPzOXzWJwqbS`Ir6*#
zfBv{_%u@&~Vd5M`Bgrw*R2fVtEzZ?gbaS$nPwn{sQm@=p|BeI{tDji}<>0I1k@BZH
zc_P!vVX@!i(sU1D7i!FUVh=@AAxyZ$Z?ZXyZT^B<2`uiu?Ba&Nx*z|$CE>4E|A7<p
z;Ag(ACS;dLXcu4aY>s6v0SuQhpD4}BZMiNmXG84_XZ~eypLlU#{eNK<R0GA)mx22%
zbP9I8MEc?ZTEZM0zhF9bafA+}%diQYBm=hxvs+=r0jW!W)bX+dQkSMI&m>-mJ@bLd
zN1~31W3u&`3MgihmZ8ZuJXPeU$nfnKa1}OGJk{>$NJWP8jF{d$#|pl$W(R$i57!7W
zF|-t;$Z$nN{l0qFo;~&TwR;=uUAyZ6X#z?EQg%1jyY|=Dr>{z0Xd67z)^}>?30?by
zc8PJhnEU&Zkcj%0HP58SK%`9Y_Z!TUZ&DFRka3F~qMVXgpD6epJkZ|;+Li<TiRz%=
z8yF$p)^HVMB^;&}nCow3<U0?-LGSf*t$?H%4?;M=VIp>wx;t?9(g&xmQY<FxP6^Ay
zkDz3kSqAPi#H=JNd2#lMgFY9|Imdw-rlqdY6_y0gg*7kMyJpXE(|%v5<q3U&59}z9
zu{S{;a;Pit=Ys?a?kMo8Vl)_-_Cp3Ds|$Fi!?Jpp_fS|>H|?AAj0Hl1^2*F?Q)B(K
zkc;<AZNr^M`aSJOP7Su5>JnrP&Gi?@%f9~Wf#uRihce;SZx4m#b)&9Xm!S0fM&=ru
zo5ISvX_nz)ObFT-Wyhd?1ncRGVGXo72UlARl%X&(GsgMCVgWL_QBP<B<R*fC!j_=v
zsMqTfq+ai+sKe_D=hlHMM;Q;?et5=MZvc`$Gcz~My2e9Hb*Od<Jw3{hnkTfA|N9-|
zXY?F1?x~#hRMzhyJ3}0JA>ifE3)6nj6o|83qL08DX)UNX)XjR?Op572_o!woXLkm6
z&+LQYSO8Y`O#prD03WC=G-8k`jujh6tbt#s-4k<&mo97pPy_`d29$z4aFO^}F(70y
z#)E`xVkYGC3ko&>=`6!8iNtXRE`(;qEKN*%#MF!ZPpDhW#BfIv6y9mLsmfeWDL64>
z6l8t~T-hkppB7}3LEn@hPhWpsKoK=FH3MA*w+mVi4l7(4dWO1Au<t@Gn?UeB0t`CY
zKS3a7aW5c-XQgu+`yqd^uAKfe{u_1MVlvF}1v$r#dM3nGC>RMd=AH3}Jm5W_cPhjQ
z+AIdEU{+9NOY9=36J(GBhS*z(N=G0yq$dP=M4)E{dP<;ukiOzH_Jq9SoS+k@IbN^9
zpmBm8kl2<<%>HLoq7$zVJR?51x`aMTJQIRq#B*_EniG_n`6ehcb4^g<2*c2BrmNgG
zP_mJR{vITqp*r%PyRumwEMx^P=5;x*+DYJkx%^YixQbUa#rHL(DU<Ds!!k;3nfHC7
zvVRek^4E9nlYgP0%ohIRoxQQo3?&Pbs|IIWwq`WVcP<p%=vy^b#O0V0ninpv*lJeI
zJL2kf1y$TeCshS&kd$7zaV1fjY-n4xwm-D?u2_3ltw-b9R84JMm8x!fSnXP=b}jE-
ztv>X?d?L|sx8dWxAME{T|NOws(>G54(b;?E6OSpax;oyOGUUY;wq1**j0Guc(arFU
zaH1k{Y1QgX=em#t>uhUg>w=W;ou@YtFvXZV-}c(<Lhge1Eei@8jPqTuhXK23xM4`-
zCfX8;PmERTHfZHhF=Z@RvlTB4B`V)8Tili`*p;-_$9q3B*}k=HabN5~SyRIMK7FsO
zX|-_AU$rKOPTx13iL2JMhI!TNC*m};W+_0!|04g+rKN%gC9cJ`ge1`bmJYn-yI0~`
z%|8&&Svx+E931*t?}LKjyO$Ok7rfA1&f>m1ZQnU?=hAmtlQpho$MV2($1;1*)}AaF
zj_UxVinb?WmlC6kHH*b}29mbD%N2i9{a4j@TUK2IE4G2S9@^IBr?iDBtu>`JrL;!)
zhlb_6-k;KzK*hQ#r!Xfj{i1-%v(8`Q3m#Ka@M~KNc)Axxz!B0!<HFITscJ=A74HxX
z1u3IxL6J}-tyL?=svFXEWj+Yt6@qp?XW>ZFuzf|fJudx>H}0~<*2=0E3s%b-A5&&^
zFMX{)-gYfAFPZONv)C54Cz{@@TeVcjd(x%dZ`Q6_s^UG+aw^ZdK+kjYnv~Hd{(}*M
zf2K{k$u?iTP(H6s<&~hLlE(6ssc_!8&@ivtLW*tBjAbCcUScroA5jLKKHl-z4tD_9
zmC6LYz%6JJ!;8$FwmZ8Qk1dxZtvxHo9_X4AtzNH%t|g5X$*Kd(z00n<1Ifysq@j03
z)f<<7s?vxq%@y5iPHF8aE#L(yts|waSc`!ZmC3@I6=Th+c8BQif_0nDnDdCzsln-w
zN-1rA%3`}Yabx0p@@4N|s~(iK-DyZT5(9~j1h?3*Sn<C8URm3!rTtpZr)j>ws9dI(
zsvndcSR6?6y|21gc3{<V5Im>SfFlxnZ+F~LF4wHocQ&rpb|nqnE2{3ebX}%YU#8b`
zOCC|Qu8UqX7T(m~&@XU{+m=J07(4$(iq!Qy{@wcCo-ZGtl~VbA^l!h=Q|3~*Dbd*k
zV*%WM=xqP`*i6~?eEC>Kl^*y~C>Z|o@yj%2Z>PWfhq43zq7rq8`oH?jVCVn2{%f)S
z2|LsWMY+Ru)Cc=I&G7RhZT_H3_9I6g!X`UVKF+rc9+G^#!-)97CV)S#R}UGqKi=O6
z_)m7|hRmv;>_gd~YHdR{*-tCmG*I|iL%SY+eonQS;O7@6!%(T}7Y<aIlxT-4R7ri&
za9xZ_)+mOWsARous9L(BRsp_}TMbP2<W7VxIl@EgA+3B>B?Wv{LnE#&M!Z@+)Sz6g
zQ-aiLlX|#Dy4s>YrIFs(SOC9Y-X<Halzvhvhr%Z{DEvvCZrCMdAK~7f<K;MJ>BkLr
zNhPK%Vf~S*S+Czm>~N0Red(K6)(JIi4T2rKuBlz~Dx&`mK|SwosyizlY<QBf80?E@
zGm9ZDD?YE_vC8g6kba*6%qbUJXZ5h3!*ftD7-BI@PCs%%BA7ld;GOEzrV_acnBH2F
z>?xz^_9aJi1^n>cdmEeaf|Qj35L6JVj0fPB8g7!zz%9O*335CJIrcbkY`I9{zq{8e
zhyU4vTH=4Ym%!84u6;?m6>lrV2+*m_oR5Cr6vL%sg(Fz`-w~jkcx1Ex3`KajDivGf
z+gxQO*s!2xnaiv%1aSrjNmRNU;)7e%RVv>O9DmIxT>p{o=l33{EoYO!(hWDx(w?qU
zf~>czty56;pFDM>zi$Y7QbY4!JMi@qb`@L3kTrci!o9TD50Ts+(DqBd{GbK;u<zhM
z(8`aH#Yyw!t>zd8kAifD^$T)%KMQb91A7*$cO&=}f?p$toE`TEN1hoR)`j)r&|O1J
z?D=bmy^bIs09bbz@%`9+j5*jF05-jxdAq}?Df3cx062fe|E%?UU~T-+_vm7rPGR{j
zh~9UFHM_)1`*a`(6O+Htw!KBP7vEULlb^i+n4p435XOVuQm_z^`KHs>DALxnpfw+&
z#3TO0wry6-mjn&O$}kbcJb~>3j<5LNwavl^%(Pc3cc4Tqz4Tr?FOk&Jd~;Vv3~z|o
zUIgL{pF}Jje<Jo@0XU`Uao^;`Y(`9Zz9VHfs6vkTNGLu)I&;(h$GI#%Mhc1m6PgGT
zcGIyJP>G2_xUo>g7h;@MUg8noPH+yf-#{LWMp+AjR{%J3Hdj>I8{+a9#d@3!=^nKs
z_7(vCe7B`o^p62jpV@R4g<C<09fB52lBN0XlQJdyKTu$j|NQ9Qv|q&eE;^?d*uW8I
z(4Hd*jv=T;a2&x=1Sb$|IEU?nVpuV9CB$&{Cv=^-r9j{>vYv*z&wmchIgM#oi9^5X
zotWqtvFRQ(Y8HVJfeC@=^__^F#5OM=w&@%ldkU$Ckt+H{bcyI3eBKrmFhe+acWOZf
zYy)1df`LGA$^(myKxE8{=`=edGQ*qoIK1rZpkUwnrPrq>?a=fC@p))=zhvp`@%@sR
zV1D69XIDRD27@nj4SG)Z4<73p910u7=O>RS#kwH-aLNSPL=fJfW%ynNGoA4Vy+lx6
z4zd@)6esPYC?h1tzBAxi=LPmW8oh+Th@JdL#Kg=4pLN*(06@^flHnis^|oNP&7$F~
z9_eb#2)zVe57}WXE5{&v^G^F%1G0$T%|#6E_`uKnx&D$E+;74gSB7sV<df6EDGqi@
z+!oRvZvra>l}CKD_jtsEKy)zd&w{GGZK%uBd1NrX6Mc?C7Z9ZLIT92zG#gUBjR3bI
zL5V3f{to~b;oT4>8djV_;J{ibrXW*T#5_Y#4>6E^OaxhmT}PrgjrtI?qIbkyMVw0F
z1bP8!uVC%h5&R*7?;`j<f*&Bjyn_|jE$;p*R$PI*Y2JG>KUM=2!Qk<Dr{Mk4i_do)
z^!O-<33@Lfo`8=KKXVzjANHS6mpF5A<7RO`6t^Qm4gU79@O;RKOOM4VgYLuh+2awE
zGqb+YAUnk}C^3d$9Ki&D9b$6nqy;+2L6NE#XCPdX1cGG7&$O~H0~IScr<^YysLJVm
zNcFBzy?;j;`JRCv9)1KFhH1Xx#^{1G{VbN~yVJ2+xbI<M>q=qkYT@B~g*|sWRxQ1&
zh9g(CDT5<^<)Oi`VsIo5t{UpEYI)7z-<GfIo9S+P!Msl4Z(<vSgdK^w_jdk9EI(pt
z{#S!LEfTssLDs1O_+8|FBmS;W$d+n`1|+e+)#uJT=N&hlH=N1hMzA1n-^0AtmAux~
zyu<hM&;ot$)t+A}A!;_ol_{CwYR|tv_R6uO(XnX0(|OmD960kpc6L3Vk`?}T-J3_L
zav>U|)q+d~(IBn<*T*3pl|M*xrQnGlwC45~Qa{n=_ivZ|#E}Q^7n(wOe}(iH4jSP9
E0Y+=RcmMzZ

delta 5405
zcmZ`-d2pM@b^rFmMdBdA0|3Dj6i@KJL{T(vQ4&c>JS0k%;G__UU6P;x0$O~eB$hJO
zL}~4*Gm^4N$1`pkw>g?rYDQE1(@vd<oq8h0nRKlBi25~?NzzQGZaoQV>5q)k>%9d*
zQMQ8NzWwdnw{LgfzJ2>X-g}?Cdz0k-(BZHu@Uu)Dj{L{)jl2@|b@PqJi>HV}6-uH-
zfg-3)(c+jZ;EK5e?wBXwiIoIOV%~sP%9x|2v9ds!#Fl7ztRhems|-{^J10=3D$K!r
zHwn(5C@Tj9sVHq)8P7C#(?AWYp}8A2MG4g6ASh&IN=y@vp`O)<Wl}}t;M0MITwIww
z+8FZ({6qmkKMZx?(Cj=gcOK1ORs+q@tFD~hJy8ZzXI3`Qx;@n+nBvp8K07U1CxP~D
z_J~@s)j?gXp1PT1(MUa4je$;D!b+fB!0NrA54c|7c5QRJp<N2?9$Lm6AXN|Ta%k_R
z6`-Y(^~#Zjte5pJsyJTiFw-iK*+);wQ9h8WhO!5xw^%;wqlA)0gA}#WnyaS3{$1*8
zVQBxZb{({zq0iEKSU>}+fU#!U2%`oh58FoS2dP2Yw6n-&Xb;gASY+$=cFnX6c%fn1
z4vY@TtOrG%z#O4nPw={dHwrd$v8r1=JH{Q$Sn(+bu$T7UR5Sb)Y4+2B1MC3pJ=drx
z+)jI!NMM{fGX`b{>AnGwT^(WvRzCj}WqsKR$CYbJSY3kh=^913tZXV7<vB_6QgOB+
z>?YfRaW=Mc?USll8LW7Mjb|0o{Ywh%{|kZ(y7kOWQ)UEFV6+gg8p~(lFuNC3I(XH1
zb6Z<r3OhfknhxzK&A3kmoWby}aYv-mfT?^7*5IL|bnMoFtc@0l^saGv1{H7y2d|oT
zCOirQUwO)ehv;ECv83Lb%xc*=+{^;Ji#c>^*8--u^=y4i7d`R`MMq&FStVwAY?qQ5
zHcO}FDXz!}G8dTpolY=AXR}KS90#f1jO6sk=7%PoqsOzNSu+Ms{7%IuXkk`5;{XA9
zspnz9+{#})Mg2TG&Q7rTTPJTCGrdH)L@tpUg*DYG+(?u&%60XnFI-SA8qO#eNLVG{
zW0#c+ivP4wa|Yc;J@+tMWjv(Cxt=qr0a}Q%)M8EpNqsf<yDD*ru>B12iSO8hru{HQ
zL#o<wO;tZ2;&1ZzkZ$o_zOSPn_&PbS8$)Z_a?$`TpU=npkee4|7d0LVYe6l3j;-=Z
zV2-5foP{c>7k!26He_%Ik}C0cg@aNT$4kTa0eMoHBgonLwFqZHoQThZz_C<)(H0>d
z@r~jxa~BTl7C$ZCLrx0fDkpuS(&aUs1$IyjxQ>vi)C(@B!Ca4WBjV3W`pt(BI>b*)
zJmwI>1@YUGffBiNdoU5=NfzXx)g{KyL+^5G##>KpQz#fml1N=C?Iisph%qSmO}a6j
zV5_<@$=EsF$XST;73k0nQMT&0@RKN+8H$LD|17I>%h{~K2pB)O7>P2z34Pa7_2n;<
z{%29_G?GsNN#Y@cZMThE5L}KXgW>q9##X_=mlBL$0f9e7$)jS_RVIom_nL9JVIuzA
zRh(L=EGOo6X!BNawQ9Nom!lgvi|T4p(+%g?rCl?KUsrid7;3&DY`*hGRFfKRyrYuO
z3QKd74~@741%7W2`}1_87Kt%kjVJjUu=sOguDOl8Ag(l*7vu5jreu_{gx|=oWA_bl
zySdaWckT#=!kJTz#>40MSD^c^Q~%ohJn7PN4_*wjgcgaf`iUHu#20yc_vj5#7J?I!
z<GuzxuZz#Oe#&M6giiS2qDfqtFG<<khE?(9j!J`r=7~gK-BvEd#{3(EI-wLmDTGo4
zrT7NXJTOrHHg}$7=y5@DZ`U5EOQ3k6l-?klIZ&5DZGpNRN(GckXy-y*1;q!Y8ro*4
z_duyR3ZxcF9hCYfrZmxp-TA=B`pA=gm#w*q<`r8_<<?CrRjGQb@uops@BMwaS)&z2
zuE#quWh0N~5k32Q$7&R<JiASZ5=ED7T2;19{j}*;b2bQV+CHPwmdm#1Z5N1El9gHU
ziF*Yu%j9L-rfp@9_+Ov5taYU>+xxhtZM6MX2b#Ro{=^KOoA!$&39*QFy`p?secF8D
z`+dz2UOwv6y?VjK(G$VZljD;!!LiBt<D>Hjbz^65$2sv~e|4j7Vw}hMhT3`wN@T;>
z8Ve;hOdb8}{T&;|j{eXvu)_W8V)GfV6H!PvghF9pF7$_lZD6UvmSju8x{kfHO-uS!
z-4tGC;d6RkIF!)VAlAg!w8WamkBYYjN(<2Ir@4#(p9RR9#lwNUImI0B33rLk!J<}l
zV2<9Xo0H3HS|qBQc}(Ms@h?i|5`*iy&Sm6zPK?yK#6n#W#M$*apJNWkHUsfH_}9h%
z4OWxuqI#&d)Dc>vk$7++0<lzMx*;5+GCuM<;#YNUh;zfkWwv`T?k<!hH3&9LeZ*A#
zGn?zjw(@(n@^@{O_lvv_M^q)(eLeDCj_=`RB0d=IGyJm1CF(~e$WO%9n0G5}tj@RI
zw-=`kQ2)$cnl?e5HY<*jv;|R);wVn%BC;xug0u~h9gzdj!#u^|yl(yDnRGt#or<F<
zU4W<%M-?F|MxG0i8<7W52_i3|(k;c|PM0ApM^u5R61%Gq`4Ckj+5;1%YY^2UuMSbY
z;wVfvAZkROA5oLyC`~sbYQaUeB5Fgqc0?VxtxiN;io=!euFl`Grh61eb$Tx{dr@#7
zqCUmpP47q4uQ+Pb&mbC59JT2|Ko5s-*Or%C?>QUZu{WlNkvBpz%$9r3`giON=}`jQ
z7Yyk`#GHG9{KW3QHvQuC%iXWizwLR?J_4q)7hM~AaY#&$kD7n;uu5@Oi}%MrGmC!q
zMp?mBi}FU__<pFq-&Hcvt=zFT0=_fk2YR<Vcgk<LJCHYNHT=Np2K)oxsBx;+@K&t}
z8gKaxAoNy?V`{&F-%TAm<X7wbpmif}a&<ivjZh!lEnkFkbZic}r^0KI)QMLn#%!2S
z@#m2=iGQDHJtN;~bWh%b#D$~{iF{K!5OpHSJj8(fCXOD-{|N{@hw-?^_hMVV?U<C}
zV+QeDtWH*#ehlsM)b+_KLIzT|r)r=Q?;hzoj;|EQmru`G<e{Y)Ja+Jm+(+&Ja!v3~
zYe{|>@UG_zdkTUVBHD5$^$4C{WBd~TIq>(2(?=;J1K&CNHW?cM24_J07TuamL?c=>
zvdWT~`#BDL-5g55n@;6Wc{z3CN<4zk`7dznfcW8bm3m(hA5NFTO|;BZnmz>nplF);
z6EY><m}#kcL|P8{4Z7j*!Fk;{ad328x6I7WPtHuAfQ_UTkvIFf(r+o5up-|?^D+xX
zA;tM0P!txoXWg*cJF~wamcPUqf31ky$BVZX0PBV|9@R~dJH(Rye3=sQR+RZJcAArM
zt}&{c_);{!@UgSuJt!wn?kb{xL-IK!e~6?I2&@isJ5J!))k%WC1dSaNdomfGH5y53
z!5E{F5I2F`vN&_%HCV2D{xwpLzO-R#hcu;q!`2>IrR-u`tb47`56&olb+UdCb2yH9
zCCBK+p97-jEa0P#`!e&S#v_T$TFjZXSYQtRbrilU=1$dmq`hnj&cF*8CPX|RBrc1W
zPOXFW4bRqDK0@IKN~--?p{frQ@#dKWTMfuNfJC}Co<Gk7bVRQKfhEf0eJqI?9v=bn
zEd$@->Q=dRnSJ>SG6#T;EHg3P9AnyYobEC!?vOj>#oD<gGAq_|F<T63m@lLM@E4F=
zL{fxg6NumX_&Q~*A@9cTVLy69W=HZ;7*UaKq#-Sov_co&v&;{V&8z77NygWu!GfV=
zl4%_N^`U%;q$-}9HRgiH$gGzMEx0dZENKjBu|g08>(t^w6d`dTd4Th~5fvlxAlb1P
zFM;NUdEt`AlD<czRR$Tqnh~vmz7PHphWniv`$>Oz?1@`vQMH_U4AFTcG88!x$)kX;
zZ-tlQoYKILE#}}=$dzs^jV0|QEf#_?x>+Xq+pj6k0S|vX7K^V2;R;g5lRR!h-3jsS
zvz3_-1IQQ9av7Iz0_}fKQolUAUp>9yT#rx|56XVt4`Bl?y>U4XxwSC?Hxc}qMdKmr
zClN()Do~vU3;9p+GdKfg2mD<muOs;fB=|YbUld;q&(_QW)Gdplq!vm<xE(vB4e}7>
zBXNpqT0siLF!hw;?albjZvp8!LHT774DvRSfd9<M5b-^fk>+xtjG4w|V&X>jSCRA}
z+XCiD;8)2avJN4cK~jZ8o|OEA`xk7^BRPu%Hn@FId(iyoyz)k55~Z!LVEb!G<h7R<
z=I7Xyp8p7t?hMCyG8pHPrO0YBh#6BF+4;d>XmvHNh48B&2^%_y+`JH_!B~XSD7ye*
zKsRDg;?i3%gv!7q<AR<G)(hG>By~)BJiKh*W}f{WxXMl>T}a-9L4Kl>xcuPgkdf|D
z&Oj_q*P?8Q9|9TpQ<B0c42uoMeeWpyM9<=zqHpP+)&I&9UCV85LaJY-X=M)TZzdne
zI=!r>)|cnhGxv@8R}TNtkv}-{wsX%ni*Jv=?tb4mk#;D?(%+<)@|2u{j}$_3bz@H2
t0QG-=w2`a0j+101O!>W@f@As0ole)WGUHuKA<!S?n~s$je&iuQ{~u(0{E7eo

diff --git a/video_server.py b/video_server.py
index db990af..96309ae 100644
--- a/video_server.py
+++ b/video_server.py
@@ -7,7 +7,8 @@ import time
 import hashlib
 from urllib.parse import parse_qsl, urlencode, urlsplit, urlunsplit
 from pathlib import Path
-from typing import Generator, Iterable, Optional, Tuple
+from typing import Any, Dict, Generator, Iterable, List, Optional, Tuple
+import threading
 
 import jwt
 from fastapi import FastAPI, HTTPException, Query, Request, Response
@@ -35,6 +36,10 @@ RANGE_RE = re.compile(r"^bytes=(\d*)-(\d*)$")
 AUTH_REQUIRED = os.getenv("VIDEO_AUTH_REQUIRED", "1").strip() not in {"0", "false", "False", "no", "NO"}
 JWT_SECRET = os.getenv("JWT_SECRET")
 
+# Limit concurrent ffmpeg transcodes (HLS generation) to avoid CPU overload.
+HLS_MAX_JOBS = max(1, int(os.getenv("HLS_MAX_JOBS", "2").strip() or "2"))
+_HLS_JOB_SEM = threading.Semaphore(HLS_MAX_JOBS)
+
 
 def _safe_resolve_media_path(rel_path: str) -> Path:
     """
@@ -170,6 +175,63 @@ def _hls_id_for_media(path: Path) -> str:
     return hashlib.sha1(key).hexdigest()
 
 
+def _probe_streams(path: Path) -> Dict[str, Any]:
+    """
+    Returns basic info about the input using ffprobe: {width,height,has_audio}.
+    """
+    cmd = [
+        "ffprobe",
+        "-v",
+        "error",
+        "-select_streams",
+        "v:0",
+        "-show_entries",
+        "stream=width,height",
+        "-of",
+        "csv=p=0:s=x",
+        str(path),
+    ]
+    try:
+        p = subprocess.run(cmd, check=True, capture_output=True, text=True)
+        wh = (p.stdout or "").strip()
+    except FileNotFoundError as exc:
+        raise HTTPException(status_code=500, detail="ffprobe not installed") from exc
+    except subprocess.CalledProcessError as exc:
+        stderr = (exc.stderr or "").strip()
+        raise HTTPException(status_code=500, detail=f"ffprobe failed: {stderr or 'ffprobe error'}") from exc
+
+    width = height = None
+    if "x" in wh:
+        try:
+            w_s, h_s = wh.split("x", 1)
+            width, height = int(w_s), int(h_s)
+        except Exception:
+            width = height = None
+
+    cmd_a = [
+        "ffprobe",
+        "-v",
+        "error",
+        "-select_streams",
+        "a:0",
+        "-show_entries",
+        "stream=index",
+        "-of",
+        "csv=p=0",
+        str(path),
+    ]
+    try:
+        pa = subprocess.run(cmd_a, check=False, capture_output=True, text=True)
+        has_audio = bool((pa.stdout or "").strip())
+    except FileNotFoundError as exc:
+        raise HTTPException(status_code=500, detail="ffprobe not installed") from exc
+
+    if not width or not height:
+        raise HTTPException(status_code=415, detail="Unsupported media: missing video stream")
+
+    return {"width": width, "height": height, "has_audio": has_audio}
+
+
 def _acquire_lock(lock_path: Path, timeout_s: int = 600) -> None:
     """
     Simple file lock to avoid concurrent transcodes for the same id.
@@ -221,12 +283,45 @@ def _ensure_hls_for_media(media_path: Path) -> str:
             shutil.rmtree(tmp_dir, ignore_errors=True)
         tmp_dir.mkdir(parents=True, exist_ok=True)
 
+        # Multi-rendition adaptive HLS (master + variants).
         hls_time = os.getenv("HLS_TIME", "6").strip()
         crf = os.getenv("HLS_CRF", "23").strip()
         preset = os.getenv("HLS_PRESET", "veryfast").strip()
-        audio_bitrate = os.getenv("HLS_AUDIO_BITRATE", "160k").strip()
 
-        cmd = [
+        info = _probe_streams(media_path)
+        src_h = int(info["height"])
+        has_audio = bool(info["has_audio"])
+
+        # Variant syntax: "height:video_kbps,height:video_kbps,..."
+        default_variants = "1080:5500,720:3000,480:1500,360:900"
+        variants_env = os.getenv("HLS_VARIANTS", default_variants).strip()
+        variants: List[Tuple[int, int]] = []
+        for part in [p.strip() for p in variants_env.split(",") if p.strip()]:
+            if ":" not in part:
+                continue
+            h_s, b_s = part.split(":", 1)
+            try:
+                h = int(h_s)
+                b = int(b_s)
+            except ValueError:
+                continue
+            if h <= 0 or b <= 0:
+                continue
+            if h <= src_h:
+                variants.append((h, b))
+
+        if not variants:
+            variants = [(min(720, src_h), 3000)]
+
+        variants = sorted(list({v for v in variants}), key=lambda x: x[0], reverse=True)
+        n = len(variants)
+
+        # Build filter_complex split+scale for N renditions
+        split_tags = "".join([f"[v{i}]" for i in range(n)])
+        scale_filters = [f"[v{i}]scale=-2:{variants[i][0]}[v{i}o]" for i in range(n)]
+        filter_complex = f"[0:v]split={n}{split_tags};" + ";".join(scale_filters)
+
+        cmd: List[str] = [
             "ffmpeg",
             "-hide_banner",
             "-loglevel",
@@ -234,20 +329,43 @@ def _ensure_hls_for_media(media_path: Path) -> str:
             "-y",
             "-i",
             str(media_path),
-            "-map",
-            "0:v:0",
-            "-map",
-            "0:a?",
-            "-c:v",
-            "libx264",
-            "-preset",
-            preset,
-            "-crf",
-            crf,
-            "-c:a",
-            "aac",
-            "-b:a",
-            audio_bitrate,
+            "-filter_complex",
+            filter_complex,
+        ]
+
+        for i in range(n):
+            cmd += ["-map", f"[v{i}o]"]
+            if has_audio:
+                cmd += ["-map", "0:a?"]
+
+        cmd += ["-pix_fmt", "yuv420p"]
+
+        audio_bitrate = os.getenv("HLS_AUDIO_BITRATE", "160k").strip()
+        for i, (_h, b_kbps) in enumerate(variants):
+            maxrate = int(b_kbps * 1.07)
+            bufsize = int(b_kbps * 1.5)
+            cmd += [
+                f"-c:v:{i}",
+                "libx264",
+                "-preset",
+                preset,
+                "-crf",
+                crf,
+                f"-b:v:{i}",
+                f"{b_kbps}k",
+                f"-maxrate:v:{i}",
+                f"{maxrate}k",
+                f"-bufsize:v:{i}",
+                f"{bufsize}k",
+                "-sc_threshold",
+                "0",
+            ]
+            if has_audio:
+                cmd += [f"-c:a:{i}", "aac", f"-b:a:{i}", audio_bitrate]
+
+        cmd += ["-force_key_frames", f"expr:gte(t,n_forced*{hls_time})"]
+
+        cmd += [
             "-f",
             "hls",
             "-hls_time",
@@ -257,12 +375,20 @@ def _ensure_hls_for_media(media_path: Path) -> str:
             "-hls_flags",
             "independent_segments",
             "-hls_segment_filename",
-            str(tmp_dir / "seg_%05d.ts"),
-            str(tmp_dir / "index.m3u8"),
+            str(tmp_dir / "seg_%v_%05d.ts"),
+            "-master_pl_name",
+            "index.m3u8",
         ]
 
+        if has_audio:
+            var_map = " ".join([f"v:{i},a:{i}" for i in range(n)])
+        else:
+            var_map = " ".join([f"v:{i}" for i in range(n)])
+        cmd += ["-var_stream_map", var_map, str(tmp_dir / "v%v.m3u8")]
+
         try:
-            subprocess.run(cmd, check=True, capture_output=True)
+            with _HLS_JOB_SEM:
+                subprocess.run(cmd, check=True, capture_output=True)
         except FileNotFoundError as exc:
             raise HTTPException(status_code=500, detail="ffmpeg not installed") from exc
         except subprocess.CalledProcessError as exc:
@@ -497,5 +623,9 @@ if __name__ == "__main__":
     host = os.getenv("VIDEO_SERVER_HOST", "0.0.0.0")
     port = int(os.getenv("VIDEO_SERVER_PORT", "8001"))
     reload = os.getenv("VIDEO_SERVER_RELOAD", "1").strip() not in {"0", "false", "False", "no", "NO"}
-    uvicorn.run("video_server:app", host=host, port=port, reload=reload)
+    workers = int(os.getenv("VIDEO_SERVER_WORKERS", "1").strip() or "1")
+    # Uvicorn ignores/limits workers when reload=True.
+    if reload:
+        workers = 1
+    uvicorn.run("video_server:app", host=host, port=port, reload=reload, workers=workers)