X-Git-Url: https://git.cworth.org/git?p=ttt;a=blobdiff_plain;f=src%2Fttt-socket.c;h=199535f300e200d0970341ea6177e53cf35bbf70;hp=f185d363780af7e5c43cb334f9e7ae42c52a258d;hb=15672ac8305a1c5ba0d9bf6edabb0a194c30628e;hpb=5d56d3cd8b4685e905ed604277ac9cb32c876127

diff --git a/src/ttt-socket.c b/src/ttt-socket.c
index f185d36..199535f 100644
--- a/src/ttt-socket.c
+++ b/src/ttt-socket.c
@@ -150,16 +150,41 @@ ttt_socket_accept (int				 listen_socket,
 		   ttt_socket_accept_func_t	 accept,
 		   void				*closure)
 {
-    pid_t pid;
     int connected_socket;
 
     connected_socket = _wait_for_connection (listen_socket);
 
-    pid = xfork();
+    (accept) (closure, connected_socket);
+}
+
+/* Exported: see ttt-socket.h for documentation. */
+void
+ttt_socket_read (int	 socket,
+		 void	*buf,
+		 size_t	 count)
+{
+    int bytes_read;
+    char *cbuf = buf;
+
+    while (count) {
+	bytes_read = xread (socket, cbuf, count);
+	cbuf += bytes_read;
+	count -= bytes_read;
+    }
+}
+
+/* Exported: see ttt-socket.h for documentation. */
+void
+ttt_socket_write (int		 socket,
+		  const void	*buf,
+		  size_t	 count)
+{
+    int written;
+    const char *cbuf = buf;
 
-    if (pid == 0) {
-	/* Child process. */
-	(accept) (closure, connected_socket);
-	return;
+    while (count) {
+	written = xwrite (socket, cbuf, count);
+	cbuf += written;
+	count -= written;
     }
 }