database/logic-worker/ProcedureLogicWorkerCommon.ts

/*
 * Copyright (C) 2022 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

export class ChartStruct {
    depth: number = 0;
    symbol: string = '';
    size: number = 0;
    count: number = 0;
    dur:number = 0;
    parent: ChartStruct | undefined;
    children: Array<ChartStruct> = [];
}

export class Msg{
    tag:string = "";
    index:number = 0;
    data:Array<any> = [];
}

export class MerageBean extends ChartStruct{
    #parentNode: MerageBean | undefined = undefined
    #total = 0
    currentTreeParentNode: MerageBean | undefined = undefined;
    id: string = "";
    parentId: string = "";
    symbolName: string = "";
    symbol: string = ""
    libName: string = ""
    path: string = ""
    self: string = "0s"
    weight: string = ""
    weightPercent: string = ""
    selfDur: number = 0;
    dur: number = 0;
    pid: number = 0;
    canCharge:boolean = true
    isStore = 0;
    isSelected: boolean = false;
    searchShow: boolean = true;
    children: MerageBean[] = []
    initChildren: MerageBean[] = []
    type:number = 0
    set parentNode(data: MerageBean | undefined) {
        this.currentTreeParentNode = data;
        this.#parentNode = data;
    }

    get parentNode() {
        return this.#parentNode
    }

    set total(data: number) {
        this.#total = data;
        this.weight = `${getProbablyTime(this.dur)}`
        this.weightPercent = `${(this.dur / data * 100).toFixed(1)}%`
    }

    get total() {
        return this.#total;
    }
}

class MerageBeanDataSplit{
    systmeRuleName = "/system/"
    numRuleName = "/max/min/"

    //所有的操作都是针对整个树结构的 不区分特定的数据
    splitTree(splitMapData:any,data: MerageBean[], name: string, isCharge: boolean, isSymbol: boolean,currentTreeList:any[],searchValue:string) {
        data.forEach((process) => {
            process.children = []
            if (isCharge) {
                this.recursionChargeInitTree(splitMapData,process, name, isSymbol)
            } else {
                this.recursionPruneInitTree(splitMapData,process, name, isSymbol)
            }
        })
        this.resetAllNode(data,currentTreeList,searchValue)
    }

    recursionChargeInitTree(splitMapData:any,node: MerageBean, symbolName: string, isSymbol: boolean) {
        if ((isSymbol && node.symbolName == symbolName) || (!isSymbol && node.libName == symbolName)) {
            (splitMapData[symbolName] = splitMapData[symbolName] || []).push(node)
            node.isStore++;
        }
        if (node.initChildren.length > 0) {
            node.initChildren.forEach((child) => {
                this.recursionChargeInitTree(splitMapData,child, symbolName, isSymbol)
            })
        }
    }

    //symbol lib charge
    recursionChargeTree(node: MerageBean, symbolName: string, isSymbol: boolean) {
        if ((isSymbol && node.symbolName == symbolName) || (!isSymbol && node.libName == symbolName)) {
            node.currentTreeParentNode && node.currentTreeParentNode.children.splice(node.currentTreeParentNode.children.indexOf(node), 1, ...node.children);
            node.children.forEach((child) => {
                child.currentTreeParentNode = node.currentTreeParentNode
            })
        }
        if (node.children.length > 0) {
            node.children.forEach((child) => {
                this.recursionChargeTree(child, symbolName, isSymbol)
            })
        }
    }

    recursionPruneInitTree(splitMapData:any,node: MerageBean, symbolName: string, isSymbol: boolean) {
        if (isSymbol && node.symbolName == symbolName || (!isSymbol && node.libName == symbolName)) {
            (splitMapData[symbolName] = splitMapData[symbolName] || []).push(node)
            node.isStore++;
            this.pruneChildren(splitMapData,node, symbolName)
        } else if (node.initChildren.length > 0) {
            node.initChildren.forEach((child) => {
                this.recursionPruneInitTree(splitMapData,child, symbolName, isSymbol)
            })
        }
    }

    //symbol lib prune
    recursionPruneTree(node: MerageBean, symbolName: string, isSymbol: boolean) {
        if (isSymbol && node.symbolName == symbolName || (!isSymbol && node.libName == symbolName)) {
            node.currentTreeParentNode && node.currentTreeParentNode.children.splice(node.currentTreeParentNode.children.indexOf(node), 1);
        } else {
            node.children.forEach((child) => {
                this.recursionPruneTree(child, symbolName, isSymbol)
            })
        }
    }

    recursionChargeByRule(splitMapData:any,node: MerageBean, ruleName: string, rule: (node: MerageBean) => boolean) {
        if (node.initChildren.length > 0) {
            node.initChildren.forEach((child) => {
                if (rule(child)) {
                    (splitMapData[ruleName] = splitMapData[ruleName] || []).push(child)
                    child.isStore++;
                }
                this.recursionChargeByRule(splitMapData,child, ruleName, rule)
            })
        }
    }

    pruneChildren(splitMapData:any,node: MerageBean, symbolName: string) {
        if (node.initChildren.length > 0) {
            node.initChildren.forEach((child) => {
                child.isStore++;
                (splitMapData[symbolName] = splitMapData[symbolName] || []).push(child);
                this.pruneChildren(splitMapData,child, symbolName)
            })
        }
    }

    hideSystemLibrary(allProcess:MerageBean[],splitMapData:any){
        allProcess.forEach((item)=>{
            item.children = []
            this.recursionChargeByRule(splitMapData,item,this.systmeRuleName,(node)=>{
                return node.path.startsWith(this.systmeRuleName)
            })
        })
    }

    hideNumMaxAndMin(allProcess:MerageBean[],splitMapData:any,startNum:number,endNum:string){
        let max = endNum == "∞"?Number.POSITIVE_INFINITY :parseInt(endNum)
        allProcess.forEach((item)=>{
            item.children = []
            this.recursionChargeByRule(splitMapData,item,this.numRuleName,(node)=>{
                return node.count < startNum || node.count > max
            })
        })
    }

    resotreAllNode(splitMapData:any,symbols: string[]) {
        symbols.forEach((symbol) => {
            let list = splitMapData[symbol];
            if (list != undefined) {
                list.forEach((item: any) => {
                    item.isStore--
                })
            }
        })
    }

    resetAllNode(data: MerageBean[],currentTreeList:any[],searchValue:string) {
        this.clearSearchNode(currentTreeList)
        data.forEach((process) => {
            process.searchShow = true
        })
        this.resetNewAllNode(data,currentTreeList)
        if (searchValue != "") {
            this.findSearchNode(data, searchValue, false)
            this.resetNewAllNode(data,currentTreeList)
        }
    }

    resetNewAllNode(data: MerageBean[],currentTreeList:any[]) {
        data.forEach((process) => {
            process.children = []
        })
        let values = currentTreeList.map((item: any) => {
            item.children = []
            return item
        })
        values.forEach((item: any) => {
            if (item.parentNode != undefined) {
                if (item.isStore == 0 && item.searchShow) {
                    let parentNode = item.parentNode
                    while (parentNode != undefined && !(parentNode.isStore == 0 && parentNode.searchShow)) {
                        parentNode = parentNode.parentNode
                    }
                    if (parentNode) {
                        item.currentTreeParentNode = parentNode
                        parentNode.children.push(item)
                    }
                }
            }
        })
    }

    findSearchNode(data: MerageBean[], search: string, parentSearch: boolean) {
        data.forEach((node) => {
            if ((node.symbolName!=undefined&&node.symbolName.includes(search)) || parentSearch) {
                node.searchShow = true
                let parentNode = node.currentTreeParentNode
                while (parentNode != undefined && !parentNode.searchShow) {
                    parentNode.searchShow = true
                    parentNode = parentNode.currentTreeParentNode
                }
            } else {
                node.searchShow = false
            }
            if (node.children.length > 0) {
                this.findSearchNode(node.children, search, node.searchShow)
            }
        })
    }

    clearSearchNode(currentTreeList:any[]) {
        currentTreeList.forEach((node) => {
            node.searchShow = true
        })
    }

    splitAllProcess(allProcess:any[],splitMapData:any,list:any[]){
        list.forEach((item:any)=>{
            allProcess.forEach((process)=>{
                if(item.select == "0"){
                    this.recursionChargeInitTree(splitMapData,process, item.name, item.type == "symbol")
                }else {
                    this.recursionPruneInitTree(splitMapData,process, item.name, item.type == "symbol")
                }
            })
            if(!item.checked){
                this.resotreAllNode(splitMapData,[item.name])
            }
        })
    }
}

export let merageBeanDataSplit = new MerageBeanDataSplit()

export abstract class LogicHandler {
    abstract  handle(data:any):void
}

let dec = new TextDecoder();

export let setFileName = (path: string)=> {
    let fileName = ""
    if (path) {
        let number = path.lastIndexOf("/");
        if (number > 0) {
            fileName = path.substring(number + 1)
            return fileName
        }
    }
    return path
}

let pagination = (page:number, pageSize:number, source:Array<any>)=>{
    let offset = (page - 1) * pageSize;
    return (offset + pageSize >= source.length) ? source.slice(offset, source.length) : source.slice(offset, offset + pageSize);
}

const PAGE_SIZE:number = 50_0000;
export let postMessage = (id: any, action: string, results: Array<any>) => {
    if(results.length > PAGE_SIZE){
        let pageCount = Math.ceil( results.length / PAGE_SIZE)
        for (let i = 0; i < pageCount; i++) {
            let tag = "start";
            if(i== 0){
                tag = "start"
            }else if(i == pageCount - 1){
                tag = "end"
            }else{
                tag = "sending"
            }
            let msg = new Msg();
            msg.tag = tag;
            msg.index = i;
            msg.data = pagination(i,PAGE_SIZE,results);
            self.postMessage({id: id, action: action, isSending:msg.tag != "end",results: msg})
        }
    }else{
        let msg = new Msg();
        msg.tag = "end";
        msg.index = 0;
        msg.data = results;
        self.postMessage({id: id, action: action,results: msg})
    }
}

export let convertJSON = (arr:ArrayBuffer)=>{
    if(arr instanceof ArrayBuffer) {
        let str = dec.decode(arr);
        let jsonArray = [];
        str = str.substring(str.indexOf("\n") + 1);
        if (!str) {
        } else {
            let parse = JSON.parse(str);
            let columns = parse.columns;
            let values = parse.values;
            for (let i = 0; i < values.length; i++) {
                let obj: any = {}
                for (let j = 0; j < columns.length; j++) {
                    obj[columns[j]] = values[i][j]
                }
                jsonArray.push(obj)
            }
        }
        return jsonArray;
    } else {
        return arr;
    }
}

export let getByteWithUnit = (bytes: number) : string => {
    if (bytes < 0) {
        return "-" + getByteWithUnit(Math.abs(bytes))
    }
    let currentBytes = bytes
    let kb1 = 1 << 10;
    let mb1 = 1 << 10 << 10;
    let gb1 = 1 << 10 << 10 << 10; // 1 gb
    let res = ""
    if (currentBytes > gb1) {
        res += (currentBytes / gb1).toFixed(2) + " Gb";
    } else if (currentBytes > mb1) {
        res += (currentBytes / mb1).toFixed(2) + " Mb";
    } else if (currentBytes > kb1) {
        res += (currentBytes / kb1).toFixed(2) + " Kb";
    } else {
        res += Math.round(currentBytes) + " byte";
    }
    return res
}

export let  getTimeString = (ns: number): string =>{
    let currentNs = ns
    let hour1 = 3600_000_000_000
    let minute1 = 60_000_000_000
    let second1 = 1_000_000_000;
    let millisecond1 = 1_000_000;
    let microsecond1 = 1_000;
    let res = "";
    if (currentNs >= hour1) {
        res += Math.floor(currentNs / hour1) + "h ";
        currentNs = currentNs - Math.floor(currentNs / hour1) * hour1
    }
    if (currentNs >= minute1) {
        res += Math.floor(currentNs / minute1) + "m ";
        currentNs = currentNs - Math.floor(ns / minute1) * minute1
    }
    if (currentNs >= second1) {
        res += Math.floor(currentNs / second1) + "s ";
        currentNs = currentNs - Math.floor(currentNs / second1) * second1
    }
    if (currentNs >= millisecond1) {
        res += Math.floor(currentNs / millisecond1) + "ms ";
        currentNs = currentNs - Math.floor(currentNs / millisecond1) * millisecond1
    }
    if (currentNs >= microsecond1) {
        res += Math.floor(currentNs / microsecond1) + "μs ";
        currentNs = currentNs - Math.floor(currentNs / microsecond1) * microsecond1
    }
    if (currentNs > 0) {
        res += currentNs + "ns ";
    }
    if (res == "") {
        res = ns + "";
    }
    return res
}

export function getProbablyTime(ns: number): string {
    let currentNs = ns
    let hour1 = 3600_000_000_000
    let minute1 = 60_000_000_000
    let second1 = 1_000_000_000;
    let millisecond1 = 1_000_000;
    let microsecond1 = 1_000;
    let res = "";
    if (currentNs >= hour1) {
        res += (currentNs / hour1).toFixed(2) + "h ";
    }else if (currentNs >= minute1) {
        res += (currentNs / minute1).toFixed(2) + "m ";
    }else if (currentNs >= second1) {
        res += (currentNs / second1).toFixed(2) + "s ";
    }else if (currentNs >= millisecond1) {
        res += (currentNs / millisecond1).toFixed(2) + "ms ";
    }else if (currentNs >= microsecond1) {
        res += (currentNs / microsecond1).toFixed(2) + "μs ";
    }else if (currentNs > 0) {
        res += currentNs + "ns ";
    }else if (res == "") {
        res = ns + "";
    }
    return res
}

export function timeMsFormat2p(ns: number) {
    let currentNs = ns
    let hour1 = 3600_000
    let minute1 = 60_000
    let second1 = 1_000; // 1 second
    let res = ""
    if (currentNs >= hour1) {
        res += Math.floor(currentNs / hour1).toFixed(2) + "h"
        return res
    }
    if (currentNs >= minute1) {
        res += Math.floor(currentNs / minute1).toFixed(2) + "min"
        return res
    }
    if (currentNs >= second1) {
        res += Math.floor(currentNs / second1).toFixed(2) + "s"
        return res
    }
    if (currentNs > 0) {
        res += currentNs.toFixed(2) + "ms";
        return res
    }
    if (res == "") {
        res = "0s";
    }
    return res
}