/third_party/ltp/testcases/kernel/device-drivers/zram/ |
H A D | zram01.sh | 39 local fs limit size stream=-1 57 stream=$((stream+3)) 62 zram_max_streams="$zram_max_streams $stream"
|
/third_party/node/deps/npm/node_modules/chalk/source/vendor/supports-color/ |
H A D | index.js | 168 export function createSupportsColor(stream, options = {}) { 169 const level = _supportsColor(stream, { 170 streamIsTTY: stream && stream.isTTY,
|
/third_party/node/deps/npm/node_modules/agent-base/dist/ |
H A D | helpers.js | 29 async function toBuffer(stream) { 32 for await (const chunk of stream) { 40 async function json(stream) { 41 const buf = await toBuffer(stream);
|
/third_party/node/deps/npm/node_modules/supports-color/ |
H A D | index.js | 168 export function createSupportsColor(stream, options = {}) { 169 const level = _supportsColor(stream, { 170 streamIsTTY: stream && stream.isTTY,
|
/third_party/ltp/tools/sparse/sparse-src/ |
H A D | token.h | 37 * the input stream. 51 struct stream { struct 67 extern struct stream *input_streams; 211 * Last token in the stream - points to itself. 219 extern int stream_prev(int stream); 220 extern const char *stream_name(int stream);
|
/third_party/node/deps/v8/src/parsing/ |
H A D | parsing.cc | 48 // Create a character stream for the parser. in ParseProgram() 51 std::unique_ptr<Utf16CharacterStream> stream( in ParseProgram() 53 info->set_character_stream(std::move(stream)); in ParseProgram() 77 // Create a character stream for the parser. in ParseFunction() 81 std::unique_ptr<Utf16CharacterStream> stream( in ParseFunction() 84 info->set_character_stream(std::move(stream)); in ParseFunction()
|
/third_party/libphonenumber/metadata/src/main/java/com/google/i18n/phonenumbers/metadata/table/ |
H A D | CsvTableCollector.java | 19 import static java.util.stream.Collectors.joining; 29 import java.util.stream.IntStream; 30 import java.util.stream.Stream; 84 return row.stream().limit(length); in getRow()
|
/third_party/skia/third_party/externals/spirv-tools/utils/vscode/src/lsp/protocol/ |
H A D | protocol.go | 64 func NewClient(ctx context.Context, stream jsonrpc2.Stream, client Client) (context.Context, *jsonrpc2.Conn, Server) { 66 conn := jsonrpc2.NewConn(stream) 71 func NewServer(ctx context.Context, stream jsonrpc2.Stream, server Server) (context.Context, *jsonrpc2.Conn, Client) { 72 conn := jsonrpc2.NewConn(stream)
|
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/protocol/ |
H A D | protocol.go | 64 func NewClient(ctx context.Context, stream jsonrpc2.Stream, client Client) (context.Context, *jsonrpc2.Conn, Server) { 66 conn := jsonrpc2.NewConn(stream) 71 func NewServer(ctx context.Context, stream jsonrpc2.Stream, server Server) (context.Context, *jsonrpc2.Conn, Client) { 72 conn := jsonrpc2.NewConn(stream)
|
/third_party/skia/src/ports/ |
H A D | SkFontMgr_custom_directory.cpp | 54 std::unique_ptr<SkStreamAsset> stream = SkStream::MakeFromFile(filename.c_str()); in load_directory_fonts() local 55 if (!stream) { in load_directory_fonts() 61 if (!scanner.recognizedFont(stream.get(), &numFaces)) { in load_directory_fonts() 70 if (!scanner.scanFont(stream.get(), faceIndex, in load_directory_fonts()
|
/third_party/skia/third_party/externals/freetype/src/base/ |
H A D | ftsnames.c | 65 FT_Stream stream = face->stream; in FT_EXPORT_DEF() local 121 FT_Stream stream = face->stream; in FT_EXPORT_DEF() local
|
/third_party/skia/experimental/skrive/src/reader/ |
H A D | BinaryReader.cpp | 20 explicit BinaryReader(std::unique_ptr<SkStreamAsset> stream) in BinaryReader() argument 21 : fStream(std::move(stream)) {} in BinaryReader() 149 std::unique_ptr<StreamReader> MakeBinaryStreamReader(std::unique_ptr<SkStreamAsset> stream) { in MakeBinaryStreamReader() argument 150 return std::make_unique<BinaryReader>(std::move(stream)); in MakeBinaryStreamReader()
|
/third_party/rust/crates/rust-openssl/openssl/src/ssl/ |
H A D | bio.rs | 18 pub stream: S, 36 pub fn new<S: Read + Write>(stream: S) -> Result<(*mut BIO, BioMethod), ErrorStack> { in new() 40 stream, in new() 67 &state.stream 71 &mut state(bio).stream in get_mut() 94 match catch_unwind(AssertUnwindSafe(|| state.stream.write(buf))) { in state() 116 match catch_unwind(AssertUnwindSafe(|| state.stream.read(buf))) { 153 match catch_unwind(AssertUnwindSafe(|| state.stream.flush())) {
|
/third_party/spirv-tools/utils/vscode/src/lsp/protocol/ |
H A D | protocol.go | 64 func NewClient(ctx context.Context, stream jsonrpc2.Stream, client Client) (context.Context, *jsonrpc2.Conn, Server) { 66 conn := jsonrpc2.NewConn(stream) 71 func NewServer(ctx context.Context, stream jsonrpc2.Stream, server Server) (context.Context, *jsonrpc2.Conn, Client) { 72 conn := jsonrpc2.NewConn(stream)
|
/base/update/updater/services/include/package/ |
H A D | pkg_manager.h | 38 * Input and output stream definition
66 * write stream
212 PkgManagerPtr manager, PkgStreamPtr stream, PkgManager::PkgInfoPtr header)>;
296 * Create a a package stream to output.
298 * @param stream stream for io management
299 * @param fileName file name corresponding to the stream
301 * @param type stream type
304 virtual int32_t CreatePkgStream(StreamPtr &stream, const std::string &fileName, size_t size,
308 * Create a package stream tha 379 NewPkgFile(PkgManager::PkgManagerPtr manager, PkgStreamPtr stream, PkgInfoPtr header) NewPkgFile() argument [all...] |
/base/update/updater/services/diffpatch/patch/ |
H A D | image_patch.cpp | 125 Hpackage::PkgManager::StreamPtr stream = nullptr; in ApplyImagePatch() local 127 if (DecompressData(pkgManager, oldData, stream, true, header.expandedLen) != 0) { in ApplyImagePatch() 146 if (UpdateApplyPatch::ApplyBlockPatch(patchInfo, stream, zipWriter.get()) != 0) { in ApplyImagePatch() 164 Hpackage::PkgManager::StreamPtr &stream, bool memory, size_t expandedLen) const in DecompressData() 180 // 申请内存stream,用于解压老文件 in DecompressData() 181 int32_t ret = pkgManager->CreatePkgStream(stream, info->identity, in DecompressData() 183 if (stream == nullptr) { in DecompressData() 184 PATCH_LOGE("Failed to create stream"); in DecompressData() 188 ret = pkgManager->DecompressBuffer(info.get(), buffer, stream); in DecompressData() 190 pkgManager->ClosePkgStream(stream); in DecompressData() 163 DecompressData(Hpackage::PkgManager::PkgManagerPtr &pkgManager, PkgBuffer buffer, Hpackage::PkgManager::StreamPtr &stream, bool memory, size_t expandedLen) const DecompressData() argument [all...] |
/drivers/peripheral/camera/vdi_base/common/adapter/platform/hdf_driver/src/driver_adapter/src/ |
H A D | camera_control.cpp | 394 isFailed |= !HdfSbufReadUint8(respData, &device.stream.mode); in ReadStreamSbufData() 395 isFailed |= strncpy_s(device.stream.driverName, DRIVER_NAME_NUM, HdfSbufReadString(respData), DRIVER_NAME_NUM); in ReadStreamSbufData() 396 isFailed |= !HdfSbufReadUint8(respData, &device.stream.id); in ReadStreamSbufData() 397 isFailed |= !HdfSbufReadUint32(respData, &device.stream.heightMaxNum); in ReadStreamSbufData() 398 isFailed |= !HdfSbufReadUint32(respData, &device.stream.widthMaxNum); in ReadStreamSbufData() 399 isFailed |= !HdfSbufReadUint32(respData, &device.stream.frameRateMaxNum); in ReadStreamSbufData() 400 isFailed |= !HdfSbufReadUint32(respData, &device.stream.bufferTypeNum); in ReadStreamSbufData() 401 isFailed |= !HdfSbufReadUint8(respData, &device.stream.bufferCount); in ReadStreamSbufData() 402 for (i = 0; i <= device.stream.bufferTypeNum; i++) { in ReadStreamSbufData() 403 isFailed |= !HdfSbufReadUint32(respData, &device.stream in ReadStreamSbufData() [all...] |
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/adaptor/src/ |
H A D | client_trans_udp_stream_interface.cpp | 50 std::unique_ptr<IStream> &stream) in CreateRawStream() 55 stream = IStream::MakeRawStream(buf, bufLen, {}, Communication::SoftBus::Scene::SOFTBUS_SCENE); in CreateRawStream() 68 stream = IStream::MakeRawStream(data.get(), dataLen, {}, Communication::SoftBus::Scene::SOFTBUS_SCENE); in CreateRawStream() 73 std::shared_ptr<StreamAdaptor> &adaptor, std::unique_ptr<IStream> &stream, const StreamData *ext) in ProcessAdaptorAndEncrypt() 76 int32_t ret = CreateRawStream(adaptor, inData->buf, inData->bufLen, stream); in ProcessAdaptorAndEncrypt() 78 TRANS_LOGE(TRANS_STREAM, "failed to create raw stream, ret=%{public}d", ret); in ProcessAdaptorAndEncrypt() 108 stream = IStream::MakeCommonStream(data, outFrameInfo); in ProcessAdaptorAndEncrypt() 133 std::unique_ptr<IStream> stream = nullptr; in SendVtpStream() local 134 int32_t result = ProcessAdaptorAndEncrypt(param, inData, adaptor, stream, ext); in SendVtpStream() 139 if (stream in SendVtpStream() 49 CreateRawStream(const std::shared_ptr<StreamAdaptor> &adaptor, const char *buf, ssize_t bufLen, std::unique_ptr<IStream> &stream) CreateRawStream() argument 72 ProcessAdaptorAndEncrypt(const StreamFrameInfo *param, const StreamData *inData, std::shared_ptr<StreamAdaptor> &adaptor, std::unique_ptr<IStream> &stream, const StreamData *ext) ProcessAdaptorAndEncrypt() argument [all...] |
/third_party/ffmpeg/doc/examples/ |
H A D | transcode_aac.c | 65 const AVStream *stream; in open_input_file() local 79 fprintf(stderr, "Could not open find stream info (error '%s')\n", in open_input_file() 85 /* Make sure that there is only one stream in the input file. */ in open_input_file() 87 fprintf(stderr, "Expected one audio input stream, but found %d\n", in open_input_file() 93 stream = (*input_format_context)->streams[0]; in open_input_file() 95 /* Find a decoder for the audio stream. */ in open_input_file() 96 if (!(input_codec = avcodec_find_decoder(stream->codecpar->codec_id))) { in open_input_file() 110 /* Initialize the stream parameters with demuxer information. */ in open_input_file() 111 error = avcodec_parameters_to_context(avctx, stream->codecpar); in open_input_file() 118 /* Open the decoder for the audio stream t in open_input_file() 153 AVStream *stream = NULL; open_output_file() local [all...] |
/third_party/ltp/utils/sctp/func_tests/ |
H A D | test_timetolive.c | 107 uint32_t stream; in main() local 211 stream = 1; in main() 213 sinfo->sinfo_stream = stream; in main() 259 MSG_EOR, stream, ppid); in main() 285 stream++; in main() 287 sinfo->sinfo_stream = stream; in main() 301 sinfo->sinfo_stream = stream; in main() 314 sinfo->sinfo_stream = stream; in main() 327 sinfo->sinfo_stream = stream; in main() 354 MSG_EOR, stream, ppi in main() [all...] |
/third_party/mesa3d/src/gallium/drivers/r600/sfn/ |
H A D | sfn_instr_export.cpp | 297 int stream): in StreamOutInstr() 303 m_stream(stream) in StreamOutInstr() 423 void MemRingOutInstr::patch_ring(int stream, PRegister index) in patch_ring() argument 427 assert(stream < 4); in patch_ring() 428 m_ring_op = ring_op[stream]; in patch_ring() 497 EmitVertexInstr::EmitVertexInstr(int stream, bool cut): 498 m_stream(stream), 537 int stream; 538 is >> stream; 540 return new EmitVertexInstr(stream, cu 295 StreamOutInstr(const RegisterVec4& value, int num_components, int array_base, int comp_mask, int out_buffer, int stream) StreamOutInstr() argument [all...] |
/third_party/rust/crates/log/src/kv/ |
H A D | source.rs | 469 fn stream(&self, stream: &mut value::Stream) -> value::Result { in stream() functions 476 .map_err(|_| Error::msg("failed to stream map key"))?; in stream() 479 .map_err(|_| Error::msg("failed to stream map value"))?; in stream() 484 stream in stream() 488 self.visit(&mut StreamVisitor(stream)) in stream() 491 stream in stream() 501 fn stream(&self, stream: &mut value::Stream) -> value::Result { in stream() functions 508 .map_err(|_| Error::msg("failed to stream se in stream() [all...] |
/third_party/skia/third_party/externals/freetype/src/pfr/ |
H A D | pfrobjs.c | 68 pfr_face_init( FT_Stream stream, in FT_LOCAL_DEF() 84 error = pfr_header_load( &face->header, stream ); in FT_LOCAL_DEF() 104 error = pfr_log_font_count( stream, in FT_LOCAL_DEF() 126 stream, in FT_LOCAL_DEF() 134 error = pfr_phy_font_load( &face->phy_font, stream, in FT_LOCAL_DEF() 217 FT_Memory memory = pfrface->stream->memory; in FT_LOCAL_DEF() 365 error = pfr_glyph_load( &slot->glyph, face->root.stream, in FT_LOCAL_DEF() 507 FT_Stream stream = pfrface->stream; in FT_LOCAL_DEF() local 528 FT_Byte* base = stream in FT_LOCAL_DEF() [all...] |
/drivers/peripheral/distributed_camera/hdi_service/src/dstream_operator/ |
H A D | dstream_operator.cpp | 36 DHLOGE("DStreamOperator::IsStreamsSupported, input stream infos is invalid."); in IsStreamsSupported() 69 DHLOGE("DStreamOperator::CreateStreams, input stream Infos is invalid."); in CreateStreams() 73 DHLOGI("DStreamOperator::CreateStreams, input stream info size=%{public}zu.", streamInfos.size()); in CreateStreams() 89 DHLOGE("Init distributed camera stream failed."); in CreateStreams() 123 DHLOGI("DStreamOperator::ReleaseStreams, input stream id list size=%{public}zu.", streamIds.size()); in ReleaseStreams() 131 auto stream = FindHalStreamById(id); in ReleaseStreams() local 132 if (stream != nullptr) { in ReleaseStreams() 133 DCamRetCode ret = stream->ReleaseDCameraBufferQueue(); in ReleaseStreams() 135 DHLOGE("Release distributed camera buffer queue for stream %{public}d failed.", id); in ReleaseStreams() 138 DHLOGI("Release distributed camera buffer queue for stream in ReleaseStreams() 257 auto stream = FindHalStreamById(streamInfo.streamId_); HalStreamCommit() local 302 auto stream = FindHalStreamById(streamId); AttachBufferQueue() local 352 auto stream = FindHalStreamById(streamId); DetachBufferQueue() local 406 auto stream = FindHalStreamById(id); DoCapture() local 480 auto stream = FindHalStreamById(id); CancelCapture() local 814 auto stream = FindHalStreamById(streamId); AcquireBuffer() local 849 auto stream = FindHalStreamById(streamId); ShutterBuffer() local [all...] |
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/muxer/ |
H A D | ffmpeg_muxer_plugin.cpp | 373 Status FFmpegMuxerPlugin::SetCodecParameterOfTrack(AVStream *stream, const std::shared_ptr<Meta> &trackDesc) in SetCodecParameterOfTrack() argument 375 AVCodecParameters *par = stream->codecpar; in SetCodecParameterOfTrack() 381 videoTracksInfo_[stream->index] = sampleInfo; in SetCodecParameterOfTrack() 386 videoTracksInfo_[stream->index].extraData_.reserve(codecConfig.size()); in SetCodecParameterOfTrack() 387 videoTracksInfo_[stream->index].extraData_.assign(codecConfig.begin(), codecConfig.end()); in SetCodecParameterOfTrack() 388 return SetNalSizeLen(stream, codecConfig); in SetCodecParameterOfTrack() 390 return SetCodecParameterExtra(stream, codecConfig.data(), codecConfig.size()); in SetCodecParameterOfTrack() 400 return SetCodecParameterExtra(stream, codecConfig.data(), codecConfig.size()); in SetCodecParameterOfTrack() 409 Status FFmpegMuxerPlugin::SetCodecParameterExtra(AVStream *stream, const uint8_t *extraData, int32_t extraDataSize) in SetCodecParameterExtra() argument 413 AVCodecParameters *par = stream in SetCodecParameterExtra() 423 SetCodecParameterColor(AVStream* stream, const std::shared_ptr<Meta> &trackDesc) SetCodecParameterColor() argument 459 SetCodecParameterTimedMeta(AVStream* stream, const std::shared_ptr<Meta> &trackDesc) SetCodecParameterTimedMeta() argument 487 SetCodecParameterColorByParser(AVStream* stream) SetCodecParameterColorByParser() argument 516 SetCodecParameterCuva(AVStream* stream, const std::shared_ptr<Meta> &trackDesc) SetCodecParameterCuva() argument 528 SetCodecParameterCuvaByParser(AVStream *stream) SetCodecParameterCuvaByParser() argument 539 SetDisplayMatrix(AVStream* stream) SetDisplayMatrix() argument 972 SetNalSizeLen(AVStream *stream, const std::vector<uint8_t> &codecConfig) SetNalSizeLen() argument [all...] |