Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 48) sorted by relevance

12

/test/xts/acts/commonlibrary/thirdparty/musl/entry/src/main/cpp/
Dstdioextndk.cpp219 FILE *stream = fopen(path, mode); in FEof_unlocked() local
220 NAPI_ASSERT(env, stream != nullptr, "FEof_unlocked fopen Error"); in FEof_unlocked()
221 backParam = feof_unlocked(stream); in FEof_unlocked()
222 fclose(stream); in FEof_unlocked()
233 FILE *stream = fopen(path, mode); in FError_unlocked() local
234 NAPI_ASSERT(env, stream != nullptr, "FError_unlocked fopen Error"); in FError_unlocked()
236 if (stream != nullptr) { in FError_unlocked()
237 fileDescribe = ferror_unlocked(stream); in FError_unlocked()
240 fclose(stream); in FError_unlocked()
249 FILE *stream = fopen(path, mode); in FFlush_unlocked() local
[all …]
/test/xts/acts/arkui/ace_ets_web_dev_four/entry/src/main/ets/MainAbility/pages/
DWebHttpBodyStream.ets86 let stream = request.getHttpBodyStream();
87 if (stream) {
88 stream.initialize().then(() => {
89 if (!stream) {
92 … console.log("[schemeHandler] onRequestStart postDataStream size:" + stream.getSize());
93 … console.log("[schemeHandler] onRequestStart postDataStream position:" + stream.getPosition());
94 … console.log("[schemeHandler] onRequestStart postDataStream isChunked:" + stream.isChunked());
95 … console.log("[schemeHandler] onRequestStart postDataStream isEof:" + stream.isEof());
96 … console.log("[schemeHandler] onRequestStart postDataStream isInMemory:" + stream.isInMemory());
97 …if(stream.getSize() == 66 && stream.getPosition() == 0 && stream.isChunked() == false && stream.is…
[all …]
/test/xts/tools/lite/reliability/
Dutils.py27 def get_decode(stream): argument
28 if isinstance(stream, str):
29 return stream
31 if not isinstance(stream, bytes):
32 return str(stream)
35 ret = stream.decode("utf-8", errors="ignore")
37 ret = str(stream)
/test/testfwk/xdevice/plugins/devicetest/log/
Dlogger.py236 def __init__(self, stream=None): argument
243 self.stream = stream if stream is not None else sys.stderr
249 if self.stream:
250 if hasattr(self.stream, "flush"):
251 self.stream.flush()
260 self.stream = self.stderr
262 self.stream = self.stdout
264 self.stream.write(msg)
265 self.stream.write(self.terminator)
/test/xts/acts/commonlibrary/ets_utils/stream_lib_standard/src/main/ets/test/
DStreamTest.test.ets16 import stream from '@ohos.util.stream';
31 * @tc.desc: Create a writable stream.
37 let writableStream = new stream.Writable();
53 let writableStream = new stream.Writable();
64 * @tc.desc: The state of the writable attribute of a writable stream.
70 let writableStream = new stream.Writable();
85 * @tc.desc: Write data to stream.
91 let writableStream = new stream.Writable();
111 let writableStream = new stream.Writable();
129 let writable = new stream.Writable();
[all …]
/test/xts/acts/storage/storagefileiojstest/src/main/js/test/module_fileio/members/
DcreateStream.test.js64 fileio.createStream(fpath, 'r+', function (err, stream) { argument
65 expect(stream.closeSync() == null).assertTrue();
89 fileio.createStream(fpath, 'r+', function (err, stream) { argument
90 expect(stream.writeSync(FILE_CONTENT) == FILE_CONTENT.length).assertTrue();
91 expect(stream.closeSync() == null).assertTrue();
/test/testfwk/developer_test/src/core/
Dutils.py183 def get_decode(stream): argument
184 if not isinstance(stream, str) and not isinstance(stream, bytes):
185 ret = str(stream)
188 ret = stream.decode("utf-8", errors="ignore")
190 ret = str(stream)
/test/xts/hats/hdf/camera/cameraHdi/buffer_manager/
Dbuffer_manager_utest.cpp100 auto stream = std::make_shared<BufferManagerTest::Stream>(); variable
101 stream->Init(producer);
102 stream->StartStream();
105 pipeline.AddStream(stream);
107 std::thread enqueueThread([&stream, &running] { in __anonc85942540402()
109 stream->EnqueueBufferNonBlock(); in __anonc85942540402()
118 stream->StopStream();
353 auto stream = std::make_shared<Stream>(); variable
354 stream->Init(producer);
355 stream->StartStream();
[all …]
Dbuffer_manager_utest.h159 bool AddStream(const std::shared_ptr<Stream>& stream);
178 std::shared_ptr<Stream> stream = nullptr; member
/test/xts/acts/multimedia/audio/audio_js_standard/OhAudioNdk/entry/src/ohosTest/ets/test/
DOHCapturer.test.ets286 * @tc.desc ：Create an audio stream constructor of input or output type.
302 * @tc.desc ：Create an audio stream constructor of input or output type.
318 * @tc.desc ：Create an output audio stream instance.
334 * @tc.desc ：Create an input audio stream instance.
350 * @tc.desc ：Set the callback for the input audio stream.
366 * @tc.desc ：Set the channel count property of the audio stream.
382 * @tc.desc ：Set the channel count property of the audio stream.
398 * @tc.desc ：Set the channel count property of the audio stream.
414 * @tc.desc ：Set the channel count property of the audio stream.
430 * @tc.desc ：Set the channel count property of the audio stream.
[all …]
DOHCapturerNew.test.ets333 * @tc.desc ：Query the current output audio stream status.
349 * @tc.desc ：Query the current output audio stream sampling format.
365 * @tc.desc ：Query the current output audio stream sampling rate.
381 * @tc.desc ：Query the current output audio stream ID.
429 * @tc.desc ：Query the current output audio stream encoding type.
477 * @tc.desc ：Query the current output audio stream delay mode.
493 * @tc.desc ：Query the current output audio stream workspace type.
527 * @tc.desc ：Stop outputting audio stream.
546 * @tc.desc ：Release the output audio stream.
567 * @tc.desc ：Stop outputting audio stream.
[all …]
DOhRenderer.test.ets333 * @tc.desc ：Query the current output audio stream status.
349 * @tc.desc ：Query the current output audio stream sampling format.
365 * @tc.desc ：Query the current output audio stream sampling rate.
381 * @tc.desc ：Query the current output audio stream ID.
429 * @tc.desc ：Query the current output audio stream encoding type.
477 * @tc.desc ：Query the current output audio stream delay mode.
493 * @tc.desc ：Query the current output audio stream workspace type.
527 * @tc.desc ：Stop outputting audio stream.
546 * @tc.desc ：Release the output audio stream.
567 * @tc.desc ：Stop outputting audio stream.
[all …]
/test/xts/acts/kernel_lite/mem_posix/src/
DMemApiTest.cpp566 FILE *stream = open_memstream(&buf, &len); variable
567 ASSERT_TRUE(stream != nullptr) << "stream == nullptr";
570 fprintf(stream, wBuf);
571 fflush(stream);
583 EXPECT_TRUE(ftello(stream) == len) << "ftello() != len";
584 EXPECT_TRUE(fseeko(stream, 0, SEEK_SET) == 0);
591 fprintf(stream, largeBuf);
592 fflush(stream);
602 EXPECT_TRUE(fclose(stream) == 0) << "fclose() != 0";
/test/xts/acts/multimedia/audio/audio_js_standard/AudioRendererEnhance/src/main/ets/test/
DGetMaxAndMinStreamVolume.test.ets514 console.error('${TagFrmwkRender} Get max stream volume Fail: ${err}');
518 console.info('${TagFrmwkRender} Get max stream volume Success! ${maxVolume}');
537 console.error('${TagFrmwkRender} Get max stream volume Fail: ${err}');
541 console.info('${TagFrmwkRender} Get max stream volume Success! ${maxVolume}');
587 console.error('${TagFrmwkRender} Get max stream volume Fail: ${err}');
591 console.info('${TagFrmwkRender} Get max stream volume Success! ${maxVolume}');
625 console.error('${TagFrmwkRender} Get max stream volume Fail: ${err}');
629 console.info(`${TagFrmwkRender} Get max stream volume Success! maxVolume: ${maxVolume}`);
655 console.error('${TagFrmwkRender} Get min stream volume Fail: ${err}');
659 console.info(`${TagFrmwkRender} Get min stream volume Success! minVolume: ${minVolume}`);
[all …]
/test/xts/acts/multimedia/media/media_js_standard/avPlayer/entry/src/main/ets/test/
DAVPlayerDataSrcNoSeekReliabilityTest.test.js27 let stream = null;
37 stream = null;
131 num = stream.readSync(buf, {offset: 0, length: length, position: pos});
/test/xts/acts/security/certificate_framework/js_api_test_oh50/src/main/ets/test/utils/common/
DcommonFunction.ets26 //input stream convert to string
35 //string convert to input stream
48 //input stream convert to hex format
/test/xts/acts/security/certificate_framework/js_api_test_oh41/src/main/ets/test/utils/common/
DcommonFunction.ets26 //input stream convert to string
35 //string convert to input stream
48 //input stream convert to hex format
/test/xts/acts/arkui/ace_ets_web_scheme_handler_two_napis/entry/src/main/cpp/
Drawfile_request.h39 ArkWeb_HttpBodyStream *stream() { return stream_; } in stream() function
/test/xts/acts/arkui/ace_ets_web_scheme_handler_three_napis/entry/src/main/cpp/
Drawfile_request.h40 ArkWeb_HttpBodyStream *stream() { return stream_; } in stream() function
/test/xts/hats/powermgr/battery/hdi_battery_additional/common/
Dhdi_battery_test.cpp69 std::ofstream stream(path.c_str()); in CreateFile() local
70 if (!stream.is_open()) { in CreateFile()
74 stream << content.c_str() << std::endl; in CreateFile()
75 stream.close(); in CreateFile()
/test/xts/hats/powermgr/battery/hdi_battery/common/
Dhdi_battery_test.cpp80 std::ofstream stream(path.c_str()); in CreateFile() local
81 if (!stream.is_open()) { in CreateFile()
85 stream << content.c_str() << std::endl; in CreateFile()
86 stream.close(); in CreateFile()
/test/testfwk/xdevice/src/xdevice/_core/
Dutils.py108 def get_decode(stream): argument
109 if not isinstance(stream, str) and not isinstance(stream, bytes):
110 ret = str(stream)
113 ret = stream.decode("utf-8", errors="ignore")
115 ret = str(stream)
/test/xts/acts/request/newRequestNormalTest/entry/src/main/ets/test/
DrequestUpload.test.ets82 mimetype: "application/octet-stream"
131 mimetype: "application/octet-stream"
/test/xts/acts/arkui/ace_ets_web_scheme_handler_napis/entry/src/main/cpp/
Dtest_request.h43 ArkWeb_HttpBodyStream *stream() { return stream_; } in stream() function
/test/xts/acts/kernel_lite/io_posix/src/
DIoTestStdio.cpp179 int FormatVfprintf(FILE *stream, char *format, ...) in FormatVfprintf() argument
183 int ret = vfprintf(stream, format, args); in FormatVfprintf()
188 int FormatVfscanf(FILE *stream, const char *format, ...) in FormatVfscanf() argument
192 int ret = vfscanf(stream, format, args); in FormatVfscanf()

12