\hypertarget{mqttsrc_8c}{}\doxysection{mqtt/mqttsrc.c File Reference}
\label{mqttsrc_8c}\index{mqtt/mqttsrc.c@{mqtt/mqttsrc.c}}


Subscribe a M\+Q\+TT topic and push incoming data to the G\+Streamer pipeline.  


{\ttfamily \#include $<$sys/types.\+h$>$}\newline
{\ttfamily \#include $<$unistd.\+h$>$}\newline
{\ttfamily \#include $<$gst/base/gstbasesrc.\+h$>$}\newline
{\ttfamily \#include $<$M\+Q\+T\+T\+Async.\+h$>$}\newline
{\ttfamily \#include $<$nnstreamer\+\_\+util.\+h$>$}\newline
{\ttfamily \#include \char`\"{}mqttsrc.\+h\char`\"{}}\newline
Include dependency graph for mqttsrc.\+c\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c__incl}
\end{center}
\end{figure}
\doxysubsection*{Macros}
\begin{DoxyCompactItemize}
\item 
\#define \mbox{\hyperlink{mqttsrc_8c_abd8670109f1fac9c72cc3b999761474c}{gst\+\_\+mqtt\+\_\+src\+\_\+parent\+\_\+class}}~parent\+\_\+class
\item 
\#define \mbox{\hyperlink{mqttsrc_8c_adef911caed7c65a1643062817f4a59d7}{G\+S\+T\+\_\+\+C\+A\+T\+\_\+\+D\+E\+F\+A\+U\+LT}}~gst\+\_\+mqtt\+\_\+src\+\_\+debug
\end{DoxyCompactItemize}
\doxysubsection*{Enumerations}
\begin{DoxyCompactItemize}
\item 
enum \{ \newline
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dac37dda0da1a44e10c0504afeeb863f3c}{P\+R\+O\+P\+\_\+0}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da5002941e2dd078f20b37d827b6f793c5}{P\+R\+O\+P\+\_\+\+D\+E\+B\+UG}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da443dccdb96d5f2ca8eb3be59f24cb5c4}{P\+R\+O\+P\+\_\+\+I\+S\+\_\+\+L\+I\+VE}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035daa8e9e69695017e869edb6df2ef4bcd1f}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+ID}}, 
\newline
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da625d763cbc971fa25899a863ef9e9c47}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+A\+D\+D\+R\+E\+SS}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da857e4c603b9584e3db0189e347d6a410}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+P\+O\+RT}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da19a8245ade1373336979890bd1b5548f}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+O\+P\+IC}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dad115782d9d44d8787f68001029bfb45c}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+I\+M\+E\+O\+UT}}, 
\newline
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da12529ca940e7dcad8643b160d4a08c25}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+C\+L\+E\+A\+N\+S\+E\+S\+S\+I\+ON}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da97c565ca6729233c9894f55dee329fea}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+K\+E\+E\+P\+\_\+\+A\+L\+I\+V\+E\+\_\+\+I\+N\+T\+E\+R\+V\+AL}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dabc82f1000422a4e81e189931a80c5c23}{P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+Q\+OS}}, 
\mbox{\hyperlink{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dab2ccf2ce99ca729409339bda94f10e60}{P\+R\+O\+P\+\_\+\+L\+A\+ST}}
 \}
\item 
enum \{ \newline
\mbox{\hyperlink{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a26d9a3b79d5290964e5a2feafd5b821b}{D\+E\+F\+A\+U\+L\+T\+\_\+\+D\+E\+B\+UG}} = F\+A\+L\+SE, 
\mbox{\hyperlink{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a77a4a32972ab8a350397bea33632998a}{D\+E\+F\+A\+U\+L\+T\+\_\+\+I\+S\+\_\+\+L\+I\+VE}} = T\+R\+UE, 
\mbox{\hyperlink{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a0621f95d211878b36cfaf3ee9464e0ac}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+C\+L\+E\+A\+N\+S\+E\+S\+S\+I\+ON}} = T\+R\+UE, 
\mbox{\hyperlink{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8afec8cffee1de75f1242ad67be046c4df}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+K\+E\+E\+P\+\_\+\+A\+L\+I\+V\+E\+\_\+\+I\+N\+T\+E\+R\+V\+AL}} = 60, 
\newline
\mbox{\hyperlink{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a227299cd231d4217dbc9001eaa965b40}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+I\+M\+E\+O\+UT}} = 10000000, 
\mbox{\hyperlink{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a4c671623012f3245d4ab687b8214d1c5}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+I\+M\+E\+O\+U\+T\+\_\+\+M\+IN}} = 1000000, 
\mbox{\hyperlink{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a812aa2f48beeea9c889bb3e323fef846}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+Q\+OS}} = 2
 \}
