| /external/libwebsockets/minimal-examples/ws-server/minimal-ws-server-echo/ |
| D | protocol_lws_minimal_server_echo.c | 69 const struct msg *pmsg; in callback_minimal_server_echo() local
115 pmsg = lws_ring_get_element(pss->ring, &pss->tail); in callback_minimal_server_echo()
116 if (!pmsg) { in callback_minimal_server_echo()
122 pmsg->binary ? LWS_WRITE_BINARY : LWS_WRITE_TEXT, in callback_minimal_server_echo()
123 pmsg->first, pmsg->final); in callback_minimal_server_echo()
126 m = lws_write(wsi, ((unsigned char *)pmsg->payload) + in callback_minimal_server_echo()
127 LWS_PRE, pmsg->len, flags); in callback_minimal_server_echo()
128 if (m < (int)pmsg->len) { in callback_minimal_server_echo()
134 m, flags, pmsg->first, pmsg->final); in callback_minimal_server_echo()
150 if ((*vhd->options & 1) && pmsg && pmsg->final) in callback_minimal_server_echo()
|
| /external/libwebsockets/minimal-examples/ws-client/minimal-ws-client-echo/ |
| D | protocol_lws_minimal_client_echo.c | 109 const struct msg *pmsg; in callback_minimal_client_echo() local
167 pmsg = lws_ring_get_element(pss->ring, &pss->tail); in callback_minimal_client_echo()
168 if (!pmsg) { in callback_minimal_client_echo()
174 pmsg->binary ? LWS_WRITE_BINARY : LWS_WRITE_TEXT, in callback_minimal_client_echo()
175 pmsg->first, pmsg->final); in callback_minimal_client_echo()
178 m = lws_write(wsi, ((unsigned char *)pmsg->payload) + in callback_minimal_client_echo()
179 LWS_PRE, pmsg->len, flags); in callback_minimal_client_echo()
180 if (m < (int)pmsg->len) { in callback_minimal_client_echo()
186 m, flags, pmsg->first, pmsg->final); in callback_minimal_client_echo()
188 if ((*vhd->options & 1) && pmsg && pmsg->final) in callback_minimal_client_echo()
|
| /external/libwebsockets/minimal-examples/ws-server/minimal-ws-broker/ |
| D | protocol_lws_minimal.c | 86 const struct msg *pmsg; in callback_minimal() local
131 pmsg = lws_ring_get_element(vhd->ring, &pss->tail); in callback_minimal()
132 if (!pmsg) in callback_minimal()
136 m = lws_write(wsi, ((unsigned char *)pmsg->payload) + LWS_PRE, in callback_minimal()
137 pmsg->len, LWS_WRITE_TEXT); in callback_minimal()
138 if (m < (int)pmsg->len) { in callback_minimal()
|
| /external/libwebsockets/minimal-examples/client-server/minimal-ws-proxy/ |
| D | protocol_lws_minimal.c | 91 const struct msg *pmsg; in callback_minimal() local
138 pmsg = lws_ring_get_element(vhd->ring, &pss->tail); in callback_minimal()
139 if (!pmsg) in callback_minimal()
143 m = lws_write(wsi, ((unsigned char *)pmsg->payload) + LWS_PRE, in callback_minimal()
144 pmsg->len, LWS_WRITE_TEXT); in callback_minimal()
145 if (m < (int)pmsg->len) { in callback_minimal()
|
| /external/libwebsockets/minimal-examples/ws-server/minimal-ws-server-ring/ |
| D | protocol_lws_minimal.c | 160 const struct msg *pmsg; in callback_minimal() local
201 pmsg = lws_ring_get_element(vhd->ring, &pss->tail); in callback_minimal()
202 if (!pmsg) in callback_minimal()
206 m = lws_write(wsi, ((unsigned char *)pmsg->payload) + in callback_minimal()
207 LWS_PRE, pmsg->len, LWS_WRITE_TEXT); in callback_minimal()
208 if (m < (int)pmsg->len) { in callback_minimal()
|
| /external/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads/ |
| D | protocol_lws_minimal.c | 150 const struct msg *pmsg; in callback_minimal() local
226 pmsg = lws_ring_get_element(vhd->ring, &pss->tail); in callback_minimal()
227 if (!pmsg) { in callback_minimal()
233 m = lws_write(wsi, ((unsigned char *)pmsg->payload) + LWS_PRE, in callback_minimal()
234 pmsg->len, LWS_WRITE_TEXT); in callback_minimal()
235 if (m < (int)pmsg->len) { in callback_minimal()
|
| /external/webrtc/rtc_base/ |
| D | thread.cc | 430 bool Thread::Peek(Message* pmsg, int cmsWait) { in Peek() argument
432 *pmsg = msgPeek_; in Peek()
435 if (!Get(pmsg, cmsWait)) in Peek()
437 msgPeek_ = *pmsg; in Peek()
442 bool Thread::Get(Message* pmsg, int cmsWait, bool process_io) { in Get() argument
447 *pmsg = msgPeek_; in Get()
486 *pmsg = messages_.front(); in Get()
492 if (MQID_DISPOSE == pmsg->message_id) { in Get()
493 RTC_DCHECK(nullptr == pmsg->phandler); in Get()
494 delete pmsg->pdata; in Get()
[all …]
|
| D | virtual_socket_server.cc | 389 void VirtualSocket::OnMessage(Message* pmsg) { in OnMessage() argument
390 if (pmsg->message_id == MSG_ID_PACKET) { in OnMessage()
391 RTC_DCHECK(nullptr != pmsg->pdata); in OnMessage()
392 Packet* packet = static_cast<Packet*>(pmsg->pdata); in OnMessage()
399 } else if (pmsg->message_id == MSG_ID_CONNECT) { in OnMessage()
400 RTC_DCHECK(nullptr != pmsg->pdata); in OnMessage()
401 MessageAddress* data = static_cast<MessageAddress*>(pmsg->pdata); in OnMessage()
415 } else if (pmsg->message_id == MSG_ID_DISCONNECT) { in OnMessage()
425 } else if (pmsg->message_id == MSG_ID_ADDRESS_BOUND) { in OnMessage()
427 } else if (pmsg->message_id == MSG_ID_SIGNALREADEVENT) { in OnMessage()
|
| D | thread.h | 238 virtual bool Get(Message* pmsg,
241 virtual bool Peek(Message* pmsg, int cmsWait = 0);
261 virtual void Dispatch(Message* pmsg);
|
| D | virtual_socket_unittest.cc | 72 void OnMessage(Message* pmsg) override { in OnMessage()
73 ASSERT_EQ(1u, pmsg->message_id); in OnMessage()
138 void OnMessage(Message* pmsg) override { in OnMessage()
139 ASSERT_EQ(1u, pmsg->message_id); in OnMessage()
|
| D | virtual_socket_server.h | 335 void OnMessage(Message* pmsg) override;
|
| /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/libwebsockets/minimal-examples/ws-client/minimal-ws-client-tx/ |
| D | minimal-ws-client.c | 149 const struct msg *pmsg; in callback_minimal_broker() local
218 pmsg = lws_ring_get_element(vhd->ring, &vhd->tail); in callback_minimal_broker()
219 if (!pmsg) in callback_minimal_broker()
223 m = lws_write(wsi, ((unsigned char *)pmsg->payload) + LWS_PRE, in callback_minimal_broker()
224 pmsg->len, LWS_WRITE_TEXT); in callback_minimal_broker()
225 if (m < (int)pmsg->len) { in callback_minimal_broker()
|
| /external/libwebsockets/minimal-examples/dbus-server/minimal-dbus-ws-proxy/ |
| D | protocol_lws_minimal_dbus_ws_proxy.c | 641 const struct msg *pmsg; in callback_minimal_dbus_wsproxy() local
700 pmsg = lws_ring_get_element(pss->ring_out, &pss->ring_out_tail); in callback_minimal_dbus_wsproxy()
701 if (!pmsg) { in callback_minimal_dbus_wsproxy()
707 pmsg->binary ? LWS_WRITE_BINARY : LWS_WRITE_TEXT, in callback_minimal_dbus_wsproxy()
708 pmsg->first, pmsg->final); in callback_minimal_dbus_wsproxy()
711 m = lws_write(wsi, ((unsigned char *)pmsg->payload) + LWS_PRE, in callback_minimal_dbus_wsproxy()
712 pmsg->len, flags); in callback_minimal_dbus_wsproxy()
713 if (m < (int)pmsg->len) { in callback_minimal_dbus_wsproxy()
719 m, flags, pmsg->first, pmsg->final); in callback_minimal_dbus_wsproxy()
|
| /external/libwebsockets/minimal-examples/ws-server/minimal-ws-server-threads-smp/ |
| D | protocol_lws_minimal.c | 150 const struct msg *pmsg; in callback_minimal() local
227 pmsg = lws_ring_get_element(vhd->ring, &pss->tail); in callback_minimal()
228 if (!pmsg) { in callback_minimal()
235 (char *)pmsg->payload + LWS_PRE); in callback_minimal()
|
| /external/libwebsockets/minimal-examples/http-server/minimal-http-server-sse-ring/ |
| D | minimal-http-server-sse-ring.c | 152 const struct msg *pmsg; in callback_sse() local
253 pmsg = lws_ring_get_element(vhd->ring, &pss->tail); in callback_sse()
254 if (!pmsg) in callback_sse()
259 (const char *)pmsg->payload); in callback_sse()
|
| /external/webrtc/pc/ |
| D | channel.cc | 739 void BaseChannel::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
741 switch (pmsg->message_id) { in OnMessage()
746 static_cast<SendPacketMessageData*>(pmsg->pdata); in OnMessage()
747 bool rtcp = pmsg->message_id == MSG_SEND_RTCP_PACKET; in OnMessage()
1400 void RtpDataChannel::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
1401 switch (pmsg->message_id) { in OnMessage()
1404 static_cast<DataChannelReadyToSendMessageData*>(pmsg->pdata); in OnMessage()
1412 static_cast<DataReceivedMessageData*>(pmsg->pdata); in OnMessage()
1418 BaseChannel::OnMessage(pmsg); in OnMessage()
|
| D | channel.h | 255 void OnMessage(rtc::Message* pmsg) override;
492 void OnMessage(rtc::Message* pmsg) override;
|
| /external/webrtc/p2p/base/ |
| D | stun_request.cc | 232 void StunRequest::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
234 RTC_DCHECK(pmsg->message_id == MSG_STUN_SEND); in OnMessage()
|
| D | tcp_port.cc | 514 void TCPConnection::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
515 switch (pmsg->message_id) { in OnMessage()
528 Connection::OnMessage(pmsg); in OnMessage()
|
| D | stun_request.h | 146 void OnMessage(rtc::Message* pmsg) override;
|
| D | tcp_port.h | 131 void OnMessage(rtc::Message* pmsg) override;
|
| D | connection.h | 367 void OnMessage(rtc::Message* pmsg) override;
|
| D | port.cc | 821 void Port::OnMessage(rtc::Message* pmsg) { in OnMessage() argument
822 RTC_DCHECK(pmsg->message_id == MSG_DESTROY_IF_DEAD); in OnMessage()
|
| D | port.h | 315 void OnMessage(rtc::Message* pmsg) override;
|