}
return l.(*UnixListener)
}
+ fileListener := func(t *testing.T, l *UnixListener) (*os.File, Listener) {
+ f, err := l.File()
+ if err != nil {
+ t.Fatal(err)
+ }
+ ln, err := FileListener(f)
+ if err != nil {
+ t.Fatal(err)
+ }
+ return f, ln
+ }
checkExists := func(t *testing.T, desc string) {
if _, err := os.Stat(name); err != nil {
t.Fatalf("unix socket does not exist %s: %v", desc, err)
// FileListener should not.
t.Run("FileListener", func(t *testing.T) {
l := listen(t)
- f, _ := l.File()
- l1, _ := FileListener(f)
+ f, l1 := fileListener(t, l)
checkExists(t, "after FileListener")
f.Close()
checkExists(t, "after File close")
t.Run("FileListener/SetUnlinkOnClose(true)", func(t *testing.T) {
l := listen(t)
- f, _ := l.File()
- l1, _ := FileListener(f)
+ f, l1 := fileListener(t, l)
checkExists(t, "after FileListener")
l1.(*UnixListener).SetUnlinkOnClose(true)
f.Close()
t.Run("FileListener/SetUnlinkOnClose(false)", func(t *testing.T) {
l := listen(t)
- f, _ := l.File()
- l1, _ := FileListener(f)
+ f, l1 := fileListener(t, l)
checkExists(t, "after FileListener")
l1.(*UnixListener).SetUnlinkOnClose(false)
f.Close()