| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | Ping.java | 29 private long received = -1; field in Ping
40 if (received != -1 || sent == -1) throw new IllegalStateException(); in receive()
41 received = System.nanoTime(); in receive()
46 if (received != -1 || sent == -1) throw new IllegalStateException(); in cancel()
47 received = sent - 1; in cancel()
58 return received - sent; in roundTripTime()
68 return received - sent; in roundTripTime()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | Ping.java | 27 private long received = -1; field in Ping
38 if (received != -1 || sent == -1) throw new IllegalStateException(); in receive()
39 received = System.nanoTime(); in receive()
44 if (received != -1 || sent == -1) throw new IllegalStateException(); in cancel()
45 received = sent - 1; in cancel()
56 return received - sent; in roundTripTime()
66 return received - sent; in roundTripTime()
|
| /external/autotest/client/common_lib/cros/network/ |
| D | ping_runner.py | 120 received = _regex_int_from_string('([0-9]+) packets received',
124 if None in (sent, received, loss):
129 return PingResult(sent, received, loss,
134 if received > 0:
137 return PingResult(sent, received, loss)
214 received = _regex_int_from_string('([0-9]+) received', loss_line)
217 if None in (sent, received, loss):
223 return PingResult(sent, received, loss,
228 if received > 0:
231 return PingResult(sent, received, loss)
[all …]
|
| /external/libchrome/dbus/ |
| D | dbus_statistics.cc | 175 int sent = 0, received = 0, sent_blocking = 0; in GetAsString() local
183 received += stat.received_signals; in GetAsString()
194 if (!sent && !received && !sent_blocking) in GetAsString()
227 if (received) { in GetAsString()
230 line += base::StringPrintf(" %d", received); in GetAsString()
232 line += base::StringPrintf(" %d/min", received / dminutes); in GetAsString()
235 " %d (%d/min)", received, received / dminutes); in GetAsString()
240 received = 0; in GetAsString()
251 int* received, in GetCalls() argument
260 *received = stat->received_signals; in GetCalls()
|
| /external/libchrome/base/ |
| D | sync_socket_unittest.cc | 72 int received = 0; in SendReceivePeek() local
74 static_assert(sizeof(kSending) == sizeof(received), "invalid data size"); in SendReceivePeek()
83 ASSERT_EQ(sizeof(kSending), socket_b->Receive(&received, sizeof(kSending))); in SendReceivePeek()
84 ASSERT_EQ(kSending, received); in SendReceivePeek()
90 received = 0; in SendReceivePeek()
93 ASSERT_EQ(sizeof(kSending), socket_a->Receive(&received, sizeof(kSending))); in SendReceivePeek()
94 ASSERT_EQ(kSending, received); in SendReceivePeek()
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | dataset_utils.cc | 109 const DataTypeVector& received) { in VerifyTypesMatch() argument
110 if (expected.size() != received.size()) { in VerifyTypesMatch()
113 " types but got ", received.size(), "."); in VerifyTypesMatch()
116 if (expected[i] != received[i]) { in VerifyTypesMatch()
119 " but got ", DataTypeString(received[i]), in VerifyTypesMatch()
127 const std::vector<PartialTensorShape>& received) { in VerifyShapesCompatible() argument
128 if (expected.size() != received.size()) { in VerifyShapesCompatible()
131 " shapes but got ", received.size(), "."); in VerifyShapesCompatible()
134 if (!expected[i].IsCompatibleWith(received[i])) { in VerifyShapesCompatible()
137 " but got ", received[i].DebugString(), in VerifyShapesCompatible()
|
| /external/libchrome/ipc/ |
| D | sync_socket_unittest.cc | 208 size_t length, size_t* received) { in BlockingRead() argument
212 *received = socket->Receive(buf, length); in BlockingRead()
226 size_t received = 1U; // Initialize to an unexpected value. in TEST_F() local
229 base::Bind(&BlockingRead, &pair[0], &buf[0], arraysize(buf), &received)); in TEST_F()
244 EXPECT_EQ(0U, received); in TEST_F()
257 size_t received = 1U; // Initialize to an unexpected value. in TEST_F() local
260 kHelloStringLength, &received)); in TEST_F()
276 EXPECT_EQ(kHelloStringLength, received); in TEST_F()
|
| /external/tensorflow/tensorflow/python/kernel_tests/ |
| D | map_fn_test.py | 149 received = self.evaluate(r)
150 self.assertAllEqual((nums + 3) * 2, received[0])
151 self.assertAllEqual(-(nums + 3) * 2, received[1])
171 received = self.evaluate(r)
172 self.assertAllEqual(nums * nums + (-nums), received)
183 received = self.evaluate(r)
184 self.assertAllEqual(2 * nums, received[0])
185 self.assertAllEqual(-nums, received[1])
186 self.assertAllEqual(nums, received[2])
|
| /external/webrtc/webrtc/base/ |
| D | macasyncsocket.cc | 192 int received = ::recv(native_socket_, reinterpret_cast<char*>(buffer), in Recv() local
194 if (received == SOCKET_ERROR) error_ = errno; in Recv()
197 ASSERT((received != 0) || (length == 0)); in Recv()
198 return received; in Recv()
206 int received = ::recvfrom(native_socket_, reinterpret_cast<char*>(buffer), in RecvFrom() local
209 if (received >= 0 && out_addr != NULL) { in RecvFrom()
211 } else if (received == SOCKET_ERROR) { in RecvFrom()
214 return received; in RecvFrom()
|
| /external/tensorflow/tensorflow/contrib/ignite/kernels/client/ |
| D | ignite_plain_client_unix.cc | 88 int received = 0; in ReadData() local
90 while (received < length) { in ReadData()
91 int res = recv(sock_, buf, length - received, 0); in ReadData()
99 received += res; in ReadData()
|
| D | ignite_plain_client_windows.cc | 107 int received = 0; in ReadData() local
109 while (received < length) { in ReadData()
110 int res = recv(sock_, (char *)buf, length - received, 0); in ReadData()
118 received += res; in ReadData()
|
| D | ignite_ssl_wrapper.cc | 116 int received = 0; in ReadData() local
118 while (received < length) { in ReadData()
119 int res = SSL_read(ssl_, buf, length - received); in ReadData()
127 received += res; in ReadData()
|
| /external/grpc-grpc/src/objective-c/tests/ |
| D | GRPCClientTests.m | 147 [self expectationWithDescription:@"Empty response received."];
156 XCTAssertNotNil(value, @"nil value received as response.");
157 XCTAssertEqual([value length], 0, @"Non-empty response received: %@", value);
186 XCTAssertNotNil(value, @"nil value received as response.");
187 XCTAssertGreaterThan(value.length, 0, @"Empty response received.");
242 [self expectationWithDescription:@"Empty response received."];
261 XCTAssertNotNil(value, @"nil value received as response.");
262 XCTAssertEqual([value length], 0, @"Non-empty response received: %@", value);
277 [self expectationWithDescription:@"Empty response received."];
289 XCTAssertNotNil(value, @"nil value received as response.");
[all …]
|
| /external/ltp/testcases/kernel/controllers/memcg/ |
| D | README | 24 The program allocates memory specified using the '-m' option when 'm' is received
38 The program allocates some memory according to the user input when received SIGUSR.
39 And, it frees all the allocated when received SIGUSR again.
47 The program allocates some memory in a specified time period when received SIGUSR.
|
| /external/ppp/pppd/plugins/radius/ |
| D | buildreq.c | 162 int rc_auth(UINT4 client_port, VALUE_PAIR *send, VALUE_PAIR **received, in rc_auth() argument
170 return rc_auth_using_server(authserver, client_port, send, received, in rc_auth()
189 VALUE_PAIR **received, in rc_auth_using_server() argument
229 *received = data.receive_pairs; in rc_auth_using_server()
247 int rc_auth_proxy(VALUE_PAIR *send, VALUE_PAIR **received, char *msg) in rc_auth_proxy() argument
273 *received = data.receive_pairs; in rc_auth_proxy()
|
| D | radius.c | 250 VALUE_PAIR *send, *received; in radius_pap_auth() local
272 received = NULL; in radius_pap_auth()
299 &received, radius_msg, NULL); in radius_pap_auth()
301 result = rc_auth(rstate.client_port, send, &received, radius_msg, NULL); in radius_pap_auth()
305 if (radius_setparams(received, radius_msg, NULL, NULL, NULL, NULL, 0) < 0) { in radius_pap_auth()
311 rc_avpair_free(received); in radius_pap_auth()
339 VALUE_PAIR *send, *received; in radius_chap_verify() local
384 send = received = NULL; in radius_chap_verify()
470 &received, radius_msg, req_info); in radius_chap_verify()
472 result = rc_auth(rstate.client_port, send, &received, radius_msg, in radius_chap_verify()
[all …]
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| D | GenericRequest.java | 453 Object received = resource.get(); in onResourceReady() local
454 if (received == null || !transcodeClass.isAssignableFrom(received.getClass())) { in onResourceReady()
457 … + " but instead got " + (received != null ? received.getClass() : "") + "{" + received + "}" in onResourceReady()
459 + (received != null ? "" : " " in onResourceReady()
473 onResourceReady(resource, (R) received); in onResourceReady()
|
| /external/testng/src/test/java/test/remote/ |
| D | RemoteTest.java | 68 List<String> received = Lists.newArrayList(); in runTest() local
73 received.add(message.getClass().getSimpleName()); in runTest()
77 Assert.assertEquals(received, EXPECTED_MESSAGES); in runTest()
|
| /external/python/cpython2/Lib/test/ |
| D | test_ftplib.py | 514 received = []
515 self.client.retrbinary('retr', received.append)
516 self.assertEqual(''.join(received), RETR_DATA)
520 received = []
521 self.client.retrbinary('retr', received.append, rest=rest)
522 self.assertEqual(''.join(received), RETR_DATA[rest:],
524 len(''.join(received)),
528 received = []
529 self.client.retrlines('retr', received.append)
530 self.assertEqual(''.join(received), RETR_DATA.replace('\r\n', ''))
[all …]
|
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| D | SocketTransportService.java | 126 int received = 0; in handshake() local
127 while (received < hello.length) { in handshake()
130 n = s.getInputStream().read(b, received, hello.length-received); in handshake()
138 received += n; in handshake()
|
| /external/oj-libjdwp/src/share/transport/socket/ |
| D | socketTransport.c | 142 int rv, helloLen, received; in handshake() local
148 received = 0; in handshake()
149 while (received < helloLen) { in handshake()
160 buf += received; in handshake()
161 n = recv_fully(fd, buf, helloLen-received); in handshake()
169 received += n; in handshake()
174 if (strncmp(b, hello, received) != 0) { in handshake()
176 b[received] = '\0'; in handshake()
|
| /external/python/cpython3/Lib/test/ |
| D | test_ftplib.py | 481 def check_data(self, received, expected): argument
482 self.assertEqual(len(received), len(expected))
483 self.assertEqual(received, expected)
571 received.append(data.decode('ascii'))
572 received = []
574 self.check_data(''.join(received), RETR_DATA)
578 received.append(data.decode('ascii'))
580 received = []
582 self.check_data(''.join(received), RETR_DATA[rest:])
585 received = []
[all …]
|
| /external/libcxx/include/ |
| D | string_view | 233 …SERT(__len == 0 || __s != nullptr, "string_view::string_view(_CharT *, size_t): received nullptr");
396 … _LIBCPP_ASSERT(__s.size() == 0 || __s.data() != nullptr, "string_view::find(): received nullptr");
411 _LIBCPP_ASSERT(__n == 0 || __s != nullptr, "string_view::find(): received nullptr");
419 _LIBCPP_ASSERT(__s != nullptr, "string_view::find(): received nullptr");
428 … _LIBCPP_ASSERT(__s.size() == 0 || __s.data() != nullptr, "string_view::find(): received nullptr");
443 _LIBCPP_ASSERT(__n == 0 || __s != nullptr, "string_view::rfind(): received nullptr");
451 _LIBCPP_ASSERT(__s != nullptr, "string_view::rfind(): received nullptr");
460 …ASSERT(__s.size() == 0 || __s.data() != nullptr, "string_view::find_first_of(): received nullptr");
472 … _LIBCPP_ASSERT(__n == 0 || __s != nullptr, "string_view::find_first_of(): received nullptr");
480 _LIBCPP_ASSERT(__s != nullptr, "string_view::find_first_of(): received nullptr");
[all …]
|
| /external/nos/test/system-test-harness/src/ |
| D | aes-cmac-tests.cc | 28 Notice received; \
29 received.ParseFromArray(reinterpret_cast<char *>(msg.data), msg.data_len); \
32 << "\n" << received.DebugString(); \
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | struct_traits_unittest.cc | 382 ScopedMessagePipeHandle received; in TEST_F() local
385 base::Bind(&CaptureMessagePipe, &received, loop.QuitClosure())); in TEST_F()
388 ASSERT_TRUE(received.is_valid()); in TEST_F()
397 EXPECT_EQ(MOJO_RESULT_OK, Wait(received.get(), MOJO_HANDLE_SIGNAL_READABLE)); in TEST_F()
401 EXPECT_EQ(MOJO_RESULT_OK, ReadMessageRaw(received.get(), &bytes, &handles, in TEST_F()
419 base::Optional<MoveOnlyStructWithTraitsImpl> received; in TEST_F() local
422 &received, loop.QuitClosure())); in TEST_F()
425 EXPECT_FALSE(received); in TEST_F()
|