Searched refs:write_stream (Results 1 – 6 of 6) sorted by relevance
| /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/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,
|