diff --git a/legacy/ecore/src/lib/ecore_con/ecore_con.c b/legacy/ecore/src/lib/ecore_con/ecore_con.c index 702d7a0c99..de291b3b96 100644 --- a/legacy/ecore/src/lib/ecore_con/ecore_con.c +++ b/legacy/ecore/src/lib/ecore_con/ecore_con.c @@ -45,7 +45,6 @@ static Eina_Bool _ecore_con_client_timer(Ecore_Con_Client *cl); static void _ecore_con_cl_timer_update(Ecore_Con_Client *cl); -static void _ecore_con_client_kill(Ecore_Con_Client *cl); static Eina_Bool _ecore_con_server_timer(Ecore_Con_Server *svr); static void _ecore_con_server_timer_update(Ecore_Con_Server *svr); @@ -105,7 +104,7 @@ static void _ecore_con_lookup_done(void *data, static const char * _ecore_con_pretty_ip(struct sockaddr *client_addr); -static void +void _ecore_con_client_kill(Ecore_Con_Client *cl) { if (cl->delete_me) diff --git a/legacy/ecore/src/lib/ecore_con/ecore_con_local_win32.c b/legacy/ecore/src/lib/ecore_con/ecore_con_local_win32.c index 90f092920c..2b7e5c5bd2 100644 --- a/legacy/ecore/src/lib/ecore_con/ecore_con_local_win32.c +++ b/legacy/ecore/src/lib/ecore_con/ecore_con_local_win32.c @@ -75,8 +75,7 @@ _ecore_con_local_win32_server_read_client_handler(void *data, Ecore_Win32_Handle free(msg); } #endif - if (!cl->delete_me) - ecore_con_event_client_del(cl); + _ecore_con_client_kill(cl); return ECORE_CALLBACK_CANCEL; } @@ -109,8 +108,7 @@ _ecore_con_local_win32_server_peek_client_handler(void *data, Ecore_Win32_Handle free(msg); } #endif - if (!cl->host_server->delete_me) - ecore_con_event_server_del(cl->host_server); + _ecore_con_server_kill(cl->host_server); return ECORE_CALLBACK_CANCEL; ecore_main_win32_handler_del(wh); @@ -138,8 +136,7 @@ _ecore_con_local_win32_client_peek_server_handler(void *data, Ecore_Win32_Handle free(msg); } #endif - if (!svr->delete_me) - ecore_con_event_server_del(svr); + _ecore_con_server_kill(svr); return ECORE_CALLBACK_CANCEL; ecore_main_win32_handler_del(wh); @@ -188,8 +185,7 @@ _ecore_con_local_win32_client_read_server_handler(void *data, Ecore_Win32_Handle free(msg); } #endif - if (!svr->delete_me) - ecore_con_event_server_del(svr); + _ecore_con_server_kill(svr); return ECORE_CALLBACK_CANCEL; } @@ -691,15 +687,14 @@ ecore_con_local_win32_server_flush(Ecore_Con_Server *svr) ecore_con_event_server_error(svr, msg); free(msg); } - if (!svr->delete_me) - ecore_con_event_server_del(svr); + _ecore_con_server_kill(svr); } svr->write_buf_offset += written; if (svr->write_buf_offset >= eina_binbuf_length_get(svr->buf)) { svr->write_buf_offset = 0; - eina_binbuf_free(svr->buf); + eina_binbuf_free(svr->buf); svr->buf = NULL; svr->want_write = 0; } @@ -741,8 +736,7 @@ ecore_con_local_win32_client_flush(Ecore_Con_Client *cl) ecore_con_event_client_error(cl, msg); free(msg); } - if (!cl->delete_me) - ecore_con_event_client_del(cl); + _ecore_con_client_kill(cl); } cl->buf_offset += written; diff --git a/legacy/ecore/src/lib/ecore_con/ecore_con_private.h b/legacy/ecore/src/lib/ecore_con/ecore_con_private.h index e48f553c1e..35f2310a76 100644 --- a/legacy/ecore/src/lib/ecore_con/ecore_con_private.h +++ b/legacy/ecore/src/lib/ecore_con/ecore_con_private.h @@ -291,6 +291,7 @@ void ecore_con_event_client_data(Ecore_Con_Client *cl, unsigned char *buf, int n void ecore_con_event_client_del(Ecore_Con_Client *cl); void ecore_con_event_client_error(Ecore_Con_Client *cl, const char *error); void _ecore_con_server_kill(Ecore_Con_Server *svr); +void _ecore_con_client_kill(Ecore_Con_Client *cl); /* from ecore_local_win32.c */ #ifdef _WIN32 Eina_Bool ecore_con_local_listen(Ecore_Con_Server *svr);