diff options
| author | Chris Lu <chris.lu@gmail.com> | 2014-03-30 11:28:04 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2014-03-30 11:28:04 -0700 |
| commit | 2861275fb67112cb2fe51521b5052c3f1a98414d (patch) | |
| tree | a86f0eeab6a0603d1217983430c11bb59632d87c /go/weed/server.go | |
| parent | 259c7d66f72938857ee94cc747fc54982fbbcb1f (diff) | |
| download | seaweedfs-2861275fb67112cb2fe51521b5052c3f1a98414d.tar.xz seaweedfs-2861275fb67112cb2fe51521b5052c3f1a98414d.zip | |
working filer server!
Diffstat (limited to 'go/weed/server.go')
| -rw-r--r-- | go/weed/server.go | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/go/weed/server.go b/go/weed/server.go index 37ce13849..c3dca3f4b 100644 --- a/go/weed/server.go +++ b/go/weed/server.go @@ -96,6 +96,25 @@ func runServer(cmd *Command, args []string) bool { serverWhiteList = strings.Split(*serverWhiteListOption, ",") } + go func() { + r := http.NewServeMux() + _, nfs_err := weed_server.NewFilerServer(r, *serverIp+":"+strconv.Itoa(*masterPort), *volumeDataFolders) + if nfs_err != nil { + glog.Fatalf(nfs_err.Error()) + } + glog.V(0).Infoln("Start Weed Filer", util.VERSION, "at port", *serverIp+":"+strconv.Itoa(8888)) + filerListener, e := util.NewListener( + *serverIp+":"+strconv.Itoa(8888), + time.Duration(*serverTimeout)*time.Second, + ) + if e != nil { + glog.Fatalf(e.Error()) + } + if e := http.Serve(filerListener, r); e != nil { + glog.Fatalf("Master Fail to serve:%s", e.Error()) + } + }() + var raftWaitForMaster sync.WaitGroup var volumeWait sync.WaitGroup |