| /external/tensorflow/tensorflow/compiler/jit/ |
| xla_device_context.h | 52 explicit XlaTransferManager(perftools::gputools::Stream* stream);
59 perftools::gputools::Stream* stream() const { return stream_; } function in class:tensorflow::XlaTransferManager
62 // Stream obtained from a Device, used to transfer tensors between
64 perftools::gputools::Stream* stream_;
72 explicit XlaDeviceContext(perftools::gputools::Stream* stream);
80 perftools::gputools::Stream* stream() const override
[all...] |
| /external/tensorflow/tensorflow/compiler/xla/ |
| executable_run_options.cc | 39 perftools::gputools::Stream* stream) {
40 stream_ = stream;
44 perftools::gputools::Stream* ExecutableRunOptions::stream() const { function in class:xla::ExecutableRunOptions
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| executable.cc | 54 TF_RET_CHECK(options.stream() != nullptr);
55 TF_RETURN_IF_ERROR(options.stream()->BlockHostUntilDone());
63 perftools::gputools::Stream* stream = run_options->stream(); local
66 timer.reset(new perftools::gputools::Timer(stream->parent()));
67 stream->InitTimer(timer.get()).ThenStartTimer(timer.get());
70 VLOG(1) << "enqueueing executable on stream...";
85 stream->ThenStopTimer(timer.get());
86 TF_RETURN_IF_ERROR(stream->BlockHostUntilDone())
[all...] |
| service_executable_run_options.h | 27 // data, now only a stream cache for GPU backend.
31 std::function<StatusOr<Pool<perftools::gputools::Stream>::SmartPtr>(int)>;
48 perftools::gputools::Stream* stream() const { return run_options_.stream(); } function in class:xla::ServiceExecutableRunOptions
52 // Borrows a stream and returns a smart pointer which returns the stream on
54 StatusOr<Pool<perftools::gputools::Stream>::SmartPtr> BorrowStream(
58 : Status(tensorflow::error::UNIMPLEMENTED, "No stream cache");
|
| /external/tensorflow/tensorflow/core/kernels/ |
| cuda_device_array.h | 79 auto stream = context_->op_device_context()->stream(); local
86 stream->ThenMemcpy(&output_values_base,
90 stream, [tensor_ref]() { tensor_ref.Unref(); });
|
| /external/webrtc/talk/app/webrtc/ |
| mediastreamobserver.h | 37 // Helper class which will listen for changes to a stream and emit the
41 explicit MediaStreamObserver(MediaStreamInterface* stream);
44 const MediaStreamInterface* stream() const { return stream_; } function in class:webrtc::MediaStreamObserver
|
| /external/webrtc/webrtc/base/ |
| proxydetect_unittest.cc | 51 FileStream* stream = FakeFileSystem::OpenFile(name, mode); local
52 return stream;
|
| /external/webrtc/webrtc/call/ |
| call_unittest.cc | 49 AudioSendStream* stream = call->CreateAudioSendStream(config); local
50 EXPECT_NE(stream, nullptr);
51 call->DestroyAudioSendStream(stream);
59 AudioReceiveStream* stream = call->CreateAudioReceiveStream(config); local
60 EXPECT_NE(stream, nullptr);
61 call->DestroyAudioReceiveStream(stream);
72 AudioSendStream* stream = call->CreateAudioSendStream(config); local
73 EXPECT_NE(stream, nullptr);
75 streams.push_back(stream);
77 streams.push_front(stream);
95 AudioReceiveStream* stream = call->CreateAudioReceiveStream(config); local
[all...] |
| /frameworks/av/media/libaaudio/tests/ |
| test_bad_disconnect.cpp | 18 * Handle a DISCONNECT by only opening and starting a new stream
20 * This caused the new stream to use the old disconnected device.
32 AAudioStream *stream,
38 AAudioStream *stream = nullptr; member in struct:AudioEngine
47 AAudioStream *stream,
55 s_AudioEngine.framesRead = AAudioStream_getFramesRead(stream);
71 // Request stream properties.
78 result = AAudioStreamBuilder_openStream(s_AudioEngine.builder, &s_AudioEngine.stream);
85 result = AAudioStream_requestStart(s_AudioEngine.stream);
91 // Check to see what kind of stream we actually got
[all...] |
| /frameworks/av/services/audioflinger/ |
| AudioStreamOut.h | 33 * Managed access to a HAL output stream.
41 sp<StreamOutHalInterface> stream; member in class:android::AudioStreamOut
|
| /frameworks/base/core/jni/android/graphics/ |
| MovieImpl.cpp | 87 SkMemoryStream stream(data, length, false);
88 return Movie::DecodeStream(&stream);
92 std::unique_ptr<SkStreamRewindable> stream = SkStream::MakeFromFile(path); local
93 return stream ? Movie::DecodeStream(stream.get()) : nullptr;
|
| /frameworks/base/services/usb/java/com/android/server/usb/descriptors/ |
| UsbBinaryParser.java | 32 private void dumpDescriptor(ByteStream stream, int length, byte type, StringBuilder builder) {
40 sb.append("0x" + Integer.toHexString(stream.getByte() & 0xFF) + " ");
50 builder.append("0x" + Integer.toHexString(stream.getByte() & 0xFF) + " ");
57 * Walk through descriptor stream and generate an HTML text report of the contents.
64 ByteStream stream = new ByteStream(descriptors); local
65 while (stream.available() > 0) {
66 int length = (int) stream.getByte() & 0x000000FF;
67 byte type = stream.getByte();
68 dumpDescriptor(stream, length, type, builder);
|
| /hardware/interfaces/camera/device/3.2/default/ |
| convert.cpp | 60 void convertFromHidl(const Stream &src, Camera3Stream* dst) {
87 // bi-directional stream to HIDL.
88 ALOGW("%s: Stream type %d is not currently supported!",
102 buffer_handle_t* bufPtr, BufferStatus status, camera3_stream_t* stream, int acquireFence,
104 dst->stream = stream;
118 // indeed one of active stream IDs
119 Camera3Stream* stream = static_cast<Camera3Stream*>( local
122 dst->msg.error.errorStreamId = (stream != nullptr) ? stream->mId : -1
[all...] |
| /libcore/luni/src/main/java/javax/xml/transform/stream/ |
| StreamResult.java | 20 package javax.xml.transform.stream;
40 "http://javax.xml.transform.stream.StreamResult/feature";
49 * Construct a StreamResult from a byte stream. Normally,
50 * a stream should be used rather than a reader, so that
61 * Construct a StreamResult from a character stream. Normally,
62 * a stream should be used rather than a reader, so that
66 * stream, such as when using a StringWriter.
94 * a stream should be used rather than a reader, so that
105 * Get the byte stream that was set with setOutputStream.
107 * @return The byte stream that was set with setOutputStream, or nul
[all...] |
| /libcore/ojluni/src/main/java/java/util/stream/ |
| BaseStream.java | 25 package java.util.stream;
38 * illustrates an aggregate operation using the stream types {@link Stream}
42 * int sum = widgets.stream()
48 * See the class documentation for {@link Stream} and the package documentation
49 * for <a href="package-summary.html">java.util.stream</a> for additional
50 * specification of streams, stream operations, stream pipelines, and
51 * parallelism, which governs the behavior of all stream types.
53 * @param <T> the type of the stream element
[all...] |
| PipelineHelper.java | 25 package java.util.stream;
32 * stream pipelines</a>, capturing all of the information about a stream
33 * pipeline (output shape, intermediate operations, stream flags, parallelism,
37 * A {@code PipelineHelper} describes the initial segment of a stream pipeline,
47 * head shape, stream flags, and size, and use the helper methods
59 * Gets the stream shape for the source of the pipeline segment.
61 * @return the stream shape for the source of the pipeline segment.
66 * Gets the combined stream and operation flags for the output of the described
67 * pipeline. This will incorporate stream flags from the stream source, al
[all...] |
| ReferencePipeline.java | 25 package java.util.stream;
59 extends AbstractPipeline<P_IN, P_OUT, Stream<P_OUT>>
60 implements Stream<P_OUT> {
63 * Constructor for the head of a stream pipeline.
65 * @param source {@code Supplier<Spliterator>} describing the stream source
66 * @param sourceFlags the source flags for the stream source, described in
76 * Constructor for the head of a stream pipeline.
78 * @param source {@code Spliterator} describing the stream source
79 * @param sourceFlags The source flags for the stream source, described in
144 // Stream
[all...] |
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| CountLargeTest.java | 30 package org.openjdk.tests.java.util.stream;
32 import java.util.stream.LongStream;
|
| ForEachOpTest.java | 23 package org.openjdk.tests.java.util.stream;
27 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
28 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
30 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.OpTestCase;
32 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
33 import org.openjdk.testlib.java.util.stream.TestData;
42 import java.util.stream.BaseStream;
43 import java.util.stream.Stream
[all...] |
| IntReduceTest.java | 23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.OpTestCase;
27 import org.openjdk.testlib.java.util.stream.TestData;
29 import java.util.stream.IntStream;
35 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.*;
41 assertEquals(55, Arrays.stream(a).reduce(irPlus).getAsInt());
42 assertEquals(55, Arrays.stream(a).reduce(0, irPlus));
43 assertEquals(10, Arrays.stream(a).reduce(irMax).getAsInt());
44 assertEquals(1, Arrays.stream(a).reduce(irMin).getAsInt())
[all...] |
| IntUniqOpTest.java | 23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
27 import org.openjdk.testlib.java.util.stream.OpTestCase;
28 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.TestData;
32 import java.util.stream.Stream;
33 import java.util.stream.IntStream;
37 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.assertCountSum
[all...] |
| ReduceTest.java | 23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.OpTestCase;
26 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.TestData;
29 import java.util.stream.Stream;
35 import static org.openjdk.testlib.java.util.stream.LambdaTestHelpers.*;
47 assertEquals(55, (int) list.stream().reduce(rPlus).get());
48 assertEquals(55, (int) list.stream().reduce(0, rPlus));
49 assertEquals(10, (int) list.stream().reduce(rMax).get())
[all...] |
| SpliteratorTest.java | 23 package org.openjdk.tests.java.util.stream;
27 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
28 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
30 import org.openjdk.testlib.java.util.stream.SpliteratorTestHelper;
31 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
|
| StreamLinkTest.java | 23 package org.openjdk.tests.java.util.stream;
25 import org.openjdk.testlib.java.util.stream.DoubleStreamTestDataProvider;
26 import org.openjdk.testlib.java.util.stream.IntStreamTestDataProvider;
27 import org.openjdk.testlib.java.util.stream.LambdaTestHelpers;
28 import org.openjdk.testlib.java.util.stream.LongStreamTestDataProvider;
29 import org.openjdk.testlib.java.util.stream.OpTestCase;
30 import org.openjdk.testlib.java.util.stream.StreamTestDataProvider;
31 import org.openjdk.testlib.java.util.stream.TestData;
33 import java.util.stream.BaseStream;
34 import java.util.stream.Collectors
[all...] |
| StreamParSeqTest.java | 23 package org.openjdk.tests.java.util.stream;
28 import java.util.stream.Stream;
37 Stream<Integer> s = Arrays.asList(1, 2, 3, 4).stream().parallel();
|
