Lines Matching refs:m_opaque

22     m_opaque (NULL),  in SBCommunication()
28 m_opaque (new Communication (broadcaster_name)), in SBCommunication()
35 "SBCommunication(%p)", broadcaster_name, m_opaque); in SBCommunication()
40 if (m_opaque && m_opaque_owned) in ~SBCommunication()
41 delete m_opaque; in ~SBCommunication()
42 m_opaque = NULL; in ~SBCommunication()
49 return m_opaque != NULL; in IsValid()
55 if (m_opaque) in GetCloseOnEOF()
56 return m_opaque->GetCloseOnEOF (); in GetCloseOnEOF()
63 if (m_opaque) in SetCloseOnEOF()
64 m_opaque->SetCloseOnEOF (b); in SetCloseOnEOF()
70 if (m_opaque) in Connect()
72 if (!m_opaque->HasConnection ()) in Connect()
73 m_opaque->SetConnection (new ConnectionFileDescriptor()); in Connect()
74 return m_opaque->Connect (url, NULL); in Connect()
85 if (m_opaque) in AdoptFileDesriptor()
87 if (m_opaque->HasConnection ()) in AdoptFileDesriptor()
89 if (m_opaque->IsConnected()) in AdoptFileDesriptor()
90 m_opaque->Disconnect(); in AdoptFileDesriptor()
92 m_opaque->SetConnection (new ConnectionFileDescriptor (fd, owns_fd)); in AdoptFileDesriptor()
93 if (m_opaque->IsConnected()) in AdoptFileDesriptor()
101 m_opaque, fd, owns_fd, Communication::ConnectionStatusAsCString (status)); in AdoptFileDesriptor()
113 if (m_opaque) in Disconnect()
114 status = m_opaque->Disconnect (); in Disconnect()
117 log->Printf ("SBCommunication(%p)::Disconnect () => %s", m_opaque, in Disconnect()
128 if (m_opaque) in IsConnected()
129 result = m_opaque->IsConnected (); in IsConnected()
132 log->Printf ("SBCommunication(%p)::IsConnected () => %i", m_opaque, result); in IsConnected()
143 m_opaque, in Read()
148 if (m_opaque) in Read()
149 bytes_read = m_opaque->Read (dst, dst_len, timeout_usec, status, NULL); in Read()
155 m_opaque, in Read()
169 if (m_opaque) in Write()
170 bytes_written = m_opaque->Write (src, src_len, status, NULL); in Write()
177m_opaque, src, (uint64_t)src_len, Communication::ConnectionStatusAsCString (status), (uint64_t)byt… in Write()
188 if (m_opaque) in ReadThreadStart()
189 success = m_opaque->StartReadThread (); in ReadThreadStart()
192 log->Printf ("SBCommunication(%p)::ReadThreadStart () => %i", m_opaque, success); in ReadThreadStart()
203 log->Printf ("SBCommunication(%p)::ReadThreadStop ()...", m_opaque); in ReadThreadStop()
206 if (m_opaque) in ReadThreadStop()
207 success = m_opaque->StopReadThread (); in ReadThreadStop()
210 log->Printf ("SBCommunication(%p)::ReadThreadStop () => %i", m_opaque, success); in ReadThreadStop()
219 if (m_opaque) in ReadThreadIsRunning()
220 result = m_opaque->ReadThreadIsRunning (); in ReadThreadIsRunning()
223 log->Printf ("SBCommunication(%p)::ReadThreadIsRunning () => %i", m_opaque, result); in ReadThreadIsRunning()
237 if (m_opaque) in SetReadThreadBytesReceivedCallback()
239 m_opaque->SetReadThreadBytesReceivedCallback (callback, callback_baton); in SetReadThreadBytesReceivedCallback()
245 m_opaque, callback, callback_baton, result); in SetReadThreadBytesReceivedCallback()
253 SBBroadcaster broadcaster (m_opaque, false); in GetBroadcaster()
259 m_opaque, broadcaster.get()); in GetBroadcaster()