From 9ec3ec6b9b2936584fe4a6caa73a575c30cd7f4a Mon Sep 17 00:00:00 2001 From: Gaukas Wang Date: Sat, 9 Dec 2023 17:23:52 -0700 Subject: [PATCH] fix: remove redundancy --- examples/pushfd/wasi-pushfd.go | 61 ---------------------------------- 1 file changed, 61 deletions(-) diff --git a/examples/pushfd/wasi-pushfd.go b/examples/pushfd/wasi-pushfd.go index 776fbda55e..bf27aa0c4d 100644 --- a/examples/pushfd/wasi-pushfd.go +++ b/examples/pushfd/wasi-pushfd.go @@ -5,9 +5,7 @@ import ( _ "embed" "fmt" "log" - "net" "os" - "sync" "github.com/tetratelabs/wazero" "github.com/tetratelabs/wazero/api" @@ -106,62 +104,3 @@ func pushOSFile(ctx context.Context, m api.Module) { fmt.Printf("read %d bytes: %s", n, string(buf[:n])) } - -func pushTCPConn(ctx context.Context, m api.Module) { - if m == nil { - log.Panicln("m is nil") - } - - // create a TCP Conn pair - lis, err := net.ListenTCP("tcp", nil) - if err != nil { - log.Panicf("failed to listen: %v", err) - } - defer lis.Close() - - var lisConn *net.TCPConn - var lisWg sync.WaitGroup - lisWg.Add(1) - go func() { - var err error - defer lisWg.Done() - lisConn, err = lis.AcceptTCP() - if err != nil { - log.Panicf("failed to accept: %v", err) - } - }() - - dialConn, err := net.DialTCP("tcp", nil, lis.Addr().(*net.TCPAddr)) - if err != nil { - log.Panicf("failed to dial: %v", err) - } - - lisWg.Wait() - - fd, ok := m.InsertTCPConn(lisConn) - if !ok { - log.Panicln("failed to insert TCPConn") - } - - results, err := m.ExportedFunction("_write").Call(ctx, uint64(fd)) - if err != nil { - log.Panicf("failed to call _write: %v", err) - } - // check the result - if len(results) != 1 { - log.Panicf("unexpected result length: %d", len(results)) - } - result := results[0] - if resi32 := api.DecodeI32(result); resi32 != 12 { - log.Panicf("unexpected result: %d", resi32) - } - - // read the result - buf := make([]byte, 1024) - n, err := dialConn.Read(buf) - if err != nil { - log.Panicf("failed to read: %v", err) - } - - fmt.Printf("read %d bytes: %s", n, string(buf[:n])) -}