diff options
| author | chrislu <chris.lu@gmail.com> | 2022-04-18 00:08:31 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-04-18 00:08:31 -0700 |
| commit | a69f0b62c2a22785b448a4cb29499b4d1410f1ca (patch) | |
| tree | 0701c7bdcb8db970bd9a2cb0c7d20be8feb00bfa | |
| parent | 9ae66f55fca158354c45006b1030fb62727c983b (diff) | |
| download | seaweedfs-a69f0b62c2a22785b448a4cb29499b4d1410f1ca.tar.xz seaweedfs-a69f0b62c2a22785b448a4cb29499b4d1410f1ca.zip | |
start filer local socket only on non windows
fix https://github.com/chrislusf/seaweedfs/issues/2930
| -rw-r--r-- | weed/command/filer.go | 32 |
1 files changed, 17 insertions, 15 deletions
diff --git a/weed/command/filer.go b/weed/command/filer.go index dd21ef364..4dbc04a0c 100644 --- a/weed/command/filer.go +++ b/weed/command/filer.go @@ -5,6 +5,7 @@ import ( "net" "net/http" "os" + "runtime" "time" "google.golang.org/grpc/reflection" @@ -248,18 +249,6 @@ func (fo *FilerOptions) startFiler() { glog.Fatalf("Filer listener error: %v", e) } - // start on local unix socket - if *fo.localSocket == "" { - *fo.localSocket = fmt.Sprintf("/tmp/seaweefs-filer-%d.sock", *fo.port) - if err := os.Remove(*fo.localSocket); err != nil && !os.IsNotExist(err) { - glog.Fatalf("Failed to remove %s, error: %s", *fo.localSocket, err.Error()) - } - } - filerSocketListener, err := net.Listen("unix", *fo.localSocket) - if err != nil { - glog.Fatalf("Failed to listen on %s: %v", *fo.localSocket, err) - } - // starting grpc server grpcPort := *fo.portGrpc grpcL, grpcLocalL, err := util.NewIpAndLocalListeners(*fo.bindIp, grpcPort, 0) @@ -275,9 +264,22 @@ func (fo *FilerOptions) startFiler() { go grpcS.Serve(grpcL) httpS := &http.Server{Handler: defaultMux} - go func() { - httpS.Serve(filerSocketListener) - }() + if runtime.GOOS != "windows" { + if *fo.localSocket == "" { + *fo.localSocket = fmt.Sprintf("/tmp/seaweefs-filer-%d.sock", *fo.port) + if err := os.Remove(*fo.localSocket); err != nil && !os.IsNotExist(err) { + glog.Fatalf("Failed to remove %s, error: %s", *fo.localSocket, err.Error()) + } + } + go func() { + // start on local unix socket + filerSocketListener, err := net.Listen("unix", *fo.localSocket) + if err != nil { + glog.Fatalf("Failed to listen on %s: %v", *fo.localSocket, err) + } + httpS.Serve(filerSocketListener) + }() + } if filerLocalListener != nil { go func() { if err := httpS.Serve(filerLocalListener); err != nil { |
