diff -r 367e76b3028e -r a8f9a0c07fc8 xmpp/stream.go --- a/xmpp/stream.go Sat Sep 07 10:04:44 2013 -0700 +++ b/xmpp/stream.go Sat Sep 07 10:30:22 2013 -0700 @@ -305,7 +305,7 @@ func (cl *Client) handleStreamError(se *streamError) { Info.Logf("Received stream error: %v", se) - close(cl.Out) + close(cl.Send) } func (cl *Client) handleFeatures(fe *Features) { @@ -313,7 +313,7 @@ if fe.Starttls != nil { start := &starttls{XMLName: xml.Name{Space: NsTLS, Local: "starttls"}} - cl.xmlOut <- start + cl.sendXml <- start return } @@ -355,7 +355,7 @@ // Now re-send the initial handshake message to start the new // session. hsOut := &stream{To: cl.Jid.Domain, Version: XMPPVersion} - cl.xmlOut <- hsOut + cl.sendXml <- hsOut } // Synchronize with handleTls(). Called from readTransport() when @@ -385,7 +385,7 @@ if digestMd5 { auth := &auth{XMLName: xml.Name{Space: NsSASL, Local: "auth"}, Mechanism: "DIGEST-MD5"} - cl.xmlOut <- auth + cl.sendXml <- auth } } @@ -411,7 +411,7 @@ Info.Log("Sasl authentication succeeded") cl.Features = nil ss := &stream{To: cl.Jid.Domain, Version: XMPPVersion} - cl.xmlOut <- ss + cl.sendXml <- ss } } @@ -485,17 +485,17 @@ clStr := packSasl(clMap) b64 := base64.StdEncoding clObj := &auth{XMLName: xml.Name{Space: NsSASL, Local: "response"}, Chardata: b64.EncodeToString([]byte(clStr))} - cl.xmlOut <- clObj + cl.sendXml <- clObj } func (cl *Client) saslDigest2(srvMap map[string]string) { if cl.saslExpected == srvMap["rspauth"] { clObj := &auth{XMLName: xml.Name{Space: NsSASL, Local: "response"}} - cl.xmlOut <- clObj + cl.sendXml <- clObj } else { clObj := &auth{XMLName: xml.Name{Space: NsSASL, Local: "failure"}, Any: &Generic{XMLName: xml.Name{Space: NsSASL, Local: "abort"}}} - cl.xmlOut <- clObj + cl.sendXml <- clObj } } @@ -594,7 +594,7 @@ return false } cl.HandleStanza(msg.Id, f) - cl.xmlOut <- msg + cl.sendXml <- msg } // Register a callback to handle the next XMPP stanza (iq, message, or