Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
K
k3s
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Registry
Registry
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Jacklull
k3s
Commits
941fc264
Unverified
Commit
941fc264
authored
Oct 01, 2018
by
k8s-ci-robot
Committed by
GitHub
Oct 01, 2018
Browse files
Options
Browse Files
Download
Plain Diff
Merge pull request #67888 from tanshanshan/glogformat
remove unused format log print
parents
43ce5fbf
8598c9dc
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
10 additions
and
10 deletions
+10
-10
config.go
pkg/proxy/config/config.go
+4
-4
healthcheck.go
pkg/proxy/healthcheck/healthcheck.go
+1
-1
proxier.go
pkg/proxy/iptables/proxier.go
+5
-5
No files found.
pkg/proxy/config/config.go
View file @
941fc264
...
...
@@ -207,7 +207,7 @@ func (c *ServiceConfig) Run(stopCh <-chan struct{}) {
}
for
i
:=
range
c
.
eventHandlers
{
glog
.
V
(
3
)
.
Info
f
(
"Calling handler.OnServiceSynced()"
)
glog
.
V
(
3
)
.
Info
(
"Calling handler.OnServiceSynced()"
)
c
.
eventHandlers
[
i
]
.
OnServiceSynced
()
}
...
...
@@ -221,7 +221,7 @@ func (c *ServiceConfig) handleAddService(obj interface{}) {
return
}
for
i
:=
range
c
.
eventHandlers
{
glog
.
V
(
4
)
.
Info
f
(
"Calling handler.OnServiceAdd"
)
glog
.
V
(
4
)
.
Info
(
"Calling handler.OnServiceAdd"
)
c
.
eventHandlers
[
i
]
.
OnServiceAdd
(
service
)
}
}
...
...
@@ -238,7 +238,7 @@ func (c *ServiceConfig) handleUpdateService(oldObj, newObj interface{}) {
return
}
for
i
:=
range
c
.
eventHandlers
{
glog
.
V
(
4
)
.
Info
f
(
"Calling handler.OnServiceUpdate"
)
glog
.
V
(
4
)
.
Info
(
"Calling handler.OnServiceUpdate"
)
c
.
eventHandlers
[
i
]
.
OnServiceUpdate
(
oldService
,
service
)
}
}
...
...
@@ -257,7 +257,7 @@ func (c *ServiceConfig) handleDeleteService(obj interface{}) {
}
}
for
i
:=
range
c
.
eventHandlers
{
glog
.
V
(
4
)
.
Info
f
(
"Calling handler.OnServiceDelete"
)
glog
.
V
(
4
)
.
Info
(
"Calling handler.OnServiceDelete"
)
c
.
eventHandlers
[
i
]
.
OnServiceDelete
(
service
)
}
}
pkg/proxy/healthcheck/healthcheck.go
View file @
941fc264
...
...
@@ -322,7 +322,7 @@ func (hs *HealthzServer) Run() {
glog
.
Errorf
(
"Healthz closed with error: %v"
,
err
)
return
}
glog
.
Error
f
(
"Unexpected healthz closed."
)
glog
.
Error
(
"Unexpected healthz closed."
)
},
nodeHealthzRetryInterval
,
wait
.
NeverStop
)
}
...
...
pkg/proxy/iptables/proxier.go
View file @
941fc264
...
...
@@ -182,7 +182,7 @@ func newEndpointInfo(baseInfo *proxy.BaseEndpointInfo) proxy.Endpoint {
func
(
e
*
endpointsInfo
)
Equal
(
other
proxy
.
Endpoint
)
bool
{
o
,
ok
:=
other
.
(
*
endpointsInfo
)
if
!
ok
{
glog
.
Error
f
(
"Failed to cast endpointsInfo"
)
glog
.
Error
(
"Failed to cast endpointsInfo"
)
return
false
}
return
e
.
Endpoint
==
o
.
Endpoint
&&
...
...
@@ -303,7 +303,7 @@ func NewProxier(ipt utiliptables.Interface,
// are connected to a Linux bridge (but not SDN bridges). Until most
// plugins handle this, log when config is missing
if
val
,
err
:=
sysctl
.
GetSysctl
(
sysctlBridgeCallIPTables
);
err
==
nil
&&
val
!=
1
{
glog
.
Warning
f
(
"missing br-netfilter module or unset sysctl br-nf-call-iptables; proxy may not work as intended"
)
glog
.
Warning
(
"missing br-netfilter module or unset sysctl br-nf-call-iptables; proxy may not work as intended"
)
}
// Generate the masquerade mark to use for SNAT rules.
...
...
@@ -311,12 +311,12 @@ func NewProxier(ipt utiliptables.Interface,
masqueradeMark
:=
fmt
.
Sprintf
(
"%#08x/%#08x"
,
masqueradeValue
,
masqueradeValue
)
if
nodeIP
==
nil
{
glog
.
Warning
f
(
"invalid nodeIP, initializing kube-proxy with 127.0.0.1 as nodeIP"
)
glog
.
Warning
(
"invalid nodeIP, initializing kube-proxy with 127.0.0.1 as nodeIP"
)
nodeIP
=
net
.
ParseIP
(
"127.0.0.1"
)
}
if
len
(
clusterCIDR
)
==
0
{
glog
.
Warning
f
(
"clusterCIDR not specified, unable to distinguish between internal and external traffic"
)
glog
.
Warning
(
"clusterCIDR not specified, unable to distinguish between internal and external traffic"
)
}
else
if
utilnet
.
IsIPv6CIDR
(
clusterCIDR
)
!=
ipt
.
IsIpv6
()
{
return
nil
,
fmt
.
Errorf
(
"clusterCIDR %s has incorrect IP version: expect isIPv6=%t"
,
clusterCIDR
,
ipt
.
IsIpv6
())
}
...
...
@@ -661,7 +661,7 @@ func (proxier *Proxier) syncProxyRules() {
}
}
glog
.
V
(
3
)
.
Info
f
(
"Syncing iptables rules"
)
glog
.
V
(
3
)
.
Info
(
"Syncing iptables rules"
)
// Create and link the kube chains.
for
_
,
chain
:=
range
iptablesJumpChains
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment