Home
last modified time | relevance | path

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

12

/external/webrtc/webrtc/base/
Dmessagequeue.cc165 bool MessageQueue::Peek(Message *pmsg, int cmsWait) { in Peek() argument
167 *pmsg = msgPeek_; in Peek()
170 if (!Get(pmsg, cmsWait)) in Peek()
172 msgPeek_ = *pmsg; in Peek()
177 bool MessageQueue::Get(Message *pmsg, int cmsWait, bool process_io) { in Get() argument
182 *pmsg = msgPeek_; in Get()
223 *pmsg = msgq_.front(); in Get()
229 if (pmsg->ts_sensitive) { in Get()
230 int32_t delay = TimeDiff(msCurrent, pmsg->ts_sensitive); in Get()
232 LOG_F(LS_WARNING) << "id: " << pmsg->message_id << " delay: " in Get()
[all …]
Dmessagequeue.h190 virtual bool Get(Message *pmsg, int cmsWait = kForever,
192 virtual bool Peek(Message *pmsg, int cmsWait = 0);
208 virtual void Dispatch(Message *pmsg);
Dvirtualsocketserver.cc386 void VirtualSocket::OnMessage(Message* pmsg) { in OnMessage() argument
387 if (pmsg->message_id == MSG_ID_PACKET) { in OnMessage()
389 ASSERT(NULL != pmsg->pdata); in OnMessage()
390 Packet* packet = static_cast<Packet*>(pmsg->pdata); in OnMessage()
397 } else if (pmsg->message_id == MSG_ID_CONNECT) { in OnMessage()
398 ASSERT(NULL != pmsg->pdata); in OnMessage()
399 MessageAddress* data = static_cast<MessageAddress*>(pmsg->pdata); in OnMessage()
412 } else if (pmsg->message_id == MSG_ID_DISCONNECT) { in OnMessage()
422 } else if (pmsg->message_id == MSG_ID_ADDRESS_BOUND) { in OnMessage()
Dvirtualsocket_unittest.cc45 void OnMessage(Message* pmsg) { in OnMessage()
46 ASSERT_EQ(1u, pmsg->message_id); in OnMessage()
111 void OnMessage(Message* pmsg) { in OnMessage()
112 ASSERT_EQ(1u, pmsg->message_id); in OnMessage()
Dthread_unittest.cc92 virtual void OnMessage(Message *pmsg) { in OnMessage() argument
93 TestMessage* msg = static_cast<TestMessage*>(pmsg->pdata); in OnMessage()
/external/webrtc/webrtc/libjingle/xmpp/
Dxmppthread.cc55 void XmppThread::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
56 if (pmsg->message_id == MSG_LOGIN) { in OnMessage()
57 ASSERT(pmsg->pdata != NULL); in OnMessage()
58 LoginData* data = reinterpret_cast<LoginData*>(pmsg->pdata); in OnMessage()
62 } else if (pmsg->message_id == MSG_DISCONNECT) { in OnMessage()
Dxmppthread.h39 void OnMessage(rtc::Message* pmsg);
Dxmpppump.h49 void OnMessage(rtc::Message *pmsg);
Dxmpppump.cc56 void XmppPump::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
/external/libvncserver/libvncserver/
Dscale.c403 rfbPalmVNCReSizeFrameBufferMsg pmsg; in rfbSendNewScaleSize() local
404 pmsg.type = rfbPalmVNCReSizeFrameBuffer; in rfbSendNewScaleSize()
405 pmsg.pad1 = 0; in rfbSendNewScaleSize()
406 pmsg.desktop_w = Swap16IfLE(cl->screen->width); in rfbSendNewScaleSize()
407 pmsg.desktop_h = Swap16IfLE(cl->screen->height); in rfbSendNewScaleSize()
408 pmsg.buffer_w = Swap16IfLE(cl->scaledScreen->width); in rfbSendNewScaleSize()
409 pmsg.buffer_h = Swap16IfLE(cl->scaledScreen->height); in rfbSendNewScaleSize()
410 pmsg.pad2 = 0; in rfbSendNewScaleSize()
413 if (rfbWriteExact(cl, (char *)&pmsg, sz_rfbPalmVNCReSizeFrameBufferMsg) < 0) { in rfbSendNewScaleSize()
/external/webrtc/talk/session/media/
Dchannel.cc1300 void BaseChannel::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
1302 switch (pmsg->message_id) { in OnMessage()
1305 PacketMessageData* data = static_cast<PacketMessageData*>(pmsg->pdata); in OnMessage()
1306 SendPacket(pmsg->message_id == MSG_RTCPPACKET, &data->packet, in OnMessage()
1606 void VoiceChannel::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
1607 switch (pmsg->message_id) { in OnMessage()
1613 static_cast<VoiceChannelErrorMessageData*>(pmsg->pdata); in OnMessage()
1618 BaseChannel::OnMessage(pmsg); in OnMessage()
1928 void VideoChannel::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
1929 switch (pmsg->message_id) { in OnMessage()
[all …]
Dchannel.h293 void OnMessage(rtc::Message* pmsg) override;
420 virtual void OnMessage(rtc::Message* pmsg);
506 virtual void OnMessage(rtc::Message* pmsg);
623 virtual void OnMessage(rtc::Message* pmsg);
/external/webrtc/webrtc/p2p/base/
Dtransportcontroller.cc227 void TransportController::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
230 switch (pmsg->message_id) { in OnMessage()
233 static_cast<rtc::TypedMessageData<IceConnectionState>*>(pmsg->pdata); in OnMessage()
240 static_cast<rtc::TypedMessageData<bool>*>(pmsg->pdata); in OnMessage()
247 static_cast<rtc::TypedMessageData<IceGatheringState>*>(pmsg->pdata); in OnMessage()
253 CandidatesData* data = static_cast<CandidatesData*>(pmsg->pdata); in OnMessage()
Drelayserver.cc531 void RelayServer::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
534 ASSERT(pmsg->message_id == kMessageAcceptConnection); in OnMessage()
536 rtc::MessageData* data = pmsg->pdata; in OnMessage()
731 void RelayServerBinding::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
732 if (pmsg->message_id == MSG_LIFETIME_TIMER) { in OnMessage()
733 ASSERT(!pmsg->pdata); in OnMessage()
Drelayserver.h119 void OnMessage(rtc::Message *pmsg);
217 void OnMessage(rtc::Message *pmsg);
Dstunrequest.cc194 void StunRequest::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
196 ASSERT(pmsg->message_id == MSG_STUN_SEND); in OnMessage()
Dtcpport.cc441 void TCPConnection::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
442 switch (pmsg->message_id) { in OnMessage()
452 Connection::OnMessage(pmsg); in OnMessage()
Dstunrequest.h124 void OnMessage(rtc::Message* pmsg);
Drelayport.cc127 virtual void OnMessage(rtc::Message *pmsg);
646 void RelayEntry::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
647 ASSERT(pmsg->message_id == kMessageConnectTimeout); in OnMessage()
Dtcpport.h132 void OnMessage(rtc::Message* pmsg) override;
Dport.h259 virtual void OnMessage(rtc::Message *pmsg);
600 void OnMessage(rtc::Message *pmsg);
Dport.cc623 void Port::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
624 ASSERT(pmsg->message_id == MSG_DEAD); in OnMessage()
1303 void Connection::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
1304 ASSERT(pmsg->message_id == MSG_DELETE); in OnMessage()
Dtransportcontroller.h123 void OnMessage(rtc::Message* pmsg) override;
Dp2ptransportchannel.h241 void OnMessage(rtc::Message* pmsg) override;
/external/regex-re2/lib/codereview/
Dcodereview.py387 pmsg = "Hello " + JoinComma(self.reviewer)
389 pmsg += " (cc: %s)" % (', '.join(self.cc),)
390 pmsg += ",\n"
391 pmsg += "\n"
394 pmsg += "I'd like you to review this change to\n" + repourl + "\n"
396 pmsg += "Please take another look.\n"
397 typecheck(pmsg, str)
398 PostMessage(ui, self.name, pmsg, subject=self.Subject())
1997 pmsg = "*** Submitted as " + changeURL + " ***\n\n" + message
2001 PostMessage(ui, cl.name, pmsg, reviewers="", cc=JoinComma(cl.reviewer+cl.cc))

12