From 9b12e9819c99d91eba48f3309bff7464190cf112 Mon Sep 17 00:00:00 2001 From: hackerchai Date: Tue, 6 Aug 2024 14:32:30 +0800 Subject: [PATCH] fix(c/libuv/demo): Fix echo_server stream convert --- c/libuv/_demo/echo_server/echo_server.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/c/libuv/_demo/echo_server/echo_server.go b/c/libuv/_demo/echo_server/echo_server.go index 9d961200..2c9a71b8 100644 --- a/c/libuv/_demo/echo_server/echo_server.go +++ b/c/libuv/_demo/echo_server/echo_server.go @@ -31,7 +31,7 @@ func main() { // Bind the server to the specified address and port (&server).Bind((*net.SockAddr)(c.Pointer(&addr)), 0) - res := (*libuv.Stream)(&server).Listen(DEFAULT_BACKLOG, OnNewConnection) + res := (*libuv.Stream)(unsafe.Pointer(&server)).Listen(DEFAULT_BACKLOG, OnNewConnection) if res != 0 { c.Fprintf(c.Stderr, c.Str("Listen error: %s\n"), libuv.Strerror((libuv.Errno(res)))) return @@ -110,8 +110,8 @@ func OnNewConnection(server *libuv.Stream, status c.Int) { } // Accept the new connection and start reading data. - if server.Accept((*libuv.Stream)(client)) == 0 { - (*libuv.Stream)(client).StartRead(AllocBuffer, EchoRead) + if server.Accept((*libuv.Stream)(unsafe.Pointer(client))) == 0 { + (*libuv.Stream)(unsafe.Pointer(client)).StartRead(AllocBuffer, EchoRead) } else { (*libuv.Handle)(c.Pointer(client)).Close(nil) }