Skip to content

Commit

Permalink
chore: format
Browse files Browse the repository at this point in the history
  • Loading branch information
Julusian committed Jan 21, 2025
1 parent f4f62e3 commit 5008a84
Show file tree
Hide file tree
Showing 28 changed files with 140 additions and 129 deletions.
15 changes: 8 additions & 7 deletions src/accelerator/ogl/image/image_kernel.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -220,13 +220,14 @@ struct image_kernel::impl
coord.vertex_y += f_p[1];
};

auto const first_plane = params.pix_desc.planes.at(0);
if (params.geometry.mode() != core::frame_geometry::scale_mode::stretch && first_plane.width > 0 && first_plane.height > 0) {
auto width_scale = static_cast<double>(params.target_width) / static_cast<double>(first_plane.width);
auto height_scale = static_cast<double>(params.target_height) / static_cast<double>(first_plane.height);
auto const first_plane = params.pix_desc.planes.at(0);
if (params.geometry.mode() != core::frame_geometry::scale_mode::stretch && first_plane.width > 0 &&
first_plane.height > 0) {
auto width_scale = static_cast<double>(params.target_width) / static_cast<double>(first_plane.width);
auto height_scale = static_cast<double>(params.target_height) / static_cast<double>(first_plane.height);

double target_scale;
switch (params.geometry.mode()) {
switch (params.geometry.mode()) {
case core::frame_geometry::scale_mode::fit:
target_scale = std::min(width_scale, height_scale);
f_s[0] *= target_scale / width_scale;
Expand All @@ -253,8 +254,8 @@ struct image_kernel::impl
break;

default:;
}
}
}
}

