//hyper/process: connect outgoing pipes

1 files changed, 10 insertions, 3 deletions

diff --git a/hyper/process/src/hyper/process/process.go b/hyper/process/src/hyper/process/process.go
index a52197f0..18cf55fb 100644
--- a/hyper/process/src/hyper/process/process.go
+++ b/hyper/process/src/hyper/process/process.go
@@ -18,6 +18,7 @@ type Process struct {
   process_stdout *os.File
   process_stderr *os.File
   id string
+  client http.Client
 }
 
 func (p *Process) Id() string {
@@ -99,18 +100,24 @@ func (hp *Process) Start() os.Error {
     file.Close()
   }
 
-  go reader(hp.process_stdout)
-  go reader(hp.process_stderr)
+  go hp.reader(hp.process_stdout, hp.Stdout)
+  go hp.reader(hp.process_stderr, hp.Stderr)
   return nil
 }
 
-func reader(file *os.File) {
+func (p *Process) reader(file *os.File, url string) {
   var b []byte = make([]byte, 1024)
   var err os.Error = nil
   for err == nil {
     var n int
     n, err = file.Read(b)
     fmt.Printf("data: %d, %s\n", n, b)
+
+    res, err := p.client.Post(url, "application/octet-stream", bytes.NewBuffer(b))
+    res = res
+    if err != nil {
+      fmt.Printf("EE: %s: %s\n", url, err)
+    }
   }
 }