-
Spawn only two Goroutines per TCP stream (#1062)
发布于
2022-05-16 13:06:36 +00:00 -
Spawn only two Goroutines per TCP stream
-
Fix the linter error
-
Use
isProtocolIdentifiedmethod instead -
Fix the
Readmethod oftcpReader -
Remove unnecessary
append -
Copy to buffer only a message is received
-
Remove
exhaustBufferfield and addrewindfunction -
Rename
bufferfield topastData -
Update tap/tcp_reader.go
Co-authored-by: Nimrod Gilboa Markevich 59927337+nimrod-up9@users.noreply.github.com
-
Use
copyinstead 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.Bufferinstead of[]api.TcpReaderDataMsg#run_acceptance_tests -
Have a single
*bytes.Buffer -
Revert "Have a single
*bytes.Buffer"
This reverts commit fad96a288ad51792e118be166643e3b58f239600.
- Revert "Use
*bytes.Bufferinstead of[]api.TcpReaderDataMsg#run_acceptance_tests"
This reverts commit 0fc70bffe2f877eb25e43931dc4790dc09d7832d.
-
Fix the early timing out issue #run_acceptance_tests
-
Remove
NewBytes()method -
Update the
NewTcpReadermethod 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
下载附件
-