diff --git a/tcp/flow.go b/tcp/flow.go
index 5436883..924b80e 100644
--- a/tcp/flow.go
+++ b/tcp/flow.go
@@ -112,9 +112,9 @@ func (f *InitiatedFlow) Reconnect() error {
 		return err
 	}
 
-	if err := conn.SetWriteBuffer(20); err != nil {
-		return err
-	}
+	//if err := conn.SetWriteBuffer(20); err != nil {
+	//	return err
+	//}
 
 	f.conn = conn
 	f.isAlive = true
@@ -209,7 +209,7 @@ func (f *Flow) consumeMarshalled() {
 }
 
 func (f *Flow) produceMarshalled() {
-	buf := bufio.NewReaderSize(f.conn, 100000)
+	buf := bufio.NewReader(f.conn)
 
 	for {
 		t1 := time.Now()
diff --git a/tcp/listener.go b/tcp/listener.go
index e1427f5..50d4abf 100644
--- a/tcp/listener.go
+++ b/tcp/listener.go
@@ -24,9 +24,9 @@ func NewListener(p *proxy.Proxy, local string, v func() proxy.MacVerifier, g fun
 				panic(err)
 			}
 
-			if err := conn.SetWriteBuffer(20); err != nil {
-				panic(err)
-			}
+			//if err := conn.SetWriteBuffer(20); err != nil {
+			//	panic(err)
+			//}
 
 			f := NewFlowConn(conn)