diff --git a/agent/main.go b/agent/main.go index fdd637a4b..c310aa16d 100644 --- a/agent/main.go +++ b/agent/main.go @@ -294,6 +294,7 @@ func pipeTapChannelToSocket(connection *websocket.Conn, messageDataChannel <-cha // NOTE: This is where the `*tapApi.OutputChannelItem` leaves the code // and goes into the intermediate WebSocket. + // (DEBUG_PERF 7) Comment out to disable writing to WebSocket err = connection.WriteMessage(websocket.TextMessage, marshaledData) if err != nil { logger.Log.Errorf("error sending message through socket server %v, err: %s, (%v,%+v)", messageData, err, err, err) diff --git a/agent/pkg/app/main.go b/agent/pkg/app/main.go index 65b7cb41d..3fb7ff5fd 100644 --- a/agent/pkg/app/main.go +++ b/agent/pkg/app/main.go @@ -24,6 +24,8 @@ var ( ) func LoadExtensions() { + // (DEBUG_PERF 5) Comment out paragraphs to disable extensions + // Remember to fix indices: Length of Extensions slice, index in assignment to Extensions Extensions = make([]*tapApi.Extension, 4) ExtensionsMap = make(map[string]*tapApi.Extension) diff --git a/tap/api/api.go b/tap/api/api.go index 74929210b..774abde90 100644 --- a/tap/api/api.go +++ b/tap/api/api.go @@ -149,6 +149,7 @@ type Emitter interface { } func (e *Emitting) Emit(item *OutputChannelItem) { + // (DEBUG_PERF 6) Comment out to disable emitting from tapper to api-server e.OutputChannel <- item e.AppStats.IncMatchedPairs() } diff --git a/tap/source/packet_source_manager.go b/tap/source/packet_source_manager.go index 9dcb60a27..2daf7f47a 100644 --- a/tap/source/packet_source_manager.go +++ b/tap/source/packet_source_manager.go @@ -44,6 +44,7 @@ func NewPacketSourceManager(procfs string, filename string, interfaceName string behaviour: behaviour, } + // (DEBUG_PERF 1) Comment out to disable host pcap (do not pass --tls or --service-mesh) go hostSource.readPackets(ipdefrag, packets) return sourceManager, nil } diff --git a/tap/tcp_assembler.go b/tap/tcp_assembler.go index eee1dbbe0..0e3f0458a 100644 --- a/tap/tcp_assembler.go +++ b/tap/tcp_assembler.go @@ -78,6 +78,7 @@ func (a *tcpAssembler) processPackets(dumpPacket bool, packets <-chan source.Tcp logger.Log.Debugf("Packet content (%d/0x%x) - %s", len(data), len(data), hex.Dump(data)) } + // (DEBUG_PERF 2) Comment out to disable assembler tcp := packet.Layer(layers.LayerTypeTCP) if tcp != nil { diagnose.AppStats.IncTcpPacketsCount() diff --git a/tap/tcp_reader.go b/tap/tcp_reader.go index 5af4b828d..472d93f03 100644 --- a/tap/tcp_reader.go +++ b/tap/tcp_reader.go @@ -55,6 +55,8 @@ func NewTcpReader(msgQueue chan api.TcpReaderDataMsg, progress *api.ReadProgress func (reader *tcpReader) run(options *api.TrafficFilteringOptions, wg *sync.WaitGroup) { defer wg.Done() b := bufio.NewReader(reader) + // (DEBUG_PERF 4) Swap with next line to disable dissectors + // _, _ = io.ReadAll(b) err := reader.extension.Dissector.Dissect(b, reader, options) if err != nil { _, err = io.Copy(ioutil.Discard, reader) diff --git a/tap/tcp_stream.go b/tap/tcp_stream.go index 753d00b20..13e0930d6 100644 --- a/tap/tcp_stream.go +++ b/tap/tcp_stream.go @@ -132,6 +132,7 @@ func (t *tcpStream) GetReqResMatchers() []api.RequestResponseMatcher { } func (t *tcpStream) GetIsTapTarget() bool { + // (DEBUG_PERF 3) Return false to disable Dissecting return t.isTapTarget }