fixes nanomsg#48 deadlock on Close()

bcalco · Jan 23, 2015 · 89caba5 · 89caba5
1 parent d3e1664
commit 89caba5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/core.go b/core.go
@@ -1,4 +1,4 @@
-// Copyright 2014 The Mangos Authors
+// Copyright 2015 The Mangos Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use file except in compliance with the License.
@@ -152,9 +152,10 @@ func (sock *socket) Close() error {
 			}
 			select {
 			case <-fin:
-				break
 			case <-time.After(100 * time.Millisecond):
+				continue
 			}
+			break
 		}
 	}
 	for _, p := range pipes {