Home
last modified time | relevance | path

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

12

/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()
180 int HdcUSBBase::SendToHdcStream(HSession hSession, uv_stream_t *stream, uint8_t *appendData, int da… in SendToHdcStream() argument
195 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()
395 int HdcUARTBase::UartToHdcProtocol(uv_stream_t *stream, uint8_t *data, int dataSize) in UartToHdcProtocol() argument
397 HSession hSession = (HSession)stream->data; in UartToHdcProtocol()
946 void HdcUARTBase::ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadDataFromUARTStream() argument
948 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 __anon7f708f190702() argument
492 return mockUARTBase.HdcUARTBase::UartToHdcProtocol(stream, data, dataSize); in __anon7f708f190702()
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.cpp127 stringstream stream; in GetCpuTotalUsage() local
128 stream << buff; in GetCpuTotalUsage()
129 stream >> name >> userTime >> niceTime >> systemTime >> idleTime; in GetCpuTotalUsage()
131 stream.clear(); in GetCpuTotalUsage()
153 stringstream stream; in GetCpuProcUsage() local
154 stream << lineBuff; in GetCpuProcUsage()
155 stream >> tmpPid; in GetCpuProcUsage()
157 stream.clear(); in GetCpuProcUsage()
158 stream << q; in GetCpuProcUsage()
159 stream >> utime >> stime >> cutime >> cstime; in GetCpuProcUsage()
/developtools/smartperf_host/ide/src/hdc/hdcclient/
DHdcClient.ts133 let stream = this.cmdStreams.get(data.getChannelId());
134 if (stream) {
135 stream.putMessageInQueue(data);
/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/profiler/host/smartperf/client/client_command/
Dcontrol_call_cmd.cpp75 stream << time; in GetResult()
76 result = "time:" + stream.str() + "ms"; in GetResult()
101 stream << strResponseTime; in TimeDelay()
105 std::string resultTime = "ResponseTime:" + stream.str() + "ms\n" + in TimeDelay()
130 stream << responseTime; in SlideList()
131 std::string responseSlide = "ResponseTime:" + stream.str() + "ms"; in SlideList()
164 stream << fps; in PageFps()
165 result = "FPS:" + stream.str() + "fps"; in PageFps()
262 stream << fps; in StartFrameFps()
263 result = "FPS:" + stream.str() + "fps"; in StartFrameFps()
/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;
314 long noDuplicatedCount = hapVerifyInfo.getAbilityNames().stream().distinct().count(); in checkAbilityNameIsValid()
716 flatMap(Collection::stream).distinct().collect(Collectors.toList()); in checkApiVersionCovered()
723 include = include.stream().distinct().collect(Collectors.toList()); in checkApiVersionCovered()
726 exclude = exclude.stream().distinct().collect(Collectors.toList()); in checkApiVersionCovered()
764 flatMap(Collection::stream).distinct().collect(Collectors.toList()); in checkScreenShapeCovered()
771 include = include.stream().distinct().collect(Collectors.toList()); in checkScreenShapeCovered()
774 exclude = exclude.stream().distinct().collect(Collectors.toList()); in checkScreenShapeCovered()
811 flatMap(Collection::stream).distinct().collect(Collectors.toList()); in checkScreenWindowCovered()
[all …]
/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.cpp403 int HdcDaemonUSB::UsbToStream(uv_stream_t *stream, const uint8_t *buf, const int size) in UsbToStream() argument
426 if (!uv_is_writable(stream)) { in UsbToStream()
433 ret = uv_write(reqWrite, stream, &bfr, 1, UvWriteCallback); in UsbToStream()
448 int HdcDaemonUSB::UsbToHdcProtocol(uv_stream_t *stream, uint8_t *appendData, int dataSize) in UsbToHdcProtocol() argument
461 return UsbToStream(stream, data, dataSize); in UsbToHdcProtocol()
492 uv_stream_t *stream = reinterpret_cast<uv_stream_t *>(&hChildSession->dataPipe[STREAM_MAIN]); in DispatchToWorkThread() local
493 if ((childRet = SendToHdcStream(hChildSession, stream, readBuf, readBytes)) < 0) { in DispatchToWorkThread()
/developtools/hdc/hdc_rust/src/host/
Dserver.rs37 let (stream, addr) = listener.accept().await?; in run_server_mode()
39 ylong_runtime::spawn(handle_client(stream)); in run_server_mode()
115 async fn handle_client(stream: TcpStream) -> io::Result<()> { in handle_client()
116 let (mut rd, wr) = stream.into_split(); in handle_client()
Dclient.rs86 let stream = match TcpStream::connect(parsed_cmd.server_addr).await { in new() localVariable
87 Ok(stream) => stream, in new()
91 let (rd, wr) = stream.into_split(); in new()
/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/profiler/host/smartperf/client/client_command/include/
Dcontrol_call_cmd.h46 std::ostringstream stream; variable
/developtools/hapsigner/hapsigntool/hap_sign_tool_lib/src/main/java/com/ohos/hapsigntool/hap/sign/
DSignHap.java45 import java.util.stream.Collectors;
79 List<JarEntry> entryListStored = in.stream() in copyFiles()
113 List<JarEntry> entryListNotStored = in.stream() in copyFiles()
139 return entryListStored.stream().sorted((entry1, entry2) -> { in storedEntryListOfSort()
/developtools/hdc/hdc_rust/src/daemon/
Dmain.rs80 async fn tcp_handle_client(stream: TcpStream) -> io::Result<()> { in tcp_handle_client()
81 let (mut rd, wr) = stream.into_split(); in tcp_handle_client()
115 let (stream, addr) = listener.accept().await?; in tcp_daemon_start()
117 ylong_runtime::spawn(tcp_handle_client(stream)); in tcp_daemon_start()
/developtools/hdc/src/host/
Dhost_usb.h58 int UsbToHdcProtocol(uv_stream_t *stream, uint8_t *appendData, int dataSize) override;
Dclient.h39 static void ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
/developtools/profiler/protos/services/
Dplugin_service.proto28 rpc GetCommand(GetCommandRequest) returns (stream GetCommandResponse);
/developtools/smartperf_host/trace_streamer/src/protos/services/
Dplugin_service.proto28 rpc GetCommand(GetCommandRequest) returns (stream GetCommandResponse);
/developtools/smartperf_host/ide/
Dwebpack.config.js197 stream: false, property

12