| /external/puffin/src/ |
| D | stream_unittest.cc | 112 void TestWrite(StreamInterface* write_stream, StreamInterface* read_stream) { in TestWrite() argument
120 ASSERT_TRUE(write_stream->Seek(0)); in TestWrite()
121 ASSERT_TRUE(write_stream->Write(buf1.data(), buf1.size())); in TestWrite()
129 ASSERT_TRUE(write_stream->Seek(0)); in TestWrite()
131 ASSERT_TRUE(write_stream->Write(&buf2[idx], 1)); in TestWrite()
167 auto write_stream = MemoryStream::CreateForWrite(&buf); in TEST_F() local
168 TestWrite(write_stream.get(), read_stream.get()); in TEST_F()
169 TestWriteBoundary(write_stream.get()); in TEST_F()
170 TestSeek(write_stream.get(), false); in TEST_F()
173 TestClose(write_stream.get()); in TEST_F()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_client_cfstream.cc | 54 CFWriteStreamRef write_stream; member
76 CFRelease(connect->write_stream); in CFStreamConnectCleanup()
124 stream_error = CFWriteStreamCopyError(connect->write_stream); in OnOpen()
132 connect->read_stream, connect->write_stream, in OnOpen()
187 CFWriteStreamRef write_stream; in CFStreamClientConnect() local
193 &write_stream); in CFStreamClientConnect()
196 connect->write_stream = write_stream; in CFStreamClientConnect()
198 CFStreamHandle::CreateStreamHandle(read_stream, write_stream); in CFStreamClientConnect()
206 CFWriteStreamOpen(write_stream); in CFStreamClientConnect()
|
| D | ev_apple.cc | 110 CFWriteStreamRef write_stream, dispatch_queue_t dispatch_queue) { in grpc_apple_register_write_stream_queue() argument
111 CFWriteStreamSetDispatchQueue(write_stream, dispatch_queue); in grpc_apple_register_write_stream_queue()
131 CFWriteStreamRef write_stream, dispatch_queue_t dispatch_queue) { in grpc_apple_register_write_stream_run_loop() argument
132 GRPC_POLLING_TRACE("Register write stream: %p", write_stream); in grpc_apple_register_write_stream_run_loop()
135 write_stream, gGlobalRunLoopContext->run_loop, kCFRunLoopDefaultMode); in grpc_apple_register_write_stream_run_loop()
156 void grpc_apple_register_write_stream(CFWriteStreamRef write_stream, in grpc_apple_register_write_stream() argument
158 grpc_apple_register_write_stream_impl(write_stream, dispatch_queue); in grpc_apple_register_write_stream()
|
| D | endpoint_cfstream.cc | 49 CFWriteStreamRef write_stream; member
68 CFRelease(ep->write_stream); in CFStreamFree()
208 ep->write_stream, GRPC_SLICE_START_PTR(slice), slice_len); in WriteAction()
211 CFErrorRef stream_error = CFWriteStreamCopyError(ep->write_stream); in WriteAction()
295 CFWriteStreamClose(ep_impl->write_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()
361 ep_impl->write_stream = write_stream; in grpc_cfstream_endpoint_create()
363 CFRetain(write_stream); 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()
132 CFWriteStreamRef write_stream) { in CFStreamHandle() argument
147 write_stream, in CFStreamHandle()
152 grpc_apple_register_write_stream(write_stream, dispatch_queue_); in CFStreamHandle()
|
| D | cfstream_handle.h | 45 CFWriteStreamRef write_stream);
47 CFStreamHandle(CFReadStreamRef read_stream, CFWriteStreamRef write_stream);
|
| D | ev_apple.h | 34 void grpc_apple_register_write_stream(CFWriteStreamRef write_stream,
|
| D | endpoint_cfstream.h | 43 CFReadStreamRef read_stream, CFWriteStreamRef write_stream,
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_client_cfstream.cc | 54 CFWriteStreamRef write_stream; member
76 CFRelease(connect->write_stream); in CFStreamConnectCleanup()
125 stream_error = CFWriteStreamCopyError(connect->write_stream); in OnOpen()
133 connect->read_stream, connect->write_stream, connect->addr_name, in OnOpen()
190 CFWriteStreamRef write_stream; in CFStreamClientConnect() local
196 &write_stream); in CFStreamClientConnect()
199 connect->write_stream = write_stream; in CFStreamClientConnect()
201 CFStreamHandle::CreateStreamHandle(read_stream, write_stream); in CFStreamClientConnect()
209 CFWriteStreamOpen(write_stream); in CFStreamClientConnect()
|
| D | endpoint_cfstream.cc | 47 CFWriteStreamRef write_stream; member
66 CFRelease(ep->write_stream); in CFStreamFree()
206 ep->write_stream, GRPC_SLICE_START_PTR(slice), slice_len); in WriteAction()
209 CFErrorRef stream_error = CFWriteStreamCopyError(ep->write_stream); in WriteAction()
290 CFWriteStreamClose(ep_impl->write_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()
348 ep_impl->write_stream = write_stream; in grpc_cfstream_endpoint_create()
350 CFRetain(write_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()
114 CFWriteStreamRef write_stream) { in CFStreamHandle() argument
128 write_stream, in CFStreamHandle()
134 CFWriteStreamScheduleWithRunLoop(write_stream, CFRunLoopGetMain(), in CFStreamHandle()
|
| D | cfstream_handle.h | 38 CFWriteStreamRef write_stream);
53 CFStreamHandle(CFReadStreamRef read_stream, CFWriteStreamRef write_stream);
|
| D | endpoint_cfstream.h | 43 CFReadStreamRef read_stream, CFWriteStreamRef write_stream,
|