| /external/openscreen/osp/public/ |
| D | message_demuxer_unittest.cc | 36 msgs::EncodePresentationConnectionOpenRequest(request_, &buffer_)); in SetUp()
41 const msgs::PresentationConnectionOpenRequest& received_request) { in ExpectDecodedRequest()
52 msgs::CborEncodeBuffer buffer_;
53 msgs::PresentationConnectionOpenRequest request_{1, "fry-am-the-egg-man",
63 endpoint_id_, msgs::Type::kPresentationConnectionOpenRequest, in TEST_F()
70 msgs::PresentationConnectionOpenRequest received_request; in TEST_F()
75 msgs::Type::kPresentationConnectionOpenRequest, _, _, _)) in TEST_F()
78 msgs::Type message_type, const uint8_t* buffer, in TEST_F()
80 decode_result = msgs::DecodePresentationConnectionOpenRequest( in TEST_F()
99 endpoint_id_, msgs::Type::kPresentationConnectionOpenRequest, in TEST_F()
[all …]
|
| D | message_demuxer.h | 38 msgs::Type message_type,
50 msgs::Type message_type);
61 msgs::Type message_type_;
73 msgs::Type message_type,
78 MessageWatch SetDefaultMessageTypeWatch(msgs::Type message_type,
95 void StopWatchingMessageType(uint64_t endpoint_id, msgs::Type message_type);
96 void StopDefaultMessageTypeWatch(msgs::Type message_type);
101 std::map<uint64_t, std::map<msgs::Type, MessageCallback*>>::iterator
108 std::map<msgs::Type, MessageCallback*>* message_callbacks,
113 std::map<uint64_t, std::map<msgs::Type, MessageCallback*>> message_callbacks_;
[all …]
|
| /external/openscreen/osp/impl/presentation/ |
| D | presentation_receiver.cc | 23 msgs::PresentationConnectionCloseEvent_reason GetEventCloseReason( in GetEventCloseReason()
27 return msgs::PresentationConnectionCloseEvent_reason:: in GetEventCloseReason()
31 return msgs::PresentationConnectionCloseEvent_reason:: in GetEventCloseReason()
36 return msgs::PresentationConnectionCloseEvent_reason::kCloseMethodCalled; in GetEventCloseReason()
40 msgs::PresentationTerminationEvent_reason GetEventTerminationReason( in GetEventTerminationReason()
44 return msgs::PresentationTerminationEvent_reason:: in GetEventTerminationReason()
47 return msgs::PresentationTerminationEvent_reason::kReceiverPoweringDown; in GetEventTerminationReason()
49 return msgs::PresentationTerminationEvent_reason:: in GetEventTerminationReason()
52 return msgs::PresentationTerminationEvent_reason:: in GetEventTerminationReason()
55 return msgs::PresentationTerminationEvent_reason::kReceiverIdleTooLong; in GetEventTerminationReason()
[all …]
|
| D | presentation_controller_unittest.cc | 104 msgs::Type::kPresentationUrlAvailabilityRequest, &mock_callback_); in SetUp()
114 msgs::PresentationUrlAvailabilityRequest* request) { in ExpectAvailabilityRequest()
116 msgs::Type msg_type; in ExpectAvailabilityRequest()
120 msgs::Type message_type, const uint8_t* buffer, in ExpectAvailabilityRequest()
123 decode_result = msgs::DecodePresentationUrlAvailabilityRequest( in ExpectAvailabilityRequest()
128 ASSERT_EQ(msg_type, msgs::Type::kPresentationUrlAvailabilityRequest); in ExpectAvailabilityRequest()
133 const msgs::PresentationUrlAvailabilityResponse& response) { in SendAvailabilityResponse()
142 response, msgs::EncodePresentationUrlAvailabilityResponse) in SendAvailabilityResponse()
146 void SendStartResponse(const msgs::PresentationStartResponse& response) { in SendStartResponse()
155 ->WriteMessage(response, msgs::EncodePresentationStartResponse) in SendStartResponse()
[all …]
|
| D | url_availability_requester_unittest.cc | 63 msgs::Type::kPresentationUrlAvailabilityRequest, &mock_callback_); in SetUp()
86 msgs::PresentationUrlAvailabilityRequest* request) { in ExpectStreamMessage()
90 msgs::Type message_type, const uint8_t* buffer, in ExpectStreamMessage()
93 msgs::DecodePresentationUrlAvailabilityRequest( in ExpectStreamMessage()
101 const msgs::PresentationUrlAvailabilityRequest& request, in SendAvailabilityResponse()
102 std::vector<msgs::UrlAvailability>&& availabilities, in SendAvailabilityResponse()
104 msgs::PresentationUrlAvailabilityResponse response; in SendAvailabilityResponse()
107 msgs::CborEncodeBuffer buffer; in SendAvailabilityResponse()
109 msgs::EncodePresentationUrlAvailabilityResponse(response, &buffer); in SendAvailabilityResponse()
116 std::vector<msgs::UrlAvailability>&& availabilities, in SendAvailabilityEvent()
[all …]
|
| D | presentation_connection.cc | 29 Error WriteConnectionMessage(const msgs::PresentationConnectionMessage& message, in WriteConnectionMessage()
32 msgs::EncodePresentationConnectionMessage); in WriteConnectionMessage()
108 msgs::PresentationConnectionMessage cbor_message; in SendString()
113 msgs::PresentationConnectionMessage::Message::Which::kString; in SendString()
124 msgs::PresentationConnectionMessage cbor_message; in SendBinary()
129 msgs::PresentationConnectionMessage::Message::Which::kBytes; in SendBinary()
157 msgs::Type::kPresentationConnectionMessage, this); in ConnectionManager()
160 msgs::Type::kPresentationConnectionCloseRequest, this); in ConnectionManager()
163 msgs::Type::kPresentationConnectionCloseEvent, this); in ConnectionManager()
186 msgs::Type message_type, in OnStreamMessage()
[all …]
|
| D | presentation_receiver_unittest.cc | 48 std::vector<msgs::UrlAvailability>(uint64_t watch_id,
54 const std::vector<msgs::HttpHeader>& http_headers));
117 msgs::Type::kPresentationUrlAvailabilityResponse, &mock_callback); in TEST_F()
122 msgs::PresentationUrlAvailabilityRequest request{/* .request_id = */ 0, in TEST_F()
126 msgs::CborEncodeBuffer buffer; in TEST_F()
127 ASSERT_TRUE(msgs::EncodePresentationUrlAvailabilityRequest(request, &buffer)); in TEST_F()
135 return std::vector<msgs::UrlAvailability>{ in TEST_F()
136 msgs::UrlAvailability::kAvailable}; in TEST_F()
139 msgs::PresentationUrlAvailabilityResponse response; in TEST_F()
143 msgs::Type message_type, const uint8_t* buffer, in TEST_F()
[all …]
|
| D | url_availability_requester.cc | 188 msgs::UrlAvailability availability = availability_entry->second; in GetOrRequestAvailabilities()
191 case msgs::UrlAvailability::kAvailable: in GetOrRequestAvailabilities()
194 case msgs::UrlAvailability::kUnavailable: in GetOrRequestAvailabilities()
195 case msgs::UrlAvailability::kInvalid: in GetOrRequestAvailabilities()
226 msgs::PresentationUrlAvailabilityRequest cbor_request; in SendRequest()
232 msgs::CborEncodeBuffer buffer; in SendRequest()
233 if (msgs::EncodePresentationUrlAvailabilityRequest(cbor_request, &buffer)) { in SendRequest()
240 endpoint_id, msgs::Type::kPresentationUrlAvailabilityEvent, this); in SendRequest()
244 endpoint_id, msgs::Type::kPresentationUrlAvailabilityResponse, this); in SendRequest()
279 const std::vector<msgs::UrlAvailability>& availabilities) { in UpdateAvailabilities()
[all …]
|
| D | presentation_controller.cc | 24 using RequestMsgType = msgs::Presentation##base_name##Request; \
25 using ResponseMsgType = msgs::Presentation##base_name##Response; \
28 &msgs::EncodePresentation##base_name##Request; \
30 &msgs::DecodePresentation##base_name##Response; \
31 static constexpr msgs::Type kResponseType = \
32 msgs::Type::kPresentation##base_name##Response
37 msgs::PresentationStartRequest request;
45 msgs::PresentationConnectionOpenRequest request;
54 msgs::PresentationConnectionCloseRequest request;
60 msgs::PresentationTerminationRequest request;
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/upb/third_party/lunit/ |
| D | console.lua | 91 local msgs = {}
98 msgs = {} -- e
118 …msgs[#msgs+1] = "Error! ("..fullname.."):\n"..message.."\n\t"..table.concat(traceback, "\n\t") .. …
131 msgs[#msgs+1] = text
145 for i, msg in ipairs(msgs) do
|
| /external/openscreen/osp/impl/ |
| D | message_demuxer.cc | 55 ErrorOr<msgs::Type> MessageTypeDecoder::DecodeType( in DecodeType()
64 msgs::Type parsed_type = in DecodeType()
65 msgs::TypeEnumValidator::SafeCast(message_type.value()); in DecodeType()
66 if (parsed_type == msgs::Type::kUnknown) { in DecodeType()
81 msgs::Type message_type) in MessageWatch()
130 msgs::Type message_type, in WatchMessageType()
136 .emplace(endpoint_id, std::map<msgs::Type, MessageCallback*>{}) in WatchMessageType()
147 auto buffered_type = static_cast<msgs::Type>(buffer.second[0]); in WatchMessageType()
158 msgs::Type message_type, in SetDefaultMessageTypeWatch()
168 auto buffered_type = static_cast<msgs::Type>(stream_map.second[0]); in SetDefaultMessageTypeWatch()
[all …]
|
| /external/python/cpython2/Lib/distutils/tests/ |
| D | test_check.py | 73 msgs = cmd._check_rst_data(broken_rest)
74 self.assertEqual(len(msgs), 1)
78 msgs = cmd._check_rst_data(rest)
79 self.assertEqual(len(msgs), 0)
129 msgs = cmd._check_rst_data(rest_with_code)
131 self.assertEqual(len(msgs), 0)
133 self.assertEqual(len(msgs), 1)
135 str(msgs[0][1]),
|
| /external/python/cpython3/Lib/distutils/tests/ |
| D | test_check.py | 81 msgs = cmd._check_rst_data(broken_rest)
82 self.assertEqual(len(msgs), 1)
86 msgs = cmd._check_rst_data(rest)
87 self.assertEqual(len(msgs), 0)
142 msgs = cmd._check_rst_data(rest_with_code)
144 self.assertEqual(len(msgs), 0)
146 self.assertEqual(len(msgs), 1)
148 str(msgs[0][1]),
|
| /external/e2fsprogs/lib/et/ |
| D | init_et.c | 35 int init_error_table(const char * const *msgs, long base, int count) in init_error_table() argument
39 if (!base || !count || !msgs) in init_error_table()
46 new_et->et.msgs = msgs; in init_error_table()
|
| D | com_right.c | 54 return p->table->msgs[code - p->table->base]; in com_right()
66 strncpy(str, p->table->msgs[code - p->table->base], len); in com_right_r()
97 if (et->table->msgs == messages) in initialize_error_table_r()
104 tab->msgs = messages; in initialize_error_table_r()
|
| /external/ltp/testcases/kernel/syscalls/symlink/ |
| D | symlink01.c | 278 const char *msgs[] = { variable
980 msgs[tc_ptr-> in do_syscalltests()
1031 tst_resm(TPASS, "%s", msgs[tc_ptr->pass_msg]); in do_EEXIST()
1041 tst_resm(TEST_RESULT, "%s", msgs[tc_ptr->pass_msg]); in do_EEXIST()
1054 tst_resm(TEST_RESULT, "%s", msgs[tc_ptr->pass_msg]); in do_EEXIST()
1079 tst_resm(TEST_RESULT, "%s", msgs[tc_ptr->pass_msg]); in do_ENOENT()
1088 tst_resm(TEST_RESULT, "%s", msgs[tc_ptr->pass_msg]); in do_ENOENT()
1101 tst_resm(TEST_RESULT, "%s", msgs[tc_ptr->pass_msg]); in do_ENOENT()
1112 tst_resm(TEST_RESULT, "%s", msgs[tc_ptr->pass_msg]); in do_ENOENT()
1122 tst_resm(TEST_RESULT, "%s", msgs[tc_ptr->pass_msg]); in do_ENOENT()
[all …]
|
| /external/jemalloc_new/test/include/test/ |
| D | mq.h | 34 ql_head(a_mq_msg_type) msgs; \
43 ql_new(&mq->msgs); \
65 msg = ql_first(&mq->msgs); \
67 ql_head_remove(&mq->msgs, a_mq_msg_type, a_field); \
104 ql_tail_insert(&mq->msgs, msg, a_field); \
|
| /external/openscreen/osp/impl/quic/ |
| D | quic_server_unittest.cc | 88 0, msgs::Type::kPresentationConnectionMessage, in SendTestMessage()
91 msgs::CborEncodeBuffer buffer; in SendTestMessage()
92 msgs::PresentationConnectionMessage message; in SendTestMessage()
96 ASSERT_TRUE(msgs::EncodePresentationConnectionMessage(message, &buffer)); in SendTestMessage()
101 msgs::PresentationConnectionMessage received_message; in SendTestMessage()
104 0, _, msgs::Type::kPresentationConnectionMessage, _, _, _)) in SendTestMessage()
107 msgs::Type message_type, const uint8_t* buffer, in SendTestMessage()
109 decode_result = msgs::DecodePresentationConnectionMessage( in SendTestMessage()
|
| D | quic_client_unittest.cc | 84 0, msgs::Type::kPresentationConnectionMessage, in SendTestMessage()
87 msgs::CborEncodeBuffer buffer; in SendTestMessage()
88 msgs::PresentationConnectionMessage message; in SendTestMessage()
92 ASSERT_TRUE(msgs::EncodePresentationConnectionMessage(message, &buffer)); in SendTestMessage()
97 msgs::PresentationConnectionMessage received_message; in SendTestMessage()
101 msgs::Type::kPresentationConnectionMessage, _, _, _)) in SendTestMessage()
104 msgs::Type message_type, const uint8_t* buffer, in SendTestMessage()
106 decode_result = msgs::DecodePresentationConnectionMessage( in SendTestMessage()
|
| /external/nanopb-c/tests/mem_release/ |
| D | mem_release.c | 127 fill_TestMessage(&msg.msgs.msg1); in test_OneofMessage()
142 msg.msgs.msg2.dynamic_str = "ABCD"; in test_OneofMessage()
165 TEST(msg.msgs.msg2.dynamic_str); in test_OneofMessage()
166 TEST(strcmp(msg.msgs.msg2.dynamic_str, "ABCD") == 0); in test_OneofMessage()
167 TEST(msg.msgs.msg2.dynamic_str_arr == NULL); in test_OneofMessage()
168 TEST(msg.msgs.msg2.dynamic_submsg == NULL); in test_OneofMessage()
|
| /external/grpc-grpc/third_party/nanopb/tests/mem_release/ |
| D | mem_release.c | 127 fill_TestMessage(&msg.msgs.msg1); in test_OneofMessage()
142 msg.msgs.msg2.dynamic_str = "ABCD"; in test_OneofMessage()
165 TEST(msg.msgs.msg2.dynamic_str); in test_OneofMessage()
166 TEST(strcmp(msg.msgs.msg2.dynamic_str, "ABCD") == 0); in test_OneofMessage()
167 TEST(msg.msgs.msg2.dynamic_str_arr == NULL); in test_OneofMessage()
168 TEST(msg.msgs.msg2.dynamic_submsg == NULL); in test_OneofMessage()
|
| /external/wpa_supplicant_8/src/radius/ |
| D | radius_client.c | 223 struct radius_msg_list *msgs; member
500 entry = radius->msgs; in radius_client_timer()
528 entry = radius->msgs; in radius_client_timer()
539 radius->msgs = entry->next; in radius_client_timer()
551 entry = radius->msgs; in radius_client_timer()
563 if (radius->msgs) { in radius_client_timer()
591 for (entry = radius->msgs; entry; entry = entry->next) { in radius_client_auth_failover()
620 for (entry = radius->msgs; entry; entry = entry->next) { in radius_client_acct_failover()
644 if (radius->msgs == NULL) { in radius_client_update_timeout()
649 for (entry = radius->msgs; entry; entry = entry->next) { in radius_client_update_timeout()
[all …]
|
| /external/strace/tests-mx32/ |
| D | netlink_protocol.c | 180 struct nlmsghdr *const msgs = tail_alloc(msg_len); in send_query() local
183 msgs[i].nlmsg_len = sizeof(*msgs); in send_query()
184 msgs[i].nlmsg_type = NLMSG_NOOP; in send_query()
185 msgs[i].nlmsg_flags = NLM_F_DUMP | NLM_F_REQUEST; in send_query()
186 msgs[i].nlmsg_seq = i; in send_query()
187 msgs[i].nlmsg_pid = 0; in send_query()
190 rc = sendto(fd, msgs, msg_len, MSG_DONTWAIT, NULL, 0); in send_query()
198 msgs[i].nlmsg_len, NLM_F_DUMP, msgs[i].nlmsg_seq); in send_query()
|
| /external/strace/tests-m32/ |
| D | netlink_protocol.c | 180 struct nlmsghdr *const msgs = tail_alloc(msg_len); in send_query() local
183 msgs[i].nlmsg_len = sizeof(*msgs); in send_query()
184 msgs[i].nlmsg_type = NLMSG_NOOP; in send_query()
185 msgs[i].nlmsg_flags = NLM_F_DUMP | NLM_F_REQUEST; in send_query()
186 msgs[i].nlmsg_seq = i; in send_query()
187 msgs[i].nlmsg_pid = 0; in send_query()
190 rc = sendto(fd, msgs, msg_len, MSG_DONTWAIT, NULL, 0); in send_query()
198 msgs[i].nlmsg_len, NLM_F_DUMP, msgs[i].nlmsg_seq); in send_query()
|
| /external/strace/tests/ |
| D | netlink_protocol.c | 180 struct nlmsghdr *const msgs = tail_alloc(msg_len); in send_query() local
183 msgs[i].nlmsg_len = sizeof(*msgs); in send_query()
184 msgs[i].nlmsg_type = NLMSG_NOOP; in send_query()
185 msgs[i].nlmsg_flags = NLM_F_DUMP | NLM_F_REQUEST; in send_query()
186 msgs[i].nlmsg_seq = i; in send_query()
187 msgs[i].nlmsg_pid = 0; in send_query()
190 rc = sendto(fd, msgs, msg_len, MSG_DONTWAIT, NULL, 0); in send_query()
198 msgs[i].nlmsg_len, NLM_F_DUMP, msgs[i].nlmsg_seq); in send_query()
|