| /external/libbrillo/brillo/http/ |
| http_form_data_unittest.cc | 22 StreamPtr stream = InputStreamSet::Create(std::move(streams), nullptr); local
24 std::vector<uint8_t> data(stream->GetSize());
25 EXPECT_TRUE(stream->ReadAllBlocking(data.data(), data.size(), nullptr));
50 StreamPtr stream = FileStream::Open(file_name, Stream::AccessMode::READ, local
53 ASSERT_NE(nullptr, stream);
55 std::move(stream),
115 "Content-Type: application/octet-stream\r\n"
173 StreamPtr stream = form_data.ExtractDataStream(); local
174 std::vector<uint8_t> data(stream->GetSize())
[all...] |
| /external/nanopb-c/tests/decode_unittests/ |
| decode_unittests.c | 11 bool stream_callback(pb_istream_t *stream, uint8_t *buf, size_t count)
13 if (stream->state != NULL)
21 /* Verifies that the stream passed to callback matches the byte array pointed to by arg. */
22 bool callback_check(pb_istream_t *stream, const pb_field_t *field, void **arg)
30 if (!pb_read(stream, &byte, 1))
47 pb_istream_t stream = pb_istream_from_buffer(buffer1, sizeof(buffer1)); local
50 TEST(pb_read(&stream, buffer2, 6))
52 TEST(stream.bytes_left == sizeof(buffer1) - 6)
53 TEST(pb_read(&stream, buffer2 + 6, stream.bytes_left)
61 pb_istream_t stream = {&stream_callback, NULL, 20}; local
[all...] |
| /external/puffin/src/ |
| stream_unittest.cc | 25 // |data| is the content of stream as a buffer.
26 void TestRead(StreamInterface* stream, const Buffer& data) {
30 ASSERT_TRUE(stream->Seek(0));
31 ASSERT_TRUE(stream->Read(buf.data(), buf.size()));
39 ASSERT_TRUE(stream->GetSize(&size));
40 ASSERT_TRUE(stream->Seek(size));
41 ASSERT_TRUE(stream->Read(tmp.data(), 0));
42 ASSERT_FALSE(stream->Read(tmp.data(), 1));
43 ASSERT_FALSE(stream->Read(tmp.data(), 2));
44 ASSERT_FALSE(stream->Read(tmp.data(), 3))
182 auto stream = FileStream::Open(filepath, true, true); local
[all...] |
| /external/skia/src/images/ |
| SkWebpEncoder.cpp | 111 SkWStream* const stream = (SkWStream*)picture->custom_ptr; local
112 return stream->write(data, data_size) ? 1 : 0;
115 bool SkWebpEncoder::Encode(SkWStream* stream, const SkPixmap& pixmap, const Options& opts) {
166 // If there is no need to embed an ICC profile, we write directly to the input stream.
171 pic.custom_ptr = icc ? (void*)&tmp : (void*)stream;
220 stream->write(assembled.bytes, assembled.size);
|
| /external/skia/src/ports/ |
| SkFontMgr_custom_embedded.cpp | 51 auto stream = skstd::make_unique<SkMemoryStream>(data, size, false); local
54 if (!scanner.recognizedFont(stream.get(), &numFaces)) {
63 if (!scanner.scanFont(stream.get(), faceIndex,
75 auto data = skstd::make_unique<SkFontData>(std::move(stream), faceIndex, nullptr, 0);
|
| /external/skia/tools/lua/ |
| lua_pictures.cpp | 43 std::unique_ptr<SkStream> stream = SkStream::MakeFromFile(path); local
44 if (stream) {
45 return SkPicture::MakeFromStream(stream.get());
|
| /external/skqp/src/images/ |
| SkWebpEncoder.cpp | 111 SkWStream* const stream = (SkWStream*)picture->custom_ptr; local
112 return stream->write(data, data_size) ? 1 : 0;
115 bool SkWebpEncoder::Encode(SkWStream* stream, const SkPixmap& pixmap, const Options& opts) {
166 // If there is no need to embed an ICC profile, we write directly to the input stream.
171 pic.custom_ptr = icc ? (void*)&tmp : (void*)stream;
220 stream->write(assembled.bytes, assembled.size);
|
| /external/skqp/src/ports/ |
| SkFontMgr_custom_embedded.cpp | 51 auto stream = skstd::make_unique<SkMemoryStream>(data, size, false); local
54 if (!scanner.recognizedFont(stream.get(), &numFaces)) {
63 if (!scanner.scanFont(stream.get(), faceIndex,
75 auto data = skstd::make_unique<SkFontData>(std::move(stream), faceIndex, nullptr, 0);
|
| /external/skqp/tools/lua/ |
| lua_pictures.cpp | 43 std::unique_ptr<SkStream> stream = SkStream::MakeFromFile(path); local
44 if (stream) {
45 return SkPicture::MakeFromStream(stream.get());
|
| /external/squashfs-tools/squashfs-tools/ |
| gzip_wrapper.h | 71 z_stream stream; member in struct:gzip_stream
|
| /external/swiftshader/src/OpenGL/compiler/ |
| intermOut.cpp | 49 TStringStream stream; local
52 stream << getQualifierString() << " " << getPrecisionString() << " ";
54 stream << "array of ";
56 stream << static_cast<int>(primarySize) << "X" << static_cast<int>(secondarySize) << " matrix of ";
58 stream << static_cast<int>(primarySize) << "-component vector of ";
60 stream << getBasicString();
61 return stream.str();
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| gpu_transfer_manager.cc | 103 se::Stream* stream = infeed_manager->GetStream(executor); local
105 // TODO(b/30467474): Since this stream is shared across different
106 // infeed requests, blocking on the stream might be
109 Status block_status = stream->BlockHostUntilDone();
114 return InternalError("Failed to complete data transfer on stream %p: %s",
115 stream, block_status.error_message().c_str());
136 se::Stream* stream = infeed_manager->GetStream(executor); local
137 if (stream == nullptr)
[all...] |
| /external/tensorflow/tensorflow/compiler/xla/service/interpreter/ |
| executable.cc | 54 se::Stream* stream = run_options->stream(); local
55 se::StreamExecutor* executor = stream->parent();
|
| /external/tensorflow/tensorflow/contrib/image/kernels/ |
| adjust_hsv_in_yiq_op_gpu.cu.cc | 50 auto* cu_stream = ctx->eigen_device<GPUDevice>().stream();
51 OP_REQUIRES(ctx, cu_stream, errors::Internal("No GPU stream available."));
69 auto* stream = ctx->op_device_context()->stream(); local
70 OP_REQUIRES(ctx, stream, errors::Internal("No GPU stream available."));
73 stream
|
| /external/tensorflow/tensorflow/contrib/tensorrt/kernels/ |
| trt_engine_op.cc | 123 const cudaStream_t* stream = CHECK_NOTNULL( local
125 ->stream()
129 // execution handled by TF since we are getting stream from TF.
131 trt_execution_context_ptr_->enqueue(num_batch, &buffers[0], *stream, nullptr);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_util.cc | 100 GrpcByteBufferSource stream; local
101 if (!stream.Init(src)) return false;
102 return dst->ParseFromZeroCopyStream(&stream);
|
| /external/tensorflow/tensorflow/core/kernels/ |
| bincount_op_gpu.cu.cc | 58 const cudaStream_t& stream = GetCudaStream(context); local
71 /* stream */ stream);
94 /* stream */ stream);
|
| /external/vixl/examples/aarch32/ |
| custom-aarch32-disasm.cc | 71 explicit CustomDisassembler(CustomStream* stream)
72 : PrintDisassembler(stream) {}
102 NamedLabel(CustomStream* stream, const char* name)
103 : stream_(stream), name_(name) {}
113 CustomStream stream; local
116 NamedLabel loop(&stream, "loop");
117 NamedLabel end(&stream, "end");
131 CustomDisassembler custom_disassembler(&stream);
|
| /external/webrtc/talk/media/base/ |
| rtpdump_unittest.cc | 79 rtc::MemoryStream stream; local
80 RtpDumpWriter writer(&stream);
83 // Write a RTP packet to the stream, which is a valid RTP dump. Next, we will
86 stream.Rewind();
87 reader.reset(new RtpDumpReader(&stream));
91 stream.Rewind();
94 stream.WriteAll(new_line, strlen(new_line), NULL, NULL));
95 stream.Rewind();
96 reader.reset(new RtpDumpReader(&stream));
100 stream.Rewind()
120 rtc::MemoryStream stream; local
158 rtc::MemoryStream stream; local
180 rtc::MemoryStream stream; local
209 rtc::MemoryStream stream; local
235 rtc::MemoryStream stream; local
246 rtc::MemoryStream stream; local
257 rtc::MemoryStream stream; local
279 rtc::MemoryStream stream; local
[all...] |
| /external/webrtc/webrtc/base/ |
| optionsfile.cc | 16 #include "webrtc/base/stream.h"
29 FileStream stream; local
31 if (!stream.Open(path_, "r", &err)) {
41 res = stream.ReadLine(&line);
66 FileStream stream; local
68 if (!stream.Open(path_, "w", &err)) {
78 res = stream.WriteAll(i->first.c_str(), i->first.length(), &written,
83 res = stream.WriteAll("=", 1, &written, &error);
87 res = stream.WriteAll(i->second.c_str(), i->second.length(), &written,
92 res = stream.WriteAll("\n", 1, &written, &error)
[all...] |
| /external/webrtc/webrtc/system_wrappers/include/ |
| logging.h | 32 // LOG(sev) logs the given stream at severity "sev", which must be a
68 std::ostream& stream() { return print_stream_; } function in class:webrtc::LogMessage
84 // conditional log stream was stolen from google3/base/logging.h.
113 webrtc::LogMessage(__FILE__, __LINE__, webrtc::sev).stream()
119 webrtc::LogMessage(__FILE__, __LINE__, sev).stream()
|
| /external/webrtc/webrtc/test/testsupport/ |
| perf_test.cc | 34 // TODO(ajm): Use of a stream here may violate the style guide (depending on
37 std::ostringstream stream; local
39 stream << "*";
41 stream << "RESULT " << measurement << modifier << ": " << trace << "= "
43 return stream.str();
|
| /frameworks/av/media/libaaudio/src/binding/ |
| IAAudioService.cpp | 69 aaudio_handle_t stream; variable
70 err = reply.readInt32(&stream);
74 } else if (stream < 0) {
75 ALOGE("BpAAudioService::client OPEN_STREAM passed stream %d", stream);
76 return stream;
81 closeStream(stream); variable
84 return stream;
|
| /frameworks/av/media/libstagefright/codecs/m4v_h263/dec/src/ |
| packet_util.cpp | 33 BitstreamDecVideo *stream = video->bitstream; local
47 status = PV_BitstreamShowBitsByteAlign(stream, resync_marker_length, &tmpvar32);
51 // DecNextStartCode(stream);
52 PV_BitstreamByteAlign(stream);
53 BitstreamReadBits32(stream, resync_marker_length);
55 *next_MB = (int) BitstreamReadBits16(stream, nbits);
65 quantizer = (int16) BitstreamReadBits16(stream, currVol->quantPrecision);
72 if (BitstreamRead1Bits(stream))
80 tmpvar16 = BitstreamRead1Bits(stream);
85 BitstreamRead1Bits(stream);
148 BitstreamDecVideo *stream = video->bitstream; local
199 BitstreamDecVideo *stream = video->bitstream; local
[all...] |
| /frameworks/base/core/java/android/app/slice/ |
| SliceQuery.java | 25 import java.util.stream.Collectors;
26 import java.util.stream.Stream;
27 import java.util.stream.StreamSupport;
77 return stream(container).filter(s -> (s == item)).findAny().isPresent();
99 return stream(s).filter(item -> compareTypes(item, type)
145 return stream(s).filter(item -> compareTypes(item, type)
152 public static Stream<SliceItem> stream(SliceItem slice) { method in class:SliceQuery
171 return StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, 0), false)
[all...] |
