fanasina/y_project
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

y_socket: debug no mut go_on workers before handling buf

Browse Source
This commit is contained in:
fanasina
2025-10-11 08:21:53 +02:00
parent b3c5fd38dc
commit 4b2ffe6cf6
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
y_socket_t/src/y_socket_t/y_socket_t.c
+2 -6
View File
@@ -719,8 +719,7 @@ void *y_socket_poll_fds(void *arg){
memset(&(node.addr), 0, sizeof(struct sockaddr_storage)); memset(&(node.addr), 0, sizeof(struct sockaddr_storage));
size_t len_sockaddr_storage = sizeof(struct sockaddr_storage); size_t len_sockaddr_storage = sizeof(struct sockaddr_storage);
node.addr_len = len_sockaddr_storage; // sizeof(struct sockaddr_storage); node.addr_len = len_sockaddr_storage; // sizeof(struct sockaddr_storage);
int w_go_on=1;
for(;check_y_socket_go_on(argSock);){ for(;check_y_socket_go_on(argSock);){
printf("poll: wait events\n"); printf("poll: wait events\n");
status = poll(fds, nbIpVersion + 1, -1); status = poll(fds, nbIpVersion + 1, -1);
@@ -798,10 +797,7 @@ void *y_socket_poll_fds(void *arg){
/// ///
} }
pthread_mutex_lock(argSock->mut_go_on); if(argSock->go_on && m_str){
w_go_on = argSock->go_on;
pthread_mutex_unlock(argSock->mut_go_on);
if(w_go_on && m_str){
printf("debug: call handle_buf_socket_rec\n"); printf("debug: call handle_buf_socket_rec\n");
handle_buf_socket_rec(m_ok_head_l_t,m_head_l_t,m_str, node, workers, argx, list_arg, arg); handle_buf_socket_rec(m_ok_head_l_t,m_head_l_t,m_str, node, workers, argx, list_arg, arg);