From f8181ccb07e54ef5ecb51a626898ccf56b193e90 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?M=2E=20Mert=20Y=C4=B1ld=C4=B1ran?= Date: Sat, 14 May 2022 08:37:16 -0700 Subject: [PATCH] Remove `ReassemblyStream` interface (duplicate of `gopacket/reassembly.Stream`) (#1079) --- tap/tcp_reassembly_stream.go | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/tap/tcp_reassembly_stream.go b/tap/tcp_reassembly_stream.go index 36edefc41..16ed07afe 100644 --- a/tap/tcp_reassembly_stream.go +++ b/tap/tcp_reassembly_stream.go @@ -10,12 +10,6 @@ import ( "github.com/up9inc/mizu/tap/diagnose" ) -type ReassemblyStream interface { - Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDirection, nextSeq reassembly.Sequence, start *bool, ac reassembly.AssemblerContext) bool - ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext) - ReassemblyComplete(ac reassembly.AssemblerContext) bool -} - type tcpReassemblyStream struct { ident string tcpState *reassembly.TCPSimpleFSM @@ -25,7 +19,7 @@ type tcpReassemblyStream struct { tcpStream api.TcpStream } -func NewTcpReassemblyStream(ident string, tcp *layers.TCP, fsmOptions reassembly.TCPSimpleFSMOptions, stream api.TcpStream) ReassemblyStream { +func NewTcpReassemblyStream(ident string, tcp *layers.TCP, fsmOptions reassembly.TCPSimpleFSMOptions, stream api.TcpStream) reassembly.Stream { return &tcpReassemblyStream{ ident: ident, tcpState: reassembly.NewTCPSimpleFSM(fsmOptions),