Home
last modified time | relevance | path

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

12

/developtools/profiler/host/smartperf/ide/src/hdc/hdcclient/
DHdcClient.ts37 private stream: HdcStream | undefined | null; property in HdcClient
116 this.stream = hdcStream;
125 this.stream = null;
126 return this.stream == null;
138 if (this.stream && data.getChannelId() == this.cmdStream) {
139 this.stream.putMessageInQueue(data);
142 this.stream?.putMessageInQueue(data);
/developtools/smartperf_host/ide/src/hdc/hdcclient/
DHdcClient.ts37 private stream: HdcStream | undefined | null; property in HdcClient
116 this.stream = hdcStream;
125 this.stream = null;
126 return this.stream == null;
138 if (this.stream && data.getChannelId() == this.cmdStream) {
139 this.stream.putMessageInQueue(data);
142 this.stream?.putMessageInQueue(data);
/developtools/profiler/host/smartperf/client/client_command/
Dcontrol_call_cmd.cpp36 std::ostringstream stream; in GetResult() local
42 stream << time; in GetResult()
43 result = "time:" + stream.str(); in GetResult()
46 stream << time; in GetResult()
47 result = "time:" + stream.str(); in GetResult()
50 stream << time; in GetResult()
51 result = "time:" + stream.str(); in GetResult()
54 stream << time; in GetResult()
55 result = "time:" + stream.str(); in GetResult()
58 stream << time; in GetResult()
[all …]
/developtools/hdc/src/common/
Dusb.h33 virtual int UsbToHdcProtocol(uv_stream_t *stream, uint8_t *appendData, int dataSize) in UsbToHdcProtocol() argument
37 int SendToHdcStream(HSession hSession, uv_stream_t *stream, uint8_t *appendData, int dataSize);
47 static void ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
Dusb.cpp29 void HdcUSBBase::ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadUSB() argument
32 HSession hSession = (HSession)stream->data; in ReadUSB()
175 int HdcUSBBase::SendToHdcStream(HSession hSession, uv_stream_t *stream, uint8_t *appendData, int da… in SendToHdcStream() argument
190 if ((childRet = UsbToHdcProtocol(stream, appendData, dataSize)) < 0) { in SendToHdcStream()
Duart.cpp55 int ExternInterface::UvRead(uv_stream_t *stream, uv_alloc_cb allocCallBack, uv_read_cb readCallBack) in UvRead() argument
57 return uv_read_start(stream, allocCallBack, readCallBack); in UvRead()
393 int HdcUARTBase::UartToHdcProtocol(uv_stream_t *stream, uint8_t *data, int dataSize) in UartToHdcProtocol() argument
395 HSession hSession = (HSession)stream->data; in UartToHdcProtocol()
944 void HdcUARTBase::ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadDataFromUARTStream() argument
946 HSession hSession = (HSession)stream->data; in ReadDataFromUARTStream()
/developtools/hdc/test/unittest/common/
DHdcJdwpTest.cpp79 uv_stream_t *stream = (uv_stream_t *)&pipe; variable
85 mJdwpTest->ReadStream(stream, (HdcJdwp::JS_PKG_MIN_SIZE - 1), nullptr);
88 mJdwpTest->ReadStream(stream, (HdcJdwp::JS_PKG_MX_SIZE + 1), nullptr);
104 mJdwpTest->ReadStream(stream, pkgSize, nullptr);
Duart_test.cpp485 uv_stream_t stream; variable
491 .WillRepeatedly([&](uv_stream_t *stream, uint8_t *data, int dataSize) { in __anon1f4edf980702() argument
492 return mockUARTBase.HdcUARTBase::UartToHdcProtocol(stream, data, dataSize); in __anon1f4edf980702()
495 stream.data = &session;
499 EXPECT_EQ(mockUARTBase.UartToHdcProtocol(&stream, data.data(), data.size()),
508 EXPECT_EQ(mockUARTBase.UartToHdcProtocol(&stream, data.data(), data.size()), ERR_IO_FAIL);
512 EXPECT_EQ(mockUARTBase.UartToHdcProtocol(&stream, data.data(), data.size()), ERR_IO_FAIL);
/developtools/hiperf/test/unittest/common/native/
Dcpu_usage_test.cpp129 stringstream stream; in GetCpuTotalUsage() local
130 stream << buff; in GetCpuTotalUsage()
131 stream >> name >> userTime >> niceTime >> systemTime >> idleTime; in GetCpuTotalUsage()
133 stream.clear(); in GetCpuTotalUsage()
155 stringstream stream; in GetCpuProcUsage() local
156 stream << lineBuff; in GetCpuProcUsage()
157 stream >> tmpPid; in GetCpuProcUsage()
159 stream.clear(); in GetCpuProcUsage()
160 stream << q; in GetCpuProcUsage()
161 stream >> utime >> stime >> cutime >> cstime; in GetCpuProcUsage()
/developtools/hdc/test/fuzztest/jdwpreadstream_fuzzer/
DJdwpReadStream_fuzzer.cpp48 uv_stream_t *stream = (uv_stream_t *)&pipe; in FuzzJdwpReadStream() local
50 jdwp->ReadStream(stream, (ssize_t)size, &rbf); in FuzzJdwpReadStream()
/developtools/packing_tool/adapter/ohos/
DUncompress.java37 import java.util.stream.Collectors;
212 InputStream stream = null; in uncompressHapAndHspFromAppPath() local
218 stream = appFile.getInputStream(entry); in uncompressHapAndHspFromAppPath()
222 UncompressResult hapInfo = uncompressHapByStream("", stream, hapName); in uncompressHapAndHspFromAppPath()
234 Utility.closeStream(stream); in uncompressHapAndHspFromAppPath()
243 InputStream stream = null; in uncompressAllAppByPath() local
249 stream = appFile.getInputStream(entry); in uncompressAllAppByPath()
251 … String packInfo = new BufferedReader(new InputStreamReader(stream, StandardCharsets.UTF_8)) in uncompressAllAppByPath()
259 UncompressResult hapInfo = uncompressHapByStream("", stream, entry.getName()); in uncompressAllAppByPath()
273 Utility.closeStream(stream); in uncompressAllAppByPath()
[all …]
DHapVerify.java27 import java.util.stream.Collectors;
28 import java.util.stream.Stream;
317 long noDuplicatedCount = hapVerifyInfo.getAbilityNames().stream().distinct().count(); in checkAbilityNameIsValid()
719 flatMap(Collection::stream).distinct().collect(Collectors.toList()); in checkApiVersionCovered()
726 include = include.stream().distinct().collect(Collectors.toList()); in checkApiVersionCovered()
729 exclude = exclude.stream().distinct().collect(Collectors.toList()); in checkApiVersionCovered()
767 flatMap(Collection::stream).distinct().collect(Collectors.toList()); in checkScreenShapeCovered()
774 include = include.stream().distinct().collect(Collectors.toList()); in checkScreenShapeCovered()
777 exclude = exclude.stream().distinct().collect(Collectors.toList()); in checkScreenShapeCovered()
814 flatMap(Collection::stream).distinct().collect(Collectors.toList()); in checkScreenWindowCovered()
[all …]
DUtility.java661 static void closeStream(Closeable stream) { in closeStream() argument
662 if (stream != null) { in closeStream()
664 stream.close(); in closeStream()
/developtools/hdc/src/daemon/
Ddaemon_usb.h56 int UsbToHdcProtocol(uv_stream_t *stream, uint8_t *appendData, int dataSize) override;
58 int UsbToStream(uv_stream_t *stream, const uint8_t *buf, const int size);
Ddaemon_usb.cpp399 int HdcDaemonUSB::UsbToStream(uv_stream_t *stream, const uint8_t *buf, const int size) in UsbToStream() argument
422 if (!uv_is_writable(stream)) { in UsbToStream()
429 ret = uv_write(reqWrite, stream, &bfr, 1, UvWriteCallback); in UsbToStream()
444 int HdcDaemonUSB::UsbToHdcProtocol(uv_stream_t *stream, uint8_t *appendData, int dataSize) in UsbToHdcProtocol() argument
457 return UsbToStream(stream, data, dataSize); in UsbToHdcProtocol()
488 uv_stream_t *stream = reinterpret_cast<uv_stream_t *>(&hChildSession->dataPipe[STREAM_MAIN]); in DispatchToWorkThread() local
489 if ((childRet = SendToHdcStream(hChildSession, stream, readBuf, readBytes)) < 0) { in DispatchToWorkThread()
/developtools/profiler/device/services/profiler_service/src/
Dtrace_file_reader.cpp52 static size_t GetReadPos(std::ifstream& stream) in GetReadPos() argument
54 return static_cast<size_t>(stream.tellg()); in GetReadPos()
/developtools/profiler/device/plugins/ftrace_plugin/src/
Dtrace_ops.cpp76 std::stringstream stream(output_); in ListCategories() local
77 while (std::getline(stream, line)) { in ListCategories()
/developtools/hdc/src/host/
Dclient.h39 static void ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
Dhost_usb.h58 int UsbToHdcProtocol(uv_stream_t *stream, uint8_t *appendData, int dataSize) override;
/developtools/profiler/protos/services/
Dplugin_service.proto28 rpc GetCommand(GetCommandRequest) returns (stream GetCommandResponse);
Dprofiler_service.proto34 rpc FetchData(FetchDataRequest) returns (stream FetchDataResponse);
/developtools/smartperf_host/trace_streamer/src/protos/services/
Dplugin_service.proto28 rpc GetCommand(GetCommandRequest) returns (stream GetCommandResponse);
/developtools/profiler/host/smartperf/trace_streamer/src/protos/services/
Dplugin_service.proto28 rpc GetCommand(GetCommandRequest) returns (stream GetCommandResponse);
/developtools/profiler/host/smartperf/ide/src/trace/proto/
Dprofiler_service.proto37 rpc FetchData(FetchDataRequest) returns (stream FetchDataResponse);
/developtools/smartperf_host/ide/src/trace/proto/
Dprofiler_service.proto37 rpc FetchData(FetchDataRequest) returns (stream FetchDataResponse);

12