From 4138cc649408df36b94b0093bfc9f4500718313e Mon Sep 17 00:00:00 2001 From: 9seconds Date: Fri, 13 Mar 2026 11:31:28 +0100 Subject: [PATCH] Use SyncWrite call to send a packet to proxy --- mtglib/internal/doppel/conn_test.go | 4 ++-- mtglib/proxy.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/mtglib/internal/doppel/conn_test.go b/mtglib/internal/doppel/conn_test.go index f8adb91..eec1f6f 100644 --- a/mtglib/internal/doppel/conn_test.go +++ b/mtglib/internal/doppel/conn_test.go @@ -247,7 +247,7 @@ func (suite *ConnTestSuite) TestSyncWriteBlocksAsyncWrite() { go func() { defer close(syncDone) - c.SyncWrite([]byte("exclusive")) + c.SyncWrite([]byte("exclusive")) //nolint: errcheck }() // Give SyncWrite time to acquire the lock. @@ -258,7 +258,7 @@ func (suite *ConnTestSuite) TestSyncWriteBlocksAsyncWrite() { go func() { defer close(writeDone) - c.Write([]byte("blocked")) + c.Write([]byte("blocked")) //nolint: errcheck }() // SyncWrite should finish first. diff --git a/mtglib/proxy.go b/mtglib/proxy.go index da1b636..4afcdd8 100644 --- a/mtglib/proxy.go +++ b/mtglib/proxy.go @@ -90,7 +90,7 @@ func (p *Proxy) ServeConn(conn essentials.Conn) { } defer clientConn.Stop() - if _, err := clientConn.Write(noise); err != nil { + if _, err := clientConn.SyncWrite(noise); err != nil { ctx.logger.InfoError("cannot send the first packet", err) return }