From 10c9685a33f18d0453d84b7260b559a2fc3a9926 Mon Sep 17 00:00:00 2001 From: Arlo Breault Date: Sat, 9 Jan 2016 10:08:22 -0800 Subject: [PATCH] Unblock the data channel --- server/snowflake.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/server/snowflake.go b/server/snowflake.go index cedea4d..b3bfc9c 100644 --- a/server/snowflake.go +++ b/server/snowflake.go @@ -95,10 +95,15 @@ func datachannelHandler(conn *webRTCConn) { conn.pr = pr dc := conn.dc + dc.OnOpen = func() { + log.Println("OnOpen channel") + } dc.OnClose = func() { + log.Println("OnClose channel") pw.Close() } dc.OnMessage = func(msg []byte) { + log.Printf("OnMessage channel %d %q", len(msg), msg) n, err := pw.Write(msg) if err != nil { pw.CloseWithError(err) @@ -108,7 +113,7 @@ func datachannelHandler(conn *webRTCConn) { } } - copyLoop(conn, or) + go copyLoop(conn, or) } func makePeerConnection(config *webrtc.Configuration) (*webrtc.PeerConnection, error) { @@ -196,6 +201,7 @@ func listenWebRTC(config *webrtc.Configuration, signal string) (*os.File, error) }() go readSignalingMessages(signalChan, signalFile) + log.Printf("waiting for offer") return signalFile, nil }