him411/UA3F
1
0
Fork 0
mirror of https://github.com/SunBK201/UA3F.git synced 2025-12-16 16:57:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: loop clean http parser

Browse Source
This commit is contained in:
SunBK201 2023-12-04 21:16:54 +08:00
parent 47730f22a8
commit 6ccf29f0be
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
main.go
View File

@ -54,6 +54,7 @@ func main() {
printAndLog(fmt.Sprintf("Accept failed: %v", err), logger, syslog.LOG_ERR) printAndLog(fmt.Sprintf("Accept failed: %v", err), logger, syslog.LOG_ERR)
continue continue
} }
printAndLog(fmt.Sprintf("Accept %s", client.RemoteAddr().String()), logger, syslog.LOG_DEBUG)
go process(client) go process(client)
} }
} }
@ -170,7 +171,6 @@ func Socks5Forward(client, target net.Conn) {
} }
func CopyPileline(dst io.Writer, src io.Reader) { func CopyPileline(dst io.Writer, src io.Reader) {
parser := NewHTTPParser()
logger, _ := syslog.Dial("", "", syslog.LOG_INFO, "UA3F") logger, _ := syslog.Dial("", "", syslog.LOG_INFO, "UA3F")
buf := make([]byte, 1024*8) buf := make([]byte, 1024*8)
nr, err := src.Read(buf) nr, err := src.Read(buf)
@ -194,6 +194,7 @@ func CopyPileline(dst io.Writer, src io.Reader) {
return return
} }
for { for {
parser := NewHTTPParser()
httpBodyOffset, err := parser.Parse(buf[0:nr]) httpBodyOffset, err := parser.Parse(buf[0:nr])
for err == ErrMissingData { for err == ErrMissingData {
var m int var m int