github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 01:40:07 +00:00
Code Issues Projects Releases Wiki Activity

auth duplicate detect, add warning message

Browse Source
This commit is contained in:
xilabao 2016-11-18 16:03:06 +08:00
parent 2c61d2f80c
commit 79b525e5a4
4 changed files with 20 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
plugin/pkg/auth/authenticator/password/passwordfile/BUILD
View File

@ -14,7 +14,10 @@ go_library(
name = "go_default_library", name = "go_default_library",
srcs = ["passwordfile.go"], srcs = ["passwordfile.go"],
tags = ["automanaged"], tags = ["automanaged"],
deps = ["//pkg/auth/user:go_default_library"], deps = [
"//pkg/auth/user:go_default_library",
"//vendor:github.com/golang/glog",
],
) )
go_test( go_test(

6
plugin/pkg/auth/authenticator/password/passwordfile/passwordfile.go
View File

@ -22,6 +22,7 @@ import (
"io" "io"
"os" "os"
"github.com/golang/glog"
"k8s.io/kubernetes/pkg/auth/user" "k8s.io/kubernetes/pkg/auth/user"
) )
@ -43,6 +44,7 @@ func NewCSV(path string) (*PasswordAuthenticator, error) {
} }
defer file.Close() defer file.Close()
recordNum := 0
users := make(map[string]*userPasswordInfo) users := make(map[string]*userPasswordInfo)
reader := csv.NewReader(file) reader := csv.NewReader(file)
for { for {
@ -60,6 +62,10 @@ func NewCSV(path string) (*PasswordAuthenticator, error) {
info: &user.DefaultInfo{Name: record[1], UID: record[2]}, info: &user.DefaultInfo{Name: record[1], UID: record[2]},
password: record[0], password: record[0],
} }
recordNum++
if _, exist := users[obj.info.Name]; exist {
glog.Warningf("duplicate username '%s' has been found in password file '%s', record number '%d'", obj.info.Name, path, recordNum)
}
users[obj.info.Name] = obj users[obj.info.Name] = obj
} }

5
plugin/pkg/auth/authenticator/token/tokenfile/BUILD
View File

@ -14,7 +14,10 @@ go_library(
name = "go_default_library", name = "go_default_library",
srcs = ["tokenfile.go"], srcs = ["tokenfile.go"],
tags = ["automanaged"], tags = ["automanaged"],
deps = ["//pkg/auth/user:go_default_library"], deps = [
"//pkg/auth/user:go_default_library",
"//vendor:github.com/golang/glog",
],
) )
go_test( go_test(

6
plugin/pkg/auth/authenticator/token/tokenfile/tokenfile.go
View File

@ -23,6 +23,7 @@ import (
"os" "os"
"strings" "strings"
"github.com/golang/glog"
"k8s.io/kubernetes/pkg/auth/user" "k8s.io/kubernetes/pkg/auth/user"
) )
@ -46,6 +47,7 @@ func NewCSV(path string) (*TokenAuthenticator, error) {
} }
defer file.Close() defer file.Close()
recordNum := 0
tokens := make(map[string]*user.DefaultInfo) tokens := make(map[string]*user.DefaultInfo)
reader := csv.NewReader(file) reader := csv.NewReader(file)
reader.FieldsPerRecord = -1 reader.FieldsPerRecord = -1
@ -64,6 +66,10 @@ func NewCSV(path string) (*TokenAuthenticator, error) {
Name: record[1], Name: record[1],
UID: record[2], UID: record[2],
} }
recordNum++
if _, exist := tokens[record[0]]; exist {
glog.Warningf("duplicate token has been found in token file '%s', record number '%d'", path, recordNum)
}
tokens[record[0]] = obj tokens[record[0]] = obj
if len(record) >= 4 { if len(record) >= 4 {