mirror of
https://github.com/zeromicro/go-zero.git
synced 2026-05-13 09:50:00 +08:00
chore: coding style (#4054)
This commit is contained in:
@@ -191,6 +191,15 @@ func (tw *timeoutWriter) Write(p []byte) (int, error) {
|
|||||||
return tw.wbuf.Write(p)
|
return tw.wbuf.Write(p)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (tw *timeoutWriter) WriteHeader(code int) {
|
||||||
|
tw.mu.Lock()
|
||||||
|
defer tw.mu.Unlock()
|
||||||
|
|
||||||
|
if !tw.wroteHeader {
|
||||||
|
tw.writeHeaderLocked(code)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func (tw *timeoutWriter) writeHeaderLocked(code int) {
|
func (tw *timeoutWriter) writeHeaderLocked(code int) {
|
||||||
checkWriteHeaderCode(code)
|
checkWriteHeaderCode(code)
|
||||||
|
|
||||||
@@ -209,15 +218,6 @@ func (tw *timeoutWriter) writeHeaderLocked(code int) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (tw *timeoutWriter) WriteHeader(code int) {
|
|
||||||
tw.mu.Lock()
|
|
||||||
defer tw.mu.Unlock()
|
|
||||||
|
|
||||||
if !tw.wroteHeader {
|
|
||||||
tw.writeHeaderLocked(code)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func checkWriteHeaderCode(code int) {
|
func checkWriteHeaderCode(code int) {
|
||||||
if code < 100 || code > 599 {
|
if code < 100 || code > 599 {
|
||||||
panic(fmt.Sprintf("invalid WriteHeader code %v", code))
|
panic(fmt.Sprintf("invalid WriteHeader code %v", code))
|
||||||
|
|||||||
Reference in New Issue
Block a user