Home
last modified time | relevance | path

Searched refs:pmsg (Results 1 – 25 of 38) sorted by relevance

12

/external/chromium_org/third_party/webrtc/base/
Dmessagequeue.cc157 bool MessageQueue::Peek(Message *pmsg, int cmsWait) { in Peek() argument
159 *pmsg = msgPeek_; in Peek()
162 if (!Get(pmsg, cmsWait)) in Peek()
164 msgPeek_ = *pmsg; in Peek()
169 bool MessageQueue::Get(Message *pmsg, int cmsWait, bool process_io) { in Get() argument
174 *pmsg = msgPeek_; in Get()
215 *pmsg = msgq_.front(); in Get()
221 if (pmsg->ts_sensitive) { in Get()
222 int32 delay = TimeDiff(msCurrent, pmsg->ts_sensitive); in Get()
224 LOG_F(LS_WARNING) << "id: " << pmsg->message_id << " delay: " in Get()
[all …]
Dmessagequeue.h188 virtual bool Get(Message *pmsg, int cmsWait = kForever,
190 virtual bool Peek(Message *pmsg, int cmsWait = 0);
203 virtual void Dispatch(Message *pmsg);
Dvirtualsocketserver.cc368 void OnMessage(Message *pmsg) { in OnMessage() argument
369 if (pmsg->message_id == MSG_ID_PACKET) { in OnMessage()
371 ASSERT(NULL != pmsg->pdata); in OnMessage()
372 Packet* packet = static_cast<Packet*>(pmsg->pdata); in OnMessage()
379 } else if (pmsg->message_id == MSG_ID_CONNECT) { in OnMessage()
380 ASSERT(NULL != pmsg->pdata); in OnMessage()
381 MessageAddress* data = static_cast<MessageAddress*>(pmsg->pdata); in OnMessage()
394 } else if (pmsg->message_id == MSG_ID_DISCONNECT) { in OnMessage()
Dschanneladapter.h46 virtual void OnMessage(Message* pmsg);
Dthread_unittest.cc93 virtual void OnMessage(Message *pmsg) { in OnMessage() argument
94 TestMessage* msg = static_cast<TestMessage*>(pmsg->pdata); in OnMessage()
/external/chromium_org/third_party/libjingle/source/talk/xmpp/
Dxmppthread.cc72 void XmppThread::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
73 if (pmsg->message_id == MSG_LOGIN) { in OnMessage()
74 ASSERT(pmsg->pdata != NULL); in OnMessage()
75 LoginData* data = reinterpret_cast<LoginData*>(pmsg->pdata); in OnMessage()
79 } else if (pmsg->message_id == MSG_DISCONNECT) { in OnMessage()
Dxmppthread.h56 void OnMessage(rtc::Message* pmsg);
Dxmpppump.h66 void OnMessage(rtc::Message *pmsg);
Dxmpppump.cc73 void XmppPump::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
/external/chromium_org/third_party/libjingle/source/talk/session/tunnel/
Dpseudotcpchannel.cc446 void PseudoTcpChannel::OnMessage(Message* pmsg) { in OnMessage() argument
447 if (pmsg->message_id == MSG_WK_CLOCK) { in OnMessage()
457 } else if (pmsg->message_id == MSG_WK_PURGE) { in OnMessage()
468 } else if (pmsg->message_id == MSG_ST_EVENT) { in OnMessage()
474 EventData* data = static_cast<EventData*>(pmsg->pdata); in OnMessage()
482 } else if (pmsg->message_id == MSG_SI_DESTROYCHANNEL) { in OnMessage()
490 } else if (pmsg->message_id == MSG_SI_DESTROY) { in OnMessage()
Dtunnelsessionclient.cc185 void TunnelSessionClientBase::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
186 if (pmsg->message_id == MSG_CREATE_TUNNEL) { in OnMessage()
188 CreateTunnelData* data = static_cast<CreateTunnelData*>(pmsg->pdata); in OnMessage()
Dpseudotcpchannel.h104 void OnMessage(rtc::Message* pmsg);
Dtunnelsessionclient.h91 void OnMessage(rtc::Message* pmsg);
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
Dportallocatorsessionproxy.cc117 void PortAllocatorSessionMuxer::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
118 ProxyObjData* proxy = static_cast<ProxyObjData*>(pmsg->pdata); in OnMessage()
119 switch (pmsg->message_id) { in OnMessage()
Drelayserver.cc548 void RelayServer::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
551 ASSERT(pmsg->message_id == kMessageAcceptConnection); in OnMessage()
553 rtc::MessageData* data = pmsg->pdata; in OnMessage()
745 void RelayServerBinding::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
746 if (pmsg->message_id == MSG_LIFETIME_TIMER) { in OnMessage()
747 ASSERT(!pmsg->pdata); in OnMessage()
Dstunrequest.cc182 void StunRequest::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
184 ASSERT(pmsg->message_id == MSG_STUN_SEND); in OnMessage()
Drelayserver.h136 void OnMessage(rtc::Message *pmsg);
233 void OnMessage(rtc::Message *pmsg);
Dstunrequest.h122 void OnMessage(rtc::Message* pmsg);
Dportallocatorsessionproxy.h62 virtual void OnMessage(rtc::Message *pmsg);
Dport.h271 virtual void OnMessage(rtc::Message *pmsg);
554 void OnMessage(rtc::Message *pmsg);
Drelayport.cc143 virtual void OnMessage(rtc::Message *pmsg);
646 void RelayEntry::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
647 ASSERT(pmsg->message_id == kMessageConnectTimeout); in OnMessage()
Dsession.cc913 void BaseSession::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
914 switch (pmsg->message_id) { in OnMessage()
1565 void Session::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
1569 BaseSession::OnMessage(pmsg); in OnMessage()
1571 switch (pmsg->message_id) { in OnMessage()
/external/chromium_org/third_party/libjingle/source/talk/session/media/
Dchannel.cc1224 void BaseChannel::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
1225 switch (pmsg->message_id) { in OnMessage()
1228 PacketMessageData* data = static_cast<PacketMessageData*>(pmsg->pdata); in OnMessage()
1229 SendPacket(pmsg->message_id == MSG_RTCPPACKET, &data->packet, data->dscp); in OnMessage()
1583 void VoiceChannel::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
1584 switch (pmsg->message_id) { in OnMessage()
1590 static_cast<VoiceChannelErrorMessageData*>(pmsg->pdata); in OnMessage()
1596 BaseChannel::OnMessage(pmsg); in OnMessage()
1986 void VideoChannel::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
1987 switch (pmsg->message_id) { in OnMessage()
[all …]
Dchannel.h346 virtual void OnMessage(rtc::Message* pmsg);
489 virtual void OnMessage(rtc::Message* pmsg);
578 virtual void OnMessage(rtc::Message* pmsg);
697 virtual void OnMessage(rtc::Message* pmsg);
/external/chromium_org/third_party/libjingle/source/talk/media/base/
Dfilemediaengine.cc138 virtual void OnMessage(rtc::Message* pmsg);
231 void RtpSenderReceiver::OnMessage(rtc::Message* pmsg) { in OnMessage() argument

12