parent
24b96e2917
commit
7cfc31151a
@ -106,7 +106,8 @@ func mutualVersion(theirMajor, theirMinor uint8) (major, minor uint8, ok bool) {
|
|||||||
// A nop implements the NULL encryption and MAC algorithms.
|
// A nop implements the NULL encryption and MAC algorithms.
|
||||||
type nop struct{}
|
type nop struct{}
|
||||||
|
|
||||||
func (nop) XORKeyStream(buf []byte) {}
|
func (nop) XORKeyStream(buf []byte) {
|
||||||
|
}
|
||||||
|
|
||||||
func (nop) Write(buf []byte) (int, os.Error) {
|
func (nop) Write(buf []byte) (int, os.Error) {
|
||||||
return len(buf), nil;
|
return len(buf), nil;
|
||||||
@ -116,7 +117,8 @@ func (nop) Sum() []byte {
|
|||||||
return nil;
|
return nil;
|
||||||
}
|
}
|
||||||
|
|
||||||
func (nop) Reset() {}
|
func (nop) Reset() {
|
||||||
|
}
|
||||||
|
|
||||||
func (nop) Size() int {
|
func (nop) Size() int {
|
||||||
return 0;
|
return 0;
|
||||||
|
@ -74,10 +74,16 @@ func (w *recordWriter) loop(writer io.Writer, appChan <-chan []byte, controlChan
|
|||||||
}
|
}
|
||||||
|
|
||||||
if !closed(appChan) {
|
if !closed(appChan) {
|
||||||
go func() { for _ = range appChan {} }();
|
go func() {
|
||||||
|
for _ = range appChan {
|
||||||
|
}
|
||||||
|
}();
|
||||||
}
|
}
|
||||||
if !closed(controlChan) {
|
if !closed(controlChan) {
|
||||||
go func() { for _ = range controlChan {} }();
|
go func() {
|
||||||
|
for _ = range controlChan {
|
||||||
|
}
|
||||||
|
}();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user