| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/distributed/util/ |
| D | DistributedDataPraser.java | 24 import java.util.stream.Collectors;
43 …List<Long> sortList = list.stream().map(DistributedFuncBean::getDur).sorted().collect(Collectors.t… in collectByName()
50 …Double.valueOf(MathUtils.average(sortList.stream().map(Long::doubleValue).collect(Collectors.toLis… in collectByName()
54 …List<Long> delaySortList = list.stream().map(DistributedFuncBean::getDelay).filter(Objects::nonNul… in collectByName()
63 ….valueOf(MathUtils.average(delaySortList.stream().map(Long::doubleValue).collect(Collectors.toList… in collectByName()
|
| D | DistributedCache.java | 128 THREAD_MAP_A.entrySet().stream().forEach(it -> it.getValue().clear()); in recycleData()
129 FUNC_MAP_A.entrySet().stream().forEach(it -> it.getValue().clear()); in recycleData()
130 THREAD_MAP_B.entrySet().stream().forEach(it -> it.getValue().clear()); in recycleData()
131 FUNC_MAP_B.entrySet().stream().forEach(it -> it.getValue().clear()); in recycleData()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/applicationtrace/ |
| D | DataProcess.java | 31 import java.util.stream.Collectors;
33 import static java.util.stream.Collectors.groupingBy;
56 …funcMap.entrySet().stream().filter(entry -> threadIds == null || threadIds.contains(entry.getKey()… in getFuncTreeTopDown()
57 .flatMap(entry -> entry.getValue().stream()).collect(Collectors.toList()); in getFuncTreeTopDown()
60 Map<String, DefaultMutableTreeNode> treeNodeMap = treeTableBeans.stream() in getFuncTreeTopDown()
70 return treeNodeMap.values().stream().filter(node -> { in getFuncTreeTopDown()
93 …funcMap.entrySet().stream().filter(entry -> threadIds == null || threadIds.contains(entry.getKey()…
94 .flatMap(entry -> entry.getValue().stream()).collect(Collectors.toList());
123 List<Map.Entry<String, List<AppFunc>>> list1 = list.stream().filter(func -> {
127 … }).collect(groupingBy(AppFunc::getBloodId)).entrySet().stream().collect(Collectors.toList());
[all …]
|
| D | AllData.java | 36 import java.util.stream.Collectors;
38 import static java.util.stream.Collectors.groupingBy;
103 Map<Integer, List<AppFunc>> collect = FUNC_MAP.entrySet().stream() in getFuncTreeTopDown()
128 Map<Integer, List<AppFunc>> collect = FUNC_MAP.entrySet().stream() in getFuncTreeBottomUp()
140 List<Func> collect = FUNC_MAP.get(func.getTid()).stream().filter( in getFuncTreeByFuncTopDown()
151 …collect.stream().filter(item -> item.getDepth() == func.getDepth() + 1).mapToLong(Func::getDur).su… in getFuncTreeByFuncTopDown()
157 …treeTableBeans.stream().collect(Collectors.toMap(TreeTableBean::getBloodId, DefaultMutableTreeNode… in getFuncTreeByFuncTopDown()
180 List<Func> collect = FUNC_MAP.get(func.getTid()).stream().filter( in getFuncTreeByFuncBottomUp()
205 if (ids.stream().noneMatch(id -> in getFuncTreeByFuncBottomUp()
206 … collect.stream().filter(item -> item.getBloodId().equals(id) && item.getDepth() < func.getDepth()) in getFuncTreeByFuncBottomUp()
[all …]
|
| D | AppTracePanel.java | 70 import java.util.stream.Collectors;
71 import java.util.stream.IntStream;
286 long min = cpuScales.stream().mapToLong(value -> value.getTimeStamp()).min().orElse(0); in insertCpuScale()
287 long max = cpuScales.stream().mapToLong(value -> value.getTimeStamp()).max().orElse(0); in insertCpuScale()
343 …frameFuncList.stream().filter(frameFunc -> frameFunc.getFuncName().contains("doFrame")).forEach(fu… in insertFrame()
345 frame.setRenderList(renderFuncList.stream().filter(renderFunc -> TimeUtils in insertFrame()
368 Process sfProcess = AllData.processes.stream() in insertSurface()
378 … flingerThreads.stream().filter(func -> func.getDepth() == 0).collect(Collectors.toList()); in insertSurface()
379 return flingerThreads.stream().map(DisplayFunc::new).collect(Collectors.toList()); in insertSurface()
386 data.stream().filter(data::contains).forEach(node -> { in insertVsyc()
[all …]
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/applicationtrace/analysis/ |
| D | OtherFunctionSummaryPanel.java | 39 import java.util.stream.Collectors;
149 List<Func> collect = AllData.FUNC_MAP.get(func.getTid()).stream() in getAppTraceData()
152 List<Long> longs = collect.stream().map(Func::getDur).collect(Collectors.toList()); in getAppTraceData()
155 collect.stream().limit(10).forEach(item -> { in getAppTraceData()
163 …<PrefFunc> collect = PerfData.getFuncMap().get(Long.valueOf(prefFunc.getTid()).intValue()).stream() in getPerfData()
166 List<Long> longs = collect.stream().map(PrefFunc::getDur).collect(Collectors.toList()); in getPerfData()
169 collect.stream().limit(10).forEach(item -> { in getPerfData()
181 eventBean.setSelfTime(func.getDur() - AllData.FUNC_MAP.get(func.getTid()).stream() in initAppBean()
185 eventBean.setCpuSelfTime(func.getRunning() - AllData.FUNC_MAP.get(func.getTid()).stream() in initAppBean()
196 …long selfTime = prefFunc.getDur() - prefFunc.getChildrenNodes().stream().mapToLong(PrefFunc::getDu… in initPerfBean()
[all …]
|
| D | EventTable.java | 44 import java.util.stream.Collectors;
131 … funcList.addAll(AllData.FUNC_MAP.get(threadId).stream().filter(func -> func.getDepth() != -1 in getAppData()
136 …Map<Long, List<Func>> collect = funcList.stream().collect(Collectors.groupingBy(Func::getParentSta… in getAppData()
137 …dataSource = funcList.stream().sorted(Comparator.comparingLong(Func::getDur).reversed()).limit(10)… in getAppData()
144 … selfTime = func.getDur() - collect.get(func.getStackId()).stream().filter(func1 -> TimeUtils in getAppData()
147 … cupSelfTime = cpuDuration - collect.get(func.getStackId()).stream().filter(func1 -> TimeUtils in getAppData()
168 funcList.addAll(PerfData.getFuncMap().get(threadId).stream().filter( in getPerfData()
175 …funcList.stream().sorted(Comparator.comparingLong(PrefFunc::getDur).reversed()).limit(10).map(func… in getPerfData()
177 …long selfTime = func.getDur() - func.getChildrenNodes().stream().mapToLong(PrefFunc::getDur).sum(); in getPerfData()
|
| D | TreeTableRowSorter.java | 35 import java.util.stream.Collectors;
92 … childs.stream().sorted(nameComparator.thenComparing(condition)).collect(Collectors.toList()) in sortDescTree()
128 …childs.stream().sorted(nameComparator.thenComparing(condition.reversed())).collect(Collectors.toLi… in sortTree()
165 if (sortKeys.stream() in toggleSortOrder()
168 } else if (sortKeys.stream() in toggleSortOrder()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/distributed/component/ |
| D | DistributedTracePanel.java | 50 import java.util.stream.Collectors;
111 Arrays.stream(contentPanel.getComponents()).filter(DeviceExpandPanel.class::isInstance) in DistributedTracePanel()
129 …scrollPane.getVerticalScrollBar().addAdjustmentListener(event -> Arrays.stream(contentPanel.getCom… in DistributedTracePanel()
146 allComponent.stream().filter(TraceFuncRow.class::isInstance) in addMonitorChange()
149 row.getData().stream().filter(it -> it.getId() == funcId).forEach(it -> { in addMonitorChange()
211 Arrays.stream(contentPanel.getComponents()).filter(it -> it instanceof ExpandPanel) in timeShaftComplete()
213 … it -> Arrays.stream(it.getContent().getComponents()).filter(row -> row instanceof TraceSimpleRow) in timeShaftComplete()
221 …allComponent = Arrays.stream(contentPanel.getComponents()).filter(DeviceExpandPanel.class::isInsta… in tip()
222 … .map(it -> ((DeviceExpandPanel) it)).flatMap(it -> Arrays.stream(it.getContent().getComponents())) in tip()
224 … .flatMap(it -> Arrays.stream(it.getContent().getComponents())).collect(Collectors.toList()); in tip()
[all …]
|
| /developtools/hdc_standard/src/common/ |
| D | usb.h | 33 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);
|
| D | usb.cpp | 29 void HdcUSBBase::ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadUSB() argument
31 HSession hSession = (HSession)stream->data; in ReadUSB()
170 int HdcUSBBase::SendToHdcStream(HSession hSession, uv_stream_t *stream, uint8_t *appendData, int da… in SendToHdcStream() argument
182 if ((childRet = UsbToHdcProtocol(stream, appendData, dataSize)) < 0) { in SendToHdcStream()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/trace/ |
| D | TracePanel.java | 40 import java.util.stream.Collectors;
204 Arrays.stream(contentPanel.getComponents()).filter(it -> it instanceof ExpandPanel) in timeShaftComplete()
206 … it -> Arrays.stream(it.getContent().getComponents()).filter(row -> row instanceof TraceSimpleRow) in timeShaftComplete()
214 … allComponent = Arrays.stream(contentPanel.getComponents()).filter(ExpandPanel.class::isInstance) in tip()
215 … .flatMap(component -> Arrays.stream(((ExpandPanel) component).getContent().getComponents())) in tip()
218 boolean flag = allComponent.stream().anyMatch(it -> { in tip()
299 if ((thread.getData() != null && thread.getData().stream() in mouseClickThreadRow()
301 .getData2().stream().anyMatch(it -> it.getRect().contains(point)))) { in mouseClickThreadRow()
303 … thread.getData().stream().filter(it -> it.getRect().contains(point)).findFirst() in mouseClickThreadRow()
307 … thread.getData2().stream().filter(it -> it.getRect().contains(point)).findFirst() in mouseClickThreadRow()
[all …]
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/perftrace/ |
| D | PerfData.java | 39 import java.util.stream.Collectors;
41 import static java.util.stream.Collectors.groupingBy;
79 …Map<Long, List<PrefSample>> sampleMap = sampleList.stream().collect(groupingBy(PrefSample::getSamp… in formatSampleList()
81 … sampleMap.entrySet().stream().sorted(Map.Entry.comparingByKey()).collect(Collectors.toList()); in formatSampleList()
94 List<PrefSample> prefSamples = collect.get(collectIndex).getValue().stream() in formatSampleList()
179 Map<Integer, List<AppFunc>> collect = funcMap.entrySet().stream() in getFuncTreeTopDown()
207 Map<Integer, List<AppFunc>> collect = funcMap.entrySet().stream() in getFuncTreeBottomUp()
219 … List<PrefFunc> collect = funcMap.get(Long.valueOf(func.getTid()).intValue()).stream().filter( in getFuncTreeByFuncTopDown()
229 long threadFuncDuration = TimeUnit.NANOSECONDS.toMicros(collect.stream().filter( in getFuncTreeByFuncTopDown()
240 Map<String, DefaultMutableTreeNode> treeNodeMap = treeTableBeans.stream() in getFuncTreeByFuncTopDown()
[all …]
|
| D | PerfTracePanel.java | 53 import static java.util.stream.Collectors.groupingBy;
155 long min = cpuScales.stream().mapToLong(value -> value.getTimeStamp()).min().orElse(0); in insertCpuScale()
156 long max = cpuScales.stream().mapToLong(value -> value.getTimeStamp()).max().orElse(0); in insertCpuScale()
190 PerfData.setPrefFiles(prefFiles.stream().collect(groupingBy(PrefFile::getFileId))); in initFileData()
221 data2.stream().filter(item -> row.contains(item)).forEach(func -> { in initRow()
251 int maxDept = funcList.stream().mapToInt(bean -> bean.getDepth()).max().orElse(0) + 1; in initRow()
|
| /developtools/hdc_standard/test/unittest/common/ |
| D | HdcJdwpTest.cpp | 79 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);
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/trace/component/ |
| D | ContentPanel.java | 49 import java.util.stream.Collectors;
169 fragmentList.stream().filter(fragment -> { in paintComponent()
207 … fragmentList.stream().filter(it -> it.visible).filter(it -> it.getDataRect().contains(x1, y1)) in drawRangeSelect()
209 …fragmentList.stream().filter(it -> it.visible).filter(it -> it.getDataRect().contains(x2 - 1, y2 -… in drawRangeSelect()
225 fragmentList.stream().filter(it -> range.intersects(it.getDataRect())) in drawRangeSelect()
230 rangeFragments.stream().filter(it -> it instanceof ProcessDataFragment) in drawRangeSelect()
232 … process.addAll(fragmentList.stream().filter(that -> that.parentUuid.equals(it.uuid)) in drawRangeSelect()
236 … List<Integer> cpu = rangeFragments.stream().filter(it -> it instanceof CpuDataFragment) in drawRangeSelect()
238 … List<Integer> threads = rangeFragments.stream().filter(it -> it instanceof ThreadDataFragment) in drawRangeSelect()
240 … List<Integer> tracks = rangeFragments.stream().filter(it -> it instanceof MemDataFragment) in drawRangeSelect()
[all …]
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/datasources/utils/plugin/service/ |
| D | PlugManager.java | 41 import java.util.stream.Collectors;
89 …collect = confLists.stream().filter(pluginConf -> pluginConf.getAnalysisTypes().contains(analysisT… in getPluginConfig()
98 return collect.stream().filter(hiProfilerPluginConf -> { in getPluginConfig()
107 return collect.stream().filter(hiProfilerPluginConf -> { in getPluginConfig()
230 List<ProfilerMonitorItem> itemList = collection.stream().filter(
234 return itemList.stream().sorted(Comparator.comparingInt(ProfilerMonitorItem::getIndex))
249 … confLists.stream().filter(pluginConf -> pluginConf.getPluginFileName().equals(configFileName))
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/applicationtrace/util/ |
| D | MathUtils.java | 34 double sum = doubles.stream().mapToDouble(it -> it).sum(); in average()
48 double varianceD = doubles.stream().mapToDouble(it -> (it - avg) * (it + avg)).sum(); in variance()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/distributed/ |
| D | DistributedDataCallTreePane.java | 61 import java.util.stream.Collectors;
199 …DistributedCache.ID_FUNC_BEAN_MAP_A.values().stream().filter((bean) -> !bean.getChainId().isEmpty(… in freshAllDataBySelectData()
205 …DistributedCache.ID_FUNC_BEAN_MAP_B.values().stream().filter((bean) -> !bean.getChainId().isEmpty(… in freshAllDataBySelectData()
210 parentIdFuncBeanMapA = DistributedCache.ID_FUNC_BEAN_MAP_A.values().stream() in freshAllDataBySelectData()
214 parentIdFuncBeanMapB = DistributedCache.ID_FUNC_BEAN_MAP_B.values().stream() in freshAllDataBySelectData()
307 DistributedFuncBean topA = chainIdFuncBeanMapA.get(selectBean.getChainId()).stream() in findTopBean()
315 DistributedFuncBean topB = chainIdFuncBeanMapB.get(selectBean.getChainId()).stream() in findTopBean()
328 … DistributedFuncBean findBeanA = chainIdFuncBeanMapA.get(selectBean.getChainId()).stream().filter( in findBeanDistributed()
333 … DistributedFuncBean findBeanB = chainIdFuncBeanMapB.get(selectBean.getChainId()).stream().filter( in findBeanDistributed()
363 list.stream().collect(Collectors.toMap(DistributedFuncBean::getId, (bean) -> { in getTreeNodes()
[all …]
|
| D | DistributedChartPanel.java | 43 import java.util.stream.Collectors;
164 DistributedCache.setThreadNamesA(DistributedCache.THREADS_A.stream() in insertDeviceA()
174 data2.stream().filter(item -> row.contains(item)).forEach(func -> { in insertDeviceA()
189 … int maxDept = funcs.stream().mapToInt(DistributedFuncBean::getDepth).max().orElse(0) + 1; in insertDeviceA()
211 DistributedCache.setThreadNamesB(DistributedCache.THREADS_B.stream() in insertDeviceB()
221 data2.stream().filter(item -> row.contains(item)).forEach(func -> { in insertDeviceB()
236 … int maxDept = funcs.stream().mapToInt(DistributedFuncBean::getDepth).max().orElse(0) + 1; in insertDeviceB()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/layout/chartview/memory/nativehook/ |
| D | NativeHookTreeTableRowSorter.java | 33 import java.util.stream.Collectors;
75 childs.stream().sorted(condition).collect(Collectors.toList()).forEach(parent::add); in sortDescTree()
110 … childs.stream().sorted(condition.reversed()).collect(Collectors.toList()).forEach(parent::add); in sortTree()
146 if (sortKeys.stream() in toggleSortOrder()
149 } else if (sortKeys.stream() in toggleSortOrder()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/layout/chartview/memory/heapdump/ |
| D | HeapDumpTreeTableRowSorter.java | 33 import java.util.stream.Collectors;
76 childs.stream().sorted(condition).collect(Collectors.toList()).forEach(parent::add); in sortDescTree()
111 … childs.stream().sorted(condition.reversed()).collect(Collectors.toList()).forEach(parent::add); in sortTree()
147 if (sortKeys.stream() in toggleSortOrder()
150 } else if (sortKeys.stream() in toggleSortOrder()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/pluginconfig/ |
| D | DataCheckConfig.java | 46 StreamPluginConfig.StreamConfig stream = in createConfig() local
48 return new HiProfilerPluginConfig(40, stream.toByteString()); in createConfig()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/trace/util/ |
| D | TimeUtils.java | 22 import java.util.stream.Collectors;
23 import java.util.stream.Stream;
98 return list.stream().collect(Collectors.joining(" ")); in getTimeString()
|
| /developtools/profiler/host/ohosprofiler/src/main/java/ohos/devtools/views/layout/chartview/memory/javaagent/ |
| D | AgentTreeTableRowSorter.java | 32 import java.util.stream.Collectors;
73 if (sortKeys.stream() in toggleSortOrder()
111 … agentDataNodes.getAllAgentDatas().stream().sorted(comparator).collect(Collectors.toList())); in sortDescTree()
144 …agentDataNodes.getAllAgentDatas().stream().sorted(comparator.reversed()).collect(Collectors.toList… in sortTree()
|