|
@@ -32,7 +32,6 @@ func (s *store) ensureAuthDirectories() error {
|
|
|
}
|
|
}
|
|
|
for _, res := range []string{StorePermsPrefix, StorePermsPrefix + "/users/", StorePermsPrefix + "/roles/"} {
|
|
for _, res := range []string{StorePermsPrefix, StorePermsPrefix + "/users/", StorePermsPrefix + "/roles/"} {
|
|
|
ctx, cancel := context.WithTimeout(context.Background(), s.timeout)
|
|
ctx, cancel := context.WithTimeout(context.Background(), s.timeout)
|
|
|
- defer cancel()
|
|
|
|
|
pe := false
|
|
pe := false
|
|
|
rr := etcdserverpb.Request{
|
|
rr := etcdserverpb.Request{
|
|
|
Method: "PUT",
|
|
Method: "PUT",
|
|
@@ -41,6 +40,7 @@ func (s *store) ensureAuthDirectories() error {
|
|
|
PrevExist: &pe,
|
|
PrevExist: &pe,
|
|
|
}
|
|
}
|
|
|
_, err := s.server.Do(ctx, rr)
|
|
_, err := s.server.Do(ctx, rr)
|
|
|
|
|
+ cancel()
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
if e, ok := err.(*v2error.Error); ok {
|
|
if e, ok := err.(*v2error.Error); ok {
|
|
|
if e.ErrorCode == v2error.EcodeNodeExist {
|
|
if e.ErrorCode == v2error.EcodeNodeExist {
|