|
@@ -62,6 +62,8 @@ const (
|
|
|
|
|
|
|
|
purgeFileInterval = 30 * time.Second
|
|
purgeFileInterval = 30 * time.Second
|
|
|
monitorVersionInterval = 5 * time.Second
|
|
monitorVersionInterval = 5 * time.Second
|
|
|
|
|
+
|
|
|
|
|
+ databaseFilename = "db"
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
var (
|
|
var (
|
|
@@ -181,8 +183,7 @@ func NewServer(cfg *ServerConfig) (*EtcdServer, error) {
|
|
|
var id types.ID
|
|
var id types.ID
|
|
|
var cl *cluster
|
|
var cl *cluster
|
|
|
|
|
|
|
|
- demoFile := path.Join(cfg.MemberDir(), "v3demo")
|
|
|
|
|
- if !cfg.V3demo && fileutil.Exist(demoFile) {
|
|
|
|
|
|
|
+ if !cfg.V3demo && fileutil.Exist(path.Join(cfg.StorageDir(), databaseFilename)) {
|
|
|
return nil, errors.New("experimental-v3demo cannot be disabled once it is enabled")
|
|
return nil, errors.New("experimental-v3demo cannot be disabled once it is enabled")
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -330,7 +331,11 @@ func NewServer(cfg *ServerConfig) (*EtcdServer, error) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
if cfg.V3demo {
|
|
if cfg.V3demo {
|
|
|
- srv.kv = dstorage.New(demoFile)
|
|
|
|
|
|
|
+ err = os.MkdirAll(cfg.StorageDir(), privateDirMode)
|
|
|
|
|
+ if err != nil && err != os.ErrExist {
|
|
|
|
|
+ return nil, err
|
|
|
|
|
+ }
|
|
|
|
|
+ srv.kv = dstorage.New(path.Join(cfg.StorageDir(), databaseFilename))
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// TODO: move transport initialization near the definition of remote
|
|
// TODO: move transport initialization near the definition of remote
|