obitools/obitools4
2
0
Fork 0
mirror of https://github.com/metabarcoding/obitools4.git synced 2025-06-29 16:20:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

improved performance

Browse Source
This commit is contained in:
Eric Coissac
2022-08-21 13:44:09 +02:00
parent 02f445f02f
commit f1e3a68dc4
2 changed files with 16 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
cmd/obitools/obipcr/main.go
View File

@ -1,9 +1,10 @@
package main package main
import ( import (
log "github.com/sirupsen/logrus"
"os" "os"
"runtime/trace" "runtime/pprof"
log "github.com/sirupsen/logrus"
"git.metabarcoding.org/lecasofts/go/obitools/pkg/obioptions" "git.metabarcoding.org/lecasofts/go/obitools/pkg/obioptions"
"git.metabarcoding.org/lecasofts/go/obitools/pkg/obitools/obiconvert" "git.metabarcoding.org/lecasofts/go/obitools/pkg/obitools/obiconvert"
@ -13,20 +14,20 @@ import (
func main() { func main() {
// go tool pprof -http=":8000" ./obipairing ./cpu.pprof // go tool pprof -http=":8000" ./obipairing ./cpu.pprof
// f, err := os.Create("cpu.pprof") f, err := os.Create("cpu.pprof")
// if err != nil {
// log.Fatal(err)
// }
// pprof.StartCPUProfile(f)
// defer pprof.StopCPUProfile()
// go tool trace cpu.trace
ftrace, err := os.Create("cpu.trace")
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
trace.Start(ftrace) pprof.StartCPUProfile(f)
defer trace.Stop() defer pprof.StopCPUProfile()
// go tool trace cpu.trace
// ftrace, err := os.Create("cpu.trace")
// if err != nil {
// log.Fatal(err)
// }
// trace.Start(ftrace)
// defer trace.Stop()
optionParser := obioptions.GenerateOptionParser(obipcr.OptionSet) optionParser := obioptions.GenerateOptionParser(obipcr.OptionSet)

3
pkg/obitools/obipcr/pcr.go
View File

@ -3,6 +3,7 @@ package obipcr
import ( import (
"git.metabarcoding.org/lecasofts/go/obitools/pkg/obiapat" "git.metabarcoding.org/lecasofts/go/obitools/pkg/obiapat"
"git.metabarcoding.org/lecasofts/go/obitools/pkg/obiiter" "git.metabarcoding.org/lecasofts/go/obitools/pkg/obiiter"
"git.metabarcoding.org/lecasofts/go/obitools/pkg/obioptions"
) )
// PCR iterates over sequences provided by a obiseq.IBioSequenceBatch // PCR iterates over sequences provided by a obiseq.IBioSequenceBatch
@ -37,5 +38,5 @@ func PCR(iterator obiiter.IBioSequenceBatch) (obiiter.IBioSequenceBatch, error)
worker := obiapat.PCRSliceWorker(opts...) worker := obiapat.PCRSliceWorker(opts...)
return iterator.MakeISliceWorker(worker), nil return iterator.MakeISliceWorker(worker, obioptions.CLIParallelWorkers(), 0), nil
} }