aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_server.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-08-12 18:10:59 -0700
committerChris Lu <chris.lu@gmail.com>2021-08-12 18:10:59 -0700
commit5571f4f70a2e304343e76638caacc3bd0338a8d1 (patch)
treedca89320167ca82dae6f9ede85eed00a78a08f06 /weed/server/master_server.go
parent5469019852cf1399b64683cbcc54f4c077377afb (diff)
downloadseaweedfs-5571f4f70a2e304343e76638caacc3bd0338a8d1.tar.xz
seaweedfs-5571f4f70a2e304343e76638caacc3bd0338a8d1.zip
master: add master.follower to handle read file id lookup requests
Diffstat (limited to 'weed/server/master_server.go')
-rw-r--r--weed/server/master_server.go9
1 files changed, 6 insertions, 3 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go
index 273d6ba7d..d2edeb6cb 100644
--- a/weed/server/master_server.go
+++ b/weed/server/master_server.go
@@ -44,6 +44,7 @@ type MasterOption struct {
DisableHttp bool
MetricsAddress string
MetricsIntervalSec int
+ IsFollower bool
}
type MasterServer struct {
@@ -145,7 +146,9 @@ func NewMasterServer(r *mux.Router, option *MasterOption, peers []string) *Maste
ms.ProcessGrowRequest()
- ms.startAdminScripts()
+ if !option.IsFollower {
+ ms.startAdminScripts()
+ }
return ms
}
@@ -193,8 +196,8 @@ func (ms *MasterServer) proxyToLeader(f http.HandlerFunc) http.HandlerFunc {
proxy.Transport = util.Transport
proxy.ServeHTTP(w, r)
} else {
- // drop it to the floor
- // writeJsonError(w, r, errors.New(ms.Topo.RaftServer.Name()+" does not know Leader yet:"+ms.Topo.RaftServer.Leader()))
+ // handle requests locally
+ f(w, r)
}
}
}