\end{DoxyCompactItemize}
\doxysubsection*{Functions}
\begin{DoxyCompactItemize}
\item 
\mbox{\hyperlink{mqttsrc_8c_abbef95aceb98034e51bec0521ff26af3}{G\+\_\+\+D\+E\+F\+I\+N\+E\+\_\+\+T\+Y\+PE}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}}, gst\+\_\+mqtt\+\_\+src, G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+B\+A\+S\+E\+\_\+\+S\+RC)
\item 
\mbox{\hyperlink{mqttsrc_8c_a552a83a0e977d89b9faa64980946cb3b}{G\+S\+T\+\_\+\+D\+E\+B\+U\+G\+\_\+\+C\+A\+T\+E\+G\+O\+R\+Y\+\_\+\+S\+T\+A\+T\+IC}} (gst\+\_\+mqtt\+\_\+src\+\_\+debug)
\item 
static void \mbox{\hyperlink{mqttsrc_8c_ac50d7a23de9ee1e188c925ebe2541c61}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+property}} (G\+Object $\ast$object, guint prop\+\_\+id, const G\+Value $\ast$value, G\+Param\+Spec $\ast$pspec)
\begin{DoxyCompactList}\small\item\em The setter for the mqttsrc\textquotesingle{}s properties. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_aee0280bfdb045d6feb9510396ad0b533}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+property}} (G\+Object $\ast$object, guint prop\+\_\+id, G\+Value $\ast$value, G\+Param\+Spec $\ast$pspec)
\begin{DoxyCompactList}\small\item\em The getter for the mqttsrc\textquotesingle{}s properties. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_abb59c0ad40f9210f3f01fc5533df3a43}{gst\+\_\+mqtt\+\_\+src\+\_\+class\+\_\+finalize}} (G\+Object $\ast$object)
\begin{DoxyCompactList}\small\item\em Finalize Gst\+Mqtt\+Src\+Class object. \end{DoxyCompactList}\item 
static Gst\+State\+Change\+Return \mbox{\hyperlink{mqttsrc_8c_ad6cb729f34768b9260486c29b7c02a37}{gst\+\_\+mqtt\+\_\+src\+\_\+change\+\_\+state}} (Gst\+Element $\ast$element, Gst\+State\+Change transition)
\begin{DoxyCompactList}\small\item\em Handle mqttsrc\textquotesingle{}s state change. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_aa8c98523c34d98c5f8849381df8250c1}{gst\+\_\+mqtt\+\_\+src\+\_\+start}} (Gst\+Base\+Src $\ast$basesrc)
\begin{DoxyCompactList}\small\item\em Start mqttsrc, called when state changed null to ready. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_a193b99c411cf9ec77335b3e9c5d30d09}{gst\+\_\+mqtt\+\_\+src\+\_\+stop}} (Gst\+Base\+Src $\ast$basesrc)
\begin{DoxyCompactList}\small\item\em Stop mqttsrc, called when state changed ready to null. \end{DoxyCompactList}\item 
static Gst\+Caps $\ast$ \mbox{\hyperlink{mqttsrc_8c_a40a52cc9dcd7fd2a664c030dec52bbac}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+caps}} (Gst\+Base\+Src $\ast$basesrc, Gst\+Caps $\ast$filter)
\begin{DoxyCompactList}\small\item\em Get caps of subclass. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_a88e9c51dd7524672a79022e2b22140a4}{gst\+\_\+mqtt\+\_\+src\+\_\+renegotiate}} (Gst\+Base\+Src $\ast$basesrc)
\begin{DoxyCompactList}\small\item\em Do negotiation procedure again if it needed. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a287955fd73eb6ca9af7be672cd1d6fd6}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+times}} (Gst\+Base\+Src $\ast$basesrc, Gst\+Buffer $\ast$buffer, Gst\+Clock\+Time $\ast$start, Gst\+Clock\+Time $\ast$end)
\begin{DoxyCompactList}\small\item\em Return the time information of the given buffer. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_aef5e7d56220b9addad44bf3162d14bc2}{gst\+\_\+mqtt\+\_\+src\+\_\+is\+\_\+seekable}} (Gst\+Base\+Src $\ast$basesrc)
\begin{DoxyCompactList}\small\item\em Check if source supports seeking. \end{DoxyCompactList}\item 
static Gst\+Flow\+Return \mbox{\hyperlink{mqttsrc_8c_a6a486710b0c3d541c99bfd6c698d7b75}{gst\+\_\+mqtt\+\_\+src\+\_\+create}} (Gst\+Base\+Src $\ast$basesrc, guint64 offset, guint size, Gst\+Buffer $\ast$$\ast$buf)
\begin{DoxyCompactList}\small\item\em Create a buffer containing the subscribed data. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_ad51a0141d5e31f8763c343f2a491aa3c}{gst\+\_\+mqtt\+\_\+src\+\_\+query}} (Gst\+Base\+Src $\ast$basesrc, Gst\+Query $\ast$query)
\begin{DoxyCompactList}\small\item\em An implementation of the Gst\+Base\+Src vmethod that handles queries. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_ad7f7964db3f583a7a91ba67be76c1171}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+debug}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}debug\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a4cc428ad2c23121abbe14310b7761b91}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+debug}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gboolean flag)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}debug\textquotesingle{} property. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_a642846cf0b1f42200691f5960196b7a4}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+is\+\_\+live}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}is-\/live\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a4d42bb15e609fcf5e33cbf2dccbd85cc}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+is\+\_\+live}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gboolean flag)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}is-\/live\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsrc_8c_ae28ac0e5ae2d80fc2ea93a8425bc0a09}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+client\+\_\+id}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}client-\/id\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_ad7bf46868fd29ac554dc38874cf05b42}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+client\+\_\+id}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gchar $\ast$id)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}client-\/id\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsrc_8c_a05687362d11b4e987c376d750bbf31fc}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+host\+\_\+address}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}host\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a7d9a8923dba5bf7661212331d95004d5}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+host\+\_\+address}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gchar $\ast$addr)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}host\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsrc_8c_aef1c5dbf0fa7cc8212fd71d1f5a837a8}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+host\+\_\+port}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}port\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a8f56fc85603f27de1a968b4d0e51a741}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+host\+\_\+port}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gchar $\ast$port)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}port\textquotesingle{} property. \end{DoxyCompactList}\item 
static gint64 \mbox{\hyperlink{mqttsrc_8c_a30e7b5029a10b67ed6b046d3ec4074eb}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+sub\+\_\+timeout}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}sub-\/timeout\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a2f0cd5ec28efac7ec7c64c32fd4c7984}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+sub\+\_\+timeout}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gint64 t)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}sub-\/timeout\textquotesingle{} property. \end{DoxyCompactList}\item 
static gchar $\ast$ \mbox{\hyperlink{mqttsrc_8c_af0ac24674227253eafe8f38f3f3391e3}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+sub\+\_\+topic}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}sub-\/topic\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_ace7b46b9a5fd3ae5b103644e8c5503ee}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+sub\+\_\+topic}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gchar $\ast$topic)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}sub-\/topic\textquotesingle{} property. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_a93318e392c49117a544d85297c85daca}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+opt\+\_\+cleansession}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}cleansession\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a649b0685ee1570ab4c32c0d048304477}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+opt\+\_\+cleansession}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gboolean val)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}cleansession\textquotesingle{} property. \end{DoxyCompactList}\item 
static gint \mbox{\hyperlink{mqttsrc_8c_ac9edd1551b1fbe85a037d68354e828dc}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+opt\+\_\+keep\+\_\+alive\+\_\+interval}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}keep-\/alive-\/interval\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a77c26708521c011ffe6417b169c2b2b4}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+opt\+\_\+keep\+\_\+alive\+\_\+interval}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gint num)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}keep-\/alive-\/interval\textquotesingle{} property. \end{DoxyCompactList}\item 
static gint \mbox{\hyperlink{mqttsrc_8c_a1fec5b3e3ac533ad91d8ccb6c39990c6}{gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+mqtt\+\_\+qos}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Getter for the \textquotesingle{}mqtt-\/qos\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_ace7a6fbafdb59597e86ff194d2a73fbc}{gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+mqtt\+\_\+qos}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, const gint qos)
\begin{DoxyCompactList}\small\item\em Setter for the \textquotesingle{}mqtt-\/qos\textquotesingle{} property. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a9d1641daa30b926d359514e56da29323}{cb\+\_\+mqtt\+\_\+on\+\_\+connection\+\_\+lost}} (void $\ast$context, char $\ast$cause)
\begin{DoxyCompactList}\small\item\em A callback to handle the connection lost to the broker. \end{DoxyCompactList}\item 
static int \mbox{\hyperlink{mqttsrc_8c_a885feb7e9cb0a60f1c09c7456fa83b64}{cb\+\_\+mqtt\+\_\+on\+\_\+message\+\_\+arrived}} (void $\ast$context, char $\ast$topic\+\_\+name, int topic\+\_\+len, M\+Q\+T\+T\+Async\+\_\+message $\ast$message)
\begin{DoxyCompactList}\small\item\em A callback to handle the arrived message. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7}{cb\+\_\+mqtt\+\_\+on\+\_\+connect}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em A callback invoked when the connection is established. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a0c22b06eae9165e52844885f7c48404c}{cb\+\_\+mqtt\+\_\+on\+\_\+connect\+\_\+failure}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em A callback invoked when it is failed to connect to the broker. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_ac76f0c62bc87c18bdab688b42ca6ac0b}{cb\+\_\+mqtt\+\_\+on\+\_\+subscribe}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Success callback for M\+Q\+T\+T\+Async\+\_\+subscribe () \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a46fb61b2876530ce7368db3bf71c1218}{cb\+\_\+mqtt\+\_\+on\+\_\+subscribe\+\_\+failure}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Failure callback for M\+Q\+T\+T\+Async\+\_\+subscribe () \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a91a203c048b8526469b8f6457dabbfdb}{cb\+\_\+mqtt\+\_\+on\+\_\+unsubscribe}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Success callback for M\+Q\+T\+T\+Async\+\_\+unsubscribe () \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a385e5109ee940d6c8def70c1051e19f1}{cb\+\_\+mqtt\+\_\+on\+\_\+unsubscribe\+\_\+failure}} (void $\ast$context, M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$response)
\begin{DoxyCompactList}\small\item\em M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Failure callback for M\+Q\+T\+T\+Async\+\_\+unsubscribe () \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a8ea26f58ca912f962b26f3c79af7ea8f}{cb\+\_\+memory\+\_\+wrapped\+\_\+destroy}} (void $\ast$p)
\begin{DoxyCompactList}\small\item\em A callback invoked when destroying the Gst\+Memory which wrapped the arrived message. \end{DoxyCompactList}\item 
static \mbox{\hyperlink{mqttcommon_8h_aebbdc549dc7aa1431f3b2b9a0b5e8f2c}{Gst\+M\+Q\+T\+T\+Message\+Hdr}} $\ast$ \mbox{\hyperlink{mqttsrc_8c_a93d4d53875e594b625c12dd12c73213b}{\+\_\+extract\+\_\+mqtt\+\_\+msg\+\_\+hdr\+\_\+from}} (Gst\+Memory $\ast$mem, Gst\+Memory $\ast$$\ast$hdr\+\_\+mem, Gst\+Map\+Info $\ast$hdr\+\_\+map\+\_\+info)
\begin{DoxyCompactList}\small\item\em A utility function to extract header information from a received message. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_af28b80418b31f51bd6c5353ab52d1b0d}{\+\_\+put\+\_\+timestamp\+\_\+on\+\_\+gst\+\_\+buf}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self, \mbox{\hyperlink{mqttcommon_8h_aebbdc549dc7aa1431f3b2b9a0b5e8f2c}{Gst\+M\+Q\+T\+T\+Message\+Hdr}} $\ast$hdr, Gst\+Buffer $\ast$buf)
\begin{DoxyCompactList}\small\item\em A utility function to put the timestamp information onto a Gst\+Buffer-\/typed buffer using the given packet header. \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_a70b649f57d639b475150b0ec2f809a3f}{\+\_\+subscribe}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em A helper function to properly invoke M\+Q\+T\+T\+Async\+\_\+subscribe () \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_a82f3c4603a163cf572c6d66d3f0826d9}{\+\_\+unsubscribe}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em A wrapper function that calls M\+Q\+T\+T\+Async\+\_\+unsubscribe () \end{DoxyCompactList}\item 
static gboolean \mbox{\hyperlink{mqttsrc_8c_ad45ca2e7e5a03ad3cbd8807b08de8d32}{\+\_\+is\+\_\+gst\+\_\+buffer\+\_\+timestamp\+\_\+valid}} (Gst\+Buffer $\ast$buf)
\begin{DoxyCompactList}\small\item\em A utility function to check whether the timestamp marked by \+\_\+put\+\_\+timestamp\+\_\+on\+\_\+gst\+\_\+buf () is valid or not. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_aca4c6cad19565538fa80a7a3b842d490}{gst\+\_\+mqtt\+\_\+src\+\_\+init}} (\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$self)
\begin{DoxyCompactList}\small\item\em Initialize Gst\+Mqtt\+Src object. \end{DoxyCompactList}\item 
static void \mbox{\hyperlink{mqttsrc_8c_a614541abe9b3c48a8d6aa6cfd42a3a14}{gst\+\_\+mqtt\+\_\+src\+\_\+class\+\_\+init}} (\mbox{\hyperlink{mqttsrc_8h_af3dd6005e7d4f293d044445ccff99cb0}{Gst\+Mqtt\+Src\+Class}} $\ast$klass)
\begin{DoxyCompactList}\small\item\em Initialize Gst\+Mqtt\+Src\+Class object. \end{DoxyCompactList}\end{DoxyCompactItemize}
\doxysubsection*{Variables}
\begin{DoxyCompactItemize}
\item 
static Gst\+Static\+Pad\+Template \mbox{\hyperlink{mqttsrc_8c_a696cd223d7a6a3dab6272a892b0ad8ca}{src\+\_\+pad\+\_\+template}}
\item 
static guint8 \mbox{\hyperlink{mqttsrc_8c_a8d3a15e3ce4889fc1efdcec4dedb76e7}{src\+\_\+client\+\_\+id}} = 0
\item 
static const gchar \mbox{\hyperlink{mqttsrc_8c_adb7c1d7abe7c50e461f495f2b6b9adbc}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+A\+D\+D\+R\+E\+SS}} \mbox{[}$\,$\mbox{]} = \char`\"{}127.\+0.\+0.\+1\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsrc_8c_a782553475a8ab1e231242a2ab4fcd43f}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+P\+O\+RT}} \mbox{[}$\,$\mbox{]} = \char`\"{}1883\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsrc_8c_a541a235141c16edf0af8892617030912}{T\+A\+G\+\_\+\+E\+R\+R\+\_\+\+M\+Q\+T\+T\+S\+RC}} \mbox{[}$\,$\mbox{]} = \char`\"{}E\+R\+R\+O\+R\+: M\+Q\+T\+T\+Src\char`\"{}
\item 
static const gchar \mbox{\hyperlink{mqttsrc_8c_ad7802f55a92df9e9b9d3cfd5e2fb11bf}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+ID}} \mbox{[}$\,$\mbox{]}
\item 
static const gchar \mbox{\hyperlink{mqttsrc_8c_acf4f9062c5331fe5613e31c923468e30}{D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+I\+D\+\_\+\+F\+O\+R\+M\+AT}} \mbox{[}$\,$\mbox{]} = \char`\"{}\%s\+\_\+\%u\+\_\+src\%u\char`\"{}
\end{DoxyCompactItemize}


\doxysubsection{Detailed Description}
Subscribe a M\+Q\+TT topic and push incoming data to the G\+Streamer pipeline. 

Copyright (C) 2021 Wook Song \href{mailto:wook16.song@samsung.com}{\texttt{ wook16.\+song@samsung.\+com}}

\begin{DoxyDate}{Date}
08 Mar 2021 
\end{DoxyDate}
\begin{DoxySeeAlso}{See also}
\href{https://github.com/nnstreamer/nnstreamer}{\texttt{ https\+://github.\+com/nnstreamer/nnstreamer}} 
\end{DoxySeeAlso}
\begin{DoxyAuthor}{Author}
Wook Song \href{mailto:wook16.song@samsung.com}{\texttt{ wook16.\+song@samsung.\+com}} 
\end{DoxyAuthor}
\begin{DoxyRefDesc}{Bug}
\item[\mbox{\hyperlink{bug__bug000020}{Bug}}]No known bugs except for N\+YI items \end{DoxyRefDesc}


\doxysubsection{Macro Definition Documentation}
\mbox{\Hypertarget{mqttsrc_8c_adef911caed7c65a1643062817f4a59d7}\label{mqttsrc_8c_adef911caed7c65a1643062817f4a59d7}} 
\index{mqttsrc.c@{mqttsrc.c}!GST\_CAT\_DEFAULT@{GST\_CAT\_DEFAULT}}
\index{GST\_CAT\_DEFAULT@{GST\_CAT\_DEFAULT}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{GST\_CAT\_DEFAULT}{GST\_CAT\_DEFAULT}}
{\footnotesize\ttfamily \#define G\+S\+T\+\_\+\+C\+A\+T\+\_\+\+D\+E\+F\+A\+U\+LT~gst\+\_\+mqtt\+\_\+src\+\_\+debug}



Definition at line 38 of file mqttsrc.\+c.

\mbox{\Hypertarget{mqttsrc_8c_abd8670109f1fac9c72cc3b999761474c}\label{mqttsrc_8c_abd8670109f1fac9c72cc3b999761474c}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_parent\_class@{gst\_mqtt\_src\_parent\_class}}
\index{gst\_mqtt\_src\_parent\_class@{gst\_mqtt\_src\_parent\_class}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_parent\_class}{gst\_mqtt\_src\_parent\_class}}
{\footnotesize\ttfamily \#define gst\+\_\+mqtt\+\_\+src\+\_\+parent\+\_\+class~parent\+\_\+class}



Definition at line 34 of file mqttsrc.\+c.



\doxysubsection{Enumeration Type Documentation}
\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035d}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035d}} 
\doxysubsubsection{\texorpdfstring{anonymous enum}{anonymous enum}}
{\footnotesize\ttfamily anonymous enum}

\begin{DoxyEnumFields}{Enumerator}
\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_0@{PROP\_0}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_0@{PROP\_0}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dac37dda0da1a44e10c0504afeeb863f3c}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dac37dda0da1a44e10c0504afeeb863f3c}} 
P\+R\+O\+P\+\_\+0&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_DEBUG@{PROP\_DEBUG}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_DEBUG@{PROP\_DEBUG}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da5002941e2dd078f20b37d827b6f793c5}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da5002941e2dd078f20b37d827b6f793c5}} 
P\+R\+O\+P\+\_\+\+D\+E\+B\+UG&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_IS\_LIVE@{PROP\_IS\_LIVE}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_IS\_LIVE@{PROP\_IS\_LIVE}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da443dccdb96d5f2ca8eb3be59f24cb5c4}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da443dccdb96d5f2ca8eb3be59f24cb5c4}} 
P\+R\+O\+P\+\_\+\+I\+S\+\_\+\+L\+I\+VE&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_CLIENT\_ID@{PROP\_MQTT\_CLIENT\_ID}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_MQTT\_CLIENT\_ID@{PROP\_MQTT\_CLIENT\_ID}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035daa8e9e69695017e869edb6df2ef4bcd1f}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035daa8e9e69695017e869edb6df2ef4bcd1f}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+ID&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_HOST\_ADDRESS@{PROP\_MQTT\_HOST\_ADDRESS}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_MQTT\_HOST\_ADDRESS@{PROP\_MQTT\_HOST\_ADDRESS}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da625d763cbc971fa25899a863ef9e9c47}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da625d763cbc971fa25899a863ef9e9c47}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+A\+D\+D\+R\+E\+SS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_HOST\_PORT@{PROP\_MQTT\_HOST\_PORT}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_MQTT\_HOST\_PORT@{PROP\_MQTT\_HOST\_PORT}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da857e4c603b9584e3db0189e347d6a410}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da857e4c603b9584e3db0189e347d6a410}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+P\+O\+RT&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_SUB\_TOPIC@{PROP\_MQTT\_SUB\_TOPIC}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_MQTT\_SUB\_TOPIC@{PROP\_MQTT\_SUB\_TOPIC}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da19a8245ade1373336979890bd1b5548f}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da19a8245ade1373336979890bd1b5548f}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+O\+P\+IC&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_SUB\_TIMEOUT@{PROP\_MQTT\_SUB\_TIMEOUT}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_MQTT\_SUB\_TIMEOUT@{PROP\_MQTT\_SUB\_TIMEOUT}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dad115782d9d44d8787f68001029bfb45c}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dad115782d9d44d8787f68001029bfb45c}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+I\+M\+E\+O\+UT&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_OPT\_CLEANSESSION@{PROP\_MQTT\_OPT\_CLEANSESSION}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_MQTT\_OPT\_CLEANSESSION@{PROP\_MQTT\_OPT\_CLEANSESSION}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da12529ca940e7dcad8643b160d4a08c25}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da12529ca940e7dcad8643b160d4a08c25}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+C\+L\+E\+A\+N\+S\+E\+S\+S\+I\+ON&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL@{PROP\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL@{PROP\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da97c565ca6729233c9894f55dee329fea}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035da97c565ca6729233c9894f55dee329fea}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+K\+E\+E\+P\+\_\+\+A\+L\+I\+V\+E\+\_\+\+I\+N\+T\+E\+R\+V\+AL&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_MQTT\_QOS@{PROP\_MQTT\_QOS}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_MQTT\_QOS@{PROP\_MQTT\_QOS}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dabc82f1000422a4e81e189931a80c5c23}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dabc82f1000422a4e81e189931a80c5c23}} 
P\+R\+O\+P\+\_\+\+M\+Q\+T\+T\+\_\+\+Q\+OS&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{PROP\_LAST@{PROP\_LAST}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!PROP\_LAST@{PROP\_LAST}}}\mbox{\Hypertarget{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dab2ccf2ce99ca729409339bda94f10e60}\label{mqttsrc_8c_abc5c98fcc1211af2b80116dd6e0a035dab2ccf2ce99ca729409339bda94f10e60}} 
P\+R\+O\+P\+\_\+\+L\+A\+ST&\\
\hline

\end{DoxyEnumFields}


Definition at line 40 of file mqttsrc.\+c.

\mbox{\Hypertarget{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8}\label{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8}} 
\doxysubsubsection{\texorpdfstring{anonymous enum}{anonymous enum}}
{\footnotesize\ttfamily anonymous enum}

\begin{DoxyEnumFields}{Enumerator}
\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_DEBUG@{DEFAULT\_DEBUG}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_DEBUG@{DEFAULT\_DEBUG}}}\mbox{\Hypertarget{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a26d9a3b79d5290964e5a2feafd5b821b}\label{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a26d9a3b79d5290964e5a2feafd5b821b}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+D\+E\+B\+UG&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_IS\_LIVE@{DEFAULT\_IS\_LIVE}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_IS\_LIVE@{DEFAULT\_IS\_LIVE}}}\mbox{\Hypertarget{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a77a4a32972ab8a350397bea33632998a}\label{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a77a4a32972ab8a350397bea33632998a}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+I\+S\+\_\+\+L\+I\+VE&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_OPT\_CLEANSESSION@{DEFAULT\_MQTT\_OPT\_CLEANSESSION}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_OPT\_CLEANSESSION@{DEFAULT\_MQTT\_OPT\_CLEANSESSION}}}\mbox{\Hypertarget{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a0621f95d211878b36cfaf3ee9464e0ac}\label{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a0621f95d211878b36cfaf3ee9464e0ac}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+C\+L\+E\+A\+N\+S\+E\+S\+S\+I\+ON&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL@{DEFAULT\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL@{DEFAULT\_MQTT\_OPT\_KEEP\_ALIVE\_INTERVAL}}}\mbox{\Hypertarget{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8afec8cffee1de75f1242ad67be046c4df}\label{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8afec8cffee1de75f1242ad67be046c4df}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+O\+P\+T\+\_\+\+K\+E\+E\+P\+\_\+\+A\+L\+I\+V\+E\+\_\+\+I\+N\+T\+E\+R\+V\+AL&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_SUB\_TIMEOUT@{DEFAULT\_MQTT\_SUB\_TIMEOUT}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_SUB\_TIMEOUT@{DEFAULT\_MQTT\_SUB\_TIMEOUT}}}\mbox{\Hypertarget{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a227299cd231d4217dbc9001eaa965b40}\label{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a227299cd231d4217dbc9001eaa965b40}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+I\+M\+E\+O\+UT&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_SUB\_TIMEOUT\_MIN@{DEFAULT\_MQTT\_SUB\_TIMEOUT\_MIN}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_SUB\_TIMEOUT\_MIN@{DEFAULT\_MQTT\_SUB\_TIMEOUT\_MIN}}}\mbox{\Hypertarget{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a4c671623012f3245d4ab687b8214d1c5}\label{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a4c671623012f3245d4ab687b8214d1c5}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+I\+M\+E\+O\+U\+T\+\_\+\+M\+IN&\\
\hline

\raisebox{\heightof{T}}[0pt][0pt]{\index{DEFAULT\_MQTT\_QOS@{DEFAULT\_MQTT\_QOS}!mqttsrc.c@{mqttsrc.c}}\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_QOS@{DEFAULT\_MQTT\_QOS}}}\mbox{\Hypertarget{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a812aa2f48beeea9c889bb3e323fef846}\label{mqttsrc_8c_ac36f475ca5b446f4fde4c9b90bec77c8a812aa2f48beeea9c889bb3e323fef846}} 
D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+Q\+OS&\\
\hline

\end{DoxyEnumFields}


Definition at line 58 of file mqttsrc.\+c.



\doxysubsection{Function Documentation}
\mbox{\Hypertarget{mqttsrc_8c_a93d4d53875e594b625c12dd12c73213b}\label{mqttsrc_8c_a93d4d53875e594b625c12dd12c73213b}} 
\index{mqttsrc.c@{mqttsrc.c}!\_extract\_mqtt\_msg\_hdr\_from@{\_extract\_mqtt\_msg\_hdr\_from}}
\index{\_extract\_mqtt\_msg\_hdr\_from@{\_extract\_mqtt\_msg\_hdr\_from}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{\_extract\_mqtt\_msg\_hdr\_from()}{\_extract\_mqtt\_msg\_hdr\_from()}}
{\footnotesize\ttfamily static \mbox{\hyperlink{mqttcommon_8h_aebbdc549dc7aa1431f3b2b9a0b5e8f2c}{Gst\+M\+Q\+T\+T\+Message\+Hdr}} $\ast$ \+\_\+extract\+\_\+mqtt\+\_\+msg\+\_\+hdr\+\_\+from (\begin{DoxyParamCaption}\item[{Gst\+Memory $\ast$}]{mem,  }\item[{Gst\+Memory $\ast$$\ast$}]{hdr\+\_\+mem,  }\item[{Gst\+Map\+Info $\ast$}]{hdr\+\_\+map\+\_\+info }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A utility function to extract header information from a received message. 



Definition at line 1347 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a93d4d53875e594b625c12dd12c73213b_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ad45ca2e7e5a03ad3cbd8807b08de8d32}\label{mqttsrc_8c_ad45ca2e7e5a03ad3cbd8807b08de8d32}} 
\index{mqttsrc.c@{mqttsrc.c}!\_is\_gst\_buffer\_timestamp\_valid@{\_is\_gst\_buffer\_timestamp\_valid}}
\index{\_is\_gst\_buffer\_timestamp\_valid@{\_is\_gst\_buffer\_timestamp\_valid}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{\_is\_gst\_buffer\_timestamp\_valid()}{\_is\_gst\_buffer\_timestamp\_valid()}}
{\footnotesize\ttfamily static gboolean \+\_\+is\+\_\+gst\+\_\+buffer\+\_\+timestamp\+\_\+valid (\begin{DoxyParamCaption}\item[{Gst\+Buffer $\ast$}]{buf }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [inline]}, {\ttfamily [static]}}



A utility function to check whether the timestamp marked by \+\_\+put\+\_\+timestamp\+\_\+on\+\_\+gst\+\_\+buf () is valid or not. 



Definition at line 156 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ad45ca2e7e5a03ad3cbd8807b08de8d32_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_af28b80418b31f51bd6c5353ab52d1b0d}\label{mqttsrc_8c_af28b80418b31f51bd6c5353ab52d1b0d}} 
\index{mqttsrc.c@{mqttsrc.c}!\_put\_timestamp\_on\_gst\_buf@{\_put\_timestamp\_on\_gst\_buf}}
\index{\_put\_timestamp\_on\_gst\_buf@{\_put\_timestamp\_on\_gst\_buf}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{\_put\_timestamp\_on\_gst\_buf()}{\_put\_timestamp\_on\_gst\_buf()}}
{\footnotesize\ttfamily static void \+\_\+put\+\_\+timestamp\+\_\+on\+\_\+gst\+\_\+buf (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{\mbox{\hyperlink{mqttcommon_8h_aebbdc549dc7aa1431f3b2b9a0b5e8f2c}{Gst\+M\+Q\+T\+T\+Message\+Hdr}} $\ast$}]{hdr,  }\item[{Gst\+Buffer $\ast$}]{buf }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A utility function to put the timestamp information onto a Gst\+Buffer-\/typed buffer using the given packet header. 



Definition at line 1366 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_af28b80418b31f51bd6c5353ab52d1b0d_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a70b649f57d639b475150b0ec2f809a3f}\label{mqttsrc_8c_a70b649f57d639b475150b0ec2f809a3f}} 
\index{mqttsrc.c@{mqttsrc.c}!\_subscribe@{\_subscribe}}
\index{\_subscribe@{\_subscribe}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{\_subscribe()}{\_subscribe()}}
{\footnotesize\ttfamily static gboolean \+\_\+subscribe (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A helper function to properly invoke M\+Q\+T\+T\+Async\+\_\+subscribe () 



Definition at line 1308 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=309pt]{mqttsrc_8c_a70b649f57d639b475150b0ec2f809a3f_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a70b649f57d639b475150b0ec2f809a3f_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a82f3c4603a163cf572c6d66d3f0826d9}\label{mqttsrc_8c_a82f3c4603a163cf572c6d66d3f0826d9}} 
\index{mqttsrc.c@{mqttsrc.c}!\_unsubscribe@{\_unsubscribe}}
\index{\_unsubscribe@{\_unsubscribe}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{\_unsubscribe()}{\_unsubscribe()}}
{\footnotesize\ttfamily static gboolean \+\_\+unsubscribe (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A wrapper function that calls M\+Q\+T\+T\+Async\+\_\+unsubscribe () 



Definition at line 1328 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=333pt]{mqttsrc_8c_a82f3c4603a163cf572c6d66d3f0826d9_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a82f3c4603a163cf572c6d66d3f0826d9_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a8ea26f58ca912f962b26f3c79af7ea8f}\label{mqttsrc_8c_a8ea26f58ca912f962b26f3c79af7ea8f}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_memory\_wrapped\_destroy@{cb\_memory\_wrapped\_destroy}}
\index{cb\_memory\_wrapped\_destroy@{cb\_memory\_wrapped\_destroy}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_memory\_wrapped\_destroy()}{cb\_memory\_wrapped\_destroy()}}
{\footnotesize\ttfamily static void cb\+\_\+memory\+\_\+wrapped\+\_\+destroy (\begin{DoxyParamCaption}\item[{void $\ast$}]{p }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback invoked when destroying the Gst\+Memory which wrapped the arrived message. 



Definition at line 1179 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a8ea26f58ca912f962b26f3c79af7ea8f_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7}\label{mqttsrc_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_mqtt\_on\_connect@{cb\_mqtt\_on\_connect}}
\index{cb\_mqtt\_on\_connect@{cb\_mqtt\_on\_connect}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_connect()}{cb\_mqtt\_on\_connect()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+connect (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback invoked when the connection is established. 

Gst\+Flow\+Return is an enum type. It is possible to use int here

Definition at line 1190 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=334pt]{mqttsrc_8c_a61a1d8fe3eae6fe768ecd6cd5dab78d7_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a0c22b06eae9165e52844885f7c48404c}\label{mqttsrc_8c_a0c22b06eae9165e52844885f7c48404c}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_mqtt\_on\_connect\_failure@{cb\_mqtt\_on\_connect\_failure}}
\index{cb\_mqtt\_on\_connect\_failure@{cb\_mqtt\_on\_connect\_failure}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_connect\_failure()}{cb\_mqtt\_on\_connect\_failure()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+connect\+\_\+failure (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback invoked when it is failed to connect to the broker. 



Definition at line 1223 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=334pt]{mqttsrc_8c_a0c22b06eae9165e52844885f7c48404c_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a9d1641daa30b926d359514e56da29323}\label{mqttsrc_8c_a9d1641daa30b926d359514e56da29323}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_mqtt\_on\_connection\_lost@{cb\_mqtt\_on\_connection\_lost}}
\index{cb\_mqtt\_on\_connection\_lost@{cb\_mqtt\_on\_connection\_lost}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_connection\_lost()}{cb\_mqtt\_on\_connection\_lost()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+connection\+\_\+lost (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{char $\ast$}]{cause }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback to handle the connection lost to the broker. 



Definition at line 1053 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a9d1641daa30b926d359514e56da29323_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a885feb7e9cb0a60f1c09c7456fa83b64}\label{mqttsrc_8c_a885feb7e9cb0a60f1c09c7456fa83b64}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_mqtt\_on\_message\_arrived@{cb\_mqtt\_on\_message\_arrived}}
\index{cb\_mqtt\_on\_message\_arrived@{cb\_mqtt\_on\_message\_arrived}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_message\_arrived()}{cb\_mqtt\_on\_message\_arrived()}}
{\footnotesize\ttfamily static int cb\+\_\+mqtt\+\_\+on\+\_\+message\+\_\+arrived (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{char $\ast$}]{topic\+\_\+name,  }\item[{int}]{topic\+\_\+len,  }\item[{M\+Q\+T\+T\+Async\+\_\+message $\ast$}]{message }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



A callback to handle the arrived message. 

Timestamp synchronization

Definition at line 1075 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a885feb7e9cb0a60f1c09c7456fa83b64_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a885feb7e9cb0a60f1c09c7456fa83b64_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ac76f0c62bc87c18bdab688b42ca6ac0b}\label{mqttsrc_8c_ac76f0c62bc87c18bdab688b42ca6ac0b}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_mqtt\_on\_subscribe@{cb\_mqtt\_on\_subscribe}}
\index{cb\_mqtt\_on\_subscribe@{cb\_mqtt\_on\_subscribe}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_subscribe()}{cb\_mqtt\_on\_subscribe()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+subscribe (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Success callback for M\+Q\+T\+T\+Async\+\_\+subscribe () 



Definition at line 1242 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ac76f0c62bc87c18bdab688b42ca6ac0b_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a46fb61b2876530ce7368db3bf71c1218}\label{mqttsrc_8c_a46fb61b2876530ce7368db3bf71c1218}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_mqtt\_on\_subscribe\_failure@{cb\_mqtt\_on\_subscribe\_failure}}
\index{cb\_mqtt\_on\_subscribe\_failure@{cb\_mqtt\_on\_subscribe\_failure}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_subscribe\_failure()}{cb\_mqtt\_on\_subscribe\_failure()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+subscribe\+\_\+failure (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Failure callback for M\+Q\+T\+T\+Async\+\_\+subscribe () 



Definition at line 1257 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a46fb61b2876530ce7368db3bf71c1218_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a91a203c048b8526469b8f6457dabbfdb}\label{mqttsrc_8c_a91a203c048b8526469b8f6457dabbfdb}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_mqtt\_on\_unsubscribe@{cb\_mqtt\_on\_unsubscribe}}
\index{cb\_mqtt\_on\_unsubscribe@{cb\_mqtt\_on\_unsubscribe}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_unsubscribe()}{cb\_mqtt\_on\_unsubscribe()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+unsubscribe (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+success\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Success callback for M\+Q\+T\+T\+Async\+\_\+unsubscribe () 



Definition at line 1275 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a91a203c048b8526469b8f6457dabbfdb_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a385e5109ee940d6c8def70c1051e19f1}\label{mqttsrc_8c_a385e5109ee940d6c8def70c1051e19f1}} 
\index{mqttsrc.c@{mqttsrc.c}!cb\_mqtt\_on\_unsubscribe\_failure@{cb\_mqtt\_on\_unsubscribe\_failure}}
\index{cb\_mqtt\_on\_unsubscribe\_failure@{cb\_mqtt\_on\_unsubscribe\_failure}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{cb\_mqtt\_on\_unsubscribe\_failure()}{cb\_mqtt\_on\_unsubscribe\_failure()}}
{\footnotesize\ttfamily static void cb\+\_\+mqtt\+\_\+on\+\_\+unsubscribe\+\_\+failure (\begin{DoxyParamCaption}\item[{void $\ast$}]{context,  }\item[{M\+Q\+T\+T\+Async\+\_\+failure\+Data $\ast$}]{response }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



M\+Q\+T\+T\+Async\+\_\+response\+Options\textquotesingle{}s on\+Failure callback for M\+Q\+T\+T\+Async\+\_\+unsubscribe () 



Definition at line 1290 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a385e5109ee940d6c8def70c1051e19f1_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_abbef95aceb98034e51bec0521ff26af3}\label{mqttsrc_8c_abbef95aceb98034e51bec0521ff26af3}} 
\index{mqttsrc.c@{mqttsrc.c}!G\_DEFINE\_TYPE@{G\_DEFINE\_TYPE}}
\index{G\_DEFINE\_TYPE@{G\_DEFINE\_TYPE}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{G\_DEFINE\_TYPE()}{G\_DEFINE\_TYPE()}}
{\footnotesize\ttfamily G\+\_\+\+D\+E\+F\+I\+N\+E\+\_\+\+T\+Y\+PE (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}}}]{,  }\item[{gst\+\_\+mqtt\+\_\+src}]{,  }\item[{G\+S\+T\+\_\+\+T\+Y\+P\+E\+\_\+\+B\+A\+S\+E\+\_\+\+S\+RC}]{ }\end{DoxyParamCaption})}

\mbox{\Hypertarget{mqttsrc_8c_a552a83a0e977d89b9faa64980946cb3b}\label{mqttsrc_8c_a552a83a0e977d89b9faa64980946cb3b}} 
\index{mqttsrc.c@{mqttsrc.c}!GST\_DEBUG\_CATEGORY\_STATIC@{GST\_DEBUG\_CATEGORY\_STATIC}}
\index{GST\_DEBUG\_CATEGORY\_STATIC@{GST\_DEBUG\_CATEGORY\_STATIC}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{GST\_DEBUG\_CATEGORY\_STATIC()}{GST\_DEBUG\_CATEGORY\_STATIC()}}
{\footnotesize\ttfamily G\+S\+T\+\_\+\+D\+E\+B\+U\+G\+\_\+\+C\+A\+T\+E\+G\+O\+R\+Y\+\_\+\+S\+T\+A\+T\+IC (\begin{DoxyParamCaption}\item[{gst\+\_\+mqtt\+\_\+src\+\_\+debug}]{ }\end{DoxyParamCaption})}

\mbox{\Hypertarget{mqttsrc_8c_ad6cb729f34768b9260486c29b7c02a37}\label{mqttsrc_8c_ad6cb729f34768b9260486c29b7c02a37}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_change\_state@{gst\_mqtt\_src\_change\_state}}
\index{gst\_mqtt\_src\_change\_state@{gst\_mqtt\_src\_change\_state}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_change\_state()}{gst\_mqtt\_src\_change\_state()}}
{\footnotesize\ttfamily static Gst\+State\+Change\+Return gst\+\_\+mqtt\+\_\+src\+\_\+change\+\_\+state (\begin{DoxyParamCaption}\item[{Gst\+Element $\ast$}]{element,  }\item[{Gst\+State\+Change}]{transition }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Handle mqttsrc\textquotesingle{}s state change. 

This handles the case when the state is changed to P\+L\+A\+Y\+I\+NG again

Definition at line 440 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ad6cb729f34768b9260486c29b7c02a37_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ad6cb729f34768b9260486c29b7c02a37_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_abb59c0ad40f9210f3f01fc5533df3a43}\label{mqttsrc_8c_abb59c0ad40f9210f3f01fc5533df3a43}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_class\_finalize@{gst\_mqtt\_src\_class\_finalize}}
\index{gst\_mqtt\_src\_class\_finalize@{gst\_mqtt\_src\_class\_finalize}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_class\_finalize()}{gst\_mqtt\_src\_class\_finalize()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+class\+\_\+finalize (\begin{DoxyParamCaption}\item[{G\+Object $\ast$}]{object }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Finalize Gst\+Mqtt\+Src\+Class object. 



Definition at line 408 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=273pt]{mqttsrc_8c_abb59c0ad40f9210f3f01fc5533df3a43_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_abb59c0ad40f9210f3f01fc5533df3a43_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a614541abe9b3c48a8d6aa6cfd42a3a14}\label{mqttsrc_8c_a614541abe9b3c48a8d6aa6cfd42a3a14}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_class\_init@{gst\_mqtt\_src\_class\_init}}
\index{gst\_mqtt\_src\_class\_init@{gst\_mqtt\_src\_class\_init}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_class\_init()}{gst\_mqtt\_src\_class\_init()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+class\+\_\+init (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_af3dd6005e7d4f293d044445ccff99cb0}{Gst\+Mqtt\+Src\+Class}} $\ast$}]{klass }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Initialize Gst\+Mqtt\+Src\+Class object. 



