blob: 94ffca49d663234f9d6d6affe817db674ebc1c2c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
package ctlsocksrv
import (
"errors"
"io/fs"
"net"
"os"
"syscall"
"time"
"github.com/rfjakob/gocryptfs/v2/internal/tlog"
)
// cleanupOrphanedSocket deletes an orphaned socket file at `path`.
// The file at `path` will only be deleted if:
// 1) It is a socket file
// 2) Connecting to it results in ECONNREFUSED
func cleanupOrphanedSocket(path string) {
fi, err := os.Stat(path)
if err != nil {
return
}
if fi.Mode().Type() != fs.ModeSocket {
return
}
conn, err := net.DialTimeout("unix", path, time.Second)
if err == nil {
// This socket file is still active. Don't delete it.
conn.Close()
return
}
if errors.Is(err, syscall.ECONNREFUSED) {
tlog.Info.Printf("ctlsock: deleting orphaned socket file %q\n", path)
err = os.Remove(path)
if err != nil {
tlog.Warn.Printf("ctlsock: deleting socket file failed: %v", path)
}
}
}
func Listen(path string) (net.Listener, error) {
cleanupOrphanedSocket(path)
return net.Listen("unix", path)
}
|
