Home
last modified time | relevance | path

Searched refs:read_stream (Results 1 – 7 of 7) sorted by relevance

/external/puffin/src/
Dstream_unittest.cc112 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/grpc-grpc/src/core/lib/iomgr/
Dtcp_client_cfstream.cc53 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()
Dendpoint_cfstream.cc46 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()
Dcfstream_handle.cc48 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()
Dcfstream_handle.h37 static CFStreamHandle* CreateStreamHandle(CFReadStreamRef read_stream,
53 CFStreamHandle(CFReadStreamRef read_stream, CFWriteStreamRef write_stream);
Dendpoint_cfstream.h43 CFReadStreamRef read_stream, CFWriteStreamRef write_stream,
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc49 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()