Queue.h File

Queue Node — wraps GStreamer queue for buffer decoupling between stages. More...

Included Headers

#include "builder/Node.h" #include <memory> #include <vector>

Namespaces Index

namespace	simaai
namespace	neat
namespace	nodes

Classes Index

class	Queue
	Wraps GStreamer's queue element — inserts a thread/buffer boundary. More...

Description

Queue Node — wraps GStreamer queue for buffer decoupling between stages.

Inserts a queue element that decouples upstream and downstream threads. Useful anywhere the natural producer rate doesn't match the consumer rate, or when crossing a thread boundary that GStreamer's caps negotiation needs explicit help with.

File Listing

The file content with the documentation metadata removed is:

1

10#pragma once

11

12#include "builder/Node.h"

13

14#include <memory>

15#include <vector>

16

17namespace simaai::neat {

18

29class Queue final : public Node {

30public:

32 std::string kind() const override {

33 return "Queue";

34 }

36 NodeCapsBehavior caps_behavior() const override {

37 return NodeCapsBehavior::Dynamic;

38 }

40 std::string backend_fragment(int node_index) const override;

42 std::vector<std::string> element_names(int node_index) const override;

43};

44

45} // namespace simaai::neat

46

47namespace simaai::neat::nodes {

49std::shared_ptr<simaai::neat::Node> Queue();

50} // namespace simaai::neat::nodes

---

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.