#include "input_state.h"
#include "pbo_frame_allocator.h"
-#if !defined LUA_VERSION_NUM || LUA_VERSION_NUM==501
-
-// Compatibility shims for LuaJIT 2.0 (LuaJIT 2.1 implements the entire Lua 5.2 API).
-// Adapted from https://github.com/keplerproject/lua-compat-5.2/blob/master/c-api/compat-5.2.c
-// and licensed as follows:
-//
-// The MIT License (MIT)
-//
-// Copyright (c) 2013 Hisham Muhammad
-//
-// Permission is hereby granted, free of charge, to any person obtaining a copy of
-// this software and associated documentation files (the "Software"), to deal in
-// the Software without restriction, including without limitation the rights to
-// use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
-// the Software, and to permit persons to whom the Software is furnished to do so,
-// subject to the following conditions:
-//
-// The above copyright notice and this permission notice shall be included in all
-// copies or substantial portions of the Software.
-//
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
-// FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
-// COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
-// IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
-// CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
-
-/*
-** Adapted from Lua 5.2.0
-*/
-void luaL_setfuncs(lua_State *L, const luaL_Reg *l, int nup) {
- luaL_checkstack(L, nup+1, "too many upvalues");
- for (; l->name != NULL; l++) { /* fill the table with given functions */
- int i;
- lua_pushstring(L, l->name);
- for (i = 0; i < nup; i++) /* copy upvalues to the top */
- lua_pushvalue(L, -(nup + 1));
- lua_pushcclosure(L, l->func, nup); /* closure with those upvalues */
- lua_settable(L, -(nup + 3)); /* table must be below the upvalues, the name and the closure */
- }
- lua_pop(L, nup); /* remove upvalues */
-}
-
-void *luaL_testudata(lua_State *L, int i, const char *tname) {
- void *p = lua_touserdata(L, i);
- luaL_checkstack(L, 2, "not enough stack slots");
- if (p == NULL || !lua_getmetatable(L, i))
- return NULL;
- else {
- int res = 0;
- luaL_getmetatable(L, tname);
- res = lua_rawequal(L, -1, -2);
- lua_pop(L, 2);
- if (!res)
- p = NULL;
- }
- return p;
-}
-
-#endif
-
class Mixer;
namespace movit {
unsigned last_width[MAX_VIDEO_CARDS], last_height[MAX_VIDEO_CARDS];
bool last_interlaced[MAX_VIDEO_CARDS], last_has_signal[MAX_VIDEO_CARDS], last_is_connected[MAX_VIDEO_CARDS];
unsigned last_frame_rate_nom[MAX_VIDEO_CARDS], last_frame_rate_den[MAX_VIDEO_CARDS];
+ bool has_last_subtitle[MAX_VIDEO_CARDS];
+ std::string last_subtitle[MAX_VIDEO_CARDS];
};
InputStateInfo::InputStateInfo(const InputState &input_state)
last_is_connected[signal_num] = userdata->last_is_connected;
last_frame_rate_nom[signal_num] = userdata->last_frame_rate_nom;
last_frame_rate_den[signal_num] = userdata->last_frame_rate_den;
+ has_last_subtitle[signal_num] = userdata->has_last_subtitle;
+ last_subtitle[signal_num] = userdata->last_subtitle;
}
}
public:
LuaRefWithDeleter(mutex *m, lua_State *L, int ref) : m(m), L(L), ref(ref) {}
~LuaRefWithDeleter() {
- unique_lock<mutex> lock(*m);
+ lock_guard<mutex> lock(*m);
luaL_unref(L, LUA_REGISTRYINDEX, ref);
}
int get() const { return ref; }
return string(cstr, len);
}
+void add_outputs_and_finalize(EffectChain *chain, bool is_main_chain)
+{
+ // Add outputs as needed.
+ // NOTE: If you change any details about the output format, you will need to
+ // also update what's given to the muxer (HTTPD::Mux constructor) and
+ // what's put in the H.264 stream (sps_rbsp()).
+ ImageFormat inout_format;
+ inout_format.color_space = COLORSPACE_REC_709;
+
+ // Output gamma is tricky. We should output Rec. 709 for TV, except that
+ // we expect to run with web players and others that don't really care and
+ // just output with no conversion. So that means we'll need to output sRGB,
+ // even though H.264 has no setting for that (we use “unspecified”).
+ inout_format.gamma_curve = GAMMA_sRGB;
+
+ if (is_main_chain) {
+ YCbCrFormat output_ycbcr_format;
+ // We actually output 4:2:0 and/or 4:2:2 in the end, but chroma subsampling
+ // happens in a pass not run by Movit (see ChromaSubsampler::subsample_chroma()).
+ output_ycbcr_format.chroma_subsampling_x = 1;
+ output_ycbcr_format.chroma_subsampling_y = 1;
+
+ // This will be overridden if HDMI/SDI output is in force.
+ if (global_flags.ycbcr_rec709_coefficients) {
+ output_ycbcr_format.luma_coefficients = YCBCR_REC_709;
+ } else {
+ output_ycbcr_format.luma_coefficients = YCBCR_REC_601;
+ }
+
+ output_ycbcr_format.full_range = false;
+ output_ycbcr_format.num_levels = 1 << global_flags.x264_bit_depth;
+
+ GLenum type = global_flags.x264_bit_depth > 8 ? GL_UNSIGNED_SHORT : GL_UNSIGNED_BYTE;
+
+ chain->add_ycbcr_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED, output_ycbcr_format, YCBCR_OUTPUT_SPLIT_Y_AND_CBCR, type);
+
+ // If we're using zerocopy video encoding (so the destination
+ // Y texture is owned by VA-API and will be unavailable for
+ // display), add a copy, where we'll only be using the Y component.
+ if (global_flags.use_zerocopy) {
+ chain->add_ycbcr_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED, output_ycbcr_format, YCBCR_OUTPUT_INTERLEAVED, type); // Add a copy where we'll only be using the Y component.
+ }
+ chain->set_dither_bits(global_flags.x264_bit_depth > 8 ? 16 : 8);
+ chain->set_output_origin(OUTPUT_ORIGIN_TOP_LEFT);
+ } else {
+ chain->add_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED);
+ }
+
+ chain->finalize();
+}
+
int EffectChain_new(lua_State* L)
{
assert(lua_gettop(L) == 2);
assert(lua_gettop(L) == 2);
EffectChain *chain = (EffectChain *)luaL_checkudata(L, 1, "EffectChain");
bool is_main_chain = checkbool(L, 2);
-
- // Add outputs as needed.
- // NOTE: If you change any details about the output format, you will need to
- // also update what's given to the muxer (HTTPD::Mux constructor) and
- // what's put in the H.264 stream (sps_rbsp()).
- ImageFormat inout_format;
- inout_format.color_space = COLORSPACE_REC_709;
-
- // Output gamma is tricky. We should output Rec. 709 for TV, except that
- // we expect to run with web players and others that don't really care and
- // just output with no conversion. So that means we'll need to output sRGB,
- // even though H.264 has no setting for that (we use “unspecified”).
- inout_format.gamma_curve = GAMMA_sRGB;
-
- if (is_main_chain) {
- YCbCrFormat output_ycbcr_format;
- // We actually output 4:2:0 and/or 4:2:2 in the end, but chroma subsampling
- // happens in a pass not run by Movit (see ChromaSubsampler::subsample_chroma()).
- output_ycbcr_format.chroma_subsampling_x = 1;
- output_ycbcr_format.chroma_subsampling_y = 1;
-
- // This will be overridden if HDMI/SDI output is in force.
- if (global_flags.ycbcr_rec709_coefficients) {
- output_ycbcr_format.luma_coefficients = YCBCR_REC_709;
- } else {
- output_ycbcr_format.luma_coefficients = YCBCR_REC_601;
- }
-
- output_ycbcr_format.full_range = false;
- output_ycbcr_format.num_levels = 1 << global_flags.x264_bit_depth;
-
- GLenum type = global_flags.x264_bit_depth > 8 ? GL_UNSIGNED_SHORT : GL_UNSIGNED_BYTE;
-
- chain->add_ycbcr_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED, output_ycbcr_format, YCBCR_OUTPUT_SPLIT_Y_AND_CBCR, type);
-
- // If we're using zerocopy video encoding (so the destination
- // Y texture is owned by VA-API and will be unavailable for
- // display), add a copy, where we'll only be using the Y component.
- if (global_flags.use_zerocopy) {
- chain->add_ycbcr_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED, output_ycbcr_format, YCBCR_OUTPUT_INTERLEAVED, type); // Add a copy where we'll only be using the Y component.
- }
- chain->set_dither_bits(global_flags.x264_bit_depth > 8 ? 16 : 8);
- chain->set_output_origin(OUTPUT_ORIGIN_TOP_LEFT);
- } else {
- chain->add_output(inout_format, OUTPUT_ALPHA_FORMAT_POSTMULTIPLIED);
- }
-
- chain->finalize();
+ add_outputs_and_finalize(chain, is_main_chain);
return 0;
}
#else
fprintf(stderr, "This version of Nageru has been compiled without CEF support.\n");
fprintf(stderr, "HTMLInput is not available.\n");
- exit(1);
+ abort();
#endif
}
return 1;
}
+int InputStateInfo_get_last_subtitle(lua_State* L)
+{
+ assert(lua_gettop(L) == 2);
+ InputStateInfo *input_state_info = get_input_state_info(L, 1);
+ Theme *theme = get_theme_updata(L);
+ int signal_num = theme->map_signal(luaL_checknumber(L, 2));
+ if (!input_state_info->has_last_subtitle[signal_num]) {
+ lua_pushnil(L);
+ } else {
+ lua_pushstring(L, input_state_info->last_subtitle[signal_num].c_str());
+ }
+ return 1;
+}
+
int Effect_set_float(lua_State *L)
{
assert(lua_gettop(L) == 3);
{ "get_is_connected", InputStateInfo_get_is_connected },
{ "get_frame_rate_nom", InputStateInfo_get_frame_rate_nom },
{ "get_frame_rate_den", InputStateInfo_get_frame_rate_den },
+ { "get_last_subtitle", InputStateInfo_get_last_subtitle },
{ NULL, NULL }
};
if (lua_pcall(L, 0, 1, 0) != 0) {
fprintf(stderr, "error running function `num_channels': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
int num_channels = luaL_checknumber(L, 1);
for (const string &error : errors) {
fprintf(stderr, "%s\n", error.c_str());
}
- exit(1);
+ abort();
}
assert(lua_gettop(L) == 0);
luaL_unref(L, LUA_REGISTRYINDEX, theme_code_ref);
if (lua_pcall(L, 0, 0, 0)) {
fprintf(stderr, "Error when running %s: %s\n", path.c_str(), lua_tostring(L, -1));
- exit(1);
+ abort();
}
assert(lua_gettop(L) == 0);
assert(lua_gettop(L) == 0);
}
-Theme::Chain Theme::get_chain(unsigned num, float t, unsigned width, unsigned height, InputState input_state)
+Theme::Chain Theme::get_chain(unsigned num, float t, unsigned width, unsigned height, const InputState &input_state)
{
Chain chain;
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
assert(lua_gettop(L) == 0);
lua_getglobal(L, "get_chain"); /* function to be called */
lua_pushnumber(L, num);
if (lua_pcall(L, 5, 2, 0) != 0) {
fprintf(stderr, "error running function `get_chain': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
EffectChain *effect_chain = (EffectChain *)luaL_testudata(L, -2, "EffectChain");
if (effect_chain == nullptr) {
fprintf(stderr, "get_chain() for chain number %d did not return an EffectChain\n",
num);
- exit(1);
+ abort();
}
chain.chain = effect_chain;
if (!lua_isfunction(L, -1)) {
fprintf(stderr, "Argument #-1 should be a function\n");
- exit(1);
+ abort();
}
lua_pushvalue(L, -1);
shared_ptr<LuaRefWithDeleter> funcref(new LuaRefWithDeleter(&m, L, luaL_ref(L, LUA_REGISTRYINDEX)));
assert(lua_gettop(L) == 0);
chain.setup_chain = [this, funcref, input_state, effect_chain]{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
assert(this->input_state == nullptr);
this->input_state = &input_state;
lua_rawgeti(L, LUA_REGISTRYINDEX, funcref->get());
if (lua_pcall(L, 0, 0, 0) != 0) {
fprintf(stderr, "error running chain setup callback: %s\n", lua_tostring(L, -1));
- exit(1);
- }
+ abort();
+ }
assert(lua_gettop(L) == 0);
// The theme can't (or at least shouldn't!) call connect_signal() on
string Theme::get_channel_name(unsigned channel)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_getglobal(L, "channel_name");
lua_pushnumber(L, channel);
if (lua_pcall(L, 1, 1, 0) != 0) {
fprintf(stderr, "error running function `channel_name': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
const char *ret = lua_tostring(L, -1);
if (ret == nullptr) {
fprintf(stderr, "function `channel_name' returned nil for channel %d\n", channel);
- exit(1);
+ abort();
}
string retstr = ret;
int Theme::get_channel_signal(unsigned channel)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_getglobal(L, "channel_signal");
lua_pushnumber(L, channel);
if (lua_pcall(L, 1, 1, 0) != 0) {
fprintf(stderr, "error running function `channel_signal': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
int ret = luaL_checknumber(L, 1);
std::string Theme::get_channel_color(unsigned channel)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_getglobal(L, "channel_color");
lua_pushnumber(L, channel);
if (lua_pcall(L, 1, 1, 0) != 0) {
fprintf(stderr, "error running function `channel_color': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
const char *ret = lua_tostring(L, -1);
if (ret == nullptr) {
fprintf(stderr, "function `channel_color' returned nil for channel %d\n", channel);
- exit(1);
+ abort();
}
string retstr = ret;
bool Theme::get_supports_set_wb(unsigned channel)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_getglobal(L, "supports_set_wb");
lua_pushnumber(L, channel);
if (lua_pcall(L, 1, 1, 0) != 0) {
fprintf(stderr, "error running function `supports_set_wb': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
bool ret = checkbool(L, -1);
void Theme::set_wb(unsigned channel, double r, double g, double b)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_getglobal(L, "set_wb");
lua_pushnumber(L, channel);
lua_pushnumber(L, r);
lua_pushnumber(L, b);
if (lua_pcall(L, 4, 0, 0) != 0) {
fprintf(stderr, "error running function `set_wb': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
assert(lua_gettop(L) == 0);
vector<string> Theme::get_transition_names(float t)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_getglobal(L, "get_transitions");
lua_pushnumber(L, t);
if (lua_pcall(L, 1, 1, 0) != 0) {
fprintf(stderr, "error running function `get_transitions': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
vector<string> ret;
lua_pop(L, 1);
assert(lua_gettop(L) == 0);
return ret;
-}
+}
int Theme::map_signal(int signal_num)
{
return -1 - signal_num;
}
- unique_lock<mutex> lock(map_m);
+ lock_guard<mutex> lock(map_m);
if (signal_to_card_mapping.count(signal_num)) {
return signal_to_card_mapping[signal_num];
}
void Theme::set_signal_mapping(int signal_num, int card_num)
{
- unique_lock<mutex> lock(map_m);
+ lock_guard<mutex> lock(map_m);
assert(card_num < int(num_cards));
signal_to_card_mapping[signal_num] = card_num;
}
void Theme::transition_clicked(int transition_num, float t)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_getglobal(L, "transition_clicked");
lua_pushnumber(L, transition_num);
lua_pushnumber(L, t);
if (lua_pcall(L, 2, 0, 0) != 0) {
fprintf(stderr, "error running function `transition_clicked': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
assert(lua_gettop(L) == 0);
}
void Theme::channel_clicked(int preview_num)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_getglobal(L, "channel_clicked");
lua_pushnumber(L, preview_num);
if (lua_pcall(L, 1, 0, 0) != 0) {
fprintf(stderr, "error running function `channel_clicked': %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
assert(lua_gettop(L) == 0);
}
void Theme::theme_menu_entry_clicked(int lua_ref)
{
- unique_lock<mutex> lock(m);
+ lock_guard<mutex> lock(m);
lua_rawgeti(L, LUA_REGISTRYINDEX, lua_ref);
if (lua_pcall(L, 0, 0, 0) != 0) {
fprintf(stderr, "error running menu callback: %s\n", lua_tostring(L, -1));
- exit(1);
+ abort();
}
}
projects / nageru / blobdiff