int corner = 0;
for (auto& coord : coords) {
Expand Down
4 changes: 2 additions & 2 deletions src/accelerator/ogl/image/image_mixer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -96,8 +96,8 @@ class image_renderer
// return make_ready_future(array<const std::uint8_t>(buffer.data(), format_desc.size, true));
// }

return flatten(ogl_->dispatch_async(
[=, layers = std::move(layers)]() mutable -> std::shared_future<core::mixed_image> {
return flatten(
ogl_->dispatch_async([=, layers = std::move(layers)]() mutable -> std::shared_future<core::mixed_image> {
auto target_texture = ogl_->create_texture(format_desc.width, format_desc.height, 4, depth_);

draw(target_texture, std::move(layers), format_desc);
Expand Down
2 changes: 1 addition & 1 deletion src/accelerator/ogl/image/image_mixer.h
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ class image_mixer final : public core::image_mixer
image_mixer& operator=(const image_mixer&) = delete;

std::future<core::mixed_image> operator()(const core::video_format_desc& format_desc) override;
core::mutable_frame create_frame(const void* tag, const core::pixel_format_desc& desc) override;
core::mutable_frame create_frame(const void* tag, const core::pixel_format_desc& desc) override;
core::mutable_frame
create_frame(const void* video_stream_tag, const core::pixel_format_desc& desc, common::bit_depth depth) override;

Expand Down
5 changes: 2 additions & 3 deletions src/common/assert.h
Original file line number Diff line number Diff line change
Expand Up @@ -35,9 +35,8 @@
#define CASPAR_VERIFY(expr) \
do { \
if (!(expr)) { \
CASPAR_LOG(warning) << "Assertion Failed: " << CASPAR_VERIFY_EXPR_STR(expr) << " " \
<< "file:" << __FILE__ << " " \
<< "line:" << __LINE__ << " "; \
CASPAR_LOG(warning) << "Assertion Failed: " << CASPAR_VERIFY_EXPR_STR(expr) << " " << "file:" << __FILE__ \
<< " " << "line:" << __LINE__ << " "; \
_CASPAR_DBG_BREAK; \
} \
} while (0);
Expand Down
2 changes: 1 addition & 1 deletion src/common/ptree.h
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,8 @@

#include <boost/algorithm/string/replace.hpp>
#include <boost/iterator/iterator_facade.hpp>
#include <boost/property_tree/ptree_fwd.hpp>
#include <boost/property_tree/exceptions.hpp>
#include <boost/property_tree/ptree_fwd.hpp>
#include <boost/range/adaptor/transformed.hpp>

#include <map>
Expand Down
4 changes: 3 additions & 1 deletion src/core/consumer/output.h
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,9 @@

#include <memory>

namespace caspar::diagnostics { class graph; }
namespace caspar::diagnostics {
class graph;
}

namespace caspar { namespace core {

Expand Down
3 changes: 2 additions & 1 deletion src/core/diagnostics/osd_graph.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,8 @@ auto& get_default_font()
if (auto pipe = popen(cmd.data(), "r")) {
char buf[128];
path.clear();
while (fgets(buf, sizeof(buf), pipe)) path += buf;
while (fgets(buf, sizeof(buf), pipe))
path += buf;
}
}
#endif
Expand Down
5 changes: 3 additions & 2 deletions src/core/frame/draw_frame.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -99,8 +99,9 @@ draw_frame::draw_frame(mutable_frame&& frame)
draw_frame::draw_frame(std::vector<draw_frame> frames)
{
auto frame_size = frames.size();
impl_ = std::make_unique<impl>(std::move(frames));
if (frame_size > 1) impl_->transform_.image_transform.layer_depth = 1;
impl_ = std::make_unique<impl>(std::move(frames));
if (frame_size > 1)
impl_->transform_.image_transform.layer_depth = 1;
}
draw_frame::~draw_frame() {}
draw_frame& draw_frame::operator=(draw_frame other)
Expand Down
4 changes: 2 additions & 2 deletions src/core/frame/frame.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ struct const_frame::impl
impl(std::vector<array<const std::uint8_t>> image_data,
array<const std::int32_t> audio_data,
const core::pixel_format_desc& desc,
std::any opaque)
std::any opaque)
: image_data_(std::move(image_data))
, audio_data_(std::move(audio_data))
, desc_(desc)
Expand Down Expand Up @@ -155,7 +155,7 @@ const_frame::const_frame(std::vector<array<const std::uint8_t>> image_data,
const_frame::const_frame(std::vector<array<const std::uint8_t>> image_data,
array<const std::int32_t> audio_data,
const struct pixel_format_desc& desc,
std::any opaque)
std::any opaque)
: impl_(new impl(std::move(image_data), std::move(audio_data), desc, opaque))
{
}
Expand Down
2 changes: 1 addition & 1 deletion src/core/frame/frame.h
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ class const_frame final
explicit const_frame(std::vector<array<const std::uint8_t>> image_data,
array<const std::int32_t> audio_data,
const struct pixel_format_desc& desc,
std::any opaque);
std::any opaque);
const_frame(const const_frame& other);
const_frame(mutable_frame&& other);

Expand Down
83 changes: 41 additions & 42 deletions src/core/frame/geometry.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,9 @@ bool frame_geometry::coord::operator==(const frame_geometry::coord& other) const

struct frame_geometry::impl
{
impl(frame_geometry::geometry_type type, frame_geometry::scale_mode mode, std::vector<coord> data) :
type_{type}, mode_{mode}
impl(frame_geometry::geometry_type type, frame_geometry::scale_mode mode, std::vector<coord> data)
: type_{type}
, mode_{mode}
{
if (type == geometry_type::quad && data.size() != 4)
CASPAR_THROW_EXCEPTION(invalid_argument() << msg_info("The number of coordinates needs to be 4"));
Expand All @@ -54,9 +55,10 @@ struct frame_geometry::impl
std::vector<coord> data_;
};

frame_geometry::frame_geometry(geometry_type type, scale_mode mode, std::vector<coord> data) :
impl_{new impl{type, mode, std::move(data)}}
{ }
frame_geometry::frame_geometry(geometry_type type, scale_mode mode, std::vector<coord> data)
: impl_{new impl{type, mode, std::move(data)}}
{
}

frame_geometry::geometry_type frame_geometry::type() const { return impl_->type_; }
frame_geometry::scale_mode frame_geometry::mode() const { return impl_->mode_; }
Expand All @@ -71,7 +73,7 @@ const frame_geometry frame_geometry::get_default(scale_mode mode)
{1.0, 1.0, 1.0, 1.0}, // lower right
{0.0, 1.0, 0.0, 1.0} // lower left
};
return frame_geometry{ frame_geometry::geometry_type::quad, mode, std::move(data) };
return frame_geometry{frame_geometry::geometry_type::quad, mode, std::move(data)};
}
const frame_geometry frame_geometry::get_default_vflip(scale_mode mode)
{
Expand All @@ -82,46 +84,43 @@ const frame_geometry frame_geometry::get_default_vflip(scale_mode mode)
{1.0, 1.0, 1.0, 0.0}, // lower right
{0.0, 1.0, 0.0, 0.0} // lower left
};
return frame_geometry{ frame_geometry::geometry_type::quad, mode, std::move(data) };
return frame_geometry{frame_geometry::geometry_type::quad, mode, std::move(data)};
}

frame_geometry::scale_mode scale_mode_from_string(const std::wstring& str) {
auto str2 = boost::to_lower_copy(str);
if (str2 == L"fit") {
return frame_geometry::scale_mode::fit;
}
else if (str2 == L"fill") {
return frame_geometry::scale_mode::fill;
}
else if (str2 == L"original") {
return frame_geometry::scale_mode::original;
}
else if (str2 == L"hfill") {
return frame_geometry::scale_mode::hfill;
}
else if (str2 == L"vfill") {
return frame_geometry::scale_mode::vfill;
}
else {
return frame_geometry::scale_mode::stretch;
}
frame_geometry::scale_mode scale_mode_from_string(const std::wstring& str)
{
auto str2 = boost::to_lower_copy(str);
if (str2 == L"fit") {
return frame_geometry::scale_mode::fit;
} else if (str2 == L"fill") {
return frame_geometry::scale_mode::fill;
} else if (str2 == L"original") {
return frame_geometry::scale_mode::original;
} else if (str2 == L"hfill") {
return frame_geometry::scale_mode::hfill;
} else if (str2 == L"vfill") {
return frame_geometry::scale_mode::vfill;
} else {
return frame_geometry::scale_mode::stretch;
}
}

std::wstring scale_mode_to_string(frame_geometry::scale_mode mode) {
switch (mode) {
case frame_geometry::scale_mode::fit:
return L"FIT";
case frame_geometry::scale_mode::fill:
return L"FILL";
case frame_geometry::scale_mode::original:
return L"ORIGINAL";
case frame_geometry::scale_mode::hfill:
return L"HFILL";
case frame_geometry::scale_mode::vfill:
return L"VFILL";
default:
return L"STRETCH";
}
std::wstring scale_mode_to_string(frame_geometry::scale_mode mode)
{
switch (mode) {
case frame_geometry::scale_mode::fit:
return L"FIT";
case frame_geometry::scale_mode::fill:
return L"FILL";
case frame_geometry::scale_mode::original:
return L"ORIGINAL";
case frame_geometry::scale_mode::hfill:
return L"HFILL";
case frame_geometry::scale_mode::vfill:
return L"VFILL";
default:
return L"STRETCH";
}
}

}} // namespace caspar::core
2 changes: 1 addition & 1 deletion src/core/frame/geometry.h
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,6 @@ class frame_geometry
};

frame_geometry::scale_mode scale_mode_from_string(const std::wstring&);
std::wstring scale_mode_to_string(frame_geometry::scale_mode);
std::wstring scale_mode_to_string(frame_geometry::scale_mode);

}} // namespace caspar::core
4 changes: 3 additions & 1 deletion src/core/mixer/audio/audio_mixer.h
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,9 @@

#include <cstdint>

namespace caspar::diagnostics { class graph; }
namespace caspar::diagnostics {
class graph;
}

namespace caspar { namespace core {

Expand Down
2 changes: 1 addition & 1 deletion src/core/mixer/image/image_mixer.h
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ namespace caspar { namespace core {
struct mixed_image
{
array<const uint8_t> rgba8;
std::any texture;
std::any texture;

mixed_image(array<const uint8_t> rgba8, std::any texture)
: rgba8(rgba8)
Expand Down
4 changes: 3 additions & 1 deletion src/core/mixer/mixer.h
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,9 @@
#include <core/fwd.h>
#include <core/monitor/monitor.h>

namespace caspar::diagnostics { class graph; }
namespace caspar::diagnostics {
class graph;
}

namespace caspar { namespace core {

Expand Down
53 changes: 27 additions & 26 deletions src/core/producer/route/route_producer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ namespace caspar { namespace core {
class route_producer
: public frame_producer
, public route_control
, public std::enable_shared_from_this<route_producer>
, public std::enable_shared_from_this<route_producer>
{
spl::shared_ptr<diagnostics::graph> graph_;

Expand All @@ -50,7 +50,7 @@ class route_producer
caspar::timer produce_timer_;
caspar::timer consume_timer_;

std::shared_ptr<route> route_;
std::shared_ptr<route> route_;

std::optional<std::pair<core::draw_frame, core::draw_frame>> frame_;
int source_channel_;
Expand Down Expand Up @@ -91,29 +91,30 @@ class route_producer

void connect_slot()
{
auto weak_self = weak_from_this();
connection_ = route_->signal.connect([weak_self](const core::draw_frame& frame1, const core::draw_frame& frame2) {
if (auto self = weak_self.lock()) {
auto frame1b = frame1;
if (!frame1b) {
// We got a frame, so ensure it is a real frame (otherwise the layer gets confused)
frame1b = core::draw_frame::push(frame1);
}
auto frame2b = frame2;
if (!frame2b) {
// Ensure that any interlaced channel will repeat frames instead of showing black.
// Note: doing 50p -> 50i will result in dropping to 25p and frame doubling.
frame2b = frame1b;
}

if (!self->buffer_.try_push(std::make_pair(frame1b, frame2b))) {
self->graph_->set_tag(diagnostics::tag_severity::WARNING, "dropped-frame");
}
self->graph_->set_value("produce-time", self->produce_timer_.elapsed() * self->route_->format_desc.fps * 0.5);
self->produce_timer_.restart();
}
}
);
auto weak_self = weak_from_this();
connection_ =
route_->signal.connect([weak_self](const core::draw_frame& frame1, const core::draw_frame& frame2) {
if (auto self = weak_self.lock()) {
auto frame1b = frame1;
if (!frame1b) {
// We got a frame, so ensure it is a real frame (otherwise the layer gets confused)
frame1b = core::draw_frame::push(frame1);
}
auto frame2b = frame2;
if (!frame2b) {
// Ensure that any interlaced channel will repeat frames instead of showing black.
// Note: doing 50p -> 50i will result in dropping to 25p and frame doubling.
frame2b = frame1b;
}

if (!self->buffer_.try_push(std::make_pair(frame1b, frame2b))) {
self->graph_->set_tag(diagnostics::tag_severity::WARNING, "dropped-frame");
}
self->graph_->set_value("produce-time",
self->produce_timer_.elapsed() * self->route_->format_desc.fps * 0.5);
self->produce_timer_.restart();
}
});
}

draw_frame last_frame(const core::video_field field) override
Expand Down Expand Up @@ -211,7 +212,7 @@ spl::shared_ptr<core::frame_producer> create_route_producer(const core::frame_pr
}

auto buffer = get_param(L"BUFFER", params, 0);
auto rp = spl::make_shared<route_producer>((*channel_it)->route(layer, mode), buffer, channel, layer);
auto rp = spl::make_shared<route_producer>((*channel_it)->route(layer, mode), buffer, channel, layer);
rp->connect_slot();
return rp;
}
Expand Down
4 changes: 3 additions & 1 deletion src/core/producer/stage.h
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,9 @@
#include <tuple>
#include <vector>

namespace caspar::diagnostics { class graph; }
namespace caspar::diagnostics {
class graph;
}

namespace caspar { namespace core {

Expand Down
Loading

0 comments on commit 5008a84

Please sign in to comment.