From 63b3e49dfaf0d4072dd325dafef5191dc345eaab Mon Sep 17 00:00:00 2001 From: Zack Scholl Date: Thu, 11 Apr 2019 09:45:11 -0700 Subject: [PATCH] debugging --- src/croc/croc.go | 1 + src/webrtc/pkg/session/receiver/receiver.go | 2 ++ src/webrtc/pkg/session/sender/sender.go | 1 + 3 files changed, 4 insertions(+) diff --git a/src/croc/croc.go b/src/croc/croc.go index e004f953..faa543f4 100644 --- a/src/croc/croc.go +++ b/src/croc/croc.go @@ -405,6 +405,7 @@ func (c *Client) processMessage(m Message) (err error) { pathToFile := path.Join(c.FilesToTransfer[c.FilesToTransferCurrentNum].FolderSource, c.FilesToTransfer[c.FilesToTransferCurrentNum].Name) c.sendSess.TransferFile(pathToFile) case "close-sender": + log.Debug("close-sender received...") c.Step4FileTransfer = false c.Step3RecipientRequestFile = false c.sendSess.StopSending() diff --git a/src/webrtc/pkg/session/receiver/receiver.go b/src/webrtc/pkg/session/receiver/receiver.go index 9885c583..3e21e35c 100644 --- a/src/webrtc/pkg/session/receiver/receiver.go +++ b/src/webrtc/pkg/session/receiver/receiver.go @@ -166,6 +166,7 @@ func (s *Session) receiveData(pathToFile string, fileSize int64) error { case <-s.sess.Done: s.sess.NetworkStats.Stop() log.Debugf("Network: %s", s.sess.NetworkStats.String()) + log.Debug("closed gracefully") return nil case msg := <-s.msgChannel: buff, errDecrypt := crypt.DecryptFromBytes(msg.Data, []byte{1, 2, 3, 4}) @@ -177,6 +178,7 @@ func (s *Session) receiveData(pathToFile string, fileSize int64) error { pos := int64(binary.LittleEndian.Uint64(buff[:8])) n, err := f.WriteAt(buff[8:], pos) if err != nil { + log.Error(err) return err } else { if firstByte { diff --git a/src/webrtc/pkg/session/sender/sender.go b/src/webrtc/pkg/session/sender/sender.go index c79b1f9a..441e4a79 100644 --- a/src/webrtc/pkg/session/sender/sender.go +++ b/src/webrtc/pkg/session/sender/sender.go @@ -271,6 +271,7 @@ func (s *Session) writeToNetwork() { } func (s *Session) StopSending() { + log.Debug("StopSending() triggered") s.stopSending <- struct{}{} }