(conn net.Conn)
| 20 | } |
| 21 | |
| 22 | func (h *tcpHandler) HandleConnection(conn net.Conn) { |
| 23 | defer conn.Close() |
| 24 | |
| 25 | scanner := bufio.NewScanner(conn) |
| 26 | scanner.Buffer(make([]byte, 0, 64*1024), 10*1024*1024) // 10MB max |
| 27 | |
| 28 | for scanner.Scan() { |
| 29 | line := strings.TrimSpace(scanner.Text()) |
| 30 | if line == "" { |
| 31 | continue |
| 32 | } |
| 33 | |
| 34 | h.processPayload(line) |
| 35 | } |
| 36 | |
| 37 | if err := scanner.Err(); err != nil { |
| 38 | slog.Debug("vardumper: connection error", "err", err) |
| 39 | } |
| 40 | } |
| 41 | |
| 42 | func (h *tcpHandler) processPayload(base64Payload string) { |
| 43 | result, err := h.php.Parse(base64Payload) |
nothing calls this directly
no test coverage detected