mirrors_public/schollz_croc
0
0
Fork 0
mirror of https://github.com/schollz/croc.git synced 2025-10-11 13:21:00 +02:00
Code Activity

fix debugging statements

Browse source
This commit is contained in:
Zack Scholl 2019-09-07 06:41:49 -07:00
parent 5b980fea35
commit cce4a7ed92
1 changed files with 3 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/croc/croc.go
View file

@ -894,7 +894,7 @@ func (c *Client) setBar() {
} }
func (c *Client) receiveData(i int) { func (c *Client) receiveData(i int) {
log.Debugf("%d receiving data") log.Debugf("%d receiving data", i)
for { for {
data, err := c.conn[i+1].Receive() data, err := c.conn[i+1].Receive()
if err != nil { if err != nil {
@ -975,12 +975,9 @@ func (c *Client) sendData(i int) {
for { for {
// Read file // Read file
data := make([]byte, models.TCP_BUFFER_SIZE/2) data := make([]byte, models.TCP_BUFFER_SIZE/2)
// if readingPos >= int64(c.fread.Len()) { // log.Debugf("%d trying to read", i)
// break
// }
log.Debugf("%d trying to read", i)
n, errRead := c.fread.ReadAt(data, readingPos) n, errRead := c.fread.ReadAt(data, readingPos)
log.Debugf("%d read %d bytes", i, n) // log.Debugf("%d read %d bytes", i, n)
readingPos += int64(n) readingPos += int64(n)
if math.Mod(curi, float64(len(c.Options.RelayPorts))) == float64(i) { if math.Mod(curi, float64(len(c.Options.RelayPorts))) == float64(i) {