| /external/puffin/src/ |
| D | stream_unittest.cc | 112 void TestWrite(StreamInterface* write_stream, StreamInterface* read_stream) { in TestWrite() argument
114 ASSERT_TRUE(read_stream->GetSize(&size)); in TestWrite()
122 ASSERT_TRUE(read_stream->Seek(0)); in TestWrite()
123 ASSERT_TRUE(read_stream->Read(buf2.data(), buf2.size())); in TestWrite()
134 ASSERT_TRUE(read_stream->Seek(0)); in TestWrite()
135 ASSERT_TRUE(read_stream->Read(buf1.data(), buf1.size())); in TestWrite()
163 auto read_stream = MemoryStream::CreateForRead(buf); in TEST_F() local
164 TestRead(read_stream.get(), buf); in TEST_F()
165 TestSeek(read_stream.get(), false); in TEST_F()
168 TestWrite(write_stream.get(), read_stream.get()); in TEST_F()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_client_cfstream.cc | 53 CFReadStreamRef read_stream; member
75 CFRelease(connect->read_stream); in CFStreamConnectCleanup()
122 CFErrorRef stream_error = CFReadStreamCopyError(connect->read_stream); in OnOpen()
132 connect->read_stream, connect->write_stream, in OnOpen()
186 CFReadStreamRef read_stream; in CFStreamClientConnect() local
192 CFStreamCreatePairWithSocketToHost(NULL, host, port, &read_stream, in CFStreamClientConnect()
195 connect->read_stream = read_stream; in CFStreamClientConnect()
198 CFStreamHandle::CreateStreamHandle(read_stream, write_stream); in CFStreamClientConnect()
205 CFReadStreamOpen(read_stream); in CFStreamClientConnect()
|
| D | ev_apple.cc | 102 CFReadStreamRef read_stream, dispatch_queue_t dispatch_queue) { in grpc_apple_register_read_stream_queue() argument
103 CFReadStreamSetDispatchQueue(read_stream, dispatch_queue); in grpc_apple_register_read_stream_queue()
118 CFReadStreamRef read_stream, dispatch_queue_t dispatch_queue) { in grpc_apple_register_read_stream_run_loop() argument
119 GRPC_POLLING_TRACE("Register read stream: %p", read_stream); in grpc_apple_register_read_stream_run_loop()
121 CFReadStreamScheduleWithRunLoop(read_stream, gGlobalRunLoopContext->run_loop, in grpc_apple_register_read_stream_run_loop()
151 void grpc_apple_register_read_stream(CFReadStreamRef read_stream, in grpc_apple_register_read_stream() argument
153 grpc_apple_register_read_stream_impl(read_stream, dispatch_queue); in grpc_apple_register_read_stream()
|
| D | endpoint_cfstream.cc | 48 CFReadStreamRef read_stream; member
67 CFRelease(ep->read_stream); in CFStreamFree()
167 CFReadStreamRead(ep->read_stream, GRPC_SLICE_START_PTR(slice), len); in ReadAction()
170 CFErrorRef stream_error = CFReadStreamCopyError(ep->read_stream); in ReadAction()
294 CFReadStreamClose(ep_impl->read_stream); in CFStreamShutdown()
349 CFReadStreamRef read_stream, CFWriteStreamRef write_stream, in grpc_cfstream_endpoint_create() argument
356 ep_impl, read_stream, write_stream); in grpc_cfstream_endpoint_create()
360 ep_impl->read_stream = read_stream; in grpc_cfstream_endpoint_create()
362 CFRetain(read_stream); in grpc_cfstream_endpoint_create()
371 ep_impl->read_stream, kCFStreamPropertySocketNativeHandle)); in grpc_cfstream_endpoint_create()
|
| D | cfstream_handle.cc | 56 CFReadStreamRef read_stream, CFWriteStreamRef write_stream) { in CreateStreamHandle() argument
57 return new CFStreamHandle(read_stream, write_stream); in CreateStreamHandle()
131 CFStreamHandle::CFStreamHandle(CFReadStreamRef read_stream, in CFStreamHandle() argument
142 read_stream, in CFStreamHandle()
151 grpc_apple_register_read_stream(read_stream, dispatch_queue_); in CFStreamHandle()
|
| D | cfstream_handle.h | 44 static CFStreamHandle* CreateStreamHandle(CFReadStreamRef read_stream,
47 CFStreamHandle(CFReadStreamRef read_stream, CFWriteStreamRef write_stream);
|
| D | ev_apple.h | 31 void grpc_apple_register_read_stream(CFReadStreamRef read_stream,
|
| D | endpoint_cfstream.h | 43 CFReadStreamRef read_stream, CFWriteStreamRef write_stream,
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_client_cfstream.cc | 53 CFReadStreamRef read_stream; member
75 CFRelease(connect->read_stream); in CFStreamConnectCleanup()
123 CFErrorRef stream_error = CFReadStreamCopyError(connect->read_stream); in OnOpen()
133 connect->read_stream, connect->write_stream, connect->addr_name, in OnOpen()
189 CFReadStreamRef read_stream; in CFStreamClientConnect() local
195 CFStreamCreatePairWithSocketToHost(NULL, host, port, &read_stream, in CFStreamClientConnect()
198 connect->read_stream = read_stream; in CFStreamClientConnect()
201 CFStreamHandle::CreateStreamHandle(read_stream, write_stream); in CFStreamClientConnect()
208 CFReadStreamOpen(read_stream); in CFStreamClientConnect()
|
| D | endpoint_cfstream.cc | 46 CFReadStreamRef read_stream; member
65 CFRelease(ep->read_stream); in CFStreamFree()
165 CFReadStreamRead(ep->read_stream, GRPC_SLICE_START_PTR(slice), len); in ReadAction()
168 CFErrorRef stream_error = CFReadStreamCopyError(ep->read_stream); in ReadAction()
289 CFReadStreamClose(ep_impl->read_stream); in CFStreamShutdown()
335 CFReadStreamRef read_stream, CFWriteStreamRef write_stream, in grpc_cfstream_endpoint_create() argument
343 ep_impl, read_stream, write_stream); in grpc_cfstream_endpoint_create()
347 ep_impl->read_stream = read_stream; in grpc_cfstream_endpoint_create()
349 CFRetain(read_stream); in grpc_cfstream_endpoint_create()
|
| D | cfstream_handle.cc | 48 CFReadStreamRef read_stream, CFWriteStreamRef write_stream) { in CreateStreamHandle() argument
49 return new CFStreamHandle(read_stream, write_stream); in CreateStreamHandle()
113 CFStreamHandle::CFStreamHandle(CFReadStreamRef read_stream, in CFStreamHandle() argument
123 read_stream, in CFStreamHandle()
132 CFReadStreamScheduleWithRunLoop(read_stream, CFRunLoopGetMain(), in CFStreamHandle()
|
| D | cfstream_handle.h | 37 static CFStreamHandle* CreateStreamHandle(CFReadStreamRef read_stream,
53 CFStreamHandle(CFReadStreamRef read_stream, CFWriteStreamRef write_stream);
|
| D | endpoint_cfstream.h | 43 CFReadStreamRef read_stream, CFWriteStreamRef write_stream,
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 49 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> read_stream; member
240 calld->read_stream.Init(&read_slice_buffer, 0); in hs_filter_incoming_metadata()
290 calld->recv_message->reset(calld->read_stream.get()); in hs_recv_initial_metadata_ready()
316 calld->recv_message->reset(calld->read_stream.get()); in hs_recv_message_ready()
436 calld->read_stream->Orphan(); in hs_destroy_call_elem()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 60 read_stream->Orphan(); in ~call_data()
72 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> read_stream; member
294 calld->read_stream.Init(&read_slice_buffer, 0); in hs_filter_incoming_metadata()
345 calld->recv_message->reset(calld->read_stream.get()); in hs_recv_initial_metadata_ready()
379 calld->recv_message->reset(calld->read_stream.get()); in hs_recv_message_ready()
|
| /external/google-breakpad/src/client/mac/handler/ |
| D | minidump_generator.cc | 136 CFReadStreamRef read_stream = CFReadStreamCreateWithFile(NULL, sys_vers); in GatherSystemInformation() local
138 if (!read_stream) { in GatherSystemInformation()
141 if (!CFReadStreamOpen(read_stream)) { in GatherSystemInformation()
142 CFRelease(read_stream); in GatherSystemInformation()
151 CFReadStreamRead(read_stream, data_bytes, kMaxBufferLength); in GatherSystemInformation()
165 CFReadStreamClose(read_stream); in GatherSystemInformation()
166 CFRelease(read_stream); in GatherSystemInformation()
|
| /external/rust/crates/futures/tests_disabled/ |
| D | stream.rs | 370 let read_stream = poll_fn(move |_| -> Poll<Option<usize>, std::io::Error> { in stream_poll_fn() localVariable
378 assert_eq!(block_on_stream(read_stream).count(), 5); in stream_poll_fn()
|