Definition at line 222 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[height=550pt]{mqttsrc_8c_a614541abe9b3c48a8d6aa6cfd42a3a14_cgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a6a486710b0c3d541c99bfd6c698d7b75}\label{mqttsrc_8c_a6a486710b0c3d541c99bfd6c698d7b75}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_create@{gst\_mqtt\_src\_create}}
\index{gst\_mqtt\_src\_create@{gst\_mqtt\_src\_create}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_create()}{gst\_mqtt\_src\_create()}}
{\footnotesize\ttfamily static Gst\+Flow\+Return gst\+\_\+mqtt\+\_\+src\+\_\+create (\begin{DoxyParamCaption}\item[{Gst\+Base\+Src $\ast$}]{basesrc,  }\item[{guint64}]{offset,  }\item[{guint}]{size,  }\item[{Gst\+Buffer $\ast$$\ast$}]{buf }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Create a buffer containing the subscribed data. 

\begin{DoxyRefDesc}{Todo}
\item[\mbox{\hyperlink{todo__todo000004}{Todo}}]D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+S\+U\+B\+\_\+\+T\+I\+M\+E\+O\+U\+T\+\_\+\+M\+IN is too long \end{DoxyRefDesc}


This buffer is coming from the past. Drop it.

Update latency

\begin{DoxyRefDesc}{Todo}
\item[\mbox{\hyperlink{todo__todo000005}{Todo}}]If the difference between new latency and old latency, gst\+\_\+element\+\_\+post\+\_\+message (G\+S\+T\+\_\+\+E\+L\+E\+M\+E\+N\+T\+\_\+\+C\+A\+ST (self), gst\+\_\+message\+\_\+new\+\_\+latency (G\+S\+T\+\_\+\+O\+B\+J\+E\+C\+T\+\_\+\+C\+A\+ST (self))); is needed. \end{DoxyRefDesc}


\begin{DoxyRefDesc}{Todo}
\item[\mbox{\hyperlink{todo__todo000006}{Todo}}]\+: Send EoS here \end{DoxyRefDesc}


Definition at line 710 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a6a486710b0c3d541c99bfd6c698d7b75_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a6a486710b0c3d541c99bfd6c698d7b75_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a40a52cc9dcd7fd2a664c030dec52bbac}\label{mqttsrc_8c_a40a52cc9dcd7fd2a664c030dec52bbac}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_caps@{gst\_mqtt\_src\_get\_caps}}
\index{gst\_mqtt\_src\_get\_caps@{gst\_mqtt\_src\_get\_caps}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_caps()}{gst\_mqtt\_src\_get\_caps()}}
{\footnotesize\ttfamily static Gst\+Caps $\ast$ gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+caps (\begin{DoxyParamCaption}\item[{Gst\+Base\+Src $\ast$}]{basesrc,  }\item[{Gst\+Caps $\ast$}]{filter }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Get caps of subclass. 



Definition at line 601 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a40a52cc9dcd7fd2a664c030dec52bbac_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ae28ac0e5ae2d80fc2ea93a8425bc0a09}\label{mqttsrc_8c_ae28ac0e5ae2d80fc2ea93a8425bc0a09}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_client\_id@{gst\_mqtt\_src\_get\_client\_id}}
\index{gst\_mqtt\_src\_get\_client\_id@{gst\_mqtt\_src\_get\_client\_id}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_client\_id()}{gst\_mqtt\_src\_get\_client\_id()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+client\+\_\+id (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}client-\/id\textquotesingle{} property. 



Definition at line 902 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ae28ac0e5ae2d80fc2ea93a8425bc0a09_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ad7f7964db3f583a7a91ba67be76c1171}\label{mqttsrc_8c_ad7f7964db3f583a7a91ba67be76c1171}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_debug@{gst\_mqtt\_src\_get\_debug}}
\index{gst\_mqtt\_src\_get\_debug@{gst\_mqtt\_src\_get\_debug}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_debug()}{gst\_mqtt\_src\_get\_debug()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+debug (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}debug\textquotesingle{} property. 



Definition at line 865 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ad7f7964db3f583a7a91ba67be76c1171_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a05687362d11b4e987c376d750bbf31fc}\label{mqttsrc_8c_a05687362d11b4e987c376d750bbf31fc}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_host\_address@{gst\_mqtt\_src\_get\_host\_address}}
\index{gst\_mqtt\_src\_get\_host\_address@{gst\_mqtt\_src\_get\_host\_address}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_host\_address()}{gst\_mqtt\_src\_get\_host\_address()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+host\+\_\+address (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}host\textquotesingle{} property. 



Definition at line 921 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a05687362d11b4e987c376d750bbf31fc_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_aef1c5dbf0fa7cc8212fd71d1f5a837a8}\label{mqttsrc_8c_aef1c5dbf0fa7cc8212fd71d1f5a837a8}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_host\_port@{gst\_mqtt\_src\_get\_host\_port}}
\index{gst\_mqtt\_src\_get\_host\_port@{gst\_mqtt\_src\_get\_host\_port}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_host\_port()}{gst\_mqtt\_src\_get\_host\_port()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+host\+\_\+port (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}port\textquotesingle{} property. 



Definition at line 943 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_aef1c5dbf0fa7cc8212fd71d1f5a837a8_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a642846cf0b1f42200691f5960196b7a4}\label{mqttsrc_8c_a642846cf0b1f42200691f5960196b7a4}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_is\_live@{gst\_mqtt\_src\_get\_is\_live}}
\index{gst\_mqtt\_src\_get\_is\_live@{gst\_mqtt\_src\_get\_is\_live}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_is\_live()}{gst\_mqtt\_src\_get\_is\_live()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+is\+\_\+live (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}is-\/live\textquotesingle{} property. 



Definition at line 883 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a642846cf0b1f42200691f5960196b7a4_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a1fec5b3e3ac533ad91d8ccb6c39990c6}\label{mqttsrc_8c_a1fec5b3e3ac533ad91d8ccb6c39990c6}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_mqtt\_qos@{gst\_mqtt\_src\_get\_mqtt\_qos}}
\index{gst\_mqtt\_src\_get\_mqtt\_qos@{gst\_mqtt\_src\_get\_mqtt\_qos}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_mqtt\_qos()}{gst\_mqtt\_src\_get\_mqtt\_qos()}}
{\footnotesize\ttfamily static gint gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+mqtt\+\_\+qos (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}mqtt-\/qos\textquotesingle{} property. 



Definition at line 1035 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a1fec5b3e3ac533ad91d8ccb6c39990c6_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a93318e392c49117a544d85297c85daca}\label{mqttsrc_8c_a93318e392c49117a544d85297c85daca}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_opt\_cleansession@{gst\_mqtt\_src\_get\_opt\_cleansession}}
\index{gst\_mqtt\_src\_get\_opt\_cleansession@{gst\_mqtt\_src\_get\_opt\_cleansession}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_opt\_cleansession()}{gst\_mqtt\_src\_get\_opt\_cleansession()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+opt\+\_\+cleansession (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}cleansession\textquotesingle{} property. 



Definition at line 999 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a93318e392c49117a544d85297c85daca_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ac9edd1551b1fbe85a037d68354e828dc}\label{mqttsrc_8c_ac9edd1551b1fbe85a037d68354e828dc}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_opt\_keep\_alive\_interval@{gst\_mqtt\_src\_get\_opt\_keep\_alive\_interval}}
\index{gst\_mqtt\_src\_get\_opt\_keep\_alive\_interval@{gst\_mqtt\_src\_get\_opt\_keep\_alive\_interval}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_opt\_keep\_alive\_interval()}{gst\_mqtt\_src\_get\_opt\_keep\_alive\_interval()}}
{\footnotesize\ttfamily static gint gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+opt\+\_\+keep\+\_\+alive\+\_\+interval (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}keep-\/alive-\/interval\textquotesingle{} property. 



Definition at line 1017 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ac9edd1551b1fbe85a037d68354e828dc_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_aee0280bfdb045d6feb9510396ad0b533}\label{mqttsrc_8c_aee0280bfdb045d6feb9510396ad0b533}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_property@{gst\_mqtt\_src\_get\_property}}
\index{gst\_mqtt\_src\_get\_property@{gst\_mqtt\_src\_get\_property}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_property()}{gst\_mqtt\_src\_get\_property()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+property (\begin{DoxyParamCaption}\item[{G\+Object $\ast$}]{object,  }\item[{guint}]{prop\+\_\+id,  }\item[{G\+Value $\ast$}]{value,  }\item[{G\+Param\+Spec $\ast$}]{pspec }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



The getter for the mqttsrc\textquotesingle{}s properties. 



Definition at line 362 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_aee0280bfdb045d6feb9510396ad0b533_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_aee0280bfdb045d6feb9510396ad0b533_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a30e7b5029a10b67ed6b046d3ec4074eb}\label{mqttsrc_8c_a30e7b5029a10b67ed6b046d3ec4074eb}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_sub\_timeout@{gst\_mqtt\_src\_get\_sub\_timeout}}
\index{gst\_mqtt\_src\_get\_sub\_timeout@{gst\_mqtt\_src\_get\_sub\_timeout}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_sub\_timeout()}{gst\_mqtt\_src\_get\_sub\_timeout()}}
{\footnotesize\ttfamily static gint64 gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+sub\+\_\+timeout (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}sub-\/timeout\textquotesingle{} property. 



Definition at line 962 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a30e7b5029a10b67ed6b046d3ec4074eb_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_af0ac24674227253eafe8f38f3f3391e3}\label{mqttsrc_8c_af0ac24674227253eafe8f38f3f3391e3}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_sub\_topic@{gst\_mqtt\_src\_get\_sub\_topic}}
\index{gst\_mqtt\_src\_get\_sub\_topic@{gst\_mqtt\_src\_get\_sub\_topic}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_sub\_topic()}{gst\_mqtt\_src\_get\_sub\_topic()}}
{\footnotesize\ttfamily static gchar $\ast$ gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+sub\+\_\+topic (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Getter for the \textquotesingle{}sub-\/topic\textquotesingle{} property. 



Definition at line 980 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_af0ac24674227253eafe8f38f3f3391e3_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a287955fd73eb6ca9af7be672cd1d6fd6}\label{mqttsrc_8c_a287955fd73eb6ca9af7be672cd1d6fd6}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_get\_times@{gst\_mqtt\_src\_get\_times}}
\index{gst\_mqtt\_src\_get\_times@{gst\_mqtt\_src\_get\_times}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_get\_times()}{gst\_mqtt\_src\_get\_times()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+get\+\_\+times (\begin{DoxyParamCaption}\item[{Gst\+Base\+Src $\ast$}]{basesrc,  }\item[{Gst\+Buffer $\ast$}]{buffer,  }\item[{Gst\+Clock\+Time $\ast$}]{start,  }\item[{Gst\+Clock\+Time $\ast$}]{end }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Return the time information of the given buffer. 



Definition at line 674 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a287955fd73eb6ca9af7be672cd1d6fd6_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_aca4c6cad19565538fa80a7a3b842d490}\label{mqttsrc_8c_aca4c6cad19565538fa80a7a3b842d490}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_init@{gst\_mqtt\_src\_init}}
\index{gst\_mqtt\_src\_init@{gst\_mqtt\_src\_init}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_init()}{gst\_mqtt\_src\_init()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+init (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Initialize Gst\+Mqtt\+Src object. 

Function definitions init mqttsrc properties

init private member variables

Definition at line 169 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_aca4c6cad19565538fa80a7a3b842d490_cgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_aef5e7d56220b9addad44bf3162d14bc2}\label{mqttsrc_8c_aef5e7d56220b9addad44bf3162d14bc2}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_is\_seekable@{gst\_mqtt\_src\_is\_seekable}}
\index{gst\_mqtt\_src\_is\_seekable@{gst\_mqtt\_src\_is\_seekable}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_is\_seekable()}{gst\_mqtt\_src\_is\_seekable()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+src\+\_\+is\+\_\+seekable (\begin{DoxyParamCaption}\item[{Gst\+Base\+Src $\ast$}]{basesrc }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Check if source supports seeking. 

\begin{DoxyNote}{Note}
Seeking is not supported since this element handles live subscription data. 
\end{DoxyNote}


Definition at line 700 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_aef5e7d56220b9addad44bf3162d14bc2_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ad51a0141d5e31f8763c343f2a491aa3c}\label{mqttsrc_8c_ad51a0141d5e31f8763c343f2a491aa3c}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_query@{gst\_mqtt\_src\_query}}
\index{gst\_mqtt\_src\_query@{gst\_mqtt\_src\_query}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_query()}{gst\_mqtt\_src\_query()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+src\+\_\+query (\begin{DoxyParamCaption}\item[{Gst\+Base\+Src $\ast$}]{basesrc,  }\item[{Gst\+Query $\ast$}]{query }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



An implementation of the Gst\+Base\+Src vmethod that handles queries. 

The second argument of gst\+\_\+query\+\_\+set\+\_\+latency should be always T\+R\+UE.

Definition at line 819 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ad51a0141d5e31f8763c343f2a491aa3c_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a88e9c51dd7524672a79022e2b22140a4}\label{mqttsrc_8c_a88e9c51dd7524672a79022e2b22140a4}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_renegotiate@{gst\_mqtt\_src\_renegotiate}}
\index{gst\_mqtt\_src\_renegotiate@{gst\_mqtt\_src\_renegotiate}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_renegotiate()}{gst\_mqtt\_src\_renegotiate()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+src\+\_\+renegotiate (\begin{DoxyParamCaption}\item[{Gst\+Base\+Src $\ast$}]{basesrc }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Do negotiation procedure again if it needed. 



Definition at line 624 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a88e9c51dd7524672a79022e2b22140a4_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ad7bf46868fd29ac554dc38874cf05b42}\label{mqttsrc_8c_ad7bf46868fd29ac554dc38874cf05b42}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_client\_id@{gst\_mqtt\_src\_set\_client\_id}}
\index{gst\_mqtt\_src\_set\_client\_id@{gst\_mqtt\_src\_set\_client\_id}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_client\_id()}{gst\_mqtt\_src\_set\_client\_id()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+client\+\_\+id (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{id }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}client-\/id\textquotesingle{} property. 



Definition at line 911 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=309pt]{mqttsrc_8c_ad7bf46868fd29ac554dc38874cf05b42_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ad7bf46868fd29ac554dc38874cf05b42_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a4cc428ad2c23121abbe14310b7761b91}\label{mqttsrc_8c_a4cc428ad2c23121abbe14310b7761b91}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_debug@{gst\_mqtt\_src\_set\_debug}}
\index{gst\_mqtt\_src\_set\_debug@{gst\_mqtt\_src\_set\_debug}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_debug()}{gst\_mqtt\_src\_set\_debug()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+debug (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gboolean}]{flag }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}debug\textquotesingle{} property. 



Definition at line 874 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a4cc428ad2c23121abbe14310b7761b91_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a7d9a8923dba5bf7661212331d95004d5}\label{mqttsrc_8c_a7d9a8923dba5bf7661212331d95004d5}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_host\_address@{gst\_mqtt\_src\_set\_host\_address}}
\index{gst\_mqtt\_src\_set\_host\_address@{gst\_mqtt\_src\_set\_host\_address}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_host\_address()}{gst\_mqtt\_src\_set\_host\_address()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+host\+\_\+address (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{addr }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}host\textquotesingle{} property. 

\begin{DoxyRefDesc}{Todo}
\item[\mbox{\hyperlink{todo__todo000007}{Todo}}]Handle the case where the addr is changed at runtime \end{DoxyRefDesc}


Definition at line 930 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=289pt]{mqttsrc_8c_a7d9a8923dba5bf7661212331d95004d5_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a7d9a8923dba5bf7661212331d95004d5_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a8f56fc85603f27de1a968b4d0e51a741}\label{mqttsrc_8c_a8f56fc85603f27de1a968b4d0e51a741}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_host\_port@{gst\_mqtt\_src\_set\_host\_port}}
\index{gst\_mqtt\_src\_set\_host\_port@{gst\_mqtt\_src\_set\_host\_port}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_host\_port()}{gst\_mqtt\_src\_set\_host\_port()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+host\+\_\+port (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{port }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}port\textquotesingle{} property. 



Definition at line 952 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=314pt]{mqttsrc_8c_a8f56fc85603f27de1a968b4d0e51a741_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a8f56fc85603f27de1a968b4d0e51a741_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a4d42bb15e609fcf5e33cbf2dccbd85cc}\label{mqttsrc_8c_a4d42bb15e609fcf5e33cbf2dccbd85cc}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_is\_live@{gst\_mqtt\_src\_set\_is\_live}}
\index{gst\_mqtt\_src\_set\_is\_live@{gst\_mqtt\_src\_set\_is\_live}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_is\_live()}{gst\_mqtt\_src\_set\_is\_live()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+is\+\_\+live (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gboolean}]{flag }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}is-\/live\textquotesingle{} property. 



Definition at line 892 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a4d42bb15e609fcf5e33cbf2dccbd85cc_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ace7a6fbafdb59597e86ff194d2a73fbc}\label{mqttsrc_8c_ace7a6fbafdb59597e86ff194d2a73fbc}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_mqtt\_qos@{gst\_mqtt\_src\_set\_mqtt\_qos}}
\index{gst\_mqtt\_src\_set\_mqtt\_qos@{gst\_mqtt\_src\_set\_mqtt\_qos}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_mqtt\_qos()}{gst\_mqtt\_src\_set\_mqtt\_qos()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+mqtt\+\_\+qos (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gint}]{qos }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}mqtt-\/qos\textquotesingle{} property. 



Definition at line 1044 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ace7a6fbafdb59597e86ff194d2a73fbc_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a649b0685ee1570ab4c32c0d048304477}\label{mqttsrc_8c_a649b0685ee1570ab4c32c0d048304477}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_opt\_cleansession@{gst\_mqtt\_src\_set\_opt\_cleansession}}
\index{gst\_mqtt\_src\_set\_opt\_cleansession@{gst\_mqtt\_src\_set\_opt\_cleansession}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_opt\_cleansession()}{gst\_mqtt\_src\_set\_opt\_cleansession()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+opt\+\_\+cleansession (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gboolean}]{val }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}cleansession\textquotesingle{} property. 



Definition at line 1008 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a649b0685ee1570ab4c32c0d048304477_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a77c26708521c011ffe6417b169c2b2b4}\label{mqttsrc_8c_a77c26708521c011ffe6417b169c2b2b4}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_opt\_keep\_alive\_interval@{gst\_mqtt\_src\_set\_opt\_keep\_alive\_interval}}
\index{gst\_mqtt\_src\_set\_opt\_keep\_alive\_interval@{gst\_mqtt\_src\_set\_opt\_keep\_alive\_interval}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_opt\_keep\_alive\_interval()}{gst\_mqtt\_src\_set\_opt\_keep\_alive\_interval()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+opt\+\_\+keep\+\_\+alive\+\_\+interval (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gint}]{num }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}keep-\/alive-\/interval\textquotesingle{} property. 



Definition at line 1026 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a77c26708521c011ffe6417b169c2b2b4_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ac50d7a23de9ee1e188c925ebe2541c61}\label{mqttsrc_8c_ac50d7a23de9ee1e188c925ebe2541c61}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_property@{gst\_mqtt\_src\_set\_property}}
\index{gst\_mqtt\_src\_set\_property@{gst\_mqtt\_src\_set\_property}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_property()}{gst\_mqtt\_src\_set\_property()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+property (\begin{DoxyParamCaption}\item[{G\+Object $\ast$}]{object,  }\item[{guint}]{prop\+\_\+id,  }\item[{const G\+Value $\ast$}]{value,  }\item[{G\+Param\+Spec $\ast$}]{pspec }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



The setter for the mqttsrc\textquotesingle{}s properties. 

Function prototype declarations 

Definition at line 316 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ac50d7a23de9ee1e188c925ebe2541c61_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ac50d7a23de9ee1e188c925ebe2541c61_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a2f0cd5ec28efac7ec7c64c32fd4c7984}\label{mqttsrc_8c_a2f0cd5ec28efac7ec7c64c32fd4c7984}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_sub\_timeout@{gst\_mqtt\_src\_set\_sub\_timeout}}
\index{gst\_mqtt\_src\_set\_sub\_timeout@{gst\_mqtt\_src\_set\_sub\_timeout}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_sub\_timeout()}{gst\_mqtt\_src\_set\_sub\_timeout()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+sub\+\_\+timeout (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gint64}]{t }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}sub-\/timeout\textquotesingle{} property. 



Definition at line 971 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a2f0cd5ec28efac7ec7c64c32fd4c7984_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_ace7b46b9a5fd3ae5b103644e8c5503ee}\label{mqttsrc_8c_ace7b46b9a5fd3ae5b103644e8c5503ee}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_set\_sub\_topic@{gst\_mqtt\_src\_set\_sub\_topic}}
\index{gst\_mqtt\_src\_set\_sub\_topic@{gst\_mqtt\_src\_set\_sub\_topic}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_set\_sub\_topic()}{gst\_mqtt\_src\_set\_sub\_topic()}}
{\footnotesize\ttfamily static void gst\+\_\+mqtt\+\_\+src\+\_\+set\+\_\+sub\+\_\+topic (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{mqttsrc_8h_a057d9175cc50a072767da28154041956}{Gst\+Mqtt\+Src}} $\ast$}]{self,  }\item[{const gchar $\ast$}]{topic }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Setter for the \textquotesingle{}sub-\/topic\textquotesingle{} property. 



Definition at line 989 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=285pt]{mqttsrc_8c_ace7b46b9a5fd3ae5b103644e8c5503ee_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_ace7b46b9a5fd3ae5b103644e8c5503ee_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_aa8c98523c34d98c5f8849381df8250c1}\label{mqttsrc_8c_aa8c98523c34d98c5f8849381df8250c1}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_start@{gst\_mqtt\_src\_start}}
\index{gst\_mqtt\_src\_start@{gst\_mqtt\_src\_start}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_start()}{gst\_mqtt\_src\_start()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+src\+\_\+start (\begin{DoxyParamCaption}\item[{Gst\+Base\+Src $\ast$}]{basesrc }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Start mqttsrc, called when state changed null to ready. 

\begin{DoxyRefDesc}{Todo}
\item[\mbox{\hyperlink{todo__todo000003}{Todo}}]Support other persistence mechanisms M\+Q\+T\+T\+C\+L\+I\+E\+N\+T\+\_\+\+P\+E\+R\+S\+I\+S\+T\+E\+N\+C\+E\+\_\+\+N\+O\+NE\+: A memory-\/based persistence mechanism M\+Q\+T\+T\+C\+L\+I\+E\+N\+T\+\_\+\+P\+E\+R\+S\+I\+S\+T\+E\+N\+C\+E\+\_\+\+D\+E\+F\+A\+U\+LT\+: The default file system-\/based persistence mechanism M\+Q\+T\+T\+C\+L\+I\+E\+N\+T\+\_\+\+P\+E\+R\+S\+I\+S\+T\+E\+N\+C\+E\+\_\+\+U\+S\+ER\+: An application-\/specific persistence mechanism \end{DoxyRefDesc}


Definition at line 522 of file mqttsrc.\+c.

Here is the call graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_aa8c98523c34d98c5f8849381df8250c1_cgraph}
\end{center}
\end{figure}
Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_aa8c98523c34d98c5f8849381df8250c1_icgraph}
\end{center}
\end{figure}
\mbox{\Hypertarget{mqttsrc_8c_a193b99c411cf9ec77335b3e9c5d30d09}\label{mqttsrc_8c_a193b99c411cf9ec77335b3e9c5d30d09}} 
\index{mqttsrc.c@{mqttsrc.c}!gst\_mqtt\_src\_stop@{gst\_mqtt\_src\_stop}}
\index{gst\_mqtt\_src\_stop@{gst\_mqtt\_src\_stop}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{gst\_mqtt\_src\_stop()}{gst\_mqtt\_src\_stop()}}
{\footnotesize\ttfamily static gboolean gst\+\_\+mqtt\+\_\+src\+\_\+stop (\begin{DoxyParamCaption}\item[{Gst\+Base\+Src $\ast$}]{basesrc }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [static]}}



Stop mqttsrc, called when state changed ready to null. 



Definition at line 583 of file mqttsrc.\+c.

Here is the caller graph for this function\+:
\nopagebreak
\begin{figure}[H]
\begin{center}
\leavevmode
\includegraphics[width=350pt]{mqttsrc_8c_a193b99c411cf9ec77335b3e9c5d30d09_icgraph}
\end{center}
\end{figure}


\doxysubsection{Variable Documentation}
\mbox{\Hypertarget{mqttsrc_8c_ad7802f55a92df9e9b9d3cfd5e2fb11bf}\label{mqttsrc_8c_ad7802f55a92df9e9b9d3cfd5e2fb11bf}} 
\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_CLIENT\_ID@{DEFAULT\_MQTT\_CLIENT\_ID}}
\index{DEFAULT\_MQTT\_CLIENT\_ID@{DEFAULT\_MQTT\_CLIENT\_ID}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_CLIENT\_ID}{DEFAULT\_MQTT\_CLIENT\_ID}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+ID\mbox{[}$\,$\mbox{]}\hspace{0.3cm}{\ttfamily [static]}}

{\bfseries Initial value\+:}
\begin{DoxyCode}{0}
\DoxyCodeLine{=}
\DoxyCodeLine{    \textcolor{stringliteral}{"\$HOSTNAME\_\$PID\_\string^[0-\/9][0-\/9]?\$|\string^255\$"}}

\end{DoxyCode}


Definition at line 73 of file mqttsrc.\+c.

\mbox{\Hypertarget{mqttsrc_8c_acf4f9062c5331fe5613e31c923468e30}\label{mqttsrc_8c_acf4f9062c5331fe5613e31c923468e30}} 
\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT@{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT}}
\index{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT@{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT}{DEFAULT\_MQTT\_CLIENT\_ID\_FORMAT}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+C\+L\+I\+E\+N\+T\+\_\+\+I\+D\+\_\+\+F\+O\+R\+M\+AT\mbox{[}$\,$\mbox{]} = \char`\"{}\%s\+\_\+\%u\+\_\+src\%u\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 75 of file mqttsrc.\+c.

\mbox{\Hypertarget{mqttsrc_8c_adb7c1d7abe7c50e461f495f2b6b9adbc}\label{mqttsrc_8c_adb7c1d7abe7c50e461f495f2b6b9adbc}} 
\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_HOST\_ADDRESS@{DEFAULT\_MQTT\_HOST\_ADDRESS}}
\index{DEFAULT\_MQTT\_HOST\_ADDRESS@{DEFAULT\_MQTT\_HOST\_ADDRESS}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_HOST\_ADDRESS}{DEFAULT\_MQTT\_HOST\_ADDRESS}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+A\+D\+D\+R\+E\+SS\mbox{[}$\,$\mbox{]} = \char`\"{}127.\+0.\+0.\+1\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 70 of file mqttsrc.\+c.

\mbox{\Hypertarget{mqttsrc_8c_a782553475a8ab1e231242a2ab4fcd43f}\label{mqttsrc_8c_a782553475a8ab1e231242a2ab4fcd43f}} 
\index{mqttsrc.c@{mqttsrc.c}!DEFAULT\_MQTT\_HOST\_PORT@{DEFAULT\_MQTT\_HOST\_PORT}}
\index{DEFAULT\_MQTT\_HOST\_PORT@{DEFAULT\_MQTT\_HOST\_PORT}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{DEFAULT\_MQTT\_HOST\_PORT}{DEFAULT\_MQTT\_HOST\_PORT}}
{\footnotesize\ttfamily const gchar D\+E\+F\+A\+U\+L\+T\+\_\+\+M\+Q\+T\+T\+\_\+\+H\+O\+S\+T\+\_\+\+P\+O\+RT\mbox{[}$\,$\mbox{]} = \char`\"{}1883\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 71 of file mqttsrc.\+c.

\mbox{\Hypertarget{mqttsrc_8c_a8d3a15e3ce4889fc1efdcec4dedb76e7}\label{mqttsrc_8c_a8d3a15e3ce4889fc1efdcec4dedb76e7}} 
\index{mqttsrc.c@{mqttsrc.c}!src\_client\_id@{src\_client\_id}}
\index{src\_client\_id@{src\_client\_id}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{src\_client\_id}{src\_client\_id}}
{\footnotesize\ttfamily guint8 src\+\_\+client\+\_\+id = 0\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 69 of file mqttsrc.\+c.

\mbox{\Hypertarget{mqttsrc_8c_a696cd223d7a6a3dab6272a892b0ad8ca}\label{mqttsrc_8c_a696cd223d7a6a3dab6272a892b0ad8ca}} 
\index{mqttsrc.c@{mqttsrc.c}!src\_pad\_template@{src\_pad\_template}}
\index{src\_pad\_template@{src\_pad\_template}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{src\_pad\_template}{src\_pad\_template}}
{\footnotesize\ttfamily Gst\+Static\+Pad\+Template src\+\_\+pad\+\_\+template\hspace{0.3cm}{\ttfamily [static]}}

{\bfseries Initial value\+:}
\begin{DoxyCode}{0}
\DoxyCodeLine{= GST\_STATIC\_PAD\_TEMPLATE (\textcolor{stringliteral}{"src"},}
\DoxyCodeLine{    GST\_PAD\_SRC, GST\_PAD\_ALWAYS, GST\_STATIC\_CAPS\_ANY)}

\end{DoxyCode}


Definition at line 31 of file mqttsrc.\+c.

\mbox{\Hypertarget{mqttsrc_8c_a541a235141c16edf0af8892617030912}\label{mqttsrc_8c_a541a235141c16edf0af8892617030912}} 
\index{mqttsrc.c@{mqttsrc.c}!TAG\_ERR\_MQTTSRC@{TAG\_ERR\_MQTTSRC}}
\index{TAG\_ERR\_MQTTSRC@{TAG\_ERR\_MQTTSRC}!mqttsrc.c@{mqttsrc.c}}
\doxysubsubsection{\texorpdfstring{TAG\_ERR\_MQTTSRC}{TAG\_ERR\_MQTTSRC}}
{\footnotesize\ttfamily const gchar T\+A\+G\+\_\+\+E\+R\+R\+\_\+\+M\+Q\+T\+T\+S\+RC\mbox{[}$\,$\mbox{]} = \char`\"{}E\+R\+R\+O\+R\+: M\+Q\+T\+T\+Src\char`\"{}\hspace{0.3cm}{\ttfamily [static]}}



Definition at line 72 of file mqttsrc.\+c.

