3 files changed, 49 insertions, 14 deletions
diff --git a/fs/fd.c b/fs/fd.c
index fe34003..1936f37 100644
--- a/fs/fd.c
+++ b/fs/fd.c
@@ -149,25 +149,57 @@ fd fd_from_fifo(fifo* fif)
     return f;
 }
 
-fd fd_from_pipe()
+uint8_t pipe_get(uint32_t *data)
 {
-    fd f;
-    f.type=FD_TYPE_PIPE;
-    f.data=kballoc(1);
+    return ringbuffer_get(data);
+}
+
+void pipe_put(void* data,uint8_t b)
+{
+    ringbuffer_put(data,b);
+}
+
+bool pipe_has(uint32_t *data)
+{
+    return ringbuffer_has(data);
+}
+
+bool pipe_eof(uint32_t *data)
+{
+    return 0;
+}
+
+int fds_from_pipe(fd pipefds[2])
+{
+    fd read;
+    fd wrt;
+
+    read.type=FD_TYPE_PIPE;
+    wrt.type=FD_TYPE_PIPE;
+
+    read.data=kballoc(1);
+    wrt.data=read.type;
+
     ringbuffer r=ringbuffer_init(1);
 
-    memcpy(f.data,&r,sizeof(ringbuffer));
+    memcpy(read.data,&r,sizeof(ringbuffer));
+    
+    read.read=pipe_get;
+    wrt.write=pipe_put;
 
-    /*
-    f.read=sysfs_get;
-    f.write=0;
-    f.has=sysfs_has;
-    f.eof=sysfs_eof;
-    */
+    read.has=pipe_has;
+    wrt.has=pipe_has;
 
-    f.close=pipe_close;
+    read.eof=pipe_eof;
+    wrt.eof=pipe_eof;
+
+    read.close=0;
+    wrt.close=0;
+
+    pipefds[0]=read;
+    pipefds[1]=wrt;
     
-    return f;
+    return 0;
 }
 
 fd fd_from_path(char* path)
diff --git a/fs/fd.h b/fs/fd.h
index c9b7fd8..64a53ed 100644
--- a/fs/fd.h
+++ b/fs/fd.h
@@ -38,5 +38,6 @@ bool    fd_close(fd*);
 fd fd_from_fifo(fifo* f);
 fd fd_from_path(char *path);
 fd fd_from_sysfs(void(*g)(ringbuffer *r,void (*f)(ringbuffer *r,char *fmt, ...)),void(*h)(uint32_t in));
+int fds_from_pipe(fd pipefds[2]);
 
 #endif
diff --git a/fs/pipe.c b/fs/pipe.c
index cbba7a9..3802851 100644
--- a/fs/pipe.c
+++ b/fs/pipe.c
@@ -5,8 +5,10 @@
 
 #include "lib/string/string.h"
 
-/* mount interface */
+#define MAX_PIPES 100
+
 
+/* mount interface */
 fd pipe_file_open(mount *m,char *path)
 {
     fd a;