gnh1201/wasm-micro-runtime
1
0
Fork 0
mirror of https://github.com/bytecodealliance/wasm-micro-runtime.git synced 2025-09-06 01:41:35 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Fix socket shutdown (#12) (#4449)

Browse Source
This commit is contained in:
TianlongLiang 2025-07-07 02:02:28 +08:00 committed by GitHub
parent 8a55a1e7a1
commit be33a40ba7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
samples/socket-api/README.md
View File

@ -79,7 +79,7 @@ Client is running...
Start receiving. Start receiving.
Start sending. Start sending.
Send 106 bytes successfully! Send 106 bytes successfully!
Receive 106 bytes successlly! Receive 106 bytes successfully!
Data: Data:
The stars shine down The stars shine down
It brings us light It brings us light

10
samples/socket-api/wasm-src/send_recv.c
View File

@ -25,6 +25,7 @@ static bool server_is_ready = false;
void * void *
run_as_server(void *arg) run_as_server(void *arg)
{ {
(void)arg;
int sock = -1, on = 1; int sock = -1, on = 1;
struct sockaddr_in addr = { 0 }; struct sockaddr_in addr = { 0 };
int addrlen = 0; int addrlen = 0;
@ -109,7 +110,7 @@ run_as_server(void *arg)
fail2: fail2:
close(new_sock); close(new_sock);
fail1: fail1:
shutdown(sock, SHUT_RD); shutdown(sock, SHUT_RDWR);
close(sock); close(sock);
return NULL; return NULL;
} }
@ -117,6 +118,7 @@ fail1:
void * void *
run_as_client(void *arg) run_as_client(void *arg)
{ {
(void)arg;
int sock = -1; int sock = -1;
struct sockaddr_in addr = { 0 }; struct sockaddr_in addr = { 0 };
/* buf of server is 106 bytes */ /* buf of server is 106 bytes */
@ -159,7 +161,7 @@ run_as_client(void *arg)
goto fail; goto fail;
} }
printf("Receive %ld bytes successlly!\n", recv_len); printf("Receive %ld bytes successfully!\n", recv_len);
assert(recv_len == 106); assert(recv_len == 106);
printf("Data:\n"); printf("Data:\n");
@ -170,7 +172,7 @@ run_as_client(void *arg)
} }
fail: fail:
shutdown(sock, SHUT_RD); shutdown(sock, SHUT_RDWR);
close(sock); close(sock);
return NULL; return NULL;
} }
@ -178,6 +180,8 @@ fail:
int int
main(int argc, char *argv[]) main(int argc, char *argv[])
{ {
(void)argc;
(void)argv;
pthread_t cs[2] = { 0 }; pthread_t cs[2] = { 0 };
uint8_t i = 0; uint8_t i = 0;
int ret = EXIT_SUCCESS; int ret = EXIT_SUCCESS;

10
samples/wasm-c-api-imports/wasm/send_recv.c
View File

@ -50,6 +50,7 @@ local_printf(const char *formatter, ...)
void * void *
run_as_server(void *arg) run_as_server(void *arg)
{ {
(void)arg;
int sock = -1, on = 1; int sock = -1, on = 1;
struct sockaddr_in addr = { 0 }; struct sockaddr_in addr = { 0 };
int addrlen = 0; int addrlen = 0;
@ -134,7 +135,7 @@ run_as_server(void *arg)
fail2: fail2:
close(new_sock); close(new_sock);
fail1: fail1:
shutdown(sock, SHUT_RD); shutdown(sock, SHUT_RDWR);
close(sock); close(sock);
return NULL; return NULL;
} }
@ -142,6 +143,7 @@ fail1:
void * void *
run_as_client(void *arg) run_as_client(void *arg)
{ {
(void)arg;
int sock = -1; int sock = -1;
struct sockaddr_in addr = { 0 }; struct sockaddr_in addr = { 0 };
/* buf of server is 106 bytes */ /* buf of server is 106 bytes */
@ -184,7 +186,7 @@ run_as_client(void *arg)
goto fail; goto fail;
} }
local_printf("Receive %ld bytes successlly!\n", recv_len); local_printf("Receive %ld bytes successfully!\n", recv_len);
assert(recv_len == 106); assert(recv_len == 106);
local_printf("Data:\n"); local_printf("Data:\n");
@ -195,7 +197,7 @@ run_as_client(void *arg)
} }
fail: fail:
shutdown(sock, SHUT_RD); shutdown(sock, SHUT_RDWR);
close(sock); close(sock);
return NULL; return NULL;
} }
@ -203,6 +205,8 @@ fail:
int int
main(int argc, char *argv[]) main(int argc, char *argv[])
{ {
(void)argc;
(void)argv;
pthread_t cs[2] = { 0 }; pthread_t cs[2] = { 0 };
uint8_t i = 0; uint8_t i = 0;
int ret = EXIT_SUCCESS; int ret = EXIT_SUCCESS;