| @@ -31,12 +31,13 @@ audio(void *aux) · 30 unmodified lines |
| 31 | | 31 | |
| 32 | a = aux; | 32 | a = aux; |
| 33 | memset(&af, 0, sizeof(af)); | 33 | memset(&af, 0, sizeof(af)); |
| | 34 | af.ns₀ = Zns₀; |
| 34 | for(;;){ | 35 | for(;;){ |
| 35 | if(adtsread(a, &af) != 0) | 36 | if(adtsread(a, &af) != 0) |
| 36 | goto err; | 37 | goto err; |
| 37 | if(af.sz == 0) /* eof */ | 38 | if(af.sz == 0) /* eof */ |
| 38 | break; | 39 | break; |
| 39 | ms = ((af.ns₀ ? af.ns₀-ns₀ : 0) + af.ns)/1000000ULL; | 40 | ms = ((af.ns₀ != Zns₀ ? af.ns₀-ns₀ : 0) + af.ns)/1000000ULL; |
| 40 | | 41 | |
| 41 | if(rtmpdata(r, sid, ms, Taudio, af.buf, af.sz) != 0){ | 42 | if(rtmpdata(r, sid, ms, Taudio, af.buf, af.sz) != 0){ |
| 42 | err: | 43 | err: |
| @@ -102,7 +103,7 @@ threadmain(int argc, char **argv) · 59 unmodified lines |
| 102 | sysfatal("%r"); | 103 | sysfatal("%r"); |
| 103 | if(vf.sz == 0) | 104 | if(vf.sz == 0) |
| 104 | break; | 105 | break; |
| 105 | ms = ((ivf.ns₀ ? ivf.ns₀-ns₀ : 0) + vf.ns)/1000000ULL; | 106 | ms = ((ivf.ns₀ != Zns₀ ? ivf.ns₀-ns₀ : 0) + vf.ns)/1000000ULL; |
| 106 | if(rtmpdata(r, sid, ms, Tvideo, vf.buf, vf.sz) != 0){ | 107 | if(rtmpdata(r, sid, ms, Tvideo, vf.buf, vf.sz) != 0){ |
| 107 | fprint(2, "%r\n"); | 108 | fprint(2, "%r\n"); |
| 108 | break; | 109 | break; |