Home
last modified time | relevance | path

Searched refs:EndRead (Results 1 – 25 of 455) sorted by relevance

12345678910>>...19

/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks/tests/TaskFactory/
H A DTaskFactory_FromAsyncTests.cs82 fac.EndRead, in RunAPMFactoryTests()
95 fac.EndRead, in RunAPMFactoryTests()
107 fac.EndRead, in RunAPMFactoryTests()
117 fac.EndRead, in RunAPMFactoryTests()
132 fac.EndRead, in RunAPMFactoryTests()
147 fac.EndRead, in RunAPMFactoryTests()
162 fac.EndRead, in RunAPMFactoryTests()
174 fac.EndRead, in RunAPMFactoryTests()
187 fac.EndRead, in RunAPMFactoryTests()
197 fac.EndRead, in RunAPMFactoryTests()
[all …]
H A DTaskFactoryTests.cs167 … () => tf.FromAsync<string>(null, fac.EndRead, (Object)null, TaskCreationOptions.None)); in RunTaskFactoryFromAsyncExceptionTests()
173 …() => tf.FromAsync<string, string>(null, fac.EndRead, "arg1", (Object)null, TaskCreationOptions.No… in RunTaskFactoryFromAsyncExceptionTests()
193 () => { tfs.FromAsync(fac.StartRead, fac.EndRead, null); }); in RunTaskFactoryFromAsyncExceptionTests()
195 () => { tfs.FromAsync(fac.StartRead, fac.EndRead, 64, null); }); in RunTaskFactoryFromAsyncExceptionTests()
197 () => { tfs.FromAsync(fac.StartRead, fac.EndRead, 64, charbuf, null); }); in RunTaskFactoryFromAsyncExceptionTests()
199 () => { tfs.FromAsync(fac.StartRead, fac.EndRead, 64, charbuf, 0, null); }); in RunTaskFactoryFromAsyncExceptionTests()
219 () => tfs.FromAsync(null, fac.EndRead, null, TaskCreationOptions.None)); in RunTaskFactoryFromAsyncExceptionTests()
225 … () => tfs.FromAsync<string>(null, fac.EndRead, "arg1", null, TaskCreationOptions.None)); in RunTaskFactoryFromAsyncExceptionTests()
231 … () => tfs.FromAsync<string, int>(null, fac.EndRead, "arg1", 2, null, TaskCreationOptions.None)); in RunTaskFactoryFromAsyncExceptionTests()
237 …() => tfs.FromAsync<string, int, int>(null, fac.EndRead, "arg1", 2, 3, null, TaskCreationOptions.N… in RunTaskFactoryFromAsyncExceptionTests()
[all …]
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.IO.Ports/tests/SerialStream/
H A DEndRead.cs115 com1.BaseStream.EndRead(readAsyncResult); in AsyncResult_MultipleSameResult()
147 … if (numBytesToRead1 != (endReadReturnValue = com1.BaseStream.EndRead(readAsyncResult1))) in AsyncResult_MultipleInOrder()
153 … if (numBytesToRead2 != (endReadReturnValue = com1.BaseStream.EndRead(readAsyncResult2))) in AsyncResult_MultipleInOrder()
159 … if (numBytesToRead3 != (endReadReturnValue = com1.BaseStream.EndRead(readAsyncResult3))) in AsyncResult_MultipleInOrder()
194 … if (numBytesToRead2 != (endReadReturnValue = com1.BaseStream.EndRead(readAsyncResult2))) in AsyncResult_MultipleOutOfOrder()
200 … if (numBytesToRead3 != (endReadReturnValue = com1.BaseStream.EndRead(readAsyncResult3))) in AsyncResult_MultipleOutOfOrder()
206 … if (numBytesToRead1 != (endReadReturnValue = com1.BaseStream.EndRead(readAsyncResult1))) in AsyncResult_MultipleOutOfOrder()
223 serialStream.EndRead(asyncResult); in VerifyEndReadException()
227 Assert.Throws(expectedException, () => serialStream.EndRead(asyncResult)); in VerifyEndReadException()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/src/profiling/memory/
H A Dshared_ring_buffer_unittest.cc66 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
72 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
92 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
102 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
112 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
124 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
129 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
134 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
139 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
144 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/src/profiling/memory/
H A Dshared_ring_buffer_unittest.cc66 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
72 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
92 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
102 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
112 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
124 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
129 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
134 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
139 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
144 rd->EndRead(std::move(buf_and_size)); in StructuredTest()
[all …]
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System/net/System/Net/Cache/
H A D_CacheStreams.cs182 count = m_HeadStream.EndRead(transportResult); in ReadCallback()
199 count = WrappedStream.EndRead(ar); in ReadCallback()
236 int bytes = m_HeadStream.EndRead(ar); in BeginRead()
261 public override int EndRead(IAsyncResult asyncResult) { in EndRead() method in System.Net.Cache.CombinedReadStream
277 … return m_HeadEOF? WrappedStream.EndRead(asyncResult): m_HeadStream.EndRead(asyncResult); in EndRead()
702 public override int EndRead(IAsyncResult asyncResult) { in EndRead() method in System.Net.Cache.ForwardingReadStream
718 int bytes = WrappedStream.EndRead(asyncResult); in EndRead()
958 public override int EndRead(IAsyncResult asyncResult) { in EndRead() method in System.Net.Cache.MetadataUpdateStream
959 return WrappedStream.EndRead(asyncResult); in EndRead()
1180 public override int EndRead(IAsyncResult asyncResult) { in EndRead() method in System.Net.Cache.RangeStream
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/core/fetch/
H A Dfetch_data_loader.cc84 result = consumer_->EndRead(available); in OnStateChange()
152 auto unused = consumer_->EndRead(0); in OnStateChange()
159 result = consumer_->EndRead(available); in OnStateChange()
250 result = consumer_->EndRead(available); in OnStateChange()
323 result = consumer_->EndRead(available); in OnStateChange()
487 result = consumer_->EndRead(available); in OnStateChange()
606 result = consumer_->EndRead(0); in OnStateChange()
612 result = consumer_->EndRead(num_bytes); in OnStateChange()
614 result = consumer_->EndRead(0); in OnStateChange()
618 result = consumer_->EndRead(0); in OnStateChange()
H A Dform_data_bytes_consumer.h36 Result EndRead(size_t read_size) override { in EndRead() function
37 return impl_->EndRead(read_size); in EndRead()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.HttpListener/src/System/Net/Managed/
H A DChunkedInputStream.cs75 return EndRead(ares); in ReadCore()
120 int nread = base.EndRead(base_ares); in OnRead()
151 public override int EndRead(IAsyncResult asyncResult) in EndRead() method in System.Net.ChunkedInputStream
163 … throw new InvalidOperationException(SR.Format(SR.net_io_invalidendcall, nameof(EndRead))); in EndRead()
H A DHttpRequestStream.Managed.cs163 public override int EndRead(IAsyncResult asyncResult) in EndRead() method in System.Net.HttpRequestStream
176 … throw new InvalidOperationException(SR.Format(SR.net_io_invalidendcall, nameof(EndRead))); in EndRead()
194 nread = _stream.EndRead(asyncResult); in EndRead()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/core/fetch/
H A Dbytes_uploader_test.cc31 MOCK_METHOD1(EndRead, Result(size_t));
146 EXPECT_CALL(Mock(), EndRead(6u)) in TEST_F()
188 EXPECT_CALL(Mock(), EndRead(10u)) in TEST_F()
197 EXPECT_CALL(Mock(), EndRead(0u)) in TEST_F()
208 EXPECT_CALL(Mock(), EndRead(2u)) in TEST_F()
H A Dfetch_data_loader.cc156 auto unused = consumer_->EndRead(0); in OnStateChange()
163 result = consumer_->EndRead(available); in OnStateChange()
252 result = consumer_->EndRead(available); in OnStateChange()
323 result = consumer_->EndRead(available); in OnStateChange()
485 result = consumer_->EndRead(available); in OnStateChange()
603 result = consumer_->EndRead(0); in OnStateChange()
609 result = consumer_->EndRead(num_bytes); in OnStateChange()
611 result = consumer_->EndRead(0); in OnStateChange()
615 result = consumer_->EndRead(0); in OnStateChange()
H A Dform_data_bytes_consumer.h37 Result EndRead(size_t read_size) override { in EndRead() function
38 return impl_->EndRead(read_size); in EndRead()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Channels/
H A DDetectEofStream.cs23 public override int EndRead(IAsyncResult result) in EndRead() method in System.ServiceModel.Channels.DetectEofStream
25 int returnValue = base.EndRead(result); in EndRead()
H A DConnection.cs35 int EndRead(); in EndRead() method
162 public virtual int EndRead() in EndRead() method in System.ServiceModel.Channels.DelegatingConnection
164 return connection.EndRead(); in EndRead()
240 public override int EndRead() in EndRead() method in System.ServiceModel.Channels.PreReadConnection
249 return base.EndRead(); in EndRead()
400 public override int EndRead(IAsyncResult asyncResult) in EndRead() method in System.ServiceModel.Channels.ConnectionStream
511 bytesRead = connection.EndRead(); in HandleIO()
833 bytesRead = stream.EndRead(localResult); in BeginRead()
843 public int EndRead() in EndRead() method in System.ServiceModel.Channels.StreamConnection
852 bytesRead = stream.EndRead(localResult); in EndRead()
H A DDelegatingStream.cs122 public override int EndRead(IAsyncResult result) in EndRead() method in System.ServiceModel.Channels.DelegatingStream
124 return stream.EndRead(result); in EndRead()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Web/
H A DImplicitAsyncPreloadModule.cs86 bytesRead = _inputStream.EndRead(readAsyncResult); in OnEnter()
112 int bytesRead = _inputStream.EndRead(readAsyncResult); in OnAsyncCompletion()
120 bytesRead = _inputStream.EndRead(readAsyncResult); in OnAsyncCompletion()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/platform/loader/fetch/
H A Dbytes_consumer.cc20 Result EndRead(size_t read_size) override { in EndRead() function in blink::__anonfa1851970111::ErroredBytesConsumer
43 Result EndRead(size_t read_size) override { in EndRead() function in blink::__anonfa1851970111::ClosedBytesConsumer
H A Dresponse_body_loader.cc46 result = bytes_consumer_->EndRead(0); in BeginRead()
64 Result EndRead(size_t read_size) override { in EndRead() function in blink::ResponseBodyLoader::DelegatingBytesConsumer
67 auto result = bytes_consumer_->EndRead(read_size); in EndRead()
178 result = bytes_consumer_->EndRead(0); in OnStateChange()
461 result = bytes_consumer_->EndRead(available); in OnStateChange()
H A Dbuffering_bytes_consumer.cc100 BytesConsumer::Result BufferingBytesConsumer::EndRead(size_t read_size) { in EndRead() function in blink::BufferingBytesConsumer
103 return bytes_consumer_->EndRead(read_size); in EndRead()
197 result = bytes_consumer_->EndRead(available); in BufferData()
/dports/lang/mono/mono-5.10.1.57/mcs/class/System/System.Net/
H A DChunkedInputStream.cs72 return EndRead (ares); in Read()
127 int nread = base.EndRead (base_ares); in OnRead()
147 public override int EndRead (IAsyncResult ares) in EndRead() method in System.Net.ChunkedInputStream
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/platform/loader/fetch/
H A Dresponse_body_loader.cc48 result = bytes_consumer_->EndRead(0); in BeginRead()
66 Result EndRead(size_t read_size) override { in EndRead() function in blink::ResponseBodyLoader::DelegatingBytesConsumer
69 auto result = bytes_consumer_->EndRead(read_size); in EndRead()
180 result = bytes_consumer_->EndRead(0); in OnStateChange()
560 result = bytes_consumer_->EndRead(available); in OnStateChange()
569 result = bytes_consumer_->EndRead(available); in OnStateChange()
H A Dbuffering_bytes_consumer.cc100 BytesConsumer::Result BufferingBytesConsumer::EndRead(size_t read_size) { in EndRead() function in blink::BufferingBytesConsumer
103 return bytes_consumer_->EndRead(read_size); in EndRead()
197 result = bytes_consumer_->EndRead(available); in BufferData()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Mail/src/System/Net/
H A DBufferedReadStream.cs51 public override int EndRead(IAsyncResult asyncResult) in EndRead() method in System.Net.BufferedReadStream
191 _read += _parent.BaseStream.EndRead(result); in Read()
210 thisPtr._read += thisPtr._parent.BaseStream.EndRead(result); in OnRead()
/dports/lang/mono/mono-5.10.1.57/external/aspnetwebstack/src/System.Net.Http.Formatting/Internal/
H A DDelegatingStream.cs91 public override int EndRead(IAsyncResult asyncResult) in EndRead() method in System.Net.Http.Internal.DelegatingStream
93 return _innerStream.EndRead(asyncResult); in EndRead()

12345678910>>...19