mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
fix unreachable code
This commit is contained in:
parent
ffa69b24ae
commit
826f96b6f3
|
@ -121,7 +121,6 @@ func runFilerReplicate(cmd *Command, args []string) bool {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return true
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func validateOneEnabledInput(config *viper.Viper) {
|
func validateOneEnabledInput(config *viper.Viper) {
|
||||||
|
|
|
@ -65,7 +65,6 @@ func (fs *FilerServer) SubscribeMetadata(req *filer_pb.SubscribeMetadataRequest,
|
||||||
fs.listenersLock.Unlock()
|
fs.listenersLock.Unlock()
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (fs *FilerServer) addClient(clientType string, clientAddress string) (clientName string) {
|
func (fs *FilerServer) addClient(clientType string, clientAddress string) (clientName string) {
|
||||||
|
|
|
@ -243,7 +243,6 @@ func (ms *MasterServer) KeepConnected(stream master_pb.Seaweed_KeepConnectedServ
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (ms *MasterServer) informNewLeader(stream master_pb.Seaweed_KeepConnectedServer) error {
|
func (ms *MasterServer) informNewLeader(stream master_pb.Seaweed_KeepConnectedServer) error {
|
||||||
|
|
Loading…
Reference in a new issue