@@ -109,7 +109,7 @@ func getProcessInclusions(commonProcesses []*ProcessCommon, cfg *config.AgentCon
109109 }
110110
111111 if totalCPUUsage >= float32 (cfg .CPUPercentageUsageThreshold ) {
112- cpuProcessChan <- deriveFmapTagProcess ( sortAndTakeN (cpuProcesses , percentageSort , cfg .AmountTopCPUPercentageUsage ) )
112+ cpuProcessChan <- sortAndTakeN (cpuProcesses , percentageSort , cfg .AmountTopCPUPercentageUsage )
113113 } else {
114114 cpuProcessChan <- make ([]* ProcessCommon , 0 )
115115 }
@@ -124,7 +124,7 @@ func getProcessInclusions(commonProcesses []*ProcessCommon, cfg *config.AgentCon
124124
125125 return sortingFunc
126126 }
127- ioReadProcessesChan <- deriveFmapTagProcess ( sortAndTakeN (ioReadProcesses , readIOSort , cfg .AmountTopIOReadUsage ) )
127+ ioReadProcessesChan <- sortAndTakeN (ioReadProcesses , readIOSort , cfg .AmountTopIOReadUsage )
128128 }()
129129
130130 // Top Write IO Using Processes, insert into chunked slice and strip from chunk slice
@@ -136,7 +136,7 @@ func getProcessInclusions(commonProcesses []*ProcessCommon, cfg *config.AgentCon
136136
137137 return sortingFunc
138138 }
139- ioWriteProcessesChan <- deriveFmapTagProcess ( sortAndTakeN (ioWriteProcesses , writeIOSort , cfg .AmountTopIOWriteUsage ) )
139+ ioWriteProcessesChan <- sortAndTakeN (ioWriteProcesses , writeIOSort , cfg .AmountTopIOWriteUsage )
140140 }()
141141
142142 // Top Memory Using Processes, insert into chunked slice and strip from chunk slice
@@ -150,7 +150,7 @@ func getProcessInclusions(commonProcesses []*ProcessCommon, cfg *config.AgentCon
150150 }
151151
152152 if totalMemUsage >= uint64 (cfg .MemoryUsageThreshold ) {
153- memoryProcessesChan <- deriveFmapTagProcess ( sortAndTakeN (memoryProcesses , memorySort , cfg .AmountTopMemoryUsage ) )
153+ memoryProcessesChan <- sortAndTakeN (memoryProcesses , memorySort , cfg .AmountTopMemoryUsage )
154154 } else {
155155 memoryProcessesChan <- make ([]* ProcessCommon , 0 )
156156 }
0 commit comments