pile of go ssh port forward attempt

sshportforward2.go

package main

import (
  "code.google.com/p/go.crypto/ssh"
  //"net/http"
  "io/ioutil"
  "net"
)

func main() {
  config := &ssh.ClientConfig{
      User: "root",
      Auth: []ssh.ClientAuth{
          ssh.ClientAuthPassword(ssh.PasswordAuth("password")),
      },
  }
  conn := Dial(config)
  defer conn.Close()
  sshListener, err := conn.Listen("tcp", "192.168.1.100:22")
  if err != nil {
    t.Fatalf("conn.Listen failed: %v", err)
  }

  go func() {
    sshConn, err := sshListener.Accept()
    if err != nil {
      t.Fatalf("listen.Accept failed: %v", err)
    }

    _, err = io.Copy(sshConn, sshConn)
    if err != nil && err != io.EOF {
      t.Fatalf("ssh client copy: %v", err)
    }
    sshConn.Close()
  }()

  forwardedAddr := sshListener.Addr().String()
  tcpConn, err := net.Dial("tcp", forwardedAddr)
  if err != nil {
    t.Fatalf("TCP dial failed: %v", err)
  }

  readChan := make(chan []byte)
  go func() {
    data, _ := ioutil.ReadAll(tcpConn)
    readChan <- data
  }()
//
//  // Invent some data.
//  data := make([]byte, 100*1000)
//  for i := range data {
//    data[i] = byte(i % 255)
//  }
//
//  var sent []byte
//  for len(sent) < 1000*1000 {
//    // Send random sized chunks
//    m := rand.Intn(len(data))
//    n, err := tcpConn.Write(data[:m])
//    if err != nil {
//      break
//    }
//    sent = append(sent, data[:n]...)
//  }
//  if err := tcpConn.(*net.TCPConn).CloseWrite(); err != nil {
//    t.Errorf("tcpConn.CloseWrite: %v", err)
//  }
//
//  read := <-readChan
//
//  if len(sent) != len(read) {
//    t.Fatalf("got %d bytes, want %d", len(read), len(sent))
//  }
//  if bytes.Compare(sent, read) != 0 {
//    t.Fatalf("read back data does not match")
//  }
//
  if err := sshListener.Close(); err != nil {
    t.Fatalf("sshListener.Close: %v", err)
  }
}