summaryrefslogtreecommitdiff
path: root/src/lib/ecore_ipc
diff options
context:
space:
mode:
authorGustavo Sverzut Barbieri <barbieri@profusion.mobi>2016-11-25 16:48:45 -0200
committerGustavo Sverzut Barbieri <barbieri@profusion.mobi>2016-11-25 17:25:18 -0200
commit16be61c7e15d89ba9ba4529e0d280dcb5fb81da7 (patch)
tree8c8b4952f4cd019ce9bcaf3d34f6ae22d7ae407b /src/lib/ecore_ipc
parentd9dafab78531f676217e0e81d78c0533edd0cc30 (diff)
efl_io_copier_flush: add may_block and ignore_line_delimiter parameters.
The may_block parameter is useful to force a flush without blocking on read/write, sometimes particularly useful if ignore_line_delimiter is true, then you get the data events without blocking -- as if a server sending some content misses a trailing line delimiter, you do not want to block on recv() but still want to flush data to user. The ignore_line_delimiter parameter is useful if we're going to close the copier and want to flush pending data which may exist due missing trailing terminator. The close method will also force that if destination can take more data.
Diffstat (limited to 'src/lib/ecore_ipc')
-rw-r--r--src/lib/ecore_ipc/ecore_ipc.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/lib/ecore_ipc/ecore_ipc.c b/src/lib/ecore_ipc/ecore_ipc.c
index e227251467..e4287aa4fa 100644
--- a/src/lib/ecore_ipc/ecore_ipc.c
+++ b/src/lib/ecore_ipc/ecore_ipc.c
@@ -1210,7 +1210,7 @@ ecore_ipc_server_flush(Ecore_Ipc_Server *svr)
1210 if (svr->dialer.input) 1210 if (svr->dialer.input)
1211 { 1211 {
1212 while (efl_io_queue_usage_get(svr->dialer.input) > 0) 1212 while (efl_io_queue_usage_get(svr->dialer.input) > 0)
1213 efl_io_copier_flush(svr->dialer.send_copier); 1213 efl_io_copier_flush(svr->dialer.send_copier, EINA_TRUE, EINA_TRUE);
1214 return; 1214 return;
1215 } 1215 }
1216 else if (svr->server) 1216 else if (svr->server)
@@ -1627,7 +1627,7 @@ ecore_ipc_client_flush(Ecore_Ipc_Client *cl)
1627 if (cl->socket.input) 1627 if (cl->socket.input)
1628 { 1628 {
1629 while (efl_io_queue_usage_get(cl->socket.input) > 0) 1629 while (efl_io_queue_usage_get(cl->socket.input) > 0)
1630 efl_io_copier_flush(cl->socket.send_copier); 1630 efl_io_copier_flush(cl->socket.send_copier, EINA_TRUE, EINA_TRUE);
1631 return; 1631 return;
1632 } 1632 }
1633#ifndef EFL_NET_SERVER_UNIX_CLASS 1633#ifndef EFL_NET_SERVER_UNIX_CLASS