发布

  • Spawn only two Goroutines per TCP stream (#1062)

    frostbyte_neo 发布于 2022-05-16 13:06:36 +00:00

    • Spawn only two Goroutines per TCP stream

    • Fix the linter error

    • Use isProtocolIdentified method instead

    • Fix the Read method of tcpReader

    • Remove unnecessary append

    • Copy to buffer only a message is received

    • Remove exhaustBuffer field and add rewind function

    • Rename buffer field to pastData

    • Update tap/tcp_reader.go

    Co-authored-by: Nimrod Gilboa Markevich 59927337+nimrod-up9@users.noreply.github.com

    • Use copy instead of assignment

    • No lint

    • #run_acceptance_tests

    • Fix rewind #run_acceptance_tests

    • Fix the buffering algorithm #run_acceptance_tests

    • Add TODO

    • Fix the problems in AMQP and Kafka #run_acceptance_tests

    • Use *bytes.Buffer instead of []api.TcpReaderDataMsg #run_acceptance_tests

    • Have a single *bytes.Buffer

    • Revert "Have a single *bytes.Buffer"

    This reverts commit fad96a288ad51792e118be166643e3b58f239600.

    • Revert "Use *bytes.Buffer instead of []api.TcpReaderDataMsg #run_acceptance_tests"

    This reverts commit 0fc70bffe2f877eb25e43931dc4790dc09d7832d.

    • Fix the early timing out issue #run_acceptance_tests

    • Remove NewBytes() method

    • Update the NewTcpReader method signature #run_acceptance_tests

    • #run_acceptance_tests

    • #run_acceptance_tests

    • #run_acceptance_tests

    Co-authored-by: Nimrod Gilboa Markevich 59927337+nimrod-up9@users.noreply.github.com

    下载附件