|
@@ -224,7 +224,7 @@ func (c *ProxyRelayConfig) Port2port(port1 string, port2 string, stopChan chan b
|
|
time.Sleep(time.Duration(c.Timeout) * time.Second)
|
|
time.Sleep(time.Duration(c.Timeout) * time.Second)
|
|
continue
|
|
continue
|
|
}
|
|
}
|
|
- forward(conn1, conn2, &c.aTobAccumulatedByteTransfer, &c.bToaAccumulatedByteTransfer)
|
|
|
|
|
|
+ go forward(conn1, conn2, &c.aTobAccumulatedByteTransfer, &c.bToaAccumulatedByteTransfer)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -322,7 +322,7 @@ func (c *ProxyRelayConfig) Host2host(address1, address2 string, stopChan chan bo
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- forward(host1, host2, &c.aTobAccumulatedByteTransfer, &c.bToaAccumulatedByteTransfer)
|
|
|
|
|
|
+ go forward(host1, host2, &c.aTobAccumulatedByteTransfer, &c.bToaAccumulatedByteTransfer)
|
|
}
|
|
}
|
|
|
|
|
|
return nil
|
|
return nil
|