1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727 1728 1729 1730 1731 1732 1733 1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756 1757 1758 1759 1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 1795 1796 1797 1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 1919 1920 1921 1922 1923 1924 1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 1943 1944 1945 1946 1947 1948 1949 1950 1951 1952 1953 1954 1955 1956 1957 1958 1959 1960 1961 1962 1963 1964 1965 1966 1967 1968 1969 1970 1971 1972 1973 1974 1975 1976 1977 1978 1979 1980 1981 1982 1983 1984 1985 1986 1987 1988 1989 1990 1991 1992 1993 1994 1995 1996 1997 1998 1999 2000 2001 2002 2003 2004 2005 2006 2007 2008 2009 2010 2011 2012 2013 2014 2015 2016 2017 2018 2019 2020 2021 2022 2023 2024 2025 2026 2027 2028 2029 2030 2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049 2050 2051 2052 2053 2054 2055 2056 2057 2058 2059 2060 2061 2062 2063 2064 2065 2066 2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077 2078 2079 2080 2081 2082 2083 2084 2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095 2096 2097 2098 2099 2100 2101 2102 2103 2104 2105 2106 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118 2119 2120 2121 2122 2123 2124 2125 2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 2139 2140 2141 2142 2143 2144 2145 2146 2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176 2177 2178 2179 2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200 2201 2202 2203 2204 2205 2206 2207 2208 2209 2210 2211 2212 2213 2214 2215 2216 2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314 2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363 2364 2365 2366 2367 2368 2369 2370 2371 2372 2373 2374 2375 2376 2377 2378 2379 2380 2381 2382 2383 2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394 2395 2396 2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408 2409 2410 2411 2412 2413 2414 2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428 2429 2430 2431 2432 2433 2434 2435 2436 2437 2438 2439 2440 2441 2442 2443 2444 2445 2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458 2459 2460 2461 2462 2463 2464 2465 2466 2467 2468 2469 2470 2471 2472 2473 2474 2475 2476 2477 2478 2479 2480 2481 2482 2483 2484 2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495 2496 2497 2498 2499 2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521 2522 2523 2524 2525 2526 2527 2528 2529 2530 2531 2532 2533 2534 2535 2536 2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553 2554 2555 2556 2557 2558 2559 2560 2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576 2577 2578 2579 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590 2591 2592 2593 2594 2595 2596 2597 2598 2599 2600 2601 2602 2603 2604 2605 2606 2607 2608 2609 2610 2611 2612 2613 2614 2615 2616 2617 2618 2619 2620 2621 2622 2623 2624 2625 2626 2627 2628 2629 2630 2631 2632 2633 2634 2635 2636 2637 2638 2639 2640 2641 2642 2643 2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663 2664 2665 2666 2667 2668 2669 2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 2690 2691 2692 2693 2694 2695 2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733 2734 2735 2736 2737 2738 2739 2740 2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772 2773 2774 2775 2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786 2787 2788 2789 2790 2791 2792 2793 2794 2795 2796 2797 2798 2799 2800 2801 2802 2803 2804 2805 2806 2807 2808 2809 2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822 2823 2824 2825 2826 2827 2828 2829 2830 2831 2832 2833 2834 2835 2836 2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847 2848 2849 2850 2851 2852 2853 2854 2855 2856 2857 2858 2859 2860 2861 2862 2863 2864 2865 2866 2867 2868 2869 2870 2871 2872 2873 2874 2875 2876 2877 2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888 2889 2890 2891 2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930 2931 2932 2933 2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951 2952 2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968 2969 2970 2971 2972 2973 2974 2975 2976 2977 2978 2979 2980 2981 2982 2983 2984 2985 2986 2987 2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998 2999 3000 3001 3002 3003 3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 3014 3015 3016 3017 3018 3019 3020 3021 3022 3023 3024 3025 3026 3027 3028 3029 3030 3031 3032 3033 3034 3035 3036 3037 3038 3039 3040 3041 3042 3043 3044 3045 3046 3047 3048 3049 3050 3051 3052 3053 3054 3055 3056 3057 3058 3059 3060 3061 3062 3063 3064 3065 3066 3067 3068 3069 3070 3071 3072 3073 3074 3075 3076 3077 3078 3079 3080 3081 3082 3083 3084 3085 3086 3087 3088 3089 3090 3091 3092 3093 3094 3095 3096 3097 3098 3099 3100 3101 3102 3103 3104 3105 3106 3107 3108 3109 3110 3111 3112 3113 3114 3115 3116 3117 3118 3119 3120 3121 3122 3123 3124 3125 3126 3127 3128 3129 3130 3131 3132 3133 3134 3135 3136 3137 3138 3139 3140 3141 3142 3143 3144 3145 3146 3147 3148 3149 3150 3151 3152 3153 3154 3155 3156 3157 3158 3159 3160 3161 3162 3163 3164 3165 3166 3167 3168 3169 3170 3171 3172 3173 3174 3175 3176 3177 3178 3179 3180 3181 3182 3183 3184 3185 3186 3187 3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202 3203 3204 3205 3206 3207 3208 3209 3210 3211 3212 3213 3214 3215 3216 3217 3218 3219 3220 3221 3222 3223 3224 3225 3226 3227 3228 3229 3230 3231 3232 3233 3234 3235 3236 3237 3238 3239 3240 3241 3242 3243 3244 3245 3246 3247 3248 3249 3250 3251 3252 3253 3254 3255 3256 3257 3258 3259 3260 3261 3262 3263 3264 3265 3266 3267 3268 3269 3270 3271 3272 3273 3274 3275 3276 3277 3278 3279 3280 3281 3282 3283 3284 3285 3286 3287 3288 3289 3290 3291 3292 3293 3294 3295 3296 3297 3298 3299 3300 3301 3302 3303 3304 3305 3306 3307 3308 3309 3310 3311 3312 3313 3314 3315 3316 3317 3318 3319 3320 3321 3322 3323 3324 3325 3326 3327 3328 3329 3330 3331 3332 3333 3334 3335 3336 3337 3338 3339 3340 3341 3342 3343 3344 3345 3346 3347 3348 3349 3350 3351 3352 3353 3354 3355 3356 3357 3358 3359 3360 3361 3362 3363 3364 3365 3366 3367 3368 3369 3370 3371 3372 3373 3374 3375 3376 3377 3378 3379 3380 3381 3382 3383 3384 3385 3386 3387 3388 3389 3390 3391 3392 3393 3394 3395 3396 3397 3398 3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409 3410 3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423 3424 3425 3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436 3437 3438 3439 3440 3441 3442 3443 3444 3445 3446 3447 3448 3449 3450 3451 3452 3453 3454 3455 3456 3457 3458 3459 3460 3461 3462 3463 3464 3465 3466 3467 3468 3469 3470 3471 3472 3473 3474 3475 3476 3477 3478 3479 3480 3481 3482 3483 3484 3485 3486 3487 3488 3489 3490 3491 3492 3493 3494 3495 3496 3497 3498 3499 3500 3501 3502 3503 3504 3505 3506 3507 3508 3509 3510 3511 3512 3513 3514 3515 3516 3517 3518 3519 3520 3521 3522 3523 3524 3525 3526 3527 3528 3529 3530 3531 3532 3533 3534 3535 3536 3537 3538 3539 3540 3541 3542 3543 3544 3545 3546 3547 3548 3549 3550 3551 3552 3553 3554 3555 3556 3557 3558 3559 3560 3561 3562 3563 3564 3565 3566 3567 3568 3569 3570 3571 3572 3573 3574 3575 3576 3577 3578 3579 3580 3581 3582 3583 3584 3585 3586 3587 3588 3589 3590 3591 3592 3593 3594 3595 3596 3597 3598 3599 3600 3601 3602 3603 3604 3605 3606 3607 3608 3609 3610 3611 3612 3613 3614 3615 3616 3617 3618 3619 3620 3621 3622 3623 3624 3625 3626 3627 3628 3629 3630 3631 3632 3633 3634 3635 3636 3637 3638 3639 3640 3641 3642 3643 3644
|
/*
PsychSourceGL/Source/Common/Screen/PsychMovieSupportGStreamer.c
PLATFORMS: All
AUTHORS:
mario.kleiner.de@gmail.com mk Mario Kleiner
HISTORY:
28.11.2010 mk Wrote it.
20.08.2014 mk Ported to GStreamer-1.4.x and later.
DESCRIPTION:
Psychtoolbox functions for dealing with movies. This is the operating system independent
version which uses the GStreamer media framework, version 1.4 or later.
These PsychGSxxx functions are called from the dispatcher in
Common/Screen/PsychMovieSupport.[hc].
*/
#ifdef PTB_USE_GSTREAMER
#include "Screen.h"
#include <glib.h>
#include "PsychMovieSupportGStreamer.h"
#include <gst/gst.h>
// Include for dynamic binding of optional functions (dlsym()), only needed for Unix:
#if PSYCH_SYSTEM != PSYCH_WINDOWS
#include <dlfcn.h>
#endif
#if GST_CHECK_VERSION(1,0,0)
#include <gst/app/gstappsink.h>
#include <gst/video/video.h>
#include <gst/pbutils/pbutils.h>
// When building against < GStreamer 1.18.0, define some missing video formats:
#ifndef GST_VIDEO_FORMAT_Y444_16LE
#define GST_VIDEO_FORMAT_Y444_16LE 88
#define GST_VIDEO_FORMAT_P012_LE 92
#define GST_VIDEO_FORMAT_P016_LE 90
#endif
// Need to define this for playbin as it is not defined
// in any header file: (Expected behaviour - not a bug)
typedef enum {
GST_PLAY_FLAG_VIDEO = (1 << 0),
GST_PLAY_FLAG_AUDIO = (1 << 1),
GST_PLAY_FLAG_TEXT = (1 << 2),
GST_PLAY_FLAG_VIS = (1 << 3),
GST_PLAY_FLAG_SOFT_VOLUME = (1 << 4),
GST_PLAY_FLAG_NATIVE_AUDIO = (1 << 5),
GST_PLAY_FLAG_NATIVE_VIDEO = (1 << 6),
GST_PLAY_FLAG_DOWNLOAD = (1 << 7),
GST_PLAY_FLAG_BUFFERING = (1 << 8),
GST_PLAY_FLAG_DEINTERLACE = (1 << 9),
GST_PLAY_FLAG_SOFT_COLORBALANCE = (1 << 10),
GST_PLAY_FLAG_FORCE_FILTERS = (1 << 11),
GST_PLAY_FLAG_FORCE_SW_DECODERS = (1 << 12)
} GstPlayFlags;
#define PSYCH_MAX_MOVIES 100
typedef struct {
psych_bool valid;
int type;
double displayPrimaryRed[2];
double displayPrimaryGreen[2];
double displayPrimaryBlue[2];
double whitePoint[2];
double minLuminance;
double maxLuminance;
double maxFrameAverageLightLevel;
double maxContentLightLevel;
} PsychMovieHDRMetaData;
typedef struct {
psych_mutex mutex;
psych_condition condition;
double pts;
GstElement *theMovie;
GMainLoop *MovieContext;
GstElement *videosink;
PsychWindowRecordType* parentRecord;
unsigned char *imageBuffer;
int frameAvail;
int preRollAvail;
double rate;
int startPending;
int endOfFetch;
int specialFlags1;
int pixelFormat;
int loopflag;
double movieduration;
int nrframes;
double fps;
int width;
int height;
double aspectRatio;
int bitdepth;
double last_pts;
int nr_droppedframes;
int nrAudioTracks;
int nrVideoTracks;
char movieLocation[FILENAME_MAX];
char movieName[FILENAME_MAX];
GLuint cached_texture;
PsychMovieHDRMetaData hdrMetaData;
GstVideoInfo codecVideoInfo;
GstVideoInfo sinkVideoInfo;
GLuint texturePlanarHDRDecodeShader;
} PsychMovieRecordType;
static PsychMovieRecordType movieRecordBANK[PSYCH_MAX_MOVIES];
static int numMovieRecords = 0;
static psych_bool firsttime = TRUE;
// Helper functions for generation of CSC matrices:
// These are a slightly modified version from the original sample code provided
// by Ryan Juckett (thanks!), which was part of a nice primer on color spaces on
// his website under http://www.ryanjuckett.com/programming/rgb-color-space-conversion
//
// The code and math used here is identical with math from Bruce Lindbloom, under
// http://www.brucelindbloom.com/index.html?Eqn_RGB_XYZ_Matrix.html
//
// The code is also consistent with GStreamer's CSC implementation.
//
// The sample code is licensed as follows:
//
/******************************************************************************
* Copyright (c) 2010 Ryan Juckett
* http://www.ryanjuckett.com/
*
* This software is provided 'as-is', without any express or implied
* warranty. In no event will the authors be held liable for any damages
* arising from the use of this software.
*
* Permission is granted to anyone to use this software for any purpose,
* including commercial applications, and to alter it and redistribute it
* freely, subject to the following restrictions:
*
* 1. The origin of this software must not be misrepresented; you must not
* claim that you wrote the original software. If you use this software
* in a product, an acknowledgment in the product documentation would be
* appreciated but is not required.
*
* 2. Altered source versions must be plainly marked as such, and must not be
* misrepresented as being the original software.
*
* 3. This notice may not be removed or altered from any source
* distribution.
******************************************************************************/
// Mario Kleiner made the following modifications:
// Change basic data type from float to double, for higher precision.
// Removed C++'isms, so it compiles as part of a regular C compilation unit.
// Slight code reformatting.
// Add additional helper function Mat_Mult at the end of the original sample code.
//
//******************************************************************************
// 2-dimensional vector.
//******************************************************************************
typedef struct { double x, y; } tVec2;
//******************************************************************************
// 3-dimensional vector.
//******************************************************************************
typedef struct { double x, y, z; } tVec3;
//******************************************************************************
// 3x3 matrix
//******************************************************************************
typedef struct { double m[3][3]; } tMat3x3;
//******************************************************************************
// Set an indexed matrix column to a given vector.
//******************************************************************************
void Mat_SetCol(tMat3x3 * pMat, int colIdx, const tVec3 vec)
{
pMat->m[0][colIdx] = vec.x;
pMat->m[1][colIdx] = vec.y;
pMat->m[2][colIdx] = vec.z;
}
//******************************************************************************
// Calculate the inverse of a 3x3 matrix. Return false if it is non-invertible.
//******************************************************************************
bool Mat_Invert(tMat3x3 * pOutMat, const tMat3x3 inMat)
{
// calculate the minors for the first row
double minor00 = inMat.m[1][1]*inMat.m[2][2] - inMat.m[1][2]*inMat.m[2][1];
double minor01 = inMat.m[1][2]*inMat.m[2][0] - inMat.m[1][0]*inMat.m[2][2];
double minor02 = inMat.m[1][0]*inMat.m[2][1] - inMat.m[1][1]*inMat.m[2][0];
// calculate the determinant
double determinant = inMat.m[0][0] * minor00
+ inMat.m[0][1] * minor01
+ inMat.m[0][2] * minor02;
// check if the input is a singular matrix (non-invertable)
// (note that the epsilon here was arbitrarily chosen)
if( determinant > -0.000001f && determinant < 0.000001f )
return false;
// the inverse of inMat is (1 / determinant) * adjoint(inMat)
double invDet = 1.0f / determinant;
pOutMat->m[0][0] = invDet * minor00;
pOutMat->m[0][1] = invDet * (inMat.m[2][1]*inMat.m[0][2] - inMat.m[2][2]*inMat.m[0][1]);
pOutMat->m[0][2] = invDet * (inMat.m[0][1]*inMat.m[1][2] - inMat.m[0][2]*inMat.m[1][1]);
pOutMat->m[1][0] = invDet * minor01;
pOutMat->m[1][1] = invDet * (inMat.m[2][2]*inMat.m[0][0] - inMat.m[2][0]*inMat.m[0][2]);
pOutMat->m[1][2] = invDet * (inMat.m[0][2]*inMat.m[1][0] - inMat.m[0][0]*inMat.m[1][2]);
pOutMat->m[2][0] = invDet * minor02;
pOutMat->m[2][1] = invDet * (inMat.m[2][0]*inMat.m[0][1] - inMat.m[2][1]*inMat.m[0][0]);
pOutMat->m[2][2] = invDet * (inMat.m[0][0]*inMat.m[1][1] - inMat.m[0][1]*inMat.m[1][0]);
return true;
}
//******************************************************************************
// Multiply a column vector on the right of a 3x3 matrix.
//******************************************************************************
void Mat_MulVec( tVec3 * pOutVec, const tMat3x3 mat, const tVec3 inVec )
{
pOutVec->x = mat.m[0][0]*inVec.x + mat.m[0][1]*inVec.y + mat.m[0][2]*inVec.z;
pOutVec->y = mat.m[1][0]*inVec.x + mat.m[1][1]*inVec.y + mat.m[1][2]*inVec.z;
pOutVec->z = mat.m[2][0]*inVec.x + mat.m[2][1]*inVec.y + mat.m[2][2]*inVec.z;
}
//******************************************************************************
// Convert a linear sRGB color to an sRGB color
//******************************************************************************
void CalcColorSpaceConversion_RGB_to_XYZ(tMat3x3 * pOutput, // conversion matrix
const tVec2 red_xy, // xy chromaticity coordinates of the red primary
const tVec2 green_xy, // xy chromaticity coordinates of the green primary
const tVec2 blue_xy, // xy chromaticity coordinates of the blue primary
const tVec2 white_xy // xy chromaticity coordinates of the white point
)
{
// generate xyz chromaticity coordinates (x + y + z = 1) from xy coordinates
tVec3 r = { red_xy.x, red_xy.y, 1.0f - (red_xy.x + red_xy.y) };
tVec3 g = { green_xy.x, green_xy.y, 1.0f - (green_xy.x + green_xy.y) };
tVec3 b = { blue_xy.x, blue_xy.y, 1.0f - (blue_xy.x + blue_xy.y) };
tVec3 w = { white_xy.x, white_xy.y, 1.0f - (white_xy.x + white_xy.y) };
// Convert white xyz coordinate to XYZ coordinate by letting that the white
// point have and XYZ relative luminance of 1.0. Relative luminance is the Y
// component of and XYZ color.
// XYZ = xyz * (Y / y)
w.x /= white_xy.y;
w.y /= white_xy.y;
w.z /= white_xy.y;
// Solve for the transformation matrix 'M' from RGB to XYZ
// * We know that the columns of M are equal to the unknown XYZ values of r, g and b.
// * We know that the XYZ values of r, g and b are each a scaled version of the known
// corresponding xyz chromaticity values.
// * We know the XYZ value of white based on its xyz value and the assigned relative
// luminance of 1.0.
// * We know the RGB value of white is (1,1,1).
//
// white_XYZ = M * white_RGB
//
// [r.x g.x b.x]
// N = [r.y g.y b.y]
// [r.z g.z b.z]
//
// [sR 0 0 ]
// S = [0 sG 0 ]
// [0 0 sB]
//
// M = N * S
// white_XYZ = N * S * white_RGB
// N^-1 * white_XYZ = S * white_RGB = (sR,sG,sB)
//
// We now have an equation for the components of the scale matrix 'S' and
// can compute 'M' from 'N' and 'S'
Mat_SetCol( pOutput, 0, r );
Mat_SetCol( pOutput, 1, g );
Mat_SetCol( pOutput, 2, b );
tMat3x3 invMat;
Mat_Invert( &invMat, *pOutput );
tVec3 scale;
Mat_MulVec( &scale, invMat, w );
pOutput->m[0][0] *= scale.x;
pOutput->m[1][0] *= scale.x;
pOutput->m[2][0] *= scale.x;
pOutput->m[0][1] *= scale.y;
pOutput->m[1][1] *= scale.y;
pOutput->m[2][1] *= scale.y;
pOutput->m[0][2] *= scale.z;
pOutput->m[1][2] *= scale.z;
pOutput->m[2][2] *= scale.z;
}
// Multiply two 3x3 matrices with each other, return resulting 3x3 matrix:
void Mat_Mult(tMat3x3 *pOutMat, const tMat3x3 inMat1, const tMat3x3 inMat2) {
int i, j, k;
for (i = 0; i < 3; i++) {
for (j = 0; j < 3; j++) {
double x = 0;
for (k = 0; k < 3; k++) {
x += inMat1.m[i][k] * inMat2.m[k][j];
}
pOutMat->m[i][j] = x;
}
}
}
// End of helper routines for CSC matrix generation.
static char movieTexturePlanarVertexShaderSrc[] =
"/* Simple pass-through vertex shader: Emulates fixed function pipeline, but passes */\n"
"/* modulateColor as varying unclampedFragColor to circumvent vertex color */\n"
"/* clamping on gfx-hardware / OS combos that don't support unclamped operation: */\n"
"/* PTBs color handling is expected to pass the vertex color in modulateColor */\n"
"/* for unclamped drawing for this reason. */\n"
"\n"
"varying vec4 unclampedFragColor;\n"
"varying vec2 texNominalSize;\n"
"attribute vec4 modulateColor;\n"
"attribute vec4 sizeAngleFilterMode;\n"
"\n"
"void main()\n"
"{\n"
" /* Simply copy input unclamped RGBA pixel color into output varying color: */\n"
" unclampedFragColor = modulateColor;\n"
" texNominalSize = sizeAngleFilterMode.xy;\n"
"\n"
" gl_TexCoord[0] = gl_TextureMatrix[0] * gl_MultiTexCoord0;\n"
"\n"
" /* Output position is the same as fixed function pipeline: */\n"
" gl_Position = ftransform();\n"
"}\n\0";
static char movieTexturePlanarFragmentShaderSrc[] =
"/* YUV-I420/422/444 planar texture sampling fragment shader. */\n"
"/* Retrieves YUV samples from proper locations in planes. */\n"
"/* Handles 8/10/12/.../16 bpc signal value, and full/limited range. */\n"
"/* Converts YUV samples to non-linear RGB color triplets, applies */\n"
"/* EOTF mapping to linear RGB, and LDR/HDR range remapping, and */\n"
"/* color space conversion, as needed. Finally GL_MODULATE texture */\n"
"/* function emulation is applied before fragment output. */\n"
"\n"
"/* switch() statement in shader needs GLSL 1.30+: */\n"
"#version 130\n"
"#extension GL_ARB_texture_rectangle : enable\n"
"\n"
"uniform sampler2DRect Image;\n"
"uniform float isSemiPlanar;\n"
"uniform float yChromaScale;\n"
"uniform int eotfType;\n"
"uniform float unormInputScaling;\n"
"uniform vec3 rangeScale;\n"
"uniform vec3 rangeOffset;\n"
"uniform float Kr;\n"
"uniform float Kb;\n"
"uniform mat3x3 M_CSC;\n"
"uniform float outUnitMultiplier;\n"
"varying vec4 unclampedFragColor;\n"
"varying vec2 texNominalSize;\n"
"\n"
"void main()\n"
"{\n"
" float y, u, v;\n"
" float nx, ny;\n"
" vec3 s, L, rgb;\n"
"\n"
" /* Nominal video texel position: */\n"
" nx = gl_TexCoord[0].x;\n"
" ny = gl_TexCoord[0].y;\n"
"\n"
" /* Get luma Y, scaled to the full digital signal content range, e.g., 0-255 for 8bpc, 0-1023 for 10 bpc, 0-4095 for 12bpc, 0-65535 for 16bpc: */\n"
" y = texture2DRect(Image, vec2(nx, ny)).r * unormInputScaling;\n"
"\n"
" /* yChromaScale != 2 signals a sampling layout other than I444, so chroma planes need different (nx,ny) sampling than luma plane: */\n"
" if (yChromaScale != 2.0) {\n"
" /* Compute lookup positions in U, V planes for chroma samples, for I420, I422 planar layout, and P semi-planar */\n"
" /* layout, depending on (quasi constant for all invocations of this shader) yChromaScale value: */\n"
" ny = floor(ny * yChromaScale);\n"
" nx = floor(nx * 0.5);\n"
"\n"
" if (isSemiPlanar > 0.5) {\n"
" nx = nx * 2.0;\n"
" }\n"
" else {\n"
" if (mod(ny, 2.0) >= 0.5) {\n"
" nx += texNominalSize.x * 0.5;\n"
" }\n"
"\n"
" ny = (ny - mod(ny, 2.0)) * 0.5;\n"
" }\n"
" }\n"
"\n"
" /* Get U, V chroma samples, scaled to the full digital signal content range: */\n"
" u = texture2DRect(Image, vec2(nx, ny + texNominalSize.y)).r * unormInputScaling;\n"
" v = texture2DRect(Image, vec2(nx + isSemiPlanar, ny + texNominalSize.y + ((1 - isSemiPlanar) * 0.5 * yChromaScale * texNominalSize.y))).r * unormInputScaling;\n"
"\n"
" /* Undo potential limited video range, scale to normalized range to get back to [0 ; 1] range for luma,\n"
" * [-0.5 ; 0.5] range for chroma: */\n"
" y = (y - rangeOffset[0]) * rangeScale[0];\n"
" u = (u - rangeOffset[1]) * rangeScale[1];\n"
" v = (v - rangeOffset[2]) * rangeScale[2];\n"
"\n"
" /* Clamp to valid range: */\n"
" y = clamp(y, 0.0, 1.0);\n"
" u = clamp(u, -0.5, 0.5);\n"
" v = clamp(v, -0.5, 0.5);\n"
"\n"
" /* Convert from yuv to r'g'b' by multiplication with suitable color matrix: */\n"
" rgb.r = y + 2.0 * (1.0 - Kr) * v;\n"
" rgb.g = y - 2.0 * (1.0 - Kb) * Kb / (1.0 - Kr - Kb) * u - 2.0 * (1.0 - Kr) * Kr / (1.0 - Kr - Kb) * v;\n"
" rgb.b = y + 2.0 * (1.0 - Kb) * u;\n"
"\n"
" /* Clamp to valid range: This is important, as some movies can contain out-of-gamut y,u,v values which */\n"
" /* cause the converted r'g'b' value to become out of allowed [0; 1] range, especially a bit < 0.0. This */\n"
" /* would cause the math below to fail, creating and propagating NaN's into very visible visual artifacts! */\n"
" rgb = clamp(rgb, 0.0, 1.0);\n"
"\n"
" /* Convert from r'g'b' non-linear encoding to rgb linear encoding by applying suitable EOTF: */\n"
" switch (eotfType) {\n"
" case 0: /* GST_VIDEO_TRANSFER_UNKNOWN: Do not know what this is! */\n"
" default:\n"
" /* Unknown EOTF! Send out a visual indicator to user that something is amiss here: */\n"
" rgb.r = step(10.0, mod(ny, 20.0));\n"
" L = mix(rgb, vec3(0.5), rgb.r);\n"
" break;\n"
"\n"
" case 1: /* GST_VIDEO_TRANSFER_GAMMA10: LDR */\n"
" /* Gamma 1.0 == linear - EOTF == Already linear rgb encoding in r,g,b so nothing to do: */\n"
" L = rgb;\n"
" break;\n"
"\n"
" case 2: {\n"
" /* 2 = GST_VIDEO_TRANSFER_GAMMA18: LDR */\n"
" L = pow(rgb, vec3(1.8));\n"
" break;\n"
" }\n"
"\n"
" case 3: {\n"
" /* 3 = GST_VIDEO_TRANSFER_GAMMA20: LDR */\n"
" L = pow(rgb, vec3(2.0));\n"
" break;\n"
" }\n"
"\n"
" case 4: {\n"
" /* 4 = GST_VIDEO_TRANSFER_GAMMA22: LDR */\n"
" L = pow(rgb, vec3(2.2));\n"
" break;\n"
" }\n"
"\n"
" case 5: /* GST_VIDEO_TRANSFER_BT709: LDR */\n"
" case 16: /* GST_VIDEO_TRANSFER_BT601: LDR */\n"
" case 13: { /* GST_VIDEO_TRANSFER_BT2020_10: LDR */\n"
" /* 5/16/13 = All the same: */\n"
" /* rgb < 0.081 --> rgb / 4.5 */\n"
" s = step(vec3(0.081), rgb);\n"
" L = mix(rgb / 4.5, pow((rgb + 0.099) / 1.099, vec3(1.0 / 0.45)), s);\n"
" break;\n"
" }\n"
"\n"
" case 6: { /* GST_VIDEO_TRANSFER_SMPTE240M: LDR */\n"
" /* rgb < 0.0913 --> rgb / 4 */\n"
" s = step(vec3(0.0913), rgb);\n"
" L = mix(rgb / 4.0, pow((rgb + 0.1115) / 1.1115, vec3(1.0 / 0.45)), s);\n"
" break;\n"
" }\n"
"\n"
" case 7: { /* GST_VIDEO_TRANSFER_SRGB: LDR */\n"
" /* rgb <= 0.4045 --> rgb / 12.92 */\n"
" s = step(rgb, vec3(0.04045));\n"
" L = mix(pow((rgb + 0.055) / 1.055, vec3(2.4)), rgb / 12.92, s);\n"
" break;\n"
" }\n"
"\n"
" case 8: {\n"
" /* 8 = GST_VIDEO_TRANSFER_GAMMA28: LDR */\n"
" L = pow(rgb, vec3(2.8));\n"
" break;\n"
" }\n"
"\n"
" case 9: { /* GST_VIDEO_TRANSFER_LOG100: LDR */\n"
" /* rgb > 0 --> pow */\n"
" s = step(rgb, vec3(0.0));\n"
" L = mix(pow(vec3(10.0), 2.0 * (rgb - 1.0)), vec3(0.0), s);\n"
" break;\n"
" }\n"
"\n"
" case 10: { /* GST_VIDEO_TRANSFER_LOG316: LDR */\n"
" /* rgb > 0 --> pow */\n"
" s = step(rgb, vec3(0.0));\n"
" L = mix(pow(vec3(10.0), 2.5 * (rgb - 1.0)), vec3(0.0), s);\n"
" break;\n"
" }\n"
"\n"
" case 11: {\n"
" /* 11 = GST_VIDEO_TRANSFER_BT2020_12: LDR */\n"
" /* rgb < 0.08145 --> rgb / 4.5 */\n"
" s = step(vec3(0.08145), rgb);\n"
" L = mix(rgb / 4.5, pow((rgb + 0.0993) / 1.0993, vec3(1.0 / 0.45)), s);\n"
" break;\n"
" }\n"
"\n"
" case 12: {\n"
" /* 12 = GST_VIDEO_TRANSFER_ADOBERGB: LDR */\n"
" L = pow(rgb, vec3(2.19921875));\n"
" break;\n"
" }\n"
"\n"
" case 14: {\n"
" /* 14 = GST_VIDEO_TRANSFER_SMPTE2084: SMPTE ST-2084 PQ EOTF: HDR */\n"
" const float c1 = 0.8359375;\n"
" const float c2 = 18.8515625;\n"
" const float c3 = 18.6875;\n"
" const float mi = 1.0 / 78.84375;\n"
" const float ni = 1.0 / 0.1593017578125;\n"
"\n"
" L = pow(rgb, vec3(mi));\n"
" L = pow(max(L - vec3(c1), vec3(0.0)) / (vec3(c2) - vec3(c3) * L), vec3(ni));\n"
"\n"
" /* L is now linear r,g,b in normalized [0; 1] linear range, where 0.0 = 0 nits and 1.0 = 10000 nits: */\n"
" break;\n"
" }\n"
"\n"
" case 15: {\n"
" /* 15 = GST_VIDEO_TRANSFER_ARIB_STD_B67: HLG: HDR */\n"
" const float c1 = 0.17883277;\n"
" const float c2 = 0.28466892;\n"
" const float c3 = 0.55991073;\n"
"\n"
" s = step(rgb, vec3(0.5));\n"
" L = mix((exp((rgb - c3) / c1) + c2) / 12.0, pow(rgb, vec3(2.0)) / 3.0, s);\n"
"\n"
" /* L is now linear r,g,b in normalized [0; 1] linear range, where 0.0 = 0 nits and 1.0 = 1000 nits. */\n"
" /* Map it down to [0; 0.1] range, as in our HDR system 0.1 should mean 1000 nits: */\n"
" L = L * 0.1;\n"
" break;\n"
" }\n"
" }\n"
"\n"
" /* Perform colorspace conversion movie->window via multiplication with 3x3 M_CSC matrix: */\n"
" L = M_CSC * L;\n"
"\n"
" /* Mark any invalid NaN component values which may have made it to here in a very clear and alarming red to prevent trouble from going unnoticed: */\n"
" if (isnan(L.r) || isnan(L.g) || isnan(L.b))\n"
" L = vec3(1.0, 0.0, 0.0);\n"
"\n"
" /* Multiply linear normalized [0 ; 1] range of r,g,b to target framebuffer range, e.g., [0 ; 10000.0] for absolute nits, [0 ; 125.0] for SDR 80-nit-units. */\n"
" /* Set alpha to 1.0 and multiply the final vec4 texcolor with incoming fragment color (GL_MODULATE emulation), and assign result as output fragment color. */\n"
" gl_FragColor = vec4(L.r * outUnitMultiplier, L.g * outUnitMultiplier, L.b * outUnitMultiplier, 1.0) * unclampedFragColor;\n"
"}\n";
// Stage 1: Sample [I420] / 422 / 444, [multiply by 65535 or 255 (> 8 bpc or not?)][, range convert (limited vs. full?)][, normalize.]
// [Y'U'V' -> R'G'B' (color matrix as input...)]
// Stage 2: R'G'B' -> RGB (apply EOTF), scale via HDR scaling factor.
// Maybe CSC?
static psych_bool PsychAssignMovieTextureConversionShader(PsychMovieRecordType* movie, PsychWindowRecordType* textureRecord)
{
// Get parent windowRecord for this movie frame texture:
PsychWindowRecordType *windowRecord = PsychGetParentWindow(textureRecord);
// Do we already have a planar HDR decode texture shader?
if (movie->texturePlanarHDRDecodeShader == 0) {
double Kr, Kb;
int offset[GST_VIDEO_MAX_COMPONENTS], scale[GST_VIDEO_MAX_COMPONENTS];
float outUnitMultiplier;
float yChromaScale;
int bpc = GST_VIDEO_FORMAT_INFO_DEPTH(movie->sinkVideoInfo.finfo, 0);
// Note: codecVideoInfo is used instead of sinkVideoInfo as source, to get the correct eotf. Why? The other one does
// not always provide accurate info. Don't know if this is a bug in GStreamer 1.18.0 or somehow intended behaviour.
int eotfType = movie->codecVideoInfo.colorimetry.transfer;
// Nope. Need to create one:
movie->texturePlanarHDRDecodeShader = PsychCreateGLSLProgram(movieTexturePlanarFragmentShaderSrc, movieTexturePlanarVertexShaderSrc, NULL);
if (movie->texturePlanarHDRDecodeShader == 0) {
if (PsychPrefStateGet_Verbosity() > 0)
printf("PTB-ERROR: Failed to create planar HDR decode and conversion shader for video texture!\n");
return(FALSE);
}
// Set up decoding parameters:
glUseProgram(movie->texturePlanarHDRDecodeShader);
// Tell shader if the planar storage mode is I420 (0.5x), I422 (1.0x) or I444 (2x -- Special value for shader!):
switch (GST_VIDEO_FORMAT_INFO_FORMAT(movie->sinkVideoInfo.finfo)) {
case GST_VIDEO_FORMAT_I420:
case GST_VIDEO_FORMAT_I420_10LE:
case GST_VIDEO_FORMAT_I420_12LE:
case GST_VIDEO_FORMAT_NV12:
case GST_VIDEO_FORMAT_P010_10LE:
case GST_VIDEO_FORMAT_P012_LE:
case GST_VIDEO_FORMAT_P016_LE:
// Half horizontal + half vertical resolution 4:2:0 sampling of chroma planes, full resolution luma plane:
yChromaScale = 0.5;
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: Using movie video frame decoding from YUV-I420/P0xx -> RGB with %i bpc precision. ", bpc);
break;
case GST_VIDEO_FORMAT_Y42B:
case GST_VIDEO_FORMAT_I422_10LE:
case GST_VIDEO_FORMAT_I422_12LE:
case GST_VIDEO_FORMAT_NV16:
// Half horizontal + full vertical resolution 4:2:2 sampling of chroma planes, full resolution luma plane:
yChromaScale = 1.0;
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: Using movie video frame decoding from YUV-I422/P2xx -> RGB with %i bpc precision. ", bpc);
break;
case GST_VIDEO_FORMAT_Y444:
case GST_VIDEO_FORMAT_Y444_10LE:
case GST_VIDEO_FORMAT_Y444_12LE:
case GST_VIDEO_FORMAT_Y444_16LE:
// Full resolution 4:4:4 sampling of all planes:
yChromaScale = 2.0;
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: Using movie video frame decoding from YUV-I444/Y444 -> RGB with %i bpc precision. ", bpc);
break;
default:
if (PsychPrefStateGet_Verbosity() > 0)
printf("PTB-ERROR: Failed to setup planar HDR decode and conversion shader for video texture! Unrecognized format.\n");
return(FALSE);
}
// Assign chroma planes vertical scaling factor:
glUniform1f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "yChromaScale"), yChromaScale);
// Tell shader if this is stored in a 16 bpc container or 8 bpc container, ie. which scaling to use,
// and if it is a planar format (separate Y, U and V planes) or semi-planar format (Y plane + one chroma
// plane with UV samples horizontally interleaved):
switch (GST_VIDEO_FORMAT_INFO_FORMAT(movie->sinkVideoInfo.finfo)) {
case GST_VIDEO_FORMAT_NV12: // 8 bpc 4:2:0
case GST_VIDEO_FORMAT_P010_10LE: // 10 bpc 4:2:0
case GST_VIDEO_FORMAT_P012_LE: // 12 bpc 4:2:0
case GST_VIDEO_FORMAT_P016_LE: // 16 bpc 4:2:0
case GST_VIDEO_FORMAT_NV16: // 8 bpc 4:2:2
// Semi-planar Pxxx formats have relevant content in MSB's, and zeros in remaining LSB's, need scaling up to 2^bpc - 1:
glUniform1f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "unormInputScaling"), (float) ((1 << bpc) - 1));
glUniform1f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "isSemiPlanar"), 1);
break;
default:
// Other - planar - formats have content in LSB's, and a need to scale up to full 8 or 16 bit magnitude in the shader:
glUniform1f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "unormInputScaling"), (bpc > 8) ? 65535.0 : 255.0);
glUniform1f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "isSemiPlanar"), 0);
}
// First handle limited vs. full range encoding, and different bit depths, to
// map all Y luma into [0; 1] range and all U,V chroma into [-0.5 ; 0.5] range:
if (PsychPrefStateGet_Verbosity() > 3)
printf("%s range input. ", (movie->sinkVideoInfo.colorimetry.range == GST_VIDEO_COLOR_RANGE_16_235) ? "Limited" : "Full");
// GStreamer gets us the needed offset and scale factors to apply in the shader as c = (c - offset) / scale:
gst_video_color_range_offsets(movie->sinkVideoInfo.colorimetry.range, movie->sinkVideoInfo.finfo, offset, scale);
glUniform3f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "rangeScale"), 1.0 / (float) scale[0], 1.0 / (float) scale[1], 1.0 / (float) scale[2]);
glUniform3f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "rangeOffset"), (float) offset[0], (float) offset[1], (float) offset[2]);
// Get Kr, Kb coefficients for conversion of YUV -> R'G'B' in the shader. GStreamer
// provides us with the proper coefficients for a given color conversion matrix:
if (!gst_video_color_matrix_get_Kr_Kb (movie->sinkVideoInfo.colorimetry.matrix, (gdouble*) &Kr, (gdouble*) &Kb)) {
if (PsychPrefStateGet_Verbosity() > 0)
printf("PTB-ERROR: Failed to setup planar HDR decode and conversion shader for video texture! Could not get color matrix coefficients.\n");
return(FALSE);
}
glUniform1f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "Kr"), Kr);
glUniform1f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "Kb"), Kb);
// Tell shader about type of EOTF transfer function:
glUniform1i(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "eotfType"), eotfType);
// Assign output multiplier for linear (r,g,b) values, to convert into target unit used in Psychtoolbox windows framebuffer:
switch(eotfType) {
case 14: // aka GST_VIDEO_TRANSFER_SMPTE2084 - HDR PQ
case 15: // aka GST_VIDEO_TRANSFER_ARIB_STD_B67 - HDR HLG
// HDR movie format: Scale normalized 0-1 range where 0 = 0 Nits, 1 = 10000 nits, to framebuffer HDR units:
outUnitMultiplier = windowRecord->normalizedToHDRScaleFactor;
if (PsychPrefStateGet_Verbosity() > 3)
printf("HDR footage, eotf %i. HDR mapping to [0.0 ; %2f].\n", eotfType, outUnitMultiplier);
break;
default:
// SDR / LDR movie format: Upscale to HDR color range of window:
outUnitMultiplier = windowRecord->maxSDRToHDRScaleFactor;
if (PsychPrefStateGet_Verbosity() > 3)
printf("SDR/LDR footage, eotf %i. HDR mapping to [0.0 ; %2f].\n", eotfType, outUnitMultiplier);
break;
}
glUniform1f(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "outUnitMultiplier"), outUnitMultiplier);
// Convert from colorspace of movie to colorspace of onscreen window, by use of a 3x3 CSC matrix:
{
tMat3x3 M_RGBMovie_to_XYZ;
tMat3x3 M_RGBWindow_to_XYZ;
tMat3x3 M_XYZ_to_RGBWindow;
tMat3x3 M_CSC;
float M_CSC_f[9];
int i, j, k = 0;
// Query chromaticity coordinates or primaries and white-point of the encoding colorspace of the movie:
const GstVideoColorPrimariesInfo *pinfo = gst_video_color_primaries_get_info(movie->sinkVideoInfo.colorimetry.primaries);
// Assign primary/wp coords to format for our helper function:
tVec2 pR = { pinfo->Rx, pinfo->Ry };
tVec2 pG = { pinfo->Gx, pinfo->Gy };
tVec2 pB = { pinfo->Bx, pinfo->By };
tVec2 pW = { pinfo->Wx, pinfo->Wy };
// Generate conversion matrix from linear movie RGB space to XYZ space:
CalcColorSpaceConversion_RGB_to_XYZ(&M_RGBMovie_to_XYZ, pR, pG, pB, pW);
// Generate conversion matrix from XYZ space to target linear onscreen window RGB space:
if (windowRecord->colorGamut[0] == 0 || windowRecord->colorGamut[1] == 0) {
// The color gamut of the target onscreen window is not yet defined, ie.
// no external script has set it up. Choose default values, based on type of
// onscreen window, which is BT-2020 for a HDR window, and assumed to be BT-709
// (~ sRGB) for a standard window:
const GstVideoColorPrimariesInfo *pinfo2 = gst_video_color_primaries_get_info((windowRecord->imagingMode & kPsychNeedHDRWindow) ? GST_VIDEO_COLOR_PRIMARIES_BT2020 : GST_VIDEO_COLOR_PRIMARIES_BT709);
// Assign primary/wp coords to format for our helper function:
pR.x = pinfo2->Rx;
pR.y = pinfo2->Ry;
pG.x = pinfo2->Gx;
pG.y = pinfo2->Gy;
pB.x = pinfo2->Bx;
pB.y = pinfo2->By;
pW.x = pinfo2->Wx;
pW.y = pinfo2->Wy;
}
else {
// Use color primaries and white point from user settings:
double *p = &windowRecord->colorGamut[0];
pR.x = *(p++);
pR.y = *(p++);
pG.x = *(p++);
pG.y = *(p++);
pB.x = *(p++);
pB.y = *(p++);
pW.x = *(p++);
pW.y = *(p++);
}
// Get XYZ to RGB window by computing RGB of window to XYZ, then inverting that matrix:
CalcColorSpaceConversion_RGB_to_XYZ(&M_RGBWindow_to_XYZ, pR, pG, pB, pW);
if (!Mat_Invert(&M_XYZ_to_RGBWindow, M_RGBWindow_to_XYZ)) {
if (PsychPrefStateGet_Verbosity() > 0)
printf("PTB-ERROR: Failed to setup planar HDR decode and conversion shader for video texture! User code assigned invalid (== non-invertible/degenerated) color gamut to target window.\n");
return(FALSE);
}
// Build final M_CSC color space conversion matrix as M_CSC = M_XYZ_to_RGBWindow * M_RGBMovie_to_XYZ:
Mat_Mult(&M_CSC, M_XYZ_to_RGBWindow, M_RGBMovie_to_XYZ);
// Shader needs float matrix, not double matrix, so need to convert M_CSC into a float version:
for (i = 0; i < 3; i++) {
for (j = 0; j < 3; j++)
M_CSC_f[k++] = (float) M_CSC.m[i][j];
}
// Assign M_CSC as CSC matrix for shader:
glUniformMatrix3fv(glGetUniformLocation(movie->texturePlanarHDRDecodeShader, "M_CSC"), 1, GL_TRUE, (const GLfloat*) M_CSC_f);
if (PsychPrefStateGet_Verbosity() > 3) {
printf("PTB-DEBUG: Applying following 3x3 colorspace conversion matrix to movie footage:\n\n");
for (i = 0; i < 3; i++) {
for (j = 0; j < 3; j++)
printf("%f ", M_CSC.m[i][j]);
printf("\n");
}
printf("\n\n");
}
}
// Setup of sampling and conversion shader complete:
glUseProgram(0);
}
// Assign our movies planar HDR decoding shader to this video frame texture:
// We don't support GL_TEXTURE_2D textures yet though, so only auto-assign shader for rectangle textures.
if (textureRecord && !(PsychGetTextureTarget(textureRecord) == GL_TEXTURE_2D))
textureRecord->textureFilterShader = -1 * movie->texturePlanarHDRDecodeShader;
// Done.
return(TRUE);
}
/*
* PsychGSMovieInit() -- Initialize movie subsystem.
* This routine is called by Screen's RegisterProject.c PsychModuleInit()
* routine at Screen load-time. It clears out the movieRecordBANK to
* bring the subsystem into a clean initial state.
*/
void PsychGSMovieInit(void)
{
// Initialize movieRecordBANK with NULL-entries:
int i;
for (i=0; i < PSYCH_MAX_MOVIES; i++) {
memset(&movieRecordBANK[i], 0, sizeof(PsychMovieRecordType));
}
numMovieRecords = 0;
// On Linux we set an environment variable to tell the GStreamer vaapidecodebin
// plugin that it should disable builtin video post processing, ie. it sets the
// "disable-vpp" property to true and prevents the use of the vaapipostprocessing
// plugin. This is important for hardware accelerated playback of movies which
// do not use the BT-709 colorspace, especially HDR/WCG movies, as the post
// processor plugin will throw away all colorspace and mastering display color
// info otherwise and degrade the HDR/WCG content to some pixel mash!
// Note that vaapi plugins are on the way to deprecation, to be replaced with
// the new va plugins for the same purpose. GStreamer 1.24+ will probably go
// that route.
#if PSYCH_SYSTEM == PSYCH_LINUX
setenv("GST_VAAPI_DISABLE_VPP", "1", 1);
#endif
// Note: This is deprecated and not needed anymore on GLib 2.31.0 and later, as
// GLib's threading system auto-initializes on first use since that version. We
// keep it for now to stay compatible to older systems, e.g., Ubuntu 10.04 LTS,
// conditionally on the GLib version we build against:
#if !GLIB_CHECK_VERSION (2, 31, 0)
// Initialize GLib's threading system early:
if (!g_thread_supported()) g_thread_init(NULL);
#endif
return;
}
int PsychGSGetMovieCount(void) {
return(numMovieRecords);
}
// Does the installed GStreamer SDK include video-hdr.h, because it is for
// GStreamer 1.17.0+?
#ifndef __GST_VIDEO_HDR_H__
// No: Use our own version of that file as a drop-in replacement, so we can
// build for GStreamer 1.17+ with an older GStreamer SDK:
#include "video-hdr.h"
#endif
// Still not there? If so, abort compile.
#ifndef __GST_VIDEO_HDR_H__
#error Missing GStreamer 1.18+ video-hdr!
#endif
// Dynamic function pointer prototypes for functions needed from GStreamer 1.18+ for HDR metadata parsing:
gboolean (*psych_gst_video_mastering_display_info_from_caps)(GstVideoMasteringDisplayInfo *minfo, const GstCaps *caps) = NULL;
gboolean (*psych_gst_video_content_light_level_from_caps)(GstVideoContentLightLevel *linfo, const GstCaps *caps) = NULL;
static void PsychParseMovieHDRMetadata(PsychMovieRecordType* movie, const GstCaps* caps)
{
GstVideoMasteringDisplayInfo minfo;
GstVideoContentLightLevel linfo;
psych_bool hdr_firsttime = TRUE;
// Zero init HDR metadata:
memset(&movie->hdrMetaData, 0, sizeof(movie->hdrMetaData));
// Need to runtime link the two HDR metadata parsing functions needed, but
// only available in GStreamer 1.18+ (or at least GStreamer 1.17+):
if (hdr_firsttime) {
hdr_firsttime = FALSE;
#if PSYCH_SYSTEM == PSYCH_WINDOWS
HANDLE gstvideo_handle = GetModuleHandle("gstvideo-1.0-0.dll");
psych_gst_video_mastering_display_info_from_caps = (void*) GetProcAddress(gstvideo_handle, "gst_video_mastering_display_info_from_caps");
psych_gst_video_content_light_level_from_caps = (void*) GetProcAddress(gstvideo_handle, "gst_video_content_light_level_from_caps");
#else
psych_gst_video_mastering_display_info_from_caps = dlsym(RTLD_DEFAULT, "gst_video_mastering_display_info_from_caps");
psych_gst_video_content_light_level_from_caps = dlsym(RTLD_DEFAULT, "gst_video_content_light_level_from_caps");
#endif
}
// Are the HDR caps parsing functions supported and bound?
if ((NULL == psych_gst_video_mastering_display_info_from_caps) || (NULL == psych_gst_video_content_light_level_from_caps)) {
// Nope, we are done here:
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: This GStreamer version does not support HDR metadata parsing.\n");
return;
}
// Parse mastering display info, ie. color gamut and min/max luminance:
if (psych_gst_video_mastering_display_info_from_caps(&minfo, caps)) {
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: HDR mastering display properties assigned.\n");
movie->hdrMetaData.displayPrimaryRed[0] = (double) minfo.display_primaries[0].x / 50000.0;
movie->hdrMetaData.displayPrimaryRed[1] = (double) minfo.display_primaries[0].y / 50000.0;
movie->hdrMetaData.displayPrimaryGreen[0] = (double) minfo.display_primaries[1].x / 50000.0;
movie->hdrMetaData.displayPrimaryGreen[1] = (double) minfo.display_primaries[1].y / 50000.0;
movie->hdrMetaData.displayPrimaryBlue[0] = (double) minfo.display_primaries[2].x / 50000.0;
movie->hdrMetaData.displayPrimaryBlue[1] = (double) minfo.display_primaries[2].y / 50000.0;
movie->hdrMetaData.whitePoint[0] = (double) minfo.white_point.x / 50000.0;
movie->hdrMetaData.whitePoint[1] = (double) minfo.white_point.y / 50000.0;
movie->hdrMetaData.minLuminance = (double) minfo.min_display_mastering_luminance / 10000.0;
movie->hdrMetaData.maxLuminance = (double) minfo.max_display_mastering_luminance / 10000.0;
movie->hdrMetaData.valid = TRUE;
// Currently we only support MetadataType 0, ie. "Static HDR Metadata Type 1" as known
// from HDR-10 standard, and supported by GStreamer 1.18.0+:
movie->hdrMetaData.type = 0;
}
else {
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: No HDR mastering display info available for movie.\n");
}
// Parse content light levels:
if (psych_gst_video_content_light_level_from_caps(&linfo, caps)) {
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: HDR content light level info assigned.\n");
movie->hdrMetaData.maxFrameAverageLightLevel = (double) linfo.max_frame_average_light_level;
movie->hdrMetaData.maxContentLightLevel = (double) linfo.max_content_light_level;
movie->hdrMetaData.valid = TRUE;
}
else {
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: No HDR content light level info available for movie.\n");
}
}
// Forward declaration:
static gboolean PsychMovieBusCallback(GstBus *bus, GstMessage *msg, gpointer dataptr);
/* Perform context loop iterations (for bus message handling) if doWait == false,
* as long as there is work to do, or at least two seconds worth of iterations
* if doWait == true. This drives the message-bus callback, so needs to be
* performed to get any error reporting etc.
*/
int PsychGSProcessMovieContext(PsychMovieRecordType* movie, psych_bool doWait)
{
GstBus* bus;
GstMessage *msg;
psych_bool workdone = FALSE;
double tdeadline, tnow;
PsychGetAdjustedPrecisionTimerSeconds(&tdeadline);
tnow = tdeadline;
tdeadline+=2.0;
// New style:
bus = gst_pipeline_get_bus(GST_PIPELINE(movie->theMovie));
msg = NULL;
// If doWait, try to perform iterations until 2 seconds elapsed or at least one event handled:
while (doWait && (tnow < tdeadline) && !gst_bus_have_pending(bus)) {
// Update time:
PsychYieldIntervalSeconds(0.010);
PsychGetAdjustedPrecisionTimerSeconds(&tnow);
}
msg = gst_bus_pop(bus);
while (msg) {
workdone = TRUE;
PsychMovieBusCallback(bus, msg, movie);
gst_message_unref(msg);
msg = gst_bus_pop(bus);
}
gst_object_unref(bus);
return(workdone);
}
/* Initiate pipeline state changes: Startup, Preroll, Playback, Pause, Standby, Shutdown. */
static psych_bool PsychMoviePipelineSetState(GstElement* theMovie, GstState state, double timeoutSecs)
{
GstState state_pending;
GstStateChangeReturn rcstate;
gst_element_set_state(theMovie, state);
// Non-Blocking, async?
if (timeoutSecs < 0) return(TRUE);
// Wait for up to timeoutSecs for state change to complete or fail:
rcstate = gst_element_get_state(theMovie, &state, &state_pending, (GstClockTime) (timeoutSecs * 1e9));
switch(rcstate) {
case GST_STATE_CHANGE_SUCCESS:
//printf("PTB-DEBUG: Statechange completed with GST_STATE_CHANGE_SUCCESS.\n");
break;
case GST_STATE_CHANGE_ASYNC:
printf("PTB-INFO: Statechange in progress with GST_STATE_CHANGE_ASYNC.\n");
break;
case GST_STATE_CHANGE_NO_PREROLL:
//printf("PTB-INFO: Statechange completed with GST_STATE_CHANGE_NO_PREROLL.\n");
break;
case GST_STATE_CHANGE_FAILURE:
printf("PTB-ERROR: Statechange failed with GST_STATE_CHANGE_FAILURE!\n");
return(FALSE);
break;
default:
printf("PTB-ERROR: Unknown state-change result in preroll.\n");
return(FALSE);
}
return(TRUE);
}
psych_bool PsychIsMovieSeekable(PsychMovieRecordType* movie)
{
GstQuery *query;
gint64 start, end;
gboolean seekable = FALSE;
query = gst_query_new_seeking(GST_FORMAT_TIME);
if (gst_element_query(movie->theMovie, query)) {
gst_query_parse_seeking(query, NULL, &seekable, &start, &end);
if (seekable) {
if (PsychPrefStateGet_Verbosity() > 4) {
printf("PTB-DEBUG: Seeking is enabled from %" GST_TIME_FORMAT " to %" GST_TIME_FORMAT "\n",
GST_TIME_ARGS (start), GST_TIME_ARGS (end));
}
}
else {
if (PsychPrefStateGet_Verbosity() > 4) printf("PTB-DEBUG: Seeking is disabled for this movie stream.\n");
}
}
else {
if (PsychPrefStateGet_Verbosity() > 1) printf("PTB-WARNING: Seeking query failed!\n");
}
gst_query_unref(query);
return((psych_bool) seekable);
}
/* Receive messages from the playback pipeline message bus and handle them: */
static gboolean PsychMovieBusCallback(GstBus *bus, GstMessage *msg, gpointer dataptr)
{
GstSeekFlags rewindFlags = 0;
PsychMovieRecordType* movie = (PsychMovieRecordType*) dataptr;
(void) bus;
if (PsychPrefStateGet_Verbosity() > 11) printf("PTB-DEBUG: PsychMovieBusCallback: Msg source name and type: %s : %s\n", GST_MESSAGE_SRC_NAME(msg), GST_MESSAGE_TYPE_NAME(msg));
switch (GST_MESSAGE_TYPE (msg)) {
case GST_MESSAGE_SEGMENT_DONE:
// We usually receive segment done message instead of eos if looped playback is active and
// the end of the stream is approaching, so we fallthrough to message eos for rewinding...
if (PsychPrefStateGet_Verbosity() > 4) printf("PTB-DEBUG: PsychMovieBusCallback: Message SEGMENT_DONE received.\n");
// Fall through.
case GST_MESSAGE_EOS: {
// Rewind at end of movie if looped playback enabled:
if ((GST_MESSAGE_TYPE (msg) == GST_MESSAGE_EOS) && (PsychPrefStateGet_Verbosity() > 4)) printf("PTB-DEBUG: PsychMovieBusCallback: Message EOS received.\n");
// Looping via seek requested (method 0x1) and playback active?
if ((movie->loopflag & 0x1) && (movie->rate != 0)) {
// Perform loop via rewind via seek:
if (PsychPrefStateGet_Verbosity() > 4) printf("PTB-DEBUG: PsychMovieBusCallback: End of iteration in active looped playback reached: Rewinding...\n");
// Seek: We normally don't GST_SEEK_FLAG_FLUSH here, so the rewinding is smooth because we don't throw away buffers queued in the pipeline,
// unless we are at the end of the stream (EOS), so there ain't anything queued in the pipeline, or code requests an explicit pipeline flush via flag 0x8.
// This seems to make no sense (why flush an already EOS - empty pipeline?) but is neccessary for some movies with sound on some systems:
if ((GST_MESSAGE_TYPE(msg) == GST_MESSAGE_EOS) || (movie->loopflag & 0x8)) rewindFlags |= GST_SEEK_FLAG_FLUSH;
// On some movies and configurations, we need a segment seek as indicated by flag 0x4:
if (movie->loopflag & 0x4) rewindFlags |= GST_SEEK_FLAG_SEGMENT;
// Seek method depends on playback direction:
if (movie->rate > 0) {
if (!gst_element_seek(movie->theMovie, movie->rate, GST_FORMAT_TIME, GST_SEEK_FLAG_ACCURATE | rewindFlags, GST_SEEK_TYPE_SET, 0, GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE)) {
if (PsychPrefStateGet_Verbosity() > 1) printf("PTB-WARNING: Rewinding video in forward playback failed!\n");
}
}
else {
if (!gst_element_seek(movie->theMovie, movie->rate, GST_FORMAT_TIME, GST_SEEK_FLAG_ACCURATE | rewindFlags, GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE, GST_SEEK_TYPE_END, 0)) {
if (PsychPrefStateGet_Verbosity() > 1) printf("PTB-WARNING: Rewinding video in reverse playback failed!\n");
}
}
}
break;
}
case GST_MESSAGE_BUFFERING: {
// Pipeline is buffering data, e.g., during network streaming playback.
// Print some optional status info:
gint percent = 0;
gst_message_parse_buffering(msg, &percent);
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Movie '%s', buffering video data: %i percent done ...\n", movie->movieName, (int) percent);
break;
}
case GST_MESSAGE_WARNING: {
gchar *debug;
GError *error;
gst_message_parse_warning(msg, &error, &debug);
if (PsychPrefStateGet_Verbosity() > 3) {
printf("PTB-WARNING: GStreamer movie playback engine reports this warning:\n"
" Warning from element %s: %s\n", GST_OBJECT_NAME(msg->src), error->message);
printf(" Additional debug info: %s.\n", (debug) ? debug : "None");
}
g_free(debug);
g_error_free(error);
break;
}
case GST_MESSAGE_ERROR: {
gchar *debug;
GError *error;
gst_message_parse_error(msg, &error, &debug);
if (PsychPrefStateGet_Verbosity() > 0) {
// Most common case, "File not found" error? If so, we provide a pretty-printed error message:
if ((error->domain == GST_RESOURCE_ERROR) && (error->code == GST_RESOURCE_ERROR_NOT_FOUND)) {
printf("PTB-ERROR: Could not open movie file [%s] for playback! No such moviefile with the given absolute path and filename.\n",
movie->movieName);
printf("PTB-ERROR: Please note that you *must* provide an absolute path and filename for your movie file, filename alone won't work.\n");
printf("PTB-ERROR: The specific file URI of the missing movie was: %s.\n", movie->movieLocation);
}
else {
// Nope, something more special. Provide detailed GStreamer error output:
printf("PTB-ERROR: GStreamer movie playback engine reports this error:\n"
" Error from element %s: %s\n", GST_OBJECT_NAME(msg->src), error->message);
printf(" Additional debug info: %s.\n\n", (debug) ? debug : "None");
// And some interpretation for our technically challenged users ;-):
if ((error->domain == GST_RESOURCE_ERROR) && (error->code != GST_RESOURCE_ERROR_NOT_FOUND)) {
printf(" This means that there was some problem with reading the movie file (permissions etc.).\n\n");
}
}
}
g_free(debug);
g_error_free(error);
break;
}
default:
break;
}
return TRUE;
}
/* Called at each end-of-stream event at end of playback: */
static void PsychEOSCallback(GstAppSink *sink, gpointer user_data)
{
(void) sink, (void) user_data;
//PsychMovieRecordType* movie = (PsychMovieRecordType*) user_data;
//PsychLockMutex(&movie->mutex);
//printf("PTB-DEBUG: Videosink reached EOS.\n");
//PsychSignalCondition(&movie->condition);
//PsychUnlockMutex(&movie->mutex);
return;
}
/* Called whenever an active seek has completed or pipeline goes into pause.
* Signals/handles arrival of preroll buffers. Used to detect/signal when
* new videobuffers are available in non-playback mode.
*/
static GstFlowReturn PsychNewPrerollCallback(GstAppSink *sink, gpointer user_data)
{
PsychMovieRecordType* movie = (PsychMovieRecordType*) user_data;
(void) sink;
PsychLockMutex(&movie->mutex);
//printf("PTB-DEBUG: New PrerollBuffer received.\n");
movie->preRollAvail++;
PsychSignalCondition(&movie->condition);
PsychUnlockMutex(&movie->mutex);
return(GST_FLOW_OK);
}
/* Called whenever pipeline is in active playback and a new video frame arrives.
* Used to detect/signal when new videobuffers are available in playback mode.
*/
static GstFlowReturn PsychNewBufferCallback(GstAppSink *sink, gpointer user_data)
{
PsychMovieRecordType* movie = (PsychMovieRecordType*) user_data;
(void) sink;
PsychLockMutex(&movie->mutex);
//printf("PTB-DEBUG: New Buffer received.\n");
movie->frameAvail++;
PsychSignalCondition(&movie->condition);
PsychUnlockMutex(&movie->mutex);
return(GST_FLOW_OK);
}
/* Not used by us, but needs to be defined as no-op anyway: */
/* // There are only 3 function pointers in GstAppSinkCallbacks now
static GstFlowReturn PsychNewBufferListCallback(GstAppSink *sink, gpointer user_data)
{
(void) sink, (void) user_data;
//PsychMovieRecordType* movie = (PsychMovieRecordType*) user_data;
//PsychLockMutex(&movie->mutex);
//printf("PTB-DEBUG: New Bufferlist received.\n");
//PsychSignalCondition(&movie->condition);
//PsychUnlockMutex(&movie->mutex);
return(GST_FLOW_OK);
}
*/
/* Not used by us, but needs to be defined as no-op anyway: */
static void PsychDestroyNotifyCallback(gpointer user_data)
{
(void) user_data;
return;
}
/* This callback is called when the pipeline is about to finish playback
* of the current movie stream. If looped playback via method 0x2 is enabled,
* this needs to trigger a repetition by rescheduling the movie URI for playback.
*
* Allows gapless playback, but doesn't work reliable on all media types.
*
*/
static void PsychMovieAboutToFinishCB(GstElement *theMovie, gpointer user_data)
{
PsychMovieRecordType* movie = (PsychMovieRecordType*) user_data;
// Loop method 0x2 active?
if ((movie->loopflag & 0x2) && (movie->rate != 0)) {
g_object_set(G_OBJECT(theMovie), "uri", movie->movieLocation, NULL);
if (PsychPrefStateGet_Verbosity() > 4) printf("PTB-DEBUG: About-to-finish received: Rewinding via uri method.\n");
}
return;
}
/* Not used, didn't work, but left here in case we find a use for it in the future. */
/*
static void PsychMessageErrorCB(GstBus *bus, GstMessage *msg)
{
gchar *debug;
GError *error;
(void) bus;
gst_message_parse_error (msg, &error, &debug);
g_free (debug);
printf("PTB-BUSERROR: %s\n", error->message);
g_error_free (error);
return;
}
*/
static GstAppSinkCallbacks videosinkCallbacks = {
PsychEOSCallback,
PsychNewPrerollCallback,
PsychNewBufferCallback,
0,
0
};
/* PsychEnableGStreamerPlugin() En-/Disable a specific plugin for use in playback pipelines:
*
* pluginName = Name string of the plugin / its plugin factory.
* enable = TRUE / FALSE for Enable / Disable of plugin for auto-plugging.
*/
static psych_bool PsychEnableGStreamerPlugin(const char* pluginName, psych_bool enable) {
GstRegistry *registry = NULL;
GstElementFactory *factory = NULL;
registry = gst_registry_get();
if (!registry) {
if (PsychPrefStateGet_Verbosity() > 1)
printf("PTB-WARNING: PsychEnableGStreamerPlugin() could not get default GStreamer registry for element '%s' %sable.\n",
pluginName, enable ? "en" : "dis");
return(FALSE);
}
factory = gst_element_factory_find((const gchar *) pluginName);
if (!factory) {
if (PsychPrefStateGet_Verbosity() > 1)
printf("PTB-WARNING: PsychEnableGStreamerPlugin() could not get GStreamer element '%s' for %sable.\n",
pluginName, enable ? "en" : "dis");
return(FALSE);
}
if (enable)
gst_plugin_feature_set_rank(GST_PLUGIN_FEATURE(factory), GST_RANK_PRIMARY + 1);
else
gst_plugin_feature_set_rank(GST_PLUGIN_FEATURE(factory), GST_RANK_NONE);
if (!gst_registry_add_feature(registry, GST_PLUGIN_FEATURE(factory))) {
if (PsychPrefStateGet_Verbosity() > 1)
printf("PTB-WARNING: PsychEnableGStreamerPlugin() could not assign new GStreamer plugin rank to registry for element '%s' %sable.\n",
pluginName, enable ? "en" : "dis");
return(FALSE);
}
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-INFO: PsychEnableGStreamerPlugin(): GStreamer element '%s' %sabled.\n", pluginName, enable ? "en" : "dis");
return(TRUE);
}
/* PsychEnableGStreamerHardwareVideoDecoding() En-/Disable plugins for hardware accelerated video decoding:
*
* enable = TRUE / FALSE for Enable / Disable of plugin for auto-plugging.
*
* Returns TRUE on success, FALSE on failure.
*/
static psych_bool PsychEnableGStreamerHardwareVideoDecoding(psych_bool enable) {
GList *listIter;
GList *factoryList = NULL;
GstRegistry *registry = NULL;
GstElementFactory *factory = NULL;
psych_bool rc = FALSE;
registry = gst_registry_get();
if (!registry) {
if (PsychPrefStateGet_Verbosity() > 4)
printf("PTB-WARNING: PsychEnableGStreamerHardwareVideoDecoding() could not get GStreamer registry for hardware video decoding %sable.\n",
enable ? "en" : "dis");
return(FALSE);
}
// Iterate over all video decoder elements / element factories:
factoryList = gst_element_factory_list_get_elements(GST_ELEMENT_FACTORY_TYPE_DECODER | GST_ELEMENT_FACTORY_TYPE_MEDIA_VIDEO, 0);
for (listIter = g_list_first(factoryList); listIter != NULL; listIter = g_list_next(listIter)) {
factory = (GstElementFactory*) listIter->data;
// Ignore all video decoders which are not hardware decoders, but software decoders:
// Note TODO: Starting with GStreamer 1.18+ / Ubuntu 22.04+ one could get rid of this and simply
// add the flag GST_ELEMENT_FACTORY_TYPE_HARDWARE to the above filter flags. Not as long as we
// support Ubuntu 20.04 / GStreamer 1.16 though...
if (!strstr(gst_element_factory_get_metadata(factory, GST_ELEMENT_METADATA_KLASS), "Hardware"))
continue;
// Set autoplugger rank/priority to primary + 1 (ie. elevated) for enable, or none (ie. off) for disable:
if (enable)
gst_plugin_feature_set_rank(GST_PLUGIN_FEATURE(factory), GST_RANK_PRIMARY + 1);
else
gst_plugin_feature_set_rank(GST_PLUGIN_FEATURE(factory), GST_RANK_NONE);
// Commit rank change:
if (!gst_registry_add_feature(registry, GST_PLUGIN_FEATURE(factory))) {
if (PsychPrefStateGet_Verbosity() > 4)
printf("PTB-WARNING: PsychEnableGStreamerHardwareVideoDecoding() could not assign new GStreamer plugin rank to registry for element '%s' %sable.\n",
gst_element_factory_get_metadata(factory, GST_ELEMENT_METADATA_LONGNAME), enable ? "en" : "dis");
goto hwPluginEnableOut;
}
if (PsychPrefStateGet_Verbosity() > 4)
printf("PTB-DEBUG: PsychEnableGStreamerHardwareVideoDecoding(): GStreamer hardware video decoding element '%s' %sabled.\n",
gst_element_factory_get_metadata(factory, GST_ELEMENT_METADATA_LONGNAME), enable ? "en" : "dis");
}
rc = TRUE;
hwPluginEnableOut:
if (factoryList)
gst_plugin_feature_list_free(factoryList);
return(rc);
}
/*
* PsychGSCreateMovie() -- Create a movie object.
*
* This function tries to open a moviefile (with or without audio/video tracks)
* and create an associated movie object for it.
*
* win = Pointer to window record of associated onscreen window.
* moviename = char* with the name of the moviefile.
* preloadSecs = How many seconds of the movie should be preloaded/prefetched into RAM at movie open time?
* moviehandle = handle to the new movie.
* asyncFlag = As passed to 'OpenMovie'
* specialFlags1 = As passed to 'OpenMovie'
* pixelFormat = As passed to 'OpenMovie'
* maxNumberThreads = Maximum number of decode threads to use (0 = auto, 1 = One, ...);
* movieOptions = Options string with additional options for movie playback.
*/
void PsychGSCreateMovie(PsychWindowRecordType *win, const char* moviename, double preloadSecs, int* moviehandle, int asyncFlag, int specialFlags1, int pixelFormat, int maxNumberThreads, char* movieOptions)
{
GValue item = G_VALUE_INIT;
GstCaps *colorcaps = NULL;
GstElement *theMovie = NULL;
GstElement *videocodec = NULL;
GstElement *videosink = NULL;
GstElement *audiosink;
gchar* pstring;
gint64 length_format;
GstPad *pad, *peerpad;
const GstCaps *caps;
GstStructure *str;
gint width,height;
gint rate1, rate2;
int i, slotid;
int max_video_threads;
char movieLocation[FILENAME_MAX];
psych_bool printErrors;
GstIterator *it;
psych_bool done;
GstPlayFlags playflags = 0;
psych_bool needCodecSetup = FALSE;
// Suppress output of error-messages if moviehandle == 1000. That means we
// run in our own Posix-Thread, not in the Matlab-Thread. Printing via Matlabs
// printing facilities would likely cause a terrible crash.
printErrors = (*moviehandle == -1000) ? FALSE : TRUE;
// Gapless playback requested? Normally *moviehandle is == -1, so a positive
// handle requests this mode and defines the actual handle of the movie to use:
if (*moviehandle >= 0) {
// Queueing a new moviename of a movie to play next: This only works
// for already opened/created movies whose pipeline is at least in
// READY state, better PAUSED or PLAYING. Validate preconditions:
// Valid handle for existing movie?
if (*moviehandle < 0 || *moviehandle >= PSYCH_MAX_MOVIES) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided!");
}
// Fetch references to objects we need:
theMovie = movieRecordBANK[*moviehandle].theMovie;
if (theMovie == NULL) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided. No movie associated with this handle !!!");
}
// Ok, this means we have a handle to an existing, fully operational
// playback pipeline. Convert moviename to a valid URL and queue it:
// Create name-string for moviename: If an URI qualifier is at the beginning,
// we're fine and just pass the URI as-is. Otherwise we add the file:// URI prefix.
if (strstr(moviename, "://") || ((strstr(moviename, "v4l") == moviename) && strstr(moviename, "//"))) {
snprintf(movieLocation, sizeof(movieLocation)-1, "%s", moviename);
} else {
snprintf(movieLocation, sizeof(movieLocation)-1, "file:///%s", moviename);
}
strncpy(movieRecordBANK[*moviehandle].movieLocation, movieLocation, FILENAME_MAX);
strncpy(movieRecordBANK[*moviehandle].movieName, moviename, FILENAME_MAX);
// Assign name of movie to play to pipeline. If the pipeline is not in playing
// state, this will switch to the specified movieLocation immediately. If it
// is playing, it will switch to it at the end of the current playback iteration:
g_object_set(G_OBJECT(theMovie), "uri", movieLocation, NULL);
// Ready.
return;
}
// Set movie handle to "failed" initially:
*moviehandle = -1;
// We start GStreamer only on first invocation.
if (firsttime) {
// Initialize GStreamer: The routine is defined in PsychVideoCaptureSupportGStreamer.c
PsychGSCheckInit("movie playback");
firsttime = FALSE;
}
if (win && !PsychIsOnscreenWindow(win)) {
if (printErrors)
PsychErrorExitMsg(PsychError_user, "Provided windowPtr is not an onscreen window.");
else
return;
}
// As a side effect of some PsychGSCheckInit() some broken GStreamer runtimes can change
// the OpenGL context binding behind our back to some GStreamer internal context.
// Make sure our own context is bound after return from PsychGSCheckInit() to protect
// against the state bleeding this would cause:
if (win) PsychSetGLContext(win);
if (NULL == moviename) {
if (printErrors)
PsychErrorExitMsg(PsychError_internal, "NULL-Ptr instead of moviename passed!");
else
return;
}
if (numMovieRecords >= PSYCH_MAX_MOVIES) {
*moviehandle = -2;
if (printErrors)
PsychErrorExitMsg(PsychError_user, "Allowed maximum number of simultaneously open movies exceeded!");
else
return;
}
// Search first free slot in movieRecordBANK:
for (i = 0; (i < PSYCH_MAX_MOVIES) && (movieRecordBANK[i].theMovie); i++);
if (i >= PSYCH_MAX_MOVIES) {
*moviehandle = -2;
if (printErrors)
PsychErrorExitMsg(PsychError_user, "Allowed maximum number of simultaneously open movies exceeded!");
else
return;
}
// Slot slotid will contain the movie record for our new movie object:
slotid=i;
// Zero-out new record in moviebank:
memset(&movieRecordBANK[slotid], 0, sizeof(PsychMovieRecordType));
// Store specialFlags1 from open call:
movieRecordBANK[slotid].specialFlags1 = specialFlags1;
// Create name-string for moviename: If an URI qualifier is at the beginning,
// we're fine and just pass the URI as-is. Otherwise we add the file:// URI prefix.
if (strstr(moviename, "://") || ((strstr(moviename, "v4l") == moviename) && strstr(moviename, "//"))) {
snprintf(movieLocation, sizeof(movieLocation)-1, "%s", moviename);
} else {
snprintf(movieLocation, sizeof(movieLocation)-1, "file:///%s", moviename);
}
strncpy(movieRecordBANK[slotid].movieLocation, movieLocation, FILENAME_MAX);
strncpy(movieRecordBANK[slotid].movieName, moviename, FILENAME_MAX);
// Try to disable hardware accelerated movie playback if requested by specialFlags1 flag 4:
if (specialFlags1 & 4) {
guint major, minor;
gst_plugins_base_version(&major, &minor, NULL, NULL);
// GStreamer 1.18+ allows to en/disable hw accelerated decoding dynamically via GST_PLAY_FLAG_FORCE_SW_DECODERS:
// Note this would not work with playbin3, but we only use playbin2 aka playbin, so we are fine with this.
if (major > 1 || minor >= 18)
playflags |= GST_PLAY_FLAG_FORCE_SW_DECODERS;
// GStreamer 1.16 and earlier only allows easy disable for the duration of a whole session by messing with hw plugin ranks:
if ((major == 1 && minor < 18) && !PsychEnableGStreamerHardwareVideoDecoding(FALSE) && (PsychPrefStateGet_Verbosity() > 1)) {
// Failed: Tell user.
printf("PTB-WARNING: Failed to disable GStreamer hardware accelerated video decoding!\n");
}
else if (PsychPrefStateGet_Verbosity() > 3) {
// All good: This statement applies to case-by-case on GStreamer 1.18+ on Ubuntu 22.04-LTS+, and Debian 11+,
// and RaspberryPi OS 11+. It applies for the remainder of a Octave/Matlab session on GStreamer < 1.18, e.g.,
// Ubuntu 20.04-LTS and earlier:
printf("PTB-INFO: GStreamer hardware accelerated video decoding disabled on user request (specialFlags1 +4).\n");
}
}
// Create movie playback pipeline:
if (TRUE) {
// Use playbin:
theMovie = gst_element_factory_make("playbin", "ptbmovieplaybackpipeline");
movieRecordBANK[slotid].theMovie = theMovie;
if (theMovie == NULL) {
printf("PTB-ERROR: Failed to create GStreamer playbin element! Your GStreamer installation is\n");
printf("PTB-ERROR: incomplete or damaged and misses at least the gst-plugins-base set of plugins!\n");
if (printErrors)
PsychErrorExitMsg(PsychError_system, "Opening the movie failed. GStreamer configuration problem.");
else
return;
}
// Assign name of movie to play:
g_object_set(G_OBJECT(theMovie), "uri", movieLocation, NULL);
// Default flags for playbin: Decode video ...
playflags |= GST_PLAY_FLAG_VIDEO;
// ... and deinterlace it if needed, unless prevented by specialFlags setting 256:
if (!(specialFlags1 & 256)) playflags |= GST_PLAY_FLAG_DEINTERLACE;
// Decode and play audio by default, with software audio volume control, unless specialFlags setting 2 enabled:
if (!(specialFlags1 & 2)) playflags |= GST_PLAY_FLAG_AUDIO | GST_PLAY_FLAG_SOFT_VOLUME;
// Enable network buffering for network videos of at least 10 seconds, or preloadSecs seconds,
// whatever is bigger.
// Setup without any buffering and caching (aka preloadSecs == 0) requested?
// Note: For now treat the default preloadSecs value 1 as a zero -> No buffering and caching.
// Why? Because the usefulness of this extra setup is not yet proven and the specific choice
// of buffering parameters may need a bit of tuning. We don't want to cause regressions in
// performance of existing scripts, so we stick to the GStreamer default buffering behaviour
// until more time has been spent tuning & testing this setup code.
if ((preloadSecs != 0) && (preloadSecs != 1)) {
// No: Use internal buffering/caching [BUFFERING] of demultiplexed/parsed data, e.g., for fast
// recycling during looped video playback, random access out-of-order frame fetching, fast
// seeking and reverse playback:
playflags |= GST_PLAY_FLAG_BUFFERING;
// Ok, this is ugly: Some movie formats, when streamed from the internet, need progressive
// download buffering to work without problems, whereas other formats will cause problems
// with progressive download buffering. So far we know that some .mov Quicktime movies, e.g.,
// Apple's commercials need it, whereas some .webm movies choke on it. Let's be optimistic
// and assume it works with everything except .webm. Also provide secret cheat code == -2
// to override the blacklisting of .webm to allow for further experiments:
if ((preloadSecs == -2) || (!strstr(moviename, ".webm"))) {
// Want some local progressive download buffering [DOWNLOAD] for network video streams,
// as temporary file on local filesystem:
playflags |= GST_PLAY_FLAG_DOWNLOAD;
}
// Undo our cheat-code if used: Map to 10 seconds preload time:
if (preloadSecs == -2) preloadSecs = 10;
// Setting maximum size of internal RAM ringbuffer supported? (since v0.10.31)
if (g_object_class_find_property(G_OBJECT_GET_CLASS(theMovie), "ring-buffer-max-size")) {
// Supported. The ringbuffer is disabled by default, we enable it with a certain maximum
// size in bytes. For preloadSecs == -1, aka "unlimited buffering", we set it to its
// allowable maximum of G_MAXUINT == 4 GB. For a given finite preloadSecs we have
// to set something reasonable. Set it to preloadSecs buffer duration (in seconds) multiplied
// by some assumed maximum datarate in bytes/second. We use 4e6 bytes, which is roughly
// 4 MB/sec. Why? This is a generously padded value, assuming a max. fps of 60 Hz, max.
// resolution 1920x1080p HD video + HD audio. Numbers are based on the bit rates of
// a HD movie trailer (Warner Brothers "I am Legend" public HD movie trailer), which has
// 7887 kbits/s for 1920x816 H264/AVC progessive scan video at 24 fps and 258 kbits/s for
// MPEG-4 AAC audio in Surround 5.1 format with 48 kHz sampling rate. This upscaled to
// research use and padded should give a good value for our purpose. Also at a default
// preloadSecs value of 1 second, this wastes at most 4 MB for buffering - a safe default:
g_object_set(G_OBJECT(theMovie), "ring-buffer-max-size", ((preloadSecs == -1) ? G_MAXUINT : (guint64) (preloadSecs * (double) 4e6)), NULL);
if (PsychPrefStateGet_Verbosity() > 4) {
printf("PTB-INFO: Playback for movie %i will use adapted RAM ring-buffer-max-size of %f MB.\n", slotid,
(float) (((double) ((preloadSecs == -1) ? G_MAXUINT : preloadSecs * (double) 4e6)) / 1024.0 / 1024.0));
}
}
// Setting of maximum buffer duration for network video stream playback:
if (preloadSecs == -1) {
// "Unlimited" - Set maximum buffering size to G_MAXINT == 2 GB.
g_object_set(G_OBJECT(theMovie), "buffer-size", (gint) G_MAXINT, NULL);
}
else {
// Limited - Set maximum buffer-duration to preloadSecs, the playbin will derive
// a proper maximum buffering size from duration and streaming bitrate:
g_object_set(G_OBJECT(theMovie), "buffer-duration", (gint64) (preloadSecs * (double) 1e9), NULL);
}
if (PsychPrefStateGet_Verbosity() > 4) {
printf("PTB-INFO: Playback for movie %i will use RAM buffering. Additional prebuffering for network streams is\n", slotid);
printf("PTB-INFO: limited to %f %s.\n", (preloadSecs == -1) ? 2 : preloadSecs, (preloadSecs == -1) ? "GB" : "seconds");
if (playflags & GST_PLAY_FLAG_DOWNLOAD) printf("PTB-INFO: Network video streams will be additionally cached to the filesystem.\n");
}
// All in all, we can end up with up to 6*x GB RAM and 6 GB disc consumption for the "unlimited" setting,
// about 4*x MB RAM and 4 MB disc consumption for the default setting of 1, and preloadSecs multiples of
// that for a given value. x is an unkown factor, depending on which internal plugins maintain ringbuffers,
// but assume x somewhere between 1 and maybe 4.
}
else {
if (PsychPrefStateGet_Verbosity() > 4) {
printf("PTB-INFO: Playback for movie %i will not use additional buffering or caching due to 'preloadSecs' setting %i.\n", slotid, (int) preloadSecs);
}
}
// Setup final playback control flags:
g_object_set(G_OBJECT(theMovie), "flags", playflags , NULL);
// Connect callback to about-to-finish signal: Signal is emitted as soon as
// end of current playback iteration is approaching. The callback checks if
// looped playback is requested. If so, it schedules a new playback iteration.
g_signal_connect(G_OBJECT(theMovie), "about-to-finish", G_CALLBACK(PsychMovieAboutToFinishCB), &(movieRecordBANK[slotid]));
}
else {
// Self-Assembled pipeline: Does not work for some not yet investigated reason,
// but is not needed anyway, so we disable it and just leave it for documentation,
// in case it will be needed in the future:
sprintf(movieLocation, "filesrc location='%s' ! qtdemux ! queue ! ffdec_h264 ! ffmpegcolorspace ! appsink name=ptbsink0", moviename);
theMovie = gst_parse_launch((const gchar*) movieLocation, NULL);
movieRecordBANK[slotid].theMovie = theMovie;
videosink = gst_bin_get_by_name(GST_BIN(theMovie), "ptbsink0");
printf("LAUNCHLINE[%p]: %s\n", videosink, movieLocation);
}
// Assign a fakesink named "ptbsink0" as destination video-sink for
// all video content. This allows us to get hold of the video frame buffers for
// converting them into PTB OpenGL textures:
if (!videosink)
videosink = gst_element_factory_make ("appsink", "ptbsink0");
if (!videosink) {
printf("PTB-ERROR: Failed to create video-sink appsink ptbsink! Your GStreamer installation is\n");
printf("PTB-ERROR: incomplete or damaged and misses at least the gst-plugins-base set of plugins!\n");
PsychGSProcessMovieContext(&(movieRecordBANK[slotid]), TRUE);
if (printErrors)
PsychErrorExitMsg(PsychError_system, "Opening the movie failed. Reason hopefully given above.");
else
return;
}
movieRecordBANK[slotid].videosink = videosink;
// Setting flag 1 in specialFlags1 is equivalent to setting pixelFormat == 5, to retain
// backwards compatibility to previous ptb releases:
if (specialFlags1 & 0x1) pixelFormat = 5;
// Assign initial pixelFormat to use, as requested by usercode:
movieRecordBANK[slotid].pixelFormat = pixelFormat;
// Default to 8 bpc bitdepth as a starter:
movieRecordBANK[slotid].bitdepth = 8;
// Our OpenGL texture creation routine usually needs GL_BGRA8 data in G_UNSIGNED_8_8_8_8_REV
// format, but the pipeline usually delivers YUV data in planar format. Therefore
// need to perform colorspace/colorformat conversion. We build a little videobin
// which consists of a ffmpegcolorspace converter plugin connected to our appsink
// plugin which will deliver video data to us for conversion into textures.
// The "sink" pad of the converter plugin is connected as the "sink" pad of our
// videobin, and the videobin is connected to the video-sink output of the pipeline,
// thereby receiving decoded video data. We place a videocaps filter inbetween the
// converter and the appsink to enforce a color format conversion to the "colorcaps"
// we need. colorcaps define the needed data format for efficient conversion into
// a RGBA8 texture. Some GPU + driver combos do support direct handling of UYVU YCrCb 4:2:2
// packed pixel data as textures. If we are on such a GPU we request UYVY data and upload it
// directly in this format to the GPU. This more efficient both for the GStreamers decode
// pipeline, and the later Videobuffer -> OpenGL texture conversion:
if (win && (win->gfxcaps & kPsychGfxCapUYVYTexture) && (movieRecordBANK[slotid].pixelFormat == 5)) {
// GPU supports handling and decoding of UYVY type yuv textures: We use these,
// as they are more efficient to decode and handle by typical video codecs:
colorcaps = gst_caps_new_simple ("video/x-raw",
"format", G_TYPE_STRING, "UYVY",
NULL);
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Movie playback for movie %i will use UYVY YCrCb 4:2:2 textures for optimized decode and rendering.\n", slotid);
}
else if ((movieRecordBANK[slotid].pixelFormat == 6) && win && (win->gfxcaps & kPsychGfxCapFBO) && PsychAssignPlanarI420TextureShader(NULL, win)) {
// Usercode wants YUV I420 planar encoded format and GPU suppports needed fragment shaders and FBO's.
// Ask for I420 decoded video. This is the native output format of HuffYUV and H264 codecs, so using it
// allows to skip colorspace conversion in GStreamer. The format is also highly efficient for texture
// creation and upload to the GPU, but requires a fragment shader for colorspace conversion during drawing:
colorcaps = gst_caps_new_simple ("video/x-raw",
"format", G_TYPE_STRING, "I420",
NULL);
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Movie playback for movie %i will use YUV-I420 planar textures for optimized decode and rendering.\n", slotid);
}
else if (((movieRecordBANK[slotid].pixelFormat == 7) || (movieRecordBANK[slotid].pixelFormat == 8)) && win && (win->gfxcaps & kPsychGfxCapFBO) && PsychAssignPlanarI800TextureShader(NULL, win)) {
// Usercode wants Y8/Y800 planar encoded format and GPU suppports needed fragment shaders and FBO's.
// Ask for I420 or Y800 decoded video. I420 is the native output format of HuffYUV and H264 codecs, so using it
// allows to skip colorspace conversion in GStreamer. The format is also highly efficient for texture
// creation and upload to the GPU, but requires a fragment shader for colorspace conversion during drawing:
// Note: The FOURCC 'Y800' is equivalent to 'Y8 ' and 'GREY' as far as we know. As of June 2012, using the
// Y800 decoding doesn't have any performance benefits compared to I420 decoding, actually performance is a
// little bit lower. Apparently the video codecs don't take the Y800 format into account, ie., they don't skip
// decoding of the chroma components, instead they probably decode as usual and the colorspace conversion then
// throws away the unwanted chroma planes, causing possible extra overhead for discarding this data. We leave
// the option in anyway, because there may be codecs (possibly in future GStreamer versions) that can take
// advantage of Y800 format for higher performance.
colorcaps = gst_caps_new_simple ("video/x-raw",
"format", G_TYPE_STRING,
(movieRecordBANK[slotid].pixelFormat == 8) ? "Y800" : "I420",
NULL);
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Movie playback for movie %i will use Y8-I800 planar textures for optimized decode and rendering.\n", slotid);
}
else if ((movieRecordBANK[slotid].pixelFormat == 11) && win && (win->gfxcaps & kPsychGfxCapFBO) &&
glewIsSupported("GL_ARB_shader_objects") && glewIsSupported("GL_ARB_shading_language_100") &&
glewIsSupported("GL_ARB_fragment_shader") && glewIsSupported("GL_ARB_vertex_shader")) {
// Usercode wants optimal format for HDR/WCG playback and GPU suppports needed shaders and FBO's.
//
// This mode accepts HDR/WCG video footage as decoded (semi-)planar YUV of different layout, range, different
// bit-depths, different color spaces, EOTF's, and tries to decode as accurate and fast as possible into a
// RGB linear format of high precision suitable for HDR content.
//
// As planar YUV is the native output format of all modern codecs like HuffYUV, H264/H265/VP-9 codecs, using
// it allows to skip cpu intensive colorspace conversion in GStreamer. The format is also highly efficient for
// texture creation and upload to the GPU, but requires a fragment shader for sampling, color space conversion,
// EOTF mapping etc. during drawing.
//
// Planar YUV seems to be mostly output by high performance software codecs, e.g., libav codecs and similar.
// Semi-planar YUV seems to be mostly output by GStreamer hardware codecs on at least Windows and Linux, e.g.,
// the Direct3D 11 and NVDEC hardware codecs supported on MS-Windows, and the vaapi hardware codecs on Linux,
// which all utilize the hardware video decoders in modern AMD, NVidia and Intel gpus.
// We accept planar 4:2:0 I420 YUV of color depth 8, 10, 12 bpc input:
colorcaps = gst_caps_new_simple ("video/x-raw",
"format", G_TYPE_STRING, "I420",
NULL);
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "I420_10LE", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "I420_12LE", NULL));
// We also accept planar 4:2:2 I422 YUV of color depth 8, 10 and 12 bpc:
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "Y42B", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "I422_10LE", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "I422_12LE", NULL));
// We also accept planar 4:4:4 I444 YUV aka Y444 of color depth 8, 10, 12 and 16 bpc:
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "Y444", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "Y444_10LE", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "Y444_12LE", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "Y444_16LE", NULL));
// We also accept the 4:2:0 semi-planar (chroma plane with horizontally UV interleaved samples) P0xx 8/10/12/16 bit formats:
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "NV12", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "P010_10LE", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "P012_LE", NULL));
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "P016_LE", NULL));
// We also accept the 4:2:2 semi-planar (chroma plane with horizontally UV interleaved samples) P2xx 8 bit format:
gst_caps_append(colorcaps, gst_caps_new_simple("video/x-raw", "format", G_TYPE_STRING, "NV16", NULL));
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Movie playback for movie %i will accept YUV-I420/I422/I444/Pxxx (semi-)planar textures of 8, 10, 12 or 16 bpc for optimized decode of HDR/WCG compatible content.\n", slotid);
}
else {
// GPU does not support yuv textures or shader based decoding. Need to go brute-force and convert
// video into RGBA8 format:
// Force unsupportable formats to RGBA8 aka format 4, except for formats 7/8, which map
// to 1 == L8, and map 2 == LA8 to 1 == L8:
switch (movieRecordBANK[slotid].pixelFormat) {
case 1: // 1 is fine.
break;
case 3: // 3 is handled after switch-case.
break;
case 4: // 4 is fine.
break;
case 2:
case 7:
case 8:
movieRecordBANK[slotid].pixelFormat = 1;
break;
case 5:
case 6:
case 11:
movieRecordBANK[slotid].pixelFormat = 4;
break;
case 9: // 9 and 10 are fine:
case 10:
break;
default:
if (printErrors)
PsychErrorExitMsg(PsychError_user, "Invalid 'pixelFormat' parameter specified!");
else
// Revert to something safe, RGBA8, as we can not error abort here:
movieRecordBANK[slotid].pixelFormat = 4;
break;
}
// Map 3 == RGB8 to 4 == RGBA8, unless it is our special proprietary 16 bpc encoding:
if ((movieRecordBANK[slotid].pixelFormat == 3) && !(specialFlags1 & 512)) movieRecordBANK[slotid].pixelFormat = 4;
// At this point we can have any of these pixelFormats: 1, 3, 4, 9, 10. Handle them:
if (movieRecordBANK[slotid].pixelFormat == 4) {
// Use RGBA8 format:
colorcaps = gst_caps_new_simple("video/x-raw",
"format", G_TYPE_STRING, "BGRA",
NULL);
if ((PsychPrefStateGet_Verbosity() > 3) && (pixelFormat == 5)) printf("PTB-INFO: Movie playback for movie %i will use RGBA8 textures due to lack of YUV-422 texture support on GPU.\n", slotid);
if ((PsychPrefStateGet_Verbosity() > 3) && (pixelFormat == 6)) printf("PTB-INFO: Movie playback for movie %i will use RGBA8 textures due to lack of YUV-I420 support on GPU.\n", slotid);
if ((PsychPrefStateGet_Verbosity() > 3) && ((pixelFormat == 7) || (pixelFormat == 8))) printf("PTB-INFO: Movie playback for movie %i will use L8 textures due to lack of Y8-I800 support on GPU.\n", slotid);
if ((PsychPrefStateGet_Verbosity() > 1) && (pixelFormat == 11)) printf("PTB-WARNING: Movie playback for movie %i will use RGBA8 textures for HDR playback due to lack of YUV-I420 HDR support on GPU. Results may be wrong!\n", slotid);
if ((PsychPrefStateGet_Verbosity() > 3) && !(pixelFormat < 5)) printf("PTB-INFO: Movie playback for movie %i will use RGBA8 textures.\n", slotid);
}
if ((movieRecordBANK[slotid].pixelFormat == 1) && !(specialFlags1 & 512)) {
// Use LUMINANCE8 format:
colorcaps = gst_caps_new_simple("video/x-raw",
"format", G_TYPE_STRING, "GRAY8",
NULL);
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Movie playback for movie %i will use L8 luminance textures.\n", slotid);
}
// Psychtoolbox proprietary 16 bpc pixelformat for 1 or 3 channel data?
if ((pixelFormat == 1 || pixelFormat == 3) && (specialFlags1 & 512)) {
// Yes. Need to always decode as RGB8 24 bpp: Texture creation will then handle this further.
colorcaps = gst_caps_new_simple("video/x-raw",
"format", G_TYPE_STRING, "RGB",
NULL);
movieRecordBANK[slotid].pixelFormat = pixelFormat;
}
if (movieRecordBANK[slotid].pixelFormat == 9) {
// Use GRAY 16 bpc format for 16 bpc decoding:
colorcaps = gst_caps_new_simple("video/x-raw",
"format", G_TYPE_STRING, "GRAY16_LE",
NULL);
// Switch to 16 bpc bitdepth and single channel pixelFormat:
movieRecordBANK[slotid].bitdepth = 16;
movieRecordBANK[slotid].pixelFormat = 1;
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Movie playback for movie %i will use 16 bpc LUMINANCE 16 float textures.\n", slotid);
}
if (movieRecordBANK[slotid].pixelFormat == 10) {
// Use ARGB64 16 bpc per color channel format for 16 bpc decoding:
colorcaps = gst_caps_new_simple("video/x-raw",
"format", G_TYPE_STRING, "ARGB64",
NULL);
// Switch to 16 bpc bitdepth and 4-channel RGBA pixelFormat:
movieRecordBANK[slotid].bitdepth = 16;
movieRecordBANK[slotid].pixelFormat = 4;
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Movie playback for movie %i will use 16 bpc RGBA 16 bpc float textures.\n", slotid);
}
}
// Assign 'colorcaps' as caps to our videosink. This marks the videosink so
// that it can only receive video image data in the format defined by colorcaps,
// i.e., a format that is easy to consume for OpenGL's texture creation on std.
// gpu's. It is the job of the video pipeline's autoplugger to plug in proper
// color & format conversion plugins to satisfy videosink's needs.
gst_app_sink_set_caps(GST_APP_SINK(videosink), colorcaps);
// Assign our special appsink 'videosink' as video-sink of the pipeline:
g_object_set(G_OBJECT(theMovie), "video-sink", videosink, NULL);
gst_caps_unref(colorcaps);
PsychGSProcessMovieContext(&(movieRecordBANK[slotid]), FALSE);
// Attach custom made audio sink?
if ((pstring = strstr(movieOptions, "AudioSink="))) {
pstring += strlen("AudioSink=");
pstring = strdup(pstring);
if (strstr(pstring, ":::") != NULL) *(strstr(pstring, ":::")) = 0;
audiosink = gst_parse_bin_from_description((const gchar *) pstring, TRUE, NULL);
if (audiosink) {
g_object_set(G_OBJECT(theMovie), "audio-sink", audiosink, NULL);
audiosink = NULL;
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Attached custom audio sink for playback of movie. Spec: '%s'\n", pstring);
free(pstring); pstring = NULL;
}
else {
printf("PTB-ERROR: Could not create requested audio sink for playback of movie! Failing sink spec was: '%s'\n", pstring);
free(pstring); pstring = NULL;
if (printErrors)
PsychErrorExitMsg(PsychError_user, "Failed to create custom audio sink for movie playback.");
else
return;
}
}
// Preload / Preroll the pipeline:
if (!PsychMoviePipelineSetState(theMovie, GST_STATE_PAUSED, 30.0)) {
PsychGSProcessMovieContext(&(movieRecordBANK[slotid]), TRUE);
if (printErrors)
PsychErrorExitMsg(PsychError_user, "In OpenMovie: Opening the movie failed I. Reason given above.");
else
return;
}
// Set video decoder parameters:
// First we try to find the video decoder plugin in the media graph. We iterate over all
// elements and try to find one whose properties match known properties of video codecs:
// Note: The typeid/name or classid/name proved useless for finding the video codec, as
// the video codecs are not derived from some "video codec class", but each codec defines
// its own type and class.
it = gst_bin_iterate_recurse(GST_BIN(theMovie));
done = FALSE;
videocodec = NULL;
while (!done) {
switch (gst_iterator_next(it, &item)) {
case GST_ITERATOR_OK:
videocodec = g_value_peek_pointer(&item);
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-DEBUG: In pipeline: Child element name: %s\n", (const char*) gst_object_get_name(GST_OBJECT(videocodec)));
// Our current match critera for video codecs: Having at least one of the properties "max-threads" or "lowres":
if ((g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "max-threads")) ||
(g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "lowres")) ||
(g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "debug-mv")) ||
(g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "skip-frame"))) {
if (PsychPrefStateGet_Verbosity() > 4) printf("PTB-DEBUG: Found video decoder element %s.\n", (const char*) gst_object_get_name(GST_OBJECT(videocodec)));
done = TRUE;
} else {
videocodec = NULL;
g_value_reset(&item);
}
break;
case GST_ITERATOR_RESYNC:
gst_iterator_resync(it);
break;
case GST_ITERATOR_DONE:
done = TRUE;
break;
default:
videocodec = NULL;
}
}
g_value_unset(&item);
gst_iterator_free(it);
it = NULL;
// Check if some codec properties need to be changed.
// This happens if usercode provides some supported non-default override parameter for the codec,
// or if the codec is multi-threaded and usercode wants us to configure its multi-threading behaviour:
needCodecSetup = FALSE;
if (videocodec && ((g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "max-threads") && (maxNumberThreads > -1)) ||
(g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "lowres") && (specialFlags1 & (0))) || /* MK: 'lowres' disabled for now. */
(g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "skip-frame") && (specialFlags1 & 8))
)) {
needCodecSetup = TRUE;
}
// Set videocodec state to "ready" if parameter change is needed, as the codec only
// accepts the new settings in that state:
if (needCodecSetup) {
// Ready the video codec, so a new max thread count or other parameters can be set:
if (!PsychMoviePipelineSetState(videocodec, GST_STATE_READY, 30.0)) {
PsychGSProcessMovieContext(&(movieRecordBANK[slotid]), TRUE);
if (printErrors)
PsychErrorExitMsg(PsychError_user, "In OpenMovie: Opening the movie failed III. Reason given above.");
else
return;
}
}
// Skipping of B-Frames video decoding requested by usercode specialflags1 flag 8? If so, enable skipping:
if (needCodecSetup && (specialFlags1 & 8) && (g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "skip-frame"))) {
g_object_set(G_OBJECT(videocodec), "skip-frame", 1, NULL);
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Playback for movie %i will skip B-Frames during video decoding for higher speed.\n", slotid);
}
// Multi-threaded codec and usercode requests setup? If so, set its multi-threading behaviour:
// By default many codecs would only use one single thread on any system, even if they are multi-threading capable.
if (needCodecSetup && (g_object_class_find_property(G_OBJECT_GET_CLASS(videocodec), "max-threads")) && (maxNumberThreads > -1)) {
max_video_threads = 1;
g_object_get(G_OBJECT(videocodec), "max-threads", &max_video_threads, NULL);
if (PsychPrefStateGet_Verbosity() > 4) printf("PTB-INFO: Movie playback for movie %i uses video decoder with a default maximum number of %i processing threads.\n", slotid, max_video_threads);
// Specific number of threads requested, or zero for auto-select?
if (maxNumberThreads > 0) {
// Specific value provided: Use it.
max_video_threads = maxNumberThreads;
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Setting video decoder to use a maximum of %i processing threads.\n", max_video_threads);
} else {
// Default behaviour: A settig of zero asks GStreamer to auto-detect the optimal
// setting for the given host computer -- typically number of threads == number of processor cores:
max_video_threads = 0;
if (PsychPrefStateGet_Verbosity() > 3) printf("PTB-INFO: Setting video decoder to use auto-selected optimal number of processing threads.\n");
}
// Assign new setting:
g_object_set(G_OBJECT(videocodec), "max-threads", max_video_threads, NULL);
// Requery:
g_object_get(G_OBJECT(videocodec), "max-threads", &max_video_threads, NULL);
if (PsychPrefStateGet_Verbosity() > 4) {
if (max_video_threads != 0) {
printf("PTB-INFO: Movie playback for movie %i uses video decoder with a current maximum number of %i processing threads.\n", slotid, max_video_threads);
} else {
printf("PTB-INFO: Movie playback for movie %i uses video decoder with a current auto-detected optimal number of processing threads.\n", slotid);
}
}
}
// Bring codec back to paused state, so it is ready to do its job with the
// new codec parameters set:
if (needCodecSetup) {
// Pause the video codec, so the new max thread count is accepted:
if (!PsychMoviePipelineSetState(videocodec, GST_STATE_PAUSED, 30.0)) {
PsychGSProcessMovieContext(&(movieRecordBANK[slotid]), TRUE);
if (printErrors)
PsychErrorExitMsg(PsychError_user, "In OpenMovie: Opening the movie failed IV. Reason given above.");
else
return;
}
}
// Query number of available video and audio tracks in movie:
g_object_get (G_OBJECT(theMovie),
"n-video", &movieRecordBANK[slotid].nrVideoTracks,
"n-audio", &movieRecordBANK[slotid].nrAudioTracks,
NULL);
// We need a valid onscreen window handle for real video playback:
if ((NULL == win) && (movieRecordBANK[slotid].nrVideoTracks > 0)) {
if (printErrors)
PsychErrorExitMsg(PsychError_user, "No windowPtr to an onscreen window provided. Must do so for movies with videotrack!");
else
return;
}
PsychGSProcessMovieContext(&(movieRecordBANK[slotid]), FALSE);
PsychInitMutex(&movieRecordBANK[slotid].mutex);
PsychInitCondition(&movieRecordBANK[slotid].condition, NULL);
// Install callbacks used by the videosink (appsink) to announce various events:
gst_app_sink_set_callbacks(GST_APP_SINK(videosink), &videosinkCallbacks, &(movieRecordBANK[slotid]), PsychDestroyNotifyCallback);
// Assign harmless initial settings for fps and frame size:
rate1 = 0;
rate2 = 1;
width = height = 0;
// Videotrack available?
if (movieRecordBANK[slotid].nrVideoTracks > 0) {
caps = NULL;
if (videocodec) {
// Try to get the pad/caps from the videocodec, so we get original colorimetry information:
pad = gst_element_get_static_pad(videocodec, "src");
caps = gst_pad_get_current_caps(pad);
}
// No videocodec for caps query, or codec src caps query failed?
if (!caps) {
// Fallback: Get the pad from the final sink for probing width x height of movie frames and nominal framerate of movie:
pad = gst_element_get_static_pad(videosink, "sink");
peerpad = gst_pad_get_peer(pad);
caps = gst_pad_get_current_caps(peerpad);
gst_object_unref(peerpad);
}
// Got valid caps?
if (caps) {
// Yes: Query size and framerate of movie:
str = gst_caps_get_structure(caps, 0);
/* Get some data about the frame */
rate1 = 1; rate2 = 1;
gst_structure_get_fraction(str, "pixel-aspect-ratio", &rate1, &rate2);
movieRecordBANK[slotid].aspectRatio = (double) rate1 / (double) rate2;
gst_structure_get_int(str,"width", &width);
gst_structure_get_int(str,"height", &height);
rate1 = 0; rate2 = 1;
gst_structure_get_fraction(str, "framerate", &rate1, &rate2);
// Try to get more detailed info about video:
if (gst_video_info_from_caps (&movieRecordBANK[slotid].codecVideoInfo, caps)) {
if (PsychPrefStateGet_Verbosity() > 3) {
printf("PTB-DEBUG: Video colorimetry is %s.\n", gst_video_colorimetry_to_string (&movieRecordBANK[slotid].codecVideoInfo.colorimetry));
printf("PTB-DEBUG: Video range %i, colormatrix %i, color primaries %i, eotf %i.\n", movieRecordBANK[slotid].codecVideoInfo.colorimetry.range,
movieRecordBANK[slotid].codecVideoInfo.colorimetry.matrix, movieRecordBANK[slotid].codecVideoInfo.colorimetry.primaries,
movieRecordBANK[slotid].codecVideoInfo.colorimetry.transfer);
printf("PTB-DEBUG: Video format %s. Depth %i bpc.\n", movieRecordBANK[slotid].codecVideoInfo.finfo->name, *movieRecordBANK[slotid].codecVideoInfo.finfo->depth);
}
}
// Optional 'movieOptions' parameter 'OverrideEOTF=x' specified to override detected EOTF to type x?
if ((pstring = strstr(movieOptions, "OverrideEOTF="))) {
// Yes. Make it so, as long as pixelFormat 11 playback is requested:
if ((pixelFormat == 11) && (1 == sscanf(pstring, "OverrideEOTF=%i", (int *) &movieRecordBANK[slotid].codecVideoInfo.colorimetry.transfer))) {
if (PsychPrefStateGet_Verbosity() > 3)
printf("PTB-DEBUG: Video EOTF id overridden by 'movieOptions' parameter. New EOTF type is %i.\n", movieRecordBANK[slotid].codecVideoInfo.colorimetry.transfer);
} else {
if (PsychPrefStateGet_Verbosity() > 0)
printf("PTB-ERROR: Invalid OverrideEOTF parameter specified in 'movieOptions' [= '%s']: %s!\n", pstring, (pixelFormat == 11) ? "Could not parse EOTF id code - Must be a number" : "Only allowed for pixelFormat 11 playback");
if (printErrors)
PsychErrorExitMsg(PsychError_user, "Invalid OverrideEOTF parameter specified in 'movieOptions' parameter. Could not parse EOTF id code or unsuitable pixelFormat!");
else
return;
}
}
// Parse HDR static metadata from movie, if supported, and if any:
PsychParseMovieHDRMetadata(&movieRecordBANK[slotid], caps);
} else {
printf("PTB-DEBUG: No frame info available after preroll.\n");
}
// Release the pad:
gst_object_unref(pad);
pad = gst_element_get_static_pad(videosink, "sink");
peerpad = gst_pad_get_peer(pad);
caps = gst_pad_get_current_caps(peerpad);
// Try to get more detailed info about the actual content received by our sink:
if (gst_video_info_from_caps (&movieRecordBANK[slotid].sinkVideoInfo, caps)) {
if (PsychPrefStateGet_Verbosity() > 3) {
printf("PTB-DEBUG: Sink colorimetry is %s.\n", gst_video_colorimetry_to_string (&movieRecordBANK[slotid].sinkVideoInfo.colorimetry));
printf("PTB-DEBUG: Sink range %i, colormatrix %i, color primaries %i, eotf %i.\n", movieRecordBANK[slotid].sinkVideoInfo.colorimetry.range,
movieRecordBANK[slotid].sinkVideoInfo.colorimetry.matrix, movieRecordBANK[slotid].sinkVideoInfo.colorimetry.primaries,
movieRecordBANK[slotid].sinkVideoInfo.colorimetry.transfer);
printf("PTB-DEBUG: Sink format %s. Depth %i bpc.\n", movieRecordBANK[slotid].sinkVideoInfo.finfo->name, *movieRecordBANK[slotid].sinkVideoInfo.finfo->depth);
}
}
gst_object_unref(peerpad);
// Release the pad:
gst_object_unref(pad);
}
if (strstr(moviename, "v4l2:")) {
// Special case: The "movie" is actually a video4linux2 live source.
// Need to make parameters up for now, so it to work as "movie":
rate1 = 30; width = 640; height = 480;
movieRecordBANK[slotid].nrVideoTracks = 1;
// Uglyness at its best ;-)
if (strstr(moviename, "320")) { width = 320; height = 240; };
}
// NULL out videocodec, we must not unref it, as we didn't aquire or own private ref:
videocodec = NULL;
// Assign new record in moviebank:
movieRecordBANK[slotid].theMovie = theMovie;
movieRecordBANK[slotid].loopflag = 0;
movieRecordBANK[slotid].frameAvail = 0;
movieRecordBANK[slotid].imageBuffer = NULL;
movieRecordBANK[slotid].startPending = 0;
movieRecordBANK[slotid].endOfFetch = 0;
*moviehandle = slotid;
// Increase counter:
numMovieRecords++;
// Compute basic movie properties - Duration and fps as well as image size:
// Retrieve duration in seconds:
if (gst_element_query_duration(theMovie, GST_FORMAT_TIME, &length_format)) {
// This returns nsecs, so convert to seconds:
movieRecordBANK[slotid].movieduration = (double) length_format / (double) 1e9;
//printf("PTB-DEBUG: Duration of movie %i [%s] is %lf seconds.\n", slotid, moviename, movieRecordBANK[slotid].movieduration);
} else {
movieRecordBANK[slotid].movieduration = DBL_MAX;
if (PsychPrefStateGet_Verbosity() > 1)
printf("PTB-WARNING: Could not query duration of movie %i [%s] in seconds. Returning infinity.\n", slotid, moviename);
}
// Assign expected framerate, assuming a linear spacing between frames:
movieRecordBANK[slotid].fps = (double) rate1 / (double) rate2;
//printf("PTB-DEBUG: Framerate fps of movie %i [%s] is %lf fps.\n", slotid, moviename, movieRecordBANK[slotid].fps);
// Drop frames if callback can't pull buffers fast enough, unless ascynFlags & 4 is set:
// This together with a max queue lengths of 1 allows to
// maintain audio-video sync by framedropping if needed.
gst_app_sink_set_drop(GST_APP_SINK(videosink), (asyncFlag & 4) ? FALSE : TRUE);
// Buffering of decoded video frames requested?
if (asyncFlag & 4) {
// Yes: If a specific preloadSecs and a valid fps playback framerate is available, we
// set the maximum buffer capacity to the number of frames corresponding to the given 'preloadSecs'.
// Otherwise we set it to zero, which means "unlimited capacity", ie., until RAM full:
gst_app_sink_set_max_buffers(GST_APP_SINK(videosink),
((movieRecordBANK[slotid].fps > 0) && (preloadSecs >= 0)) ? ((int) (movieRecordBANK[slotid].fps * preloadSecs) + 1) : 0);
}
else {
// No: Only allow one queued buffer before dropping, to avoid optimal audio-video sync:
gst_app_sink_set_max_buffers(GST_APP_SINK(videosink), 1);
}
// Compute framecount from fps and duration:
movieRecordBANK[slotid].nrframes = (int)(movieRecordBANK[slotid].fps * movieRecordBANK[slotid].movieduration + 0.5);
//printf("PTB-DEBUG: Number of frames in movie %i [%s] is %i.\n", slotid, moviename, movieRecordBANK[slotid].nrframes);
// Is this movie supposed to be encoded in Psychtoolbox special proprietary "16 bpc stuffed into 8 bpc" format?
if (specialFlags1 & 512) {
// Yes. Invert the hacks applied during encoding/writing of movie:
// Only 1 layer and 3 layer are supported:
if (pixelFormat != 1 && pixelFormat !=3) {
if (printErrors)
PsychErrorExitMsg(PsychError_user, "You specified 'specialFlags1' setting 512 for Psychtoolbox proprietary 16 bpc decoding, but pixelFormat is not 1 or 3 as required for this decoding method!");
else
return;
}
// Set bitdepth of movie to 16 bpc for later texture creation from decoded video frames:
movieRecordBANK[slotid].bitdepth = 16;
// 1-layer: 1 bpc 16 gray pixel stored in 2/3 RGB8 pixel. This was achieved by multiplying
// height by 2/3 in encoding, so invert by multiplying with 3/2:
if (pixelFormat == 1) height = height * 3 / 2;
// 3-layer: 1 RGB16 pixel stored in two adjacent RGB8 pixels. This was achieved by doubling
// width, so undo by dividing width by 2:
if (pixelFormat == 3) width = width / 2;
if (PsychPrefStateGet_Verbosity() > 2) printf("PTB-INFO: Playing back movie in Psychtoolbox proprietary 16 bpc %i channel encoding.\n", pixelFormat);
}
// Make sure the input format for raw Bayer sensor data is actually 1 layer grayscale, and that PTB for this OS supports debayering:
if (specialFlags1 & 1024) {
if (movieRecordBANK[slotid].pixelFormat != 1) {
if (printErrors)
PsychErrorExitMsg(PsychError_user, "specialFlags1 & 1024 set to indicate this movie consists of raw Bayer sensor data, but pixelFormat is not == 1, as required!");
else
return;
}
// Abort early if libdc1394 support is not available on this configuration:
#ifndef PTBVIDEOCAPTURE_LIBDC
if (printErrors)
PsychErrorExitMsg(PsychError_user, "Sorry, Bayer filtering of video frames, as requested by specialFlags1 setting & 1024, is not supported on this operating system.");
else
return;
#endif
}
// Define size of images in movie:
movieRecordBANK[slotid].width = width;
movieRecordBANK[slotid].height = height;
// Assign parent window record, for use in movie deletion code:
movieRecordBANK[slotid].parentRecord = win;
// Should we dump the whole decoding pipeline graph to a file for visualization
// with GraphViz? This can be controlled via PsychTweak('GStreamerDumpFilterGraph' dirname);
if (getenv("GST_DEBUG_DUMP_DOT_DIR")) {
// Dump complete decoding filter graph to a .dot file for later visualization with GraphViz:
printf("PTB-DEBUG: Dumping movie decoder graph for movie %s to directory %s.\n", moviename, getenv("GST_DEBUG_DUMP_DOT_DIR"));
GST_DEBUG_BIN_TO_DOT_FILE_WITH_TS(GST_BIN(movieRecordBANK[slotid].theMovie), GST_DEBUG_GRAPH_SHOW_ALL, "PsychMoviePlaybackGraph");
}
// Ready to rock!
return;
}
/*
* PsychGSGetMovieInfos() - Return basic information about a movie.
*
* framecount = Total number of video frames in the movie, determined by counting.
* durationsecs = Total playback duration of the movie, in seconds.
* framerate = Estimated video playback framerate in frames per second (fps).
* width = Width of movie images in pixels.
* height = Height of movie images in pixels.
* nrdroppedframes = Total count of videoframes that had to be dropped during last movie playback,
* in order to keep the movie synced with the realtime clock.
*/
void PsychGSGetMovieInfos(int moviehandle, int* width, int* height, int* framecount, double* durationsecs, double* framerate, int* nrdroppedframes, double* aspectRatio)
{
if (moviehandle < 0 || moviehandle >= PSYCH_MAX_MOVIES) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided!");
}
if (movieRecordBANK[moviehandle].theMovie == NULL) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided. No movie associated with this handle !!!");
}
if (framecount) *framecount = movieRecordBANK[moviehandle].nrframes;
if (durationsecs) *durationsecs = movieRecordBANK[moviehandle].movieduration;
if (framerate) *framerate = movieRecordBANK[moviehandle].fps;
if (nrdroppedframes) *nrdroppedframes = movieRecordBANK[moviehandle].nr_droppedframes;
if (width) *width = movieRecordBANK[moviehandle].width;
if (height) *height = movieRecordBANK[moviehandle].height;
if (aspectRatio) *aspectRatio = movieRecordBANK[moviehandle].aspectRatio;
return;
}
/*
* PsychGSDeleteMovie() -- Delete a movie object and release all associated ressources.
*/
void PsychGSDeleteMovie(int moviehandle)
{
PsychWindowRecordType **windowRecordArray;
int i, numWindows;
if (moviehandle < 0 || moviehandle >= PSYCH_MAX_MOVIES) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided!");
}
if (movieRecordBANK[moviehandle].theMovie == NULL) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided. No movie associated with this handle !!!");
}
// Stop movie playback immediately:
PsychMoviePipelineSetState(movieRecordBANK[moviehandle].theMovie, GST_STATE_NULL, 20.0);
// Delete movieobject for this handle:
gst_object_unref(GST_OBJECT(movieRecordBANK[moviehandle].theMovie));
movieRecordBANK[moviehandle].theMovie=NULL;
// Delete visual context for this movie:
movieRecordBANK[moviehandle].MovieContext = NULL;
PsychDestroyMutex(&movieRecordBANK[moviehandle].mutex);
PsychDestroyCondition(&movieRecordBANK[moviehandle].condition);
free(movieRecordBANK[moviehandle].imageBuffer);
movieRecordBANK[moviehandle].imageBuffer = NULL;
movieRecordBANK[moviehandle].videosink = NULL;
// Recycled texture in texture cache?
if ((movieRecordBANK[moviehandle].parentRecord) && (movieRecordBANK[moviehandle].cached_texture > 0)) {
// Yes. Release it.
PsychSetGLContext(movieRecordBANK[moviehandle].parentRecord);
glDeleteTextures(1, &(movieRecordBANK[moviehandle].cached_texture));
movieRecordBANK[moviehandle].cached_texture = 0;
}
if (movieRecordBANK[moviehandle].texturePlanarHDRDecodeShader)
PsychSetShader(movieRecordBANK[moviehandle].parentRecord, 0);
// Delete all references to us in textures originally originating from us:
PsychCreateVolatileWindowRecordPointerList(&numWindows, &windowRecordArray);
for(i = 0; i < numWindows; i++) {
if ((windowRecordArray[i]->windowType == kPsychTexture) && (windowRecordArray[i]->texturecache_slot == moviehandle)) {
// This one is referencing us. Reset its reference to "undefined" to detach it from us:
windowRecordArray[i]->texturecache_slot = -1;
// Transform video texture into a normalized, upright texture of RGB(A) format of
// suitable precision if it isn't already in that format. This way we can get rid
// of our special conversion/draw shader now:
if (movieRecordBANK[moviehandle].texturePlanarHDRDecodeShader)
PsychNormalizeTextureOrientation(windowRecordArray[i]);
}
}
PsychDestroyVolatileWindowRecordPointerList(windowRecordArray);
// Delete our conversion shader:
if (movieRecordBANK[moviehandle].texturePlanarHDRDecodeShader)
glDeleteProgram(movieRecordBANK[moviehandle].texturePlanarHDRDecodeShader);
// Decrease counter:
if (numMovieRecords>0) numMovieRecords--;
return;
}
/*
* PsychGSDeleteAllMovies() -- Delete all movie objects and release all associated ressources.
*/
void PsychGSDeleteAllMovies(void)
{
int i;
for (i=0; i<PSYCH_MAX_MOVIES; i++) {
if (movieRecordBANK[i].theMovie) PsychGSDeleteMovie(i);
}
return;
}
/*
* PsychGSGetTextureFromMovie() -- Create an OpenGL texture map from a specific videoframe from given movie object.
*
* win = Window pointer of onscreen window for which a OpenGL texture should be created.
* moviehandle = Handle to the movie object.
* checkForImage = 0 == Retrieve the image, blocking until error timeout if necessary.
* 1 == Check for new image in polling fashion.
* 2 == Check for new image in blocking fashion. Wait up to 5 seconds blocking for a new frame.
* timeindex = When not in playback mode, this allows specification of a requested frame by presentation time.
* If set to -1, or if in realtime playback mode, this parameter is ignored and the next video frame is returned.
* out_texture = Pointer to the Psychtoolbox texture-record where the new texture should be stored.
* presentation_timestamp = A ptr to a double variable, where the presentation timestamp of the returned frame should be stored.
*
* Returns true (1) on success, false (0) if no new image available, -1 if no new image available and there won't be any in future.
*/
int PsychGSGetTextureFromMovie(PsychWindowRecordType *win, int moviehandle, int checkForImage, double timeindex,
PsychWindowRecordType *out_texture, double *presentation_timestamp)
{
GstElement *theMovie;
double rate;
double targetdelta, realdelta, frames;
GstBuffer *videoBuffer = NULL;
GstSample *videoSample = NULL;
gint64 bufferIndex;
double deltaT = 0;
GstEvent *event;
static double tStart = 0;
double tNow;
double preT, postT;
unsigned char* releaseMemPtr = NULL;
#if PSYCH_SYSTEM == PSYCH_WINDOWS
#pragma warning( disable : 4068 )
#endif
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wmissing-field-initializers"
GstMapInfo mapinfo = GST_MAP_INFO_INIT;
#pragma GCC diagnostic pop
if (!PsychIsOnscreenWindow(win)) {
PsychErrorExitMsg(PsychError_user, "Need onscreen window ptr!!!");
}
if (moviehandle < 0 || moviehandle >= PSYCH_MAX_MOVIES) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided.");
}
if ((timeindex!=-1) && (timeindex < 0 || timeindex >= 100000.0)) {
PsychErrorExitMsg(PsychError_user, "Invalid timeindex provided.");
}
// Fetch references to objects we need:
theMovie = movieRecordBANK[moviehandle].theMovie;
if (theMovie == NULL) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided. No movie associated with this handle.");
}
// Deferred start of movie playback requested? This so if movie is supposed to be
// actively playing (rate != 0) and the startPending flag marks a pending deferred start:
if ((movieRecordBANK[moviehandle].rate != 0) && movieRecordBANK[moviehandle].startPending) {
// Deferred start: Reset flag, start pipeline with a max timeout of 1 second:
movieRecordBANK[moviehandle].startPending = 0;
PsychMoviePipelineSetState(theMovie, GST_STATE_PLAYING, 1);
// This point is reached after either the pipeline is fully started, or the
// timeout has elapsed. In the latter case, a GST_STATE_CHANGE_ASYNC message
// is printed and start of pipeline continues asynchronously. No big deal for
// us, as we'll simply block in the rest of the texture fetch (checkForImage) path
// until the first frame is ready and audio playback has started. The main purpose
// of setting a reasonable timeout above is to avoid cluttering the console with
// status messages (timeout big enough for common case) but allow user to interrupt
// ops that take too long (timeout small enough to avoid long user-perceived exec-hangs).
// 1 Second is used to cater to the common case of playing files from disc, but coping
// with multi-second delays for network streaming (buffering delays in preroll).
}
// Allow context task to do its internal bookkeeping and cleanup work:
PsychGSProcessMovieContext(&(movieRecordBANK[moviehandle]), FALSE);
// If this is a pure audio "movie" with no video tracks, we always return failed,
// as those certainly don't have movie frames associated.
if (movieRecordBANK[moviehandle].nrVideoTracks == 0) return((checkForImage) ? -1 : FALSE);
// Get current playback rate:
rate = movieRecordBANK[moviehandle].rate;
// Is movie actively playing (automatic async playback, possibly with synced sound)?
// If so, then we ignore the 'timeindex' parameter, because the automatic playback
// process determines which frames should be delivered to PTB when. This function will
// simply wait or poll for arrival/presence of a new frame that hasn't been fetched
// in previous calls.
if (0 == rate) {
// Movie playback inactive. We are in "manual" mode: No automatic async playback,
// no synced audio output. The user just wants to manually fetch movie frames into
// textures for manual playback in a standard Matlab-loop.
// First pass - checking for new image?
if (checkForImage) {
// Image for specific point in time requested?
if (timeindex >= 0) {
// Yes. We try to retrieve the next possible image for requested timeindex.
// Seek to target timeindex:
PsychGSSetMovieTimeIndex(moviehandle, timeindex, FALSE);
}
// Check for frame availability happens down there in the shared check code...
}
}
// Should we just check for new image? If so, just return availability status:
if (checkForImage) {
// Take reference timestamps of fetch start:
if (tStart == 0) PsychGetAdjustedPrecisionTimerSeconds(&tStart);
PsychLockMutex(&movieRecordBANK[moviehandle].mutex);
if ((((0 != rate) && movieRecordBANK[moviehandle].frameAvail) || ((0 == rate) && movieRecordBANK[moviehandle].preRollAvail)) &&
!gst_app_sink_is_eos(GST_APP_SINK(movieRecordBANK[moviehandle].videosink))) {
// New frame available. Unlock and report success:
//printf("PTB-DEBUG: NEW FRAME %d\n", movieRecordBANK[moviehandle].frameAvail);
PsychUnlockMutex(&movieRecordBANK[moviehandle].mutex);
return(TRUE);
}
// None available. Any chance there will be one in the future?
if (((rate != 0) && gst_app_sink_is_eos(GST_APP_SINK(movieRecordBANK[moviehandle].videosink)) && (movieRecordBANK[moviehandle].loopflag == 0)) ||
((rate == 0) && (movieRecordBANK[moviehandle].endOfFetch))) {
// No new frame available and there won't be any in the future, because this is a non-looping
// movie that has reached its end.
movieRecordBANK[moviehandle].endOfFetch = 0;
PsychUnlockMutex(&movieRecordBANK[moviehandle].mutex);
return(-1);
}
else {
// No new frame available yet:
PsychUnlockMutex(&movieRecordBANK[moviehandle].mutex);
// In the polling check, we return with statue "no new frame yet" aka false:
if (checkForImage < 2) return(FALSE);
// Otherwise (blocking/waiting check) we fall-through the wait code below...
}
}
// If we reach this point, then an image fetch is requested. If no new data
// is available we shall block:
PsychLockMutex(&movieRecordBANK[moviehandle].mutex);
// printf("PTB-DEBUG: Blocking fetch start %d\n", movieRecordBANK[moviehandle].frameAvail);
if (((0 != rate) && !movieRecordBANK[moviehandle].frameAvail) ||
((0 == rate) && !movieRecordBANK[moviehandle].preRollAvail)) {
// No new frame available. Perform a blocking wait with timeout of 0.5 seconds:
PsychTimedWaitCondition(&movieRecordBANK[moviehandle].condition, &movieRecordBANK[moviehandle].mutex, 0.5);
// Allow context task to do its internal bookkeeping and cleanup work:
PsychGSProcessMovieContext(&(movieRecordBANK[moviehandle]), FALSE);
// Recheck:
if (((0 != rate) && !movieRecordBANK[moviehandle].frameAvail) ||
((0 == rate) && !movieRecordBANK[moviehandle].preRollAvail)) {
// Wait timed out after 0.5 secs.
PsychUnlockMutex(&movieRecordBANK[moviehandle].mutex);
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-DEBUG: No frame received after timed blocking wait of 0.5 seconds.\n");
// This is the end of a "up to 0.5 seconds blocking wait" style checkForImage of type 2.
// Return "no new frame available yet". The calling code will retry the wait until its own
// higher master timeout value is reached:
return(FALSE);
}
// At this point we should have at least one frame available.
// printf("PTB-DEBUG: After blocking fetch start %d\n", movieRecordBANK[moviehandle].frameAvail);
}
// We're here with at least one frame available and the mutex lock held.
// Was this a pure "blocking check for new image"?
if (checkForImage) {
// Yes. Unlock mutex and signal success to caller - A new frame is ready.
PsychUnlockMutex(&movieRecordBANK[moviehandle].mutex);
return(TRUE);
}
// If we reach this point, then at least 1 frame should be available and we are
// asked to fetch it now and return it as a new OpenGL texture. The mutex is locked:
// Preroll case is simple:
movieRecordBANK[moviehandle].preRollAvail = 0;
// Perform texture fetch & creation:
// Active playback mode?
if (0 != rate) {
// Active playback mode:
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-DEBUG: Pulling buffer from videosink, %d buffers decoded and queued.\n", movieRecordBANK[moviehandle].frameAvail);
// Clamp frameAvail to maximum queue capacity, unless queue capacity is zero == "unlimited" capacity:
if (((int) gst_app_sink_get_max_buffers(GST_APP_SINK(movieRecordBANK[moviehandle].videosink)) < movieRecordBANK[moviehandle].frameAvail) &&
(gst_app_sink_get_max_buffers(GST_APP_SINK(movieRecordBANK[moviehandle].videosink)) > 0)) {
movieRecordBANK[moviehandle].frameAvail = (int) gst_app_sink_get_max_buffers(GST_APP_SINK(movieRecordBANK[moviehandle].videosink));
}
// One less frame available after our fetch:
movieRecordBANK[moviehandle].frameAvail--;
// We can unlock early, thanks to videosink's internal buffering: XXX FIXME: Perfectly race-free to do this before the pull?
PsychUnlockMutex(&movieRecordBANK[moviehandle].mutex);
// This will pull the oldest video buffer from the videosink. It would block if none were available,
// but that won't happen as we wouldn't reach this statement if none were available. It would return
// NULL if the stream would be EOS or the pipeline off, but that shouldn't ever happen:
videoSample = gst_app_sink_pull_sample(GST_APP_SINK(movieRecordBANK[moviehandle].videosink));
} else {
// Passive fetch mode: Use prerolled buffers after seek:
// These are available even after eos...
// We can unlock early, thanks to videosink's internal buffering: XXX FIXME: Perfectly race-free to do this before the pull?
PsychUnlockMutex(&movieRecordBANK[moviehandle].mutex);
videoSample = gst_app_sink_pull_preroll(GST_APP_SINK(movieRecordBANK[moviehandle].videosink));
}
// Sample received?
if (videoSample) {
// Get pointer to buffer - no ownership transfer, no unref needed:
videoBuffer = gst_sample_get_buffer(videoSample);
// Assign pts presentation timestamp in pipeline stream time and convert to seconds:
movieRecordBANK[moviehandle].pts = (double) GST_BUFFER_PTS(videoBuffer) / (double) 1e9;
// Iff forward playback is active and a target timeindex was specified and this buffer is not at least of
// that timeindex and at least one more buffer is queued, then skip this buffer, pull the next one and check
// if that one meets the required pts:
while ((rate > 0) && (timeindex >= 0) && (movieRecordBANK[moviehandle].pts < timeindex) && (movieRecordBANK[moviehandle].frameAvail > 0)) {
// Tell user about reason for rejecting this buffer:
if (PsychPrefStateGet_Verbosity() > 5) {
printf("PTB-DEBUG: Fast-Skipped buffer id %i with pts %f secs < targetpts %f secs.\n", (int) GST_BUFFER_OFFSET(videoBuffer), movieRecordBANK[moviehandle].pts, timeindex);
}
// Decrement available frame counter:
PsychLockMutex(&movieRecordBANK[moviehandle].mutex);
movieRecordBANK[moviehandle].frameAvail--;
PsychUnlockMutex(&movieRecordBANK[moviehandle].mutex);
// Return the unused sample to queue:
gst_sample_unref(videoSample);
// Pull the next one. As frameAvail was > 0 at check-time, we know there is at least one pending,
// so there shouldn't be a danger of hanging here:
videoSample = gst_app_sink_pull_sample(GST_APP_SINK(movieRecordBANK[moviehandle].videosink));
if (NULL == videoSample) {
// This should never happen!
printf("PTB-ERROR: No new video frame received in gst_app_sink_pull_sample skipper loop! Something's wrong. Aborting fetch.\n");
return(FALSE);
}
// Get pointer to buffer - no ownership transfer, no unref needed:
videoBuffer = gst_sample_get_buffer(videoSample);
// Assign updated pts presentation timestamp of new candidate in pipeline stream time and convert to seconds:
movieRecordBANK[moviehandle].pts = (double) GST_BUFFER_PTS(videoBuffer) / (double) 1e9;
// Recheck if this is a better candidate...
}
// Compute timedelta and bufferindex:
if (GST_CLOCK_TIME_IS_VALID(GST_BUFFER_DURATION(videoBuffer)))
deltaT = (double) GST_BUFFER_DURATION(videoBuffer) / (double) 1e9;
bufferIndex = GST_BUFFER_OFFSET(videoBuffer);
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-DEBUG: pts %f secs, dT %f secs, bufferId %i.\n", movieRecordBANK[moviehandle].pts, deltaT, (int) bufferIndex);
// Assign pointer to videoBuffer's data directly:
if (out_texture) {
// Map the buffers memory for reading:
if (!gst_buffer_map(videoBuffer, &mapinfo, GST_MAP_READ)) {
printf("PTB-ERROR: Failed to map video data of movie frame! Something's wrong. Aborting fetch.\n");
gst_sample_unref(videoSample);
videoBuffer = NULL;
return(FALSE);
}
out_texture->textureMemory = (GLuint*) mapinfo.data;
}
} else {
printf("PTB-ERROR: No new video frame received in gst_app_sink_pull_sample! Something's wrong. Aborting fetch.\n");
return(FALSE);
}
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-DEBUG: ...done.\n");
PsychGetAdjustedPrecisionTimerSeconds(&tNow);
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-DEBUG: Start of frame query to decode completion: %f msecs.\n", (tNow - tStart) * 1000.0);
tStart = tNow;
// Assign presentation_timestamp:
if (presentation_timestamp) *presentation_timestamp = movieRecordBANK[moviehandle].pts;
// Only create actual OpenGL texture if out_texture is non-NULL. Otherwise we're
// just skipping this. Useful for benchmarks, fast forward seeking, etc.
if (out_texture) {
// Activate OpenGL context of target window:
PsychSetGLContext(win);
#if PSYCH_SYSTEM == PSYCH_OSX
// Explicitely disable Apple's Client storage extensions. For now they are not really useful to us.
glPixelStorei(GL_UNPACK_CLIENT_STORAGE_APPLE, GL_FALSE);
#endif
// Build a standard PTB texture record:
PsychMakeRect(out_texture->rect, 0, 0, movieRecordBANK[moviehandle].width, movieRecordBANK[moviehandle].height);
// Set texture orientation as if it were an inverted Offscreen window: Upside-down.
out_texture->textureOrientation = 3;
// We use zero client storage memory bytes:
out_texture->textureMemorySizeBytes = 0;
// Assign default number of effective color channels:
out_texture->nrchannels = movieRecordBANK[moviehandle].pixelFormat;
// Is this grayscale movie actually a Bayer-encoded RGB movie? specialFlags1 & 1024 would indicate that:
if (movieRecordBANK[moviehandle].specialFlags1 & 1024) {
// This is Bayer raw sensor data which needs to get decoded into full RGB images.
#ifdef PTBVIDEOCAPTURE_LIBDC
// Ok, need to convert this grayscale image which actually contains raw Bayer sensor data into
// a RGB image. Need to perform software Bayer filtering via libdc1394 Debayering routines.
out_texture->textureMemory = (GLuint*) PsychDCDebayerFrame((unsigned char*) (out_texture->textureMemory), movieRecordBANK[moviehandle].width, movieRecordBANK[moviehandle].height, movieRecordBANK[moviehandle].bitdepth);
// Return failure if Debayering did not work:
if (out_texture->textureMemory == NULL) {
gst_buffer_unmap(videoBuffer, &mapinfo);
gst_sample_unref(videoSample);
videoBuffer = NULL;
return(FALSE);
}
releaseMemPtr = (unsigned char*) out_texture->textureMemory;
out_texture->nrchannels = 3; // Always 3 for RGB.
#else
// Won't ever reach this, as already Screen('OpenMovie') would have bailed out
// if libdc1394 is not supported.
return(FALSE);
#endif
}
// Assign default depth according to number of channels:
out_texture->depth = out_texture->nrchannels * movieRecordBANK[moviehandle].bitdepth;
if (out_texture->nrchannels < 4) {
// For 1-3 channel textures, play safe, don't assume alignment:
out_texture->textureByteAligned = 1;
}
else {
// 4 channel format:
// Textures are aligned on at least 4 Byte boundaries because texels are RGBA8. For
// frames of even-numbered pixel width, we can even get 8 Byte alignment:
out_texture->textureByteAligned = (movieRecordBANK[moviehandle].width % 2) ? 4 : 8;
}
// Assign texturehandle of our cached texture, if any, so it gets recycled now:
out_texture->textureNumber = movieRecordBANK[moviehandle].cached_texture;
// Mark this texture as originating from us, ie., our moviehandle, so texture recycling
// actually gets used:
out_texture->texturecache_slot = moviehandle;
// YUV 422 packed pixel upload requested?
if ((win->gfxcaps & kPsychGfxCapUYVYTexture) && (movieRecordBANK[moviehandle].pixelFormat == 5)) {
// GPU supports UYVY textures and we get data in that YCbCr format. Tell
// texture creation routine to use this optimized format:
if (!glewIsSupported("GL_APPLE_ycbcr_422")) {
// No support for more powerful Apple extension. Use Linux MESA extension:
out_texture->textureinternalformat = GL_YCBCR_MESA;
out_texture->textureexternalformat = GL_YCBCR_MESA;
} else {
// Apple extension supported:
out_texture->textureinternalformat = GL_RGB8;
out_texture->textureexternalformat = GL_YCBCR_422_APPLE;
}
// Same enumerant for Apple and Mesa:
out_texture->textureexternaltype = GL_UNSIGNED_SHORT_8_8_MESA;
// Number of effective channels is 3 for RGB8:
out_texture->nrchannels = 3;
// And 24 bpp depth:
out_texture->depth = 24;
// Byte alignment: For even number of pixels, assume at least 4 Byte alignment due to packing of 2 effective
// pixels into one 32-Bit packet, maybe even 8 Byte alignment if divideable by 4. For other width's, assume
// no alignment ie., 1 Byte:
out_texture->textureByteAligned = (movieRecordBANK[moviehandle].width % 2) ? 1 : ((movieRecordBANK[moviehandle].width % 4) ? 4 : 8);
}
// Upload of a "pseudo YUV" planar texture with only 8 bits Y component requested?
if ((movieRecordBANK[moviehandle].pixelFormat == 7) || (movieRecordBANK[moviehandle].pixelFormat == 8)) {
// We encode Y luminance data inside a 8 bit per pixel luminance texture. The
// "Y" luminance plane is stored at full 1 sample per pixel resolution with 8 bits.
// As such the texture appears to OpenGL as a normal LUMINANCE8 texture. Conversion of the Y
// luminance data into useable RGBA8 pixel fragments will happen during rendering via a suitable fragment
// shader. The net gain of this is that we can skip any kind of cpu based colorspace conversion
// for video formats/codecs which provide YUV data, by offloading the conversion to the GPU:
out_texture->textureinternalformat = 0;
// Mark texture as planar encoded, so proper conversion shader gets applied during
// call to PsychNormalizeTextureOrientation(), prior to any render-to-texture operation, e.g.,
// if used as an offscreen window, or as a participant of a Screen('TransformTexture') call:
out_texture->specialflags |= kPsychPlanarTexture;
// Assign special filter shader for Y8 -> RGBA8 color-space conversion of the
// planar texture during drawing or PsychNormalizeTextureOrientation():
if (!PsychAssignPlanarI800TextureShader(out_texture, win)) PsychErrorExitMsg(PsychError_user, "Assignment of Y8-Y800 video decoding shader failed during movie texture creation!");
// Number of effective channels is 1 for L8:
out_texture->nrchannels = 1;
// And 8 bpp depth: This will trigger bog-standard LUMINANCE8 texture creation in PsychCreateTexture():
out_texture->depth = 8;
// Byte alignment - Only depends on width of an image row, given the 1 Byte per pixel data:
out_texture->textureByteAligned = 1;
if (movieRecordBANK[moviehandle].width % 2 == 0) out_texture->textureByteAligned = 2;
if (movieRecordBANK[moviehandle].width % 4 == 0) out_texture->textureByteAligned = 4;
if (movieRecordBANK[moviehandle].width % 8 == 0) out_texture->textureByteAligned = 8;
}
// YUV I420 planar pixel upload requested?
if (movieRecordBANK[moviehandle].pixelFormat == 6) {
// We encode I420 planar data inside a 8 bit per pixel luminance texture of
// 1.5x times the height of the video frame. First the "Y" luminance plane
// is stored at full 1 sample per pixel resolution with 8 bits. Then a 0.25x
// height slice with "U" Cr chrominance data at half the horizontal and vertical
// resolution aka 1 sample per 2x2 pixel quad. Then a 0.25x height slice with "V"
// Cb chrominance data at 1 sample per 2x2 pixel quad resolution. As such the texture
// appears to OpenGL as a normal LUMINANCE8 texture. Conversion of the planar format
// into useable RGBA8 pixel fragments will happen during rendering via a suitable fragment
// shader. The net gain of this is that we effectively only need 1.5 Bytes per pixel instead
// of 3 Bytes for RGB8 or 4 Bytes for RGBA8:
out_texture->textureexternaltype = GL_UNSIGNED_BYTE;
out_texture->textureexternalformat = GL_LUMINANCE;
out_texture->textureinternalformat = GL_LUMINANCE8;
// Define a rect of 1.5 times the video frame height, so PsychCreateTexture() will source
// the whole input data buffer:
PsychMakeRect(out_texture->rect, 0, 0, movieRecordBANK[moviehandle].width, movieRecordBANK[moviehandle].height * 1.5);
// Check if 1.5x height texture fits within hardware limits of this GPU:
if (movieRecordBANK[moviehandle].height * 1.5 > win->maxTextureSize) PsychErrorExitMsg(PsychError_user, "Videoframe size too big for this graphics card and pixelFormat! Please retry with a pixelFormat of 4 in 'OpenMovie'.");
// Byte alignment: Assume no alignment for now:
out_texture->textureByteAligned = 1;
// Create planar "I420 inside L8" texture:
PsychCreateTexture(out_texture);
// Restore rect and clientrect of texture to effective size of video frame:
PsychMakeRect(out_texture->rect, 0, 0, movieRecordBANK[moviehandle].width, movieRecordBANK[moviehandle].height);
PsychCopyRect(out_texture->clientrect, out_texture->rect);
// Mark texture as planar encoded, so proper conversion shader gets applied during
// call to PsychNormalizeTextureOrientation(), prior to any render-to-texture operation, e.g.,
// if used as an offscreen window, or as a participant of a Screen('TransformTexture') call:
out_texture->specialflags |= kPsychPlanarTexture;
// Assign special filter shader for sampling and color-space conversion of the
// planar texture during drawing or PsychNormalizeTextureOrientation():
if (!PsychAssignPlanarI420TextureShader(out_texture, win)) PsychErrorExitMsg(PsychError_user, "Assignment of I420 video decoding shader failed during movie texture creation!");
// Number of effective channels is 3 for RGB8:
out_texture->nrchannels = 3;
// And 24 bpp depth:
out_texture->depth = 24;
}
// HDR/WCG YUV planar pixel upload requested?
if (movieRecordBANK[moviehandle].pixelFormat == 11) {
float overSize;
int bpc = GST_VIDEO_FORMAT_INFO_DEPTH(movieRecordBANK[moviehandle].sinkVideoInfo.finfo, 0);
// We encode planar data inside a single-layer luminance texture of
// 1.5x times the height of the video frame. First the "Y" luminance plane
// is stored at full 1 sample per pixel resolution. Then a 0.25x height slice
// with "U" Cr chrominance data at half the horizontal and vertical resolution
// aka 1 sample per 2x2 pixel quad. Then a 0.25x height slice with "V" Cb
// chrominance data at 1 sample per 2x2 pixel quad resolution. As such, the texture
// appears to OpenGL as a normal LUMINANCE texture. Conversion of the planar format
// into useable RGBA pixel fragments will happen during rendering via a suitable fragment
// shader. The net gain of this is that we effectively only need 1.5 Bytes per pixel instead
// of 3 Bytes for RGB8 or 4 Bytes for RGBA8:
out_texture->textureexternalformat = GL_LUMINANCE;
// Discriminate between 8 bpc content and > 8 bpc content:
if (bpc > 8) {
// More than 8 bpc, e.g., typically 10 bpc or 12 bpc, but up to 16 bpc. Use a 16 bpc
// unorm range texture:
out_texture->textureexternaltype = GL_UNSIGNED_SHORT;
out_texture->textureinternalformat = GL_LUMINANCE16;
// Word alignment. At least 2 bytes:
out_texture->textureByteAligned = 2;
// Effective color depth is 48 bits:
out_texture->depth = 48;
}
else {
// Standard 8 bpc content:
out_texture->textureexternaltype = GL_UNSIGNED_BYTE;
out_texture->textureinternalformat = GL_LUMINANCE8;
// Byte alignment. Assume no alignment for now:
out_texture->textureByteAligned = 1;
// Effective color depth is 24 bits:
out_texture->depth = 24;
// Assign an effective depth of 48 bit (ie. 16 bpc RGB) if the target window is a HDR
// window, because then even 8 bpc low dynamic range content must get mapped into the
// HDR range for proper display inside the HDR window, ie. the original unorm 0 - 1 range
// values must be mapped to 0 - maxSDRToHDRScaleFactor, e.g., up to 80.0 nits. This is not
// a problem for direct decode+draw by the planar decode shader during 'DrawTexture', but
// in case that immediate conversion into a regular packed pixel color renderable texture
// is required via PsychNormalizeTextureOrientation(), or when converting the texture into
// an offscreen window for drawing into it, or for Screen('TransformTexture') or similar.
// In those cases the LUMINANCE backing texture must get replaced with a backing texture
// that is not only colorbuffer renderable, but also capable to contain color values outside
// the 0-1 unorm range, iow. we need a floating point texture as backing store. We achieve
// this by marking the texture as a high bpc precision texture, so the conversion code in
// PsychNormalizeTextureOrientation() will pick a RGBA32F texture as new container, which
// can store outside unorm range content with more than 16 bpc linear precision:
if (win->imagingMode & kPsychNeedHDRWindow)
out_texture->depth = 48;
}
// Define a rect of overSize times the video frame height, so PsychCreateTexture() will source
// the whole input data buffer:
switch (GST_VIDEO_FORMAT_INFO_FORMAT(movieRecordBANK[moviehandle].sinkVideoInfo.finfo)) {
case GST_VIDEO_FORMAT_I420:
case GST_VIDEO_FORMAT_I420_10LE:
case GST_VIDEO_FORMAT_I420_12LE:
case GST_VIDEO_FORMAT_NV12:
case GST_VIDEO_FORMAT_P010_10LE:
case GST_VIDEO_FORMAT_P012_LE:
case GST_VIDEO_FORMAT_P016_LE:
// 420: Luma at full resolution, chroma half horizontal and half vertical -> 1/4 per plane
// times 2 chroma planes = 1/2 frame height for chroma planes, for a total of 1.5x
overSize = 1.5;
break;
case GST_VIDEO_FORMAT_Y42B:
case GST_VIDEO_FORMAT_I422_10LE:
case GST_VIDEO_FORMAT_I422_12LE:
case GST_VIDEO_FORMAT_NV16:
// 422: Luma at full resolution, chroma half horizontal resolution -> 1/2 per plane
// times 2 chroma planes = 1 extra frame height for chroma planes, for a total of 2.0x
overSize = 2.0;
break;
case GST_VIDEO_FORMAT_Y444:
case GST_VIDEO_FORMAT_Y444_10LE:
case GST_VIDEO_FORMAT_Y444_12LE:
case GST_VIDEO_FORMAT_Y444_16LE:
// 444: All planes at full resolution, so 3x the height:
overSize = 3.0;
break;
default:
overSize = 1.0; // Shut up false unused variable compiler warning.
PsychErrorExitMsg(PsychError_user, "Failed videoframe conversion into texture! Unrecognized sink format for pixelFormat 11 code.\n");
}
PsychMakeRect(out_texture->rect, 0, 0, movieRecordBANK[moviehandle].width, movieRecordBANK[moviehandle].height * overSize);
// Check if overSize x height texture fits within hardware limits of this GPU:
if (movieRecordBANK[moviehandle].height * overSize > win->maxTextureSize)
PsychErrorExitMsg(PsychError_user, "Videoframe size too big for this graphics card with pixelFormat 11! Can not handle content of this resolution on this graphics card!");
// Create "planar content inside single-plane luminance" texture:
PsychCreateTexture(out_texture);
// Restore rect and clientrect of texture to effective size of video frame:
PsychMakeRect(out_texture->rect, 0, 0, movieRecordBANK[moviehandle].width, movieRecordBANK[moviehandle].height);
PsychCopyRect(out_texture->clientrect, out_texture->rect);
// Number of effective color channels is 3 for RGB true color content:
out_texture->nrchannels = 3;
// Mark texture as planar encoded, so proper conversion shader gets applied during
// call to PsychNormalizeTextureOrientation(), prior to any render-to-texture operation, e.g.,
// if used as an offscreen window, or as a participant of a Screen('TransformTexture') call:
out_texture->specialflags |= kPsychPlanarTexture;
// Assign special filter shader for sampling and color-space conversion of the
// planar texture during drawing or PsychNormalizeTextureOrientation():
if (!PsychAssignMovieTextureConversionShader(&movieRecordBANK[moviehandle], out_texture))
PsychErrorExitMsg(PsychError_user, "Assignment of planar YUV video decoding shader failed during movie texture creation!");
}
else if (movieRecordBANK[moviehandle].bitdepth > 8) {
// Is this a > 8 bpc image format? If not, we ain't nothing more to prepare.
// If yes, we need to use a high precision floating point texture to represent
// the > 8 bpc image payload without loss of image information:
// highbitthreshold: If the net bpc value is greater than this, then use 32bpc floats
// instead of 16 bpc half-floats, because 16 bpc would not be sufficient to represent
// more than highbitthreshold bits faithfully:
const int highbitthreshold = 11;
unsigned int w = movieRecordBANK[moviehandle].width;
unsigned int h = movieRecordBANK[moviehandle].height;
unsigned int i, count;
// 9 - 16 bpc color/luminance resolution:
out_texture->depth = out_texture->nrchannels * ((movieRecordBANK[moviehandle].bitdepth > highbitthreshold) ? 32 : 16);
// Byte alignment: Assume at least 2 Byte alignment due to 16 bit per component aka 2 Byte input:
out_texture->textureByteAligned = 2;
if (out_texture->nrchannels == 1) {
// 1 layer Luminance:
out_texture->textureinternalformat = (movieRecordBANK[moviehandle].bitdepth > highbitthreshold) ? GL_LUMINANCE_FLOAT32_APPLE : GL_LUMINANCE_FLOAT16_APPLE;
out_texture->textureexternalformat = GL_LUMINANCE;
// Override for missing floating point texture support: Try to use 16 bit fixed point signed normalized textures [-1.0 ; 1.0] resolved at 15 bits:
if (!(win->gfxcaps & kPsychGfxCapFPTex16)) out_texture->textureinternalformat = GL_LUMINANCE16_SNORM;
out_texture->textureByteAligned = (w % 2) ? 2 : ((w % 4) ? 4 : 8);
}
else if (out_texture->nrchannels == 3) {
// 3 layer RGB:
out_texture->textureinternalformat = (movieRecordBANK[moviehandle].bitdepth > highbitthreshold) ? GL_RGB_FLOAT32_APPLE : GL_RGB_FLOAT16_APPLE;
out_texture->textureexternalformat = GL_RGB;
// Override for missing floating point texture support: Try to use 16 bit fixed point signed normalized textures [-1.0 ; 1.0] resolved at 15 bits:
if (!(win->gfxcaps & kPsychGfxCapFPTex16)) out_texture->textureinternalformat = GL_RGB16_SNORM;
out_texture->textureByteAligned = (w % 2) ? 2 : ((w % 4) ? 4 : 8);
}
else {
// 4 layer RGBA:
psych_uint64 *p;
union {
psych_uint64 raw;
psych_uint16 bits[4];
} vin, vout;
out_texture->textureinternalformat = (movieRecordBANK[moviehandle].bitdepth > highbitthreshold) ? GL_RGBA_FLOAT32_APPLE : GL_RGBA_FLOAT16_APPLE;
out_texture->textureexternalformat = GL_RGBA;
// Override for missing floating point texture support: Try to use 16 bit fixed point signed normalized textures [-1.0 ; 1.0] resolved at 15 bits:
if (!(win->gfxcaps & kPsychGfxCapFPTex16)) out_texture->textureinternalformat = GL_RGBA16_SNORM;
// Always 8 Byte aligned:
out_texture->textureByteAligned = 8;
// GStreamer delivers 16 bpc 4 channel data in ARGB 64 bpp layout, but
// OpenGL needs RGBA 64 bpp layout, so we need to manually swizzle
// the components:
count = w * h;
if (movieRecordBANK[moviehandle].imageBuffer == NULL)
movieRecordBANK[moviehandle].imageBuffer = malloc(count * sizeof(psych_uint64));
p = (void*) movieRecordBANK[moviehandle].imageBuffer;
memcpy(p, out_texture->textureMemory, count * sizeof(psych_uint64));
out_texture->textureMemory = (void*) p;
for (i = 0; i < count; i++) {
vin.raw = *p;
// ARGB -> RGBA
vout.bits[0] = vin.bits[1];
vout.bits[1] = vin.bits[2];
vout.bits[2] = vin.bits[3];
vout.bits[3] = vin.bits[0];
*p = vout.raw;
p++;
}
}
// External datatype is 16 bit unsigned integer, each color component encoded in a 16 bit value:
out_texture->textureexternaltype = GL_UNSIGNED_SHORT;
// Scale input data, so highest significant bit of payload is in bit 16:
glPixelTransferi(GL_RED_SCALE, 1 << (16 - movieRecordBANK[moviehandle].bitdepth));
glPixelTransferi(GL_GREEN_SCALE, 1 << (16 - movieRecordBANK[moviehandle].bitdepth));
glPixelTransferi(GL_BLUE_SCALE, 1 << (16 - movieRecordBANK[moviehandle].bitdepth));
// Let PsychCreateTexture() do the rest of the job of creating, setting up and
// filling an OpenGL texture with content:
PsychCreateTexture(out_texture);
// Undo scaling:
glPixelTransferi(GL_RED_SCALE, 1);
glPixelTransferi(GL_GREEN_SCALE, 1);
glPixelTransferi(GL_BLUE_SCALE, 1);
}
else {
// Let PsychCreateTexture() do the rest of the job of creating, setting up and
// filling an OpenGL texture with content:
PsychCreateTexture(out_texture);
}
// Release buffer for target RGB debayered image, if any:
if ((movieRecordBANK[moviehandle].specialFlags1 & 1024) && releaseMemPtr) free(releaseMemPtr);
// NULL-out the texture memory pointer after PsychCreateTexture(). This is not strictly
// needed, as PsychCreateTexture() did it already, but we add it here as an annotation
// to make it obvious during code correctness review that we won't touch or free() the
// video memory buffer anymore, which is owned and only memory-managed by GStreamer:
out_texture->textureMemory = NULL;
// After PsychCreateTexture() the cached texture object from our cache is used
// and no longer available for recycling. We mark the cache as empty:
// It will be filled with a new textureid for recycling if a texture gets
// deleted in PsychMovieDeleteTexture()....
movieRecordBANK[moviehandle].cached_texture = 0;
// Does usercode want immediate conversion of texture into standard RGBA8 packed pixel
// upright format for use as a render-target? If so, do it:
if (movieRecordBANK[moviehandle].specialFlags1 & 16) {
// Transform out_texture video texture into a normalized, upright texture if it isn't already in
// that format. We require this standard orientation for simplified shader design.
PsychSetShader(win, 0);
PsychNormalizeTextureOrientation(out_texture);
}
PsychGetAdjustedPrecisionTimerSeconds(&tNow);
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-DEBUG: Decode completion to texture created: %f msecs.\n", (tNow - tStart) * 1000.0);
tStart = tNow;
// End of texture creation code.
}
// Detection of dropped frames: This is a heuristic. We'll see how well it works out...
// TODO: GstBuffer videoBuffer provides special flags that should allow to do a more
// robust job, although nothing's wrong with the current approach per se...
if (rate && presentation_timestamp) {
// Try to check for dropped frames in playback mode:
// Expected delta between successive presentation timestamps:
// This is not dependent on playback rate, as it measures time in the
// GStreamer movies timeline == Assuming 1x playback rate.
targetdelta = 1.0f / movieRecordBANK[moviehandle].fps;
// Compute real delta, given rate and playback direction:
if (rate > 0) {
realdelta = *presentation_timestamp - movieRecordBANK[moviehandle].last_pts;
if (realdelta < 0) realdelta = 0;
}
else {
realdelta = -1.0 * (*presentation_timestamp - movieRecordBANK[moviehandle].last_pts);
if (realdelta < 0) realdelta = 0;
}
frames = realdelta / targetdelta;
// Dropped frames?
if (frames > 1 && movieRecordBANK[moviehandle].last_pts >= 0) {
movieRecordBANK[moviehandle].nr_droppedframes += (int) (frames - 1 + 0.5);
}
movieRecordBANK[moviehandle].last_pts = *presentation_timestamp;
}
// Unlock.
gst_buffer_unmap(videoBuffer, &mapinfo);
gst_sample_unref(videoSample);
videoBuffer = NULL;
// Manually advance movie time, if in fetch mode:
if (0 == rate) {
// We are in manual fetch mode: Need to manually advance movie to next
// media sample:
movieRecordBANK[moviehandle].endOfFetch = 0;
preT = PsychGSGetMovieTimeIndex(moviehandle);
event = gst_event_new_step(GST_FORMAT_BUFFERS, 1, 1.0, TRUE, FALSE);
// Send the seek event *only* to the videosink. This follows recommendations from GStreamer SDK tutorial 13 (Playback speed) to
// not send to high level playbin itself, as that would propagate to all sinks and trigger multiple seeks. While this was not
// ever a problem in the past on Linux or with upstream GStreamer, it caused deadlocks, timeouts and seek failures when done
// with the GStreamer SDK on some movie files that have audio tracks, e.g., our standard demo movie! Sending only to videosink
// fixes this problem:
if (!gst_element_send_event(movieRecordBANK[moviehandle].videosink, event)) printf("PTB-DEBUG: In single-step seek I - Failed.\n");
// Block until seek completed, failed, or timeout of 10 seconds reached:
if (GST_STATE_CHANGE_SUCCESS != gst_element_get_state(theMovie, NULL, NULL, (GstClockTime) (10 * 1e9))) printf("PTB-DEBUG: In single-step seek II - Failed.\n");
postT = PsychGSGetMovieTimeIndex(moviehandle);
if (PsychPrefStateGet_Verbosity() > 6) printf("PTB-DEBUG: Movie fetch advance: preT %f postT %f DELTA %lf %s\n", preT, postT, postT - preT, (postT - preT < 0.001) ? "SAME" : "DIFF");
// Signal end-of-fetch if time no longer progresses signficiantly:
if (postT - preT < 0.001) movieRecordBANK[moviehandle].endOfFetch = 1;
}
PsychGetAdjustedPrecisionTimerSeconds(&tNow);
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-DEBUG: Texture created to fetch completion: %f msecs.\n", (tNow - tStart) * 1000.0);
// Reset tStart for next fetch cycle:
tStart = 0;
return(TRUE);
}
/*
* PsychGSFreeMovieTexture() - Release texture memory for a texture.
*
* This routine is called by PsychDeleteTexture() in PsychTextureSupport.c
* It performs the special cleanup necessary for cached movie textures.
*/
void PsychGSFreeMovieTexture(PsychWindowRecordType *win)
{
// Is this a GStreamer movietexture? If not, just skip this routine.
if (win->windowType!=kPsychTexture || win->textureOrientation != 3 || win->texturecache_slot < 0) return;
// Movie texture: Check if we can move it into our recycler cache
// for later reuse...
if (movieRecordBANK[win->texturecache_slot].cached_texture == 0) {
// Cache free. Put this texture object into it for later reuse:
movieRecordBANK[win->texturecache_slot].cached_texture = win->textureNumber;
// 0-out the textureNumber so our standard cleanup routine (glDeleteTextures) gets
// skipped - if we wouldn't do this, our caching scheme would screw up.
win->textureNumber = 0;
}
else {
// Cache already occupied. We don't do anything but leave the cleanup work for
// this texture to the standard PsychDeleteTexture() routine...
}
return;
}
/*
* PsychGSPlaybackRate() - Start- and stop movieplayback, set playback parameters.
*
* moviehandle = Movie to start-/stop.
* playbackrate = zero == Stop playback, non-zero == Play movie with spec. rate,
* e.g., 1 = forward, 2 = double speed forward, -1 = backward, ...
* loop = 0 = Play once. 1 = Loop, aka rewind at end of movie and restart.
* soundvolume = 0 == Mute sound playback, between 0.0 and 1.0 == Set volume to 0 - 100 %.
* Returns Number of dropped frames to keep playback in sync.
*/
int PsychGSPlaybackRate(int moviehandle, double playbackrate, int loop, double soundvolume)
{
GstElement *audiosink, *actual_audiosink;
gchar* pstring;
int dropped = 0;
GstElement *theMovie = NULL;
double timeindex;
GstSeekFlags seekFlags = 0;
if (moviehandle < 0 || moviehandle >= PSYCH_MAX_MOVIES) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided!");
}
// Fetch references to objects we need:
theMovie = movieRecordBANK[moviehandle].theMovie;
if (theMovie == NULL) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided. No movie associated with this handle !!!");
}
// Try to set movie playback rate to value identical to current value?
if (playbackrate == movieRecordBANK[moviehandle].rate) {
// Yes: This would be a no-op, except we allow to change the sound output volume
// dynamically and on-the-fly with low overhead this way:
// Set volume and mute state for audio:
g_object_set(G_OBJECT(theMovie), "mute", (soundvolume <= 0) ? TRUE : FALSE, NULL);
g_object_set(G_OBJECT(theMovie), "volume", soundvolume, NULL);
// Done. Return success status code:
return(0);
}
if (playbackrate != 0) {
// Start playback of movie:
// Set volume and mute state for audio:
g_object_set(G_OBJECT(theMovie), "mute", (soundvolume <= 0) ? TRUE : FALSE, NULL);
g_object_set(G_OBJECT(theMovie), "volume", soundvolume, NULL);
// Set playback rate: An explicit seek to the position we are already (supposed to be)
// is needed to avoid jumps in movies with bad encoding or keyframe placement:
timeindex = PsychGSGetMovieTimeIndex(moviehandle);
// Which loop setting?
if (loop <= 0) {
// Looped playback disabled. Set to well defined off value zero:
loop = 0;
}
else {
// Looped playback requested. With default settings (==1)?
// Otherwise we'll just pass on any special != 1 setting as a
// user-override:
if (loop == 1) {
// Playback with defaults. Apply default setup + specialFlags1 quirks:
// specialFlags & 32? Use 'uri' injection method for looped playback, instead of seek method:
if (movieRecordBANK[moviehandle].specialFlags1 & 32) loop = 2;
// specialFlags & 64? Use segment seeks.
if (movieRecordBANK[moviehandle].specialFlags1 & 64) loop |= 4;
// specialFlags & 128? Use pipeline flushing seeks
if (movieRecordBANK[moviehandle].specialFlags1 & 128) loop |= 8;
}
}
// On some movies and configurations, we need a segment seek as indicated by flag 0x4:
if (loop & 0x4) seekFlags |= GST_SEEK_FLAG_SEGMENT;
if (playbackrate > 0) {
gst_element_seek(theMovie, playbackrate, GST_FORMAT_TIME, GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_ACCURATE | ((loop & 0x1) ? seekFlags : 0), GST_SEEK_TYPE_SET,
(gint64) (timeindex * (double) 1e9), GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE);
}
else {
gst_element_seek(theMovie, playbackrate, GST_FORMAT_TIME, GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_ACCURATE | ((loop & 0x1) ? seekFlags : 0), GST_SEEK_TYPE_SET,
0, GST_SEEK_TYPE_SET, (gint64) (timeindex * (double) 1e9));
}
movieRecordBANK[moviehandle].loopflag = loop;
movieRecordBANK[moviehandle].last_pts = -1.0;
movieRecordBANK[moviehandle].nr_droppedframes = 0;
movieRecordBANK[moviehandle].rate = playbackrate;
movieRecordBANK[moviehandle].frameAvail = 0;
movieRecordBANK[moviehandle].preRollAvail = 0;
// Is this a movie with actual videotracks and frame-dropping on videosink full enabled?
if ((movieRecordBANK[moviehandle].nrVideoTracks > 0) && gst_app_sink_get_drop(GST_APP_SINK(movieRecordBANK[moviehandle].videosink))) {
// Yes: We only schedule deferred start of playback at first Screen('GetMovieImage')
// frame fetch. This to avoid dropped frames due to random delays between
// call to Screen('PlayMovie') and Screen('GetMovieImage'):
movieRecordBANK[moviehandle].startPending = 1;
}
else {
// Only soundtrack or framedropping disabled with videotracks - Start it immediately:
movieRecordBANK[moviehandle].startPending = 0;
PsychMoviePipelineSetState(theMovie, GST_STATE_PLAYING, 10.0);
PsychGSProcessMovieContext(&(movieRecordBANK[moviehandle]), FALSE);
}
}
else {
// Stop playback of movie:
movieRecordBANK[moviehandle].rate = 0;
movieRecordBANK[moviehandle].startPending = 0;
movieRecordBANK[moviehandle].loopflag = 0;
movieRecordBANK[moviehandle].endOfFetch = 0;
// Print name of audio sink - the output device which was actually playing the sound, if requested:
// This is a Linux only feature, as GStreamer for MS-Windows doesn't support such queries at all,
// and GStreamer for OSX doesn't expose the information in a way that would be in any way meaningful for us.
if ((PSYCH_SYSTEM == PSYCH_LINUX) && (PsychPrefStateGet_Verbosity() > 3)) {
audiosink = NULL;
if (g_object_class_find_property(G_OBJECT_GET_CLASS(theMovie), "audio-sink")) {
g_object_get(G_OBJECT(theMovie), "audio-sink", &audiosink, NULL);
}
if (audiosink) {
actual_audiosink = NULL;
actual_audiosink = (GST_IS_CHILD_PROXY(audiosink)) ? ((GstElement*) gst_child_proxy_get_child_by_index(GST_CHILD_PROXY(audiosink), 0)) : audiosink;
if (actual_audiosink) {
if (g_object_class_find_property(G_OBJECT_GET_CLASS(actual_audiosink), "device")) {
pstring = NULL;
g_object_get(G_OBJECT(actual_audiosink), "device", &pstring, NULL);
if (pstring) {
printf("PTB-INFO: Audio output device name for movie playback was '%s'", pstring);
g_free(pstring); pstring = NULL;
}
}
if (g_object_class_find_property(G_OBJECT_GET_CLASS(actual_audiosink), "device-name")) {
pstring = NULL;
g_object_get(G_OBJECT(actual_audiosink), "device-name", &pstring, NULL);
if (pstring) {
printf(" [%s].", pstring);
g_free(pstring); pstring = NULL;
}
}
if (g_object_class_find_property(G_OBJECT_GET_CLASS(actual_audiosink), "target-object")) {
pstring = NULL;
g_object_get(G_OBJECT(actual_audiosink), "target-object", &pstring, NULL);
if (pstring) {
printf("PTB-INFO: Audio output pipewire sink name/serial for movie playback was '%s'.", pstring);
g_free(pstring); pstring = NULL;
}
}
printf("\n");
if (actual_audiosink != audiosink) gst_object_unref(actual_audiosink);
}
gst_object_unref(audiosink);
}
}
PsychMoviePipelineSetState(theMovie, GST_STATE_PAUSED, 10.0);
PsychGSProcessMovieContext(&(movieRecordBANK[moviehandle]), FALSE);
// Output count of dropped frames:
if ((dropped=movieRecordBANK[moviehandle].nr_droppedframes) > 0) {
if (PsychPrefStateGet_Verbosity()>2) {
printf("PTB-INFO: Movie playback had to drop %i frames of movie %i to keep playback in sync.\n", movieRecordBANK[moviehandle].nr_droppedframes, moviehandle);
}
}
}
return(dropped);
}
/*
* void PsychGSExitMovies() - Shutdown handler.
*
* This routine is called by Screen('CloseAll') and on clear Screen time to
* do final cleanup. It releases all movie objects.
*
*/
void PsychGSExitMovies(void)
{
// Release all movies:
PsychGSDeleteAllMovies();
firsttime = TRUE;
return;
}
/*
* PsychGSGetMovieTimeIndex() -- Return current playback time of movie.
*/
double PsychGSGetMovieTimeIndex(int moviehandle)
{
GstElement *theMovie = NULL;
gint64 pos_nsecs;
if (moviehandle < 0 || moviehandle >= PSYCH_MAX_MOVIES) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided!");
}
// Fetch references to objects we need:
theMovie = movieRecordBANK[moviehandle].theMovie;
if (theMovie == NULL) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided. No movie associated with this handle !!!");
}
if (!gst_element_query_position(theMovie, GST_FORMAT_TIME, &pos_nsecs)) {
if (PsychPrefStateGet_Verbosity() > 1) printf("PTB-WARNING: Could not query position in movie %i in seconds. Returning zero.\n", moviehandle);
pos_nsecs = 0;
}
// Retrieve timeindex:
return((double) pos_nsecs / (double) 1e9);
}
/*
* PsychGSSetMovieTimeIndex() -- Set current playback time of movie, perform active seek if needed.
*/
double PsychGSSetMovieTimeIndex(int moviehandle, double timeindex, psych_bool indexIsFrames)
{
GstElement *theMovie;
double oldtime;
gint64 targetIndex;
GstSeekFlags flags;
if (moviehandle < 0 || moviehandle >= PSYCH_MAX_MOVIES) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided!");
}
// Fetch references to objects we need:
theMovie = movieRecordBANK[moviehandle].theMovie;
if (theMovie == NULL) {
PsychErrorExitMsg(PsychError_user, "Invalid moviehandle provided. No movie associated with this handle !!!");
}
// Retrieve current timeindex:
oldtime = PsychGSGetMovieTimeIndex(moviehandle);
// NOTE: We could use GST_SEEK_FLAG_SKIP to allow framedropping on fast forward/reverse playback...
flags = GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_ACCURATE;
// Need segment seek flag for seek during active looped playback if also flag 0x4 is set:
if ((movieRecordBANK[moviehandle].rate != 0) && (movieRecordBANK[moviehandle].loopflag & 0x1) && (movieRecordBANK[moviehandle].loopflag & 0x4)) {
flags |= GST_SEEK_FLAG_SEGMENT;
}
// Index based or target time based seeking?
if (indexIsFrames) {
// Index based seeking:
targetIndex = (gint64) (timeindex + 0.5);
// Simple seek, videobuffer (index) oriented, with pipeline flush and accurate seek,
// i.e., not locked to keyframes, but frame-accurate:
if (!gst_element_seek_simple(theMovie, GST_FORMAT_DEFAULT, flags, targetIndex)) {
// Failed: This can happen on various movie formats as not all codecs and formats support frame-based seeks.
// Fallback to time-based seek by faking a target time for given targetIndex:
timeindex = (double) targetIndex / (double) movieRecordBANK[moviehandle].fps;
if (PsychPrefStateGet_Verbosity() > 1) {
printf("PTB-WARNING: Could not seek to frame index %i via frame-based seeking in movie %i.\n", (int) targetIndex, moviehandle);
printf("PTB-WARNING: Will do a time-based seek to approximately equivalent time %f seconds instead.\n", timeindex);
printf("PTB-WARNING: Not all movie formats support frame-based seeking. Please change your movie format for better precision.\n");
}
if (!gst_element_seek_simple(theMovie, GST_FORMAT_TIME, flags, (gint64) (timeindex * (double) 1e9)) &&
(PsychPrefStateGet_Verbosity() > 1)) {
printf("PTB-WARNING: Time-based seek failed as well! Something is wrong with this movie!\n");
}
}
}
else {
// Time based seeking:
// Set new timeindex as time in seconds:
// Simple seek, time-oriented, with pipeline flush and accurate seek,
// i.e., not locked to keyframes, but frame-accurate:
if (!gst_element_seek_simple(theMovie, GST_FORMAT_TIME, flags, (gint64) (timeindex * (double) 1e9)) &&
(PsychPrefStateGet_Verbosity() > 1)) {
printf("PTB-WARNING: Time-based seek to %f seconds in movie %i failed. Something is wrong with this movie or the target time.\n", timeindex, moviehandle);
}
}
// Block until seek completed, failed or timeout of 30 seconds reached:
if (GST_STATE_CHANGE_FAILURE == gst_element_get_state(theMovie, NULL, NULL, (GstClockTime) (30 * 1e9)) && (PsychPrefStateGet_Verbosity() > 1)) {
printf("PTB-WARNING: SetTimeIndex on movie %i failed. Something is wrong with this movie or the target position. [Statechange-Failure in seek]\n", moviehandle);
printf("PTB-WARNING: Requested target position was %f %s. This could happen if the movie is not efficiently seekable and a timeout was hit.\n",
timeindex, (indexIsFrames) ? "frames" : "seconds");
}
if (PsychPrefStateGet_Verbosity() > 5) printf("PTB-INFO: Seeked to position %f secs in movie %i.\n", PsychGSGetMovieTimeIndex(moviehandle), moviehandle);
// Reset fetch flag:
movieRecordBANK[moviehandle].endOfFetch = 0;
// Return old time value of previous position:
return(oldtime);
}
/*
* PsychCopyOutMovieHDRMetaData() -- Return a struct with HDR static metadata about this movie to scripting environment.
*/
void PsychGSCopyOutMovieHDRMetaData(int moviehandle, int argPosition)
{
PsychGenericScriptType *s;
PsychGenericScriptType *outMat;
double *v;
const char *fieldNames[] = { "Valid", "MetadataType", "MinLuminance", "MaxLuminance", "MaxFrameAverageLightLevel", "MaxContentLightLevel", "ColorGamut",
"Colorimetry", "LimitedRange", "YUVRGBMatrixType", "PrimariesType", "EOTFType", "Format", "Depth" };
const int fieldCount = 14;
// Userscript wants this info?
if (PsychIsArgPresent(PsychArgOut, argPosition)) {
PsychMovieHDRMetaData *hdrMetaData = &movieRecordBANK[moviehandle].hdrMetaData;
// Create a structure and populate it with the movies parsed HDR metadata:
PsychAllocOutStructArray(argPosition, kPsychArgOptional, -1, fieldCount, fieldNames, &s);
// Set validity status:
PsychSetStructArrayDoubleElement("Valid", 0, (double) hdrMetaData->valid, s);
// Type of metadata:
PsychSetStructArrayDoubleElement("MetadataType", 0, (double) hdrMetaData->type, s);
// Mastering display min and max luminance:
PsychSetStructArrayDoubleElement("MinLuminance", 0, hdrMetaData->minLuminance, s);
PsychSetStructArrayDoubleElement("MaxLuminance", 0, hdrMetaData->maxLuminance, s);
// Scene content average and maximum content light level:
PsychSetStructArrayDoubleElement("MaxFrameAverageLightLevel", 0, hdrMetaData->maxFrameAverageLightLevel, s);
PsychSetStructArrayDoubleElement("MaxContentLightLevel", 0, hdrMetaData->maxContentLightLevel, s);
// Create color gamut and white point matrix defining the mastering display color gamut / color space:
PsychAllocateNativeDoubleMat(2, 4, 1, &v, &outMat);
*(v++) = hdrMetaData->displayPrimaryRed[0];
*(v++) = hdrMetaData->displayPrimaryRed[1];
*(v++) = hdrMetaData->displayPrimaryGreen[0];
*(v++) = hdrMetaData->displayPrimaryGreen[1];
*(v++) = hdrMetaData->displayPrimaryBlue[0];
*(v++) = hdrMetaData->displayPrimaryBlue[1];
*(v++) = hdrMetaData->whitePoint[0];
*(v++) = hdrMetaData->whitePoint[1];
PsychSetStructArrayNativeElement("ColorGamut", 0, outMat, s);
// Some not strictly HDR properties, more like general movie properties:
PsychSetStructArrayStringElement("Colorimetry", 0, (char *) gst_video_colorimetry_to_string (&movieRecordBANK[moviehandle].codecVideoInfo.colorimetry), s);
PsychSetStructArrayDoubleElement("LimitedRange", 0, movieRecordBANK[moviehandle].codecVideoInfo.colorimetry.range, s);
PsychSetStructArrayDoubleElement("YUVRGBMatrixType", 0, movieRecordBANK[moviehandle].codecVideoInfo.colorimetry.matrix, s);
PsychSetStructArrayDoubleElement("PrimariesType", 0, movieRecordBANK[moviehandle].codecVideoInfo.colorimetry.primaries, s);
PsychSetStructArrayDoubleElement("EOTFType", 0, movieRecordBANK[moviehandle].codecVideoInfo.colorimetry.transfer, s);
if (hdrMetaData->valid) {
PsychSetStructArrayStringElement("Format", 0, (char *) movieRecordBANK[moviehandle].codecVideoInfo.finfo->name, s);
PsychSetStructArrayDoubleElement("Depth", 0, GST_VIDEO_FORMAT_INFO_DEPTH(movieRecordBANK[moviehandle].codecVideoInfo.finfo, 0), s);
}
}
}
// #if GST_CHECK_VERSION(1,0,0)
#endif
// #ifdef PTB_USE_GSTREAMER
#endif
|