summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/lib/ecore_con/ecore_con_legacy.c4
-rw-r--r--src/lib/ecore_ipc/ecore_ipc.c3
2 files changed, 7 insertions, 0 deletions
diff --git a/src/lib/ecore_con/ecore_con_legacy.c b/src/lib/ecore_con/ecore_con_legacy.c
index e99b4a90bd..684c25da58 100644
--- a/src/lib/ecore_con/ecore_con_legacy.c
+++ b/src/lib/ecore_con/ecore_con_legacy.c
@@ -2262,6 +2262,10 @@ ecore_con_server_flush(Ecore_Con_Server *svr)
2262 2262
2263 if (!svr->dialer) return; 2263 if (!svr->dialer) return;
2264 2264
2265 while (!efl_io_closer_closed_get(svr->dialer) &&
2266 !efl_net_dialer_connected_get(svr->dialer))
2267 ecore_main_loop_iterate();
2268
2265 efl_io_buffered_stream_flush(svr->dialer, EINA_FALSE, EINA_TRUE); 2269 efl_io_buffered_stream_flush(svr->dialer, EINA_FALSE, EINA_TRUE);
2266 2270
2267 inner_dialer = efl_io_buffered_stream_inner_io_get(svr->dialer); 2271 inner_dialer = efl_io_buffered_stream_inner_io_get(svr->dialer);
diff --git a/src/lib/ecore_ipc/ecore_ipc.c b/src/lib/ecore_ipc/ecore_ipc.c
index 40a1e1e8a7..ec83de76f5 100644
--- a/src/lib/ecore_ipc/ecore_ipc.c
+++ b/src/lib/ecore_ipc/ecore_ipc.c
@@ -1182,6 +1182,9 @@ ecore_ipc_server_flush(Ecore_Ipc_Server *svr)
1182 } 1182 }
1183 if (svr->dialer.input) 1183 if (svr->dialer.input)
1184 { 1184 {
1185 while (!efl_io_closer_closed_get(svr->dialer.dialer) &&
1186 !efl_net_dialer_connected_get(svr->dialer.dialer))
1187 ecore_main_loop_iterate();
1185 while (efl_io_queue_usage_get(svr->dialer.input) > 0) 1188 while (efl_io_queue_usage_get(svr->dialer.input) > 0)
1186 efl_io_copier_flush(svr->dialer.send_copier, EINA_TRUE, EINA_TRUE); 1189 efl_io_copier_flush(svr->dialer.send_copier, EINA_TRUE, EINA_TRUE);
1187 return; 1190 return;