mirror of
https://github.com/buger/goreplay.git
synced 2024-04-21 12:32:02 +00:00
Urban IshimweandGitHub
fdc8b094f0
### performance - handling of the very big packet(any size that can be buffered) - speeding up TCP sessions by using message hints: Added **proto.HasFullPayload** that helps to validate the entire HTTP request, it supports `Chunked` encoding too! Added **proto.HasRequestTitle** and **proto.HasResponseTitle** for validating the beginning of HTTP request. Those methods are used `input_raw.go` with `TCP`. - supports Keep-Alive: the above functions helps to support keep-alive ### Packaging - **capture:** engines(capture/doc.go) - **tcp:** tcp message parser (tcp/doc.go) ### benchmarking - **capture.BenchmarkPcapDump:** the benchmarks regarding dumping packets in a pcap file - **capture.BenchmarkPcapFile:** the benchmarks of reading packets from a pcap file - **capture.BenchmarkPcap:** the benchmarks of parsing packets from the loopback interface with pcap handles - **proto.BenchmarkHasFullPayload:**: benchmarking this function which validates the HTTP payload - **tcp.BenchmarkPacketParseAndSort:** benchmarks of parsing and sorting packets - **tcp.BenchmarkMessageParserWithoutHint:** benchmarks of message reasembling by using `SYN` and `FIN` flag - **tcp.BenchmarkMessageParserWithHint:** benchmarks of message reasembling by using `proto.HasRequestTitle` and `proto.HasFullPayload` flag ### issues see linked issues ### tests - fixed input raw and engine tests **Most of the changed of the files, was about using functionalities of** `tcp` **and** `capture` **in existing functionalities**
36 lines
1003 B
Go
36 lines
1003 B
Go
/*
|
|
Package capture provides traffic sniffier using AF_PACKET, pcap or pcap file.
|
|
it allows you to listen for traffic from any port (e.g. sniffing) because they operate on IP level.
|
|
Ports is TCP/IP feature, same as flow control, reliable transmission and etc.
|
|
Currently this package implements TCP layer: flow control is managed under tcp package.
|
|
BPF filters can also be applied.
|
|
|
|
example:
|
|
|
|
// for the transport should be "tcp"
|
|
listener, err := capture.NewListener(host, port, transport, engine, trackResponse)
|
|
if err != nil {
|
|
// handle error
|
|
}
|
|
listener.SetPcapOptions(opts)
|
|
err = listner.Activate()
|
|
if err != nil {
|
|
// handle it
|
|
}
|
|
|
|
if err := listener.Listen(context.Background(), handler); err != nil {
|
|
// handle error
|
|
}
|
|
// or
|
|
errCh := listener.ListenBackground(context.Background(), handler) // runs in the backgorund
|
|
select {
|
|
case err := <- errCh:
|
|
// handle error
|
|
case <-quit:
|
|
//
|
|
case <- l.Reading: // if we have started reading
|
|
}
|
|
|
|
*/
|
|
package capture // import github.com/buger/goreplay/capture
|