zishuo/sponge
1
0
Fork 0
mirror of https://github.com/zhufuyi/sponge.git synced 2025-09-26 20:51:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

style: adjustment code

Browse Source
This commit is contained in:
zhuyasen
2025-08-21 23:16:15 +08:00
parent ed05939320
commit 793b25eb33
2 changed files with 15 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
pkg/prof/profile.go
View File

@@ -49,7 +49,7 @@ var (
// }
//}
type profile struct {
type Profile struct {
files []string
closeFns []func()
@@ -58,15 +58,15 @@ type profile struct {
}
// NewProfile create a new profile
func NewProfile() *profile {
p := new(profile)
func NewProfile() *Profile {
p := new(Profile)
p.stopCh = make(chan struct{})
return p
}
// StartOrStop start and stop sampling profile, the first call to start sampling data, the default maximum is 60 seconds,
// in less than 60s, if the second execution will actively stop sampling profile
func (p *profile) StartOrStop() {
func (p *Profile) StartOrStop() {
if isStart() {
p.startProfile()
} else if isStop() {
@@ -74,7 +74,7 @@ func (p *profile) StartOrStop() {
}
}
func (p *profile) startProfile() {
func (p *Profile) startProfile() {
fmt.Printf("[profile] start sampling profile, status=%d\n", status)
defer func() {
@@ -123,7 +123,7 @@ func (p *profile) startProfile() {
go p.checkTimeout()
}
func (p *profile) stopProfile() {
func (p *Profile) stopProfile() {
fmt.Printf("[profile] stop sampling profile, status=%d\n", status)
defer func() {
@@ -149,7 +149,7 @@ func (p *profile) stopProfile() {
p = NewProfile() //nolint
}
func (p *profile) checkTimeout() {
func (p *Profile) checkTimeout() {
if p == nil {
return
}
@@ -167,7 +167,7 @@ func (p *profile) checkTimeout() {
}
}
func (p *profile) cpu() error {
func (p *Profile) cpu() error {
profileName := "cpu"
file := getFilePath(profileName)
f, err := os.Create(file)
@@ -186,7 +186,7 @@ func (p *profile) cpu() error {
return nil
}
func (p *profile) mem() error {
func (p *Profile) mem() error {
profileName := "mem"
file := getFilePath(profileName)
f, err := os.Create(file)
@@ -207,7 +207,7 @@ func (p *profile) mem() error {
return nil
}
func (p *profile) goroutine() error {
func (p *Profile) goroutine() error {
profileName := "goroutine"
file := getFilePath(profileName)
f, err := os.Create(file)
@@ -224,7 +224,7 @@ func (p *profile) goroutine() error {
return nil
}
func (p *profile) block() error {
func (p *Profile) block() error {
profileName := "block"
file := getFilePath(profileName)
f, err := os.Create(file)
@@ -244,7 +244,7 @@ func (p *profile) block() error {
return nil
}
func (p *profile) mutex() error {
func (p *Profile) mutex() error {
profileName := "mutex"
file := getFilePath(profileName)
f, err := os.Create(file)
@@ -266,7 +266,7 @@ func (p *profile) mutex() error {
return nil
}
func (p *profile) threadCreate() error {
func (p *Profile) threadCreate() error {
profileName := "threadcreate"
file := getFilePath(profileName)
f, err := os.Create(file)
@@ -285,7 +285,7 @@ func (p *profile) threadCreate() error {
return nil
}
func (p *profile) tracing() error {
func (p *Profile) tracing() error {
profileName := "trace"
file := getFilePath(profileName)
f, err := os.Create(file)

2
pkg/sql2code/parser/commonParser.go
View File

@@ -406,7 +406,7 @@ func getHandlerGoType(field *tmplField) string {
switch field.rewriterField.goType {
case jsonTypeName:
goType = "string"
case boolTypeName:
case boolTypeName, boolTypeTinyName:
goType = "*bool"
case decimalTypeName:
goType = "string"