diff --git a/handshake_server.go b/handshake_server.go index 7303189..86f11e6 100644 --- a/handshake_server.go +++ b/handshake_server.go @@ -22,8 +22,8 @@ import ( ) type cipherSuite struct { - id uint16; // The number of this suite on the wire. - hashLength, cipherKeyLength int; + id uint16; // The number of this suite on the wire. + hashLength, cipherKeyLength int; // TODO(agl): need a method to create the cipher and hash interfaces. } @@ -226,7 +226,10 @@ func (h *serverHandshake) error(e alertType) { // to tell it about the error. h.controlChan <- ConnectionState{false, "", e}; close(h.controlChan); - go func() { for _ = range h.msgChan {} }(); + go func() { + for _ = range h.msgChan { + } + }(); h.writeChan <- alert{alertLevelError, e}; } } diff --git a/record_process.go b/record_process.go index 4c69319..1cd6879 100644 --- a/record_process.go +++ b/record_process.go @@ -114,7 +114,10 @@ func (p *recordProcessor) loop(appDataChan chan<- []byte, requestChan <-chan int p.wakeWaiters(); go drainRequestChannel(p.requestChan, p.connState); - go func() { for _ = range controlChan {} }(); + go func() { + for _ = range controlChan { + } + }(); close(handshakeChan); if len(p.appData) > 0 {