| /external/webrtc/webrtc/base/ |
| D | messagequeue.cc | 165 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 …]
|
| D | messagequeue.h | 190 virtual bool Get(Message *pmsg, int cmsWait = kForever,
192 virtual bool Peek(Message *pmsg, int cmsWait = 0);
208 virtual void Dispatch(Message *pmsg);
|
| D | virtualsocketserver.cc | 386 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()
|
| D | virtualsocket_unittest.cc | 45 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()
|
| D | thread_unittest.cc | 92 virtual void OnMessage(Message *pmsg) { in OnMessage() argument
93 TestMessage* msg = static_cast<TestMessage*>(pmsg->pdata); in OnMessage()
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | xmppthread.cc | 55 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()
|
| D | xmppthread.h | 39 void OnMessage(rtc::Message* pmsg);
|
| D | xmpppump.h | 49 void OnMessage(rtc::Message *pmsg);
|
| D | xmpppump.cc | 56 void XmppPump::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
|
| /external/u-boot/drivers/mailbox/ |
| D | sandbox-mbox.c | 43 const uint32_t *pmsg = data; in sandbox_mbox_send() local
47 sbm->chans[chan->id].rx_msg = *pmsg ^ SANDBOX_MBOX_PING_XOR; in sandbox_mbox_send()
56 uint32_t *pmsg = data; in sandbox_mbox_recv() local
63 *pmsg = sbm->chans[chan->id].rx_msg; in sandbox_mbox_recv()
|
| /external/linux-kselftest/tools/testing/selftests/pstore/ |
| D | pstore_post_reboot_tests | 47 check_files_exist pmsg
63 nr_matched=`grep -c "$TEST_STRING_PATTERN" pmsg-${backend}-0`
65 grep -q "$TEST_STRING_PATTERN"$prev_uuid pmsg-${backend}-0
|
| /external/u-boot/drivers/i2c/ |
| D | kona_i2c.c | 487 struct kona_i2c_msg *pmsg; in bcm_kona_i2c_xfer() local
506 pmsg = &msgs[i]; in bcm_kona_i2c_xfer()
509 if ((i != 0) && ((pmsg->flags & I2C_M_NOSTART) == 0)) { in bcm_kona_i2c_xfer()
518 if (!(pmsg->flags & I2C_M_NOSTART)) { in bcm_kona_i2c_xfer()
519 rc = bcm_kona_i2c_do_addr(dev, pmsg); in bcm_kona_i2c_xfer()
522 pmsg->addr, i, rc); in bcm_kona_i2c_xfer()
528 if (pmsg->flags & I2C_M_RD) { in bcm_kona_i2c_xfer()
529 rc = bcm_kona_i2c_read_fifo(dev, pmsg); in bcm_kona_i2c_xfer()
535 rc = bcm_kona_i2c_write_fifo(dev, pmsg); in bcm_kona_i2c_xfer()
|
| /external/webrtc/talk/session/media/ |
| D | channel.cc | 1300 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 …]
|
| D | channel.h | 293 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/ |
| D | transportcontroller.cc | 227 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()
|
| D | relayserver.cc | 531 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()
|
| D | stunrequest.cc | 194 void StunRequest::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
196 ASSERT(pmsg->message_id == MSG_STUN_SEND); in OnMessage()
|
| D | relayserver.h | 119 void OnMessage(rtc::Message *pmsg);
217 void OnMessage(rtc::Message *pmsg);
|
| D | tcpport.cc | 441 void TCPConnection::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
442 switch (pmsg->message_id) { in OnMessage()
452 Connection::OnMessage(pmsg); in OnMessage()
|
| D | stunrequest.h | 124 void OnMessage(rtc::Message* pmsg);
|
| D | relayport.cc | 127 virtual void OnMessage(rtc::Message *pmsg);
646 void RelayEntry::OnMessage(rtc::Message *pmsg) { in OnMessage() argument
647 ASSERT(pmsg->message_id == kMessageConnectTimeout); in OnMessage()
|
| D | tcpport.h | 132 void OnMessage(rtc::Message* pmsg) override;
|
| D | port.h | 259 virtual void OnMessage(rtc::Message *pmsg);
600 void OnMessage(rtc::Message *pmsg);
|
| D | port.cc | 623 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()
|
| D | transportcontroller.h | 123 void OnMessage(rtc::Message* pmsg) override;
|