mirror of
https://github.com/kubeshark/kubeshark.git
synced 2026-05-06 09:17:22 +00:00
d3e6a69d82
* Remove `tcpStreamWrapper` struct * Refactor `tap` module and move some of the code to `tap/api` module * Move `TrafficFilteringOptions` struct to `shared` module * Change the `Dissect` method signature to have `*TcpReader` as an argument * Add `CloseOtherProtocolDissectors` method and use it to synchronously close the other protocol dissectors * Run `go mod tidy` in `cli` module * Rename `SuperIdentifier` struct to `ProtoIdentifier` * Remove `SuperTimer` struct * Bring back `CloseTimedoutTcpStreamChannels` method * Run `go mod tidy` everywhere * Remove `GOGC` environment variable from tapper * Fix the tests * Bring back `debug.FreeOSMemory()` call * Make `CloseOtherProtocolDissectors` method mutexed * Revert "Remove `GOGC` environment variable from tapper" This reverts commitcfc2484bbb. * Bring back the removed `checksum`, `nooptcheck` and `ignorefsmerr` flags * Define a bunch of interfaces and don't export any new structs from `tap/api` * Keep the interfaces in `tap/api` but move the structs to `tap/tcp` * Fix the unit tests by depending on `github.com/up9inc/mizu/tap` * Use the modified `tlsEmitter` * Define `TlsChunk` interface and make `tlsReader` implement `TcpReader` * Remove unused fields in `tlsReader` * Define `ReassemblyStream` interface and separate `gopacket` specififc fields to `tcpReassemblyStream` struct Such that make `tap/api` don't depend on `gopacket` * Remove the unused fields * Make `tlsPoller` implement `TcpStream` interface and remove the call to `NewTcpStreamDummy` method * Remove unused fields from `tlsPoller` * Remove almost all of the setter methods in `TcpReader` and `TcpStream` interface and remove `TlsChunk` interface * Revert "Revert "Remove `GOGC` environment variable from tapper"" This reverts commitab2b9a803b. * Revert "Bring back `debug.FreeOSMemory()` call" This reverts commit1cce863bbb. * Remove excess comment * Fix acceptance tests (`logger` module) #run_acceptance_tests * Bring back `github.com/patrickmn/go-cache` * Fix `NewTcpStream` method signature * Put `tcpReader` and `tcpStream` mocks into protocol dissectors to remove `github.com/up9inc/mizu/tap` dependency * Fix AMQP tests * Revert960ba644cd* Revert `go.mod` and `go.sum` files in protocol dissectors * Fix the comment position * Revert `AppStatsInst` change * Fix indent * Fix CLI build * Fix linter error * Fix error msg * Revert some of the changes in `chunk.go`
76 lines
2.0 KiB
Go
76 lines
2.0 KiB
Go
package tlstapper
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/binary"
|
|
"net"
|
|
|
|
"github.com/go-errors/errors"
|
|
)
|
|
|
|
const FLAGS_IS_CLIENT_BIT uint32 = (1 << 0)
|
|
const FLAGS_IS_READ_BIT uint32 = (1 << 1)
|
|
|
|
// The same struct can be found in maps.h
|
|
//
|
|
// Be careful when editing, alignment and padding should be exactly the same in go/c.
|
|
//
|
|
type tlsChunk struct {
|
|
Pid uint32 // process id
|
|
Tgid uint32 // thread id inside the process
|
|
Len uint32 // the size of the native buffer used to read/write the tls data (may be bigger than tlsChunk.Data[])
|
|
Start uint32 // the start offset withing the native buffer
|
|
Recorded uint32 // number of bytes copied from the native buffer to tlsChunk.Data[]
|
|
Fd uint32 // the file descriptor used to read/write the tls data (probably socket file descriptor)
|
|
Flags uint32 // bitwise flags
|
|
Address [16]byte // ipv4 address and port
|
|
Data [4096]byte // actual tls data
|
|
}
|
|
|
|
func (c *tlsChunk) getAddress() (net.IP, uint16, error) {
|
|
address := bytes.NewReader(c.Address[:])
|
|
var family uint16
|
|
var port uint16
|
|
var ip32 uint32
|
|
|
|
if err := binary.Read(address, binary.BigEndian, &family); err != nil {
|
|
return nil, 0, errors.Wrap(err, 0)
|
|
}
|
|
|
|
if err := binary.Read(address, binary.BigEndian, &port); err != nil {
|
|
return nil, 0, errors.Wrap(err, 0)
|
|
}
|
|
|
|
if err := binary.Read(address, binary.BigEndian, &ip32); err != nil {
|
|
return nil, 0, errors.Wrap(err, 0)
|
|
}
|
|
|
|
ip := net.IP{uint8(ip32 >> 24), uint8(ip32 >> 16), uint8(ip32 >> 8), uint8(ip32)}
|
|
|
|
return ip, port, nil
|
|
}
|
|
|
|
func (c *tlsChunk) isClient() bool {
|
|
return c.Flags&FLAGS_IS_CLIENT_BIT != 0
|
|
}
|
|
|
|
func (c *tlsChunk) isServer() bool {
|
|
return !c.isClient()
|
|
}
|
|
|
|
func (c *tlsChunk) isRead() bool {
|
|
return c.Flags&FLAGS_IS_READ_BIT != 0
|
|
}
|
|
|
|
func (c *tlsChunk) isWrite() bool {
|
|
return !c.isRead()
|
|
}
|
|
|
|
func (c *tlsChunk) getRecordedData() []byte {
|
|
return c.Data[:c.Recorded]
|
|
}
|
|
|
|
func (c *tlsChunk) isRequest() bool {
|
|
return (c.isClient() && c.isWrite()) || (c.isServer() && c.isRead())
|
|
}
|