- go performSP(ctx, conn, "PIPE", nice, *noCK, nodeIdC)
+ addr := "PIPE"
+ if proto := os.Getenv("PROTO"); proto == "TCP" {
+ port := os.Getenv("TCPREMOTEPORT")
+ if host := os.Getenv("TCPREMOTEHOST"); host == "" {
+ addr = fmt.Sprintf("[%s]:%s", os.Getenv("TCPREMOTEIP"), port)
+ } else {
+ addr = fmt.Sprintf("%s:%s", host, port)
+ }
+ }
+ go performSP(ctx, conn, addr, nice, *noCK, nodeIdC)