代码拉取完成,页面将自动刷新
/*
* Copyright (c) 2018, Psiphon Inc.
* All rights reserved.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/
package common
import (
"os"
"path/filepath"
"runtime"
"runtime/pprof"
"time"
)
// WriteRuntimeProfiles writes Go runtime profile information to a set of
// files in the specified output directory. The profiles include "heap",
// "goroutine", and other selected profiles from:
// https://golang.org/pkg/runtime/pprof/#Profile.
//
// The SampleDurationSeconds inputs determine how long to wait and sample
// profiles that require active sampling. When set to 0, these profiles are
// skipped.
func WriteRuntimeProfiles(
logger Logger,
outputDirectory string,
blockSampleDurationSeconds int,
cpuSampleDurationSeconds int) {
openProfileFile := func(profileName string) *os.File {
fileName := filepath.Join(outputDirectory, profileName+".profile")
file, err := os.OpenFile(
fileName, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
if err != nil {
logger.WithContextFields(
LogFields{
"error": err,
"fileName": fileName}).Error("open profile file failed")
return nil
}
return file
}
writeProfile := func(profileName string) {
file := openProfileFile(profileName)
if file == nil {
return
}
err := pprof.Lookup(profileName).WriteTo(file, 1)
file.Close()
if err != nil {
logger.WithContextFields(
LogFields{
"error": err,
"profileName": profileName}).Error("write profile failed")
}
}
// TODO: capture https://golang.org/pkg/runtime/debug/#WriteHeapDump?
// May not be useful in its current state, as per:
// https://groups.google.com/forum/#!topic/golang-dev/cYAkuU45Qyw
// Write goroutine, heap, and threadcreate profiles
// https://golang.org/pkg/runtime/pprof/#Profile
writeProfile("goroutine")
writeProfile("heap")
writeProfile("threadcreate")
// Write CPU profile (after sampling)
// https://golang.org/pkg/runtime/pprof/#StartCPUProfile
if cpuSampleDurationSeconds > 0 {
file := openProfileFile("cpu")
if file != nil {
logger.WithContext().Info("start cpu profiling")
err := pprof.StartCPUProfile(file)
if err != nil {
logger.WithContextFields(
LogFields{"error": err}).Error("StartCPUProfile failed")
} else {
time.Sleep(time.Duration(cpuSampleDurationSeconds) * time.Second)
pprof.StopCPUProfile()
logger.WithContext().Info("end cpu profiling")
}
file.Close()
}
}
// Write block profile (after sampling)
// https://golang.org/pkg/runtime/pprof/#Profile
if blockSampleDurationSeconds > 0 {
logger.WithContext().Info("start block/mutex profiling")
runtime.SetBlockProfileRate(1)
runtime.SetMutexProfileFraction(1)
time.Sleep(time.Duration(blockSampleDurationSeconds) * time.Second)
runtime.SetBlockProfileRate(0)
runtime.SetMutexProfileFraction(0)
logger.WithContext().Info("end block/mutex profiling")
writeProfile("block")
writeProfile("mutex")
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。