| /external/rust/crates/flate2/src/ |
| D | zio.rs | 15 type Flush: Flush; typedef
22 flush: Self::Flush, in run() argument
28 flush: Self::Flush, in run_vec() argument
33 type Flush = FlushCompress; typedef
59 type Flush = FlushDecompress; typedef
84 pub trait Flush { trait
90 impl Flush for FlushCompress {
104 impl Flush for FlushDecompress {
131 D::Flush::finish() in read()
133 D::Flush::none() in read()
[all …]
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | ev_epollex_linux_test.cc | 57 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
62 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
66 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
70 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
79 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
83 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
90 grpc_core::ExecCtx::Get()->Flush(); in test_pollable_owner_fd()
|
| D | resource_quota_test.cc | 158 grpc_core::ExecCtx::Get()->Flush(); in test_simple_async_alloc()
181 grpc_core::ExecCtx::Get()->Flush(); in test_async_alloc_blocked_by_size()
208 grpc_core::ExecCtx::Get()->Flush(); in test_scavenge()
222 grpc_core::ExecCtx::Get()->Flush(); in test_scavenge()
247 grpc_core::ExecCtx::Get()->Flush(); in test_scavenge_blocked()
256 grpc_core::ExecCtx::Get()->Flush(); in test_scavenge_blocked()
263 grpc_core::ExecCtx::Get()->Flush(); in test_scavenge_blocked()
288 grpc_core::ExecCtx::Get()->Flush(); in test_blocked_until_scheduled_reclaim()
305 grpc_core::ExecCtx::Get()->Flush(); in test_blocked_until_scheduled_reclaim()
332 grpc_core::ExecCtx::Get()->Flush(); in test_blocked_until_scheduled_reclaim_and_scavenge()
[all …]
|
| D | pollset_set_test.cc | 87 grpc_core::ExecCtx::Get()->Flush(); in cleanup_test_pollsets()
132 grpc_core::ExecCtx::Get()->Flush(); in cleanup_test_fds()
140 grpc_core::ExecCtx::Get()->Flush(); in cleanup_test_fds()
238 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
261 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
264 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
272 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
279 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_basic()
339 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_dup_fds()
342 grpc_core::ExecCtx::Get()->Flush(); in pollset_set_test_dup_fds()
[all …]
|
| D | resolve_address_test.cc | 72 grpc_core::ExecCtx::Get()->Flush(); in args_finish()
98 grpc_core::ExecCtx::Get()->Flush(); in poll_pollset_until_request_done()
131 grpc_core::ExecCtx::Get()->Flush(); in test_localhost()
144 grpc_core::ExecCtx::Get()->Flush(); in test_default_port()
157 grpc_core::ExecCtx::Get()->Flush(); in test_non_numeric_default_port()
170 grpc_core::ExecCtx::Get()->Flush(); in test_missing_default_port()
183 grpc_core::ExecCtx::Get()->Flush(); in test_ipv6_with_port()
203 grpc_core::ExecCtx::Get()->Flush(); in test_ipv6_without_port()
223 grpc_core::ExecCtx::Get()->Flush(); in test_invalid_ip_addresses()
242 grpc_core::ExecCtx::Get()->Flush(); in test_unparseable_hostports()
|
| D | ev_epollsig_linux_test.cc | 80 grpc_core::ExecCtx::Get()->Flush(); in test_fd_cleanup()
83 grpc_core::ExecCtx::Get()->Flush(); in test_fd_cleanup()
112 grpc_core::ExecCtx::Get()->Flush(); in test_pollset_cleanup()
170 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
175 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
180 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
186 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
191 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
195 grpc_core::ExecCtx::Get()->Flush(); in test_add_fd_to_pollset()
|
| D | timer_list_test.cc | 79 grpc_core::ExecCtx::Get()->Flush(); in add_test()
87 grpc_core::ExecCtx::Get()->Flush(); in add_test()
96 grpc_core::ExecCtx::Get()->Flush(); in add_test()
142 grpc_core::ExecCtx::Get()->Flush(); in destruction_test()
146 grpc_core::ExecCtx::Get()->Flush(); in destruction_test()
151 grpc_core::ExecCtx::Get()->Flush(); in destruction_test()
202 grpc_core::ExecCtx::Get()->Flush(); in long_running_service_cleanup_test()
213 grpc_core::ExecCtx::Get()->Flush(); in long_running_service_cleanup_test()
|
| /external/llvm-project/clang-tools-extra/clang-include-fixer/ |
| D | FuzzySymbolIndex.cpp | 72 auto Flush = [&](size_t End) { in tokenize() local
82 Flush(I); in tokenize()
86 Flush(I - 1); // FOOBar: first token is FOO, not FOOB. in tokenize()
94 Flush(I); in tokenize()
105 Flush(I); in tokenize()
109 Flush(I); in tokenize()
113 Flush(Text.size()); in tokenize()
|
| /external/puffin/src/ |
| D | puff_io_unittest.cc | 37 ASSERT_TRUE(pw.Flush()); in TestLiteralLength()
77 ASSERT_TRUE(pw.Flush()); in TEST()
78 ASSERT_TRUE(epw.Flush()); in TEST()
101 ASSERT_TRUE(pw.Flush()); in TEST()
102 ASSERT_TRUE(epw.Flush()); in TEST()
126 ASSERT_TRUE(pw.Flush()); in TEST()
127 ASSERT_TRUE(epw.Flush()); in TEST()
143 ASSERT_TRUE(pw.Flush()); in TEST()
144 ASSERT_TRUE(epw.Flush()); in TEST()
171 ASSERT_TRUE(pw.Flush()); in TEST()
[all …]
|
| /external/rust/crates/futures-util/src/io/ |
| D | flush.rs | 10 pub struct Flush<'a, W: ?Sized> { struct
14 impl<W: ?Sized + Unpin> Unpin for Flush<'_, W> {} implementation
16 impl<'a, W: AsyncWrite + ?Sized + Unpin> Flush<'a, W> { impl
22 impl<W> Future for Flush<'_, W> implementation
|
| /external/rust/crates/tokio/src/io/util/ |
| D | flush.rs | 17 pub struct Flush<'a, A: ?Sized> {
26 pub(super) fn flush<A>(a: &mut A) -> Flush<'_, A> in flush()
30 Flush { in flush()
36 impl<A> Future for Flush<'_, A> implementation
|
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| D | fake_resolver_test.cc | 136 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
149 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
164 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
167 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
179 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
192 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
202 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
211 grpc_core::ExecCtx::Get()->Flush(); in test_fake_resolver()
|
| /external/grpc-grpc/test/core/transport/ |
| D | connectivity_state_test.cc | 84 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_then_unsubscribe()
88 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_then_unsubscribe()
106 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_then_destroy()
111 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_then_destroy()
127 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_with_failure_then_destroy()
131 grpc_core::ExecCtx::Get()->Flush(); in test_subscribe_with_failure_then_destroy()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | flush.rs | 10 pub struct Flush<'a, Si: ?Sized, Item> { struct
16 impl<Si: Unpin + ?Sized, Item> Unpin for Flush<'_, Si, Item> {} implementation
24 impl<'a, Si: Sink<Item> + Unpin + ?Sized, Item> Flush<'a, Si, Item> { implementation
33 impl<Si: Sink<Item> + Unpin + ?Sized, Item> Future for Flush<'_, Si, Item> { implementation
|
| /external/tensorflow/tensorflow/core/summary/ |
| D | summary_file_writer_test.cc | 57 TF_CHECK_OK(writer->Flush()); in SummaryTestHelper()
100 TF_RETURN_IF_ERROR(writer->Flush()); in TEST_F()
115 TF_RETURN_IF_ERROR(writer->Flush()); in TEST_F()
134 TF_RETURN_IF_ERROR(writer->Flush()); in TEST_F()
152 TF_RETURN_IF_ERROR(writer->Flush()); in TEST_F()
170 TF_RETURN_IF_ERROR(writer->Flush()); in TEST_F()
191 TF_RETURN_IF_ERROR(writer->Flush()); in TEST_F()
210 TF_RETURN_IF_ERROR(writer->Flush()); in TEST_F()
228 TF_RETURN_IF_ERROR(writer->Flush()); in TEST_F()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_closure.cc | 48 grpc_core::ExecCtx::Get()->Flush(); in BM_WellFlushed()
90 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureRunOnExecCtx()
131 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSchedOnExecCtx()
148 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSched2OnExecCtx()
168 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSched3OnExecCtx()
251 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSchedOnCombiner()
270 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSched2OnCombiner()
292 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSched3OnCombiner()
314 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSched2OnTwoCombiners()
345 grpc_core::ExecCtx::Get()->Flush(); in BM_ClosureSched4OnTwoCombiners()
[all …]
|
| /external/protobuf/csharp/compatibility_tests/v3.0.0/src/Google.Protobuf.Test/ |
| D | CodedOutputStreamTest.cs | 54 output.Flush(); in AssertWriteVarint()
64 output.Flush(); in AssertWriteVarint()
81 output.Flush(); in AssertWriteVarint()
89 output.Flush(); in AssertWriteVarint()
139 output.Flush(); in AssertWriteLittleEndian32()
148 output.Flush(); in AssertWriteLittleEndian32()
162 output.Flush(); in AssertWriteLittleEndian64()
171 output.Flush(); in AssertWriteLittleEndian64()
206 output.Flush(); in WriteWholeMessage_VaryingBlockSizes()
312 cout.Flush(); in TestCodedInputOutputPosition()
[all …]
|
| /external/lzma/Java/SevenZip/Compression/LZ/ |
| D | OutWindow.java | 32 Flush(); in ReleaseStream()
45 public void Flush() throws IOException in Flush() method in OutWindow
67 Flush(); in CopyBlock()
75 Flush(); in PutByte()
|
| /external/protobuf/csharp/src/Google.Protobuf.Test/ |
| D | CodedOutputStreamTest.cs | 54 output.Flush(); in AssertWriteVarint()
64 output.Flush(); in AssertWriteVarint()
81 output.Flush(); in AssertWriteVarint()
89 output.Flush(); in AssertWriteVarint()
139 output.Flush(); in AssertWriteLittleEndian32()
148 output.Flush(); in AssertWriteLittleEndian32()
162 output.Flush(); in AssertWriteLittleEndian64()
171 output.Flush(); in AssertWriteLittleEndian64()
206 output.Flush(); in WriteWholeMessage_VaryingBlockSizes()
312 cout.Flush(); in TestCodedInputOutputPosition()
[all …]
|
| /external/lzma/CPP/7zip/UI/Console/ |
| D | ExtractCallbackConsole.cpp | 66 _se->Flush(); in ScanError()
310 _so->Flush(); in AskOverwrite()
356 _so->Flush(); in PrepareOperation()
391 _se->Flush(); in MessageError()
475 _se->Flush(); in SetOperationResult()
661 _se->Flush(); in OpenResult()
699 _so->Flush(); in OpenResult()
710 _so->Flush(); in OpenResult()
728 _so->Flush(); in OpenResult()
747 _se->Flush(); in OpenResult()
[all …]
|
| D | UpdateCallbackConsole.cpp | 85 _se->Flush(); in OpenResult()
116 _so->Flush(); in OpenResult()
127 _so->Flush(); in OpenResult()
143 _so->Flush(); in OpenResult()
151 _se->Flush(); in OpenResult()
186 _so->Flush(); in CommonError()
193 _se->Flush(); in CommonError()
354 _so->Flush(); in DeletingAfterArchiving()
490 _so->Flush(); in PrintProgress()
575 _so->Flush(); in ReportExtractResult()
[all …]
|
| /external/lzma/CS/7zip/Compress/LZ/ |
| D | LzOutWindow.cs | 65 Flush(); in ReleaseStream()
69 public void Flush() in Flush() method in SevenZip.Compression.LZ.OutWindow
91 Flush(); in CopyBlock()
99 Flush(); in PutByte()
|
| /external/tensorflow/tensorflow/python/client/ |
| D | session_ref.cc | 83 Flush(op).IgnoreError(); \
116 return Flush(op); in RecordNewSession()
178 return Flush(op); in RecordRun()
199 return Flush(op); in RecordCreate()
220 return Flush(op); in RecordExtend()
238 return Flush(op); in RecordClose()
251 return Flush(op); in RecordListDevices()
274 return Flush(op); in RecordPRunSetup()
307 return Flush(op); in RecordPRun()
323 return Flush(op); in RecordMakeCallable()
[all …]
|
| /external/tensorflow/tensorflow/core/lib/io/ |
| D | record_reader_writer_test.cc | 80 TF_CHECK_OK(writer.Flush()); in VerifyFlush()
81 TF_CHECK_OK(file->Flush()); in VerifyFlush()
134 TF_CHECK_OK(writer.Flush()); in TEST()
176 TF_CHECK_OK(writer.Flush()); in TEST()
212 TF_CHECK_OK(writer.Flush()); in TEST()
249 TF_CHECK_OK(writer.Flush()); in TEST()
287 TF_CHECK_OK(writer.Flush()); in TEST()
320 TF_CHECK_OK(writer.Flush()); in TEST()
324 CHECK_EQ(writer.Flush().code(), error::FAILED_PRECONDITION); in TEST()
|
| /external/webrtc/test/ |
| D | run_loop_unittest.cc | 25 TEST(RunLoopTest, Flush) { in TEST() argument
30 loop.Flush(); in TEST()
43 loop.Flush(); in TEST()
|