, channel_index_(-1)\r
{\r
graph_->set_color("tick-time", diagnostics::color(0.0f, 0.6f, 0.9f)); \r
+ graph_->set_color("dropped-frame", diagnostics::color(0.3f, 0.6f, 0.3f));\r
diagnostics::register_graph(graph_);\r
\r
is_running_ = true;\r
- input_.set_capacity(1);\r
+ input_.set_capacity(2);\r
}\r
\r
~oal_consumer()\r
\r
virtual bool send(core::const_frame frame) override\r
{ \r
- input_.push(std::make_shared<audio_buffer_16>(core::audio_32_to_16(frame.audio_data())));\r
+ if(!input_.try_push(std::make_shared<audio_buffer_16>(core::audio_32_to_16(frame.audio_data()))))\r
+ graph_->set_tag("dropped-frame");\r
+\r
return true;\r
}\r
\r
return info;\r
}\r
\r
+ virtual bool has_synchronization_clock() const override\r
+ {\r
+ return false;\r
+ }\r
+ \r
virtual int buffer_depth() const override\r
{\r
return 3;\r