Skip to content

Commit 2e3afb4

Browse files
authored
Merge pull request kosmos-io#144 from duanmengkk/fix_endpoints_connected
Fix comment
2 parents e81dff7 + 244d650 commit 2e3afb4

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

pkg/clustertree/knode-manager/controllers/mcs/serviceimport_controller.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -334,7 +334,7 @@ func (c *ServiceImportController) syncClientEndpointSlice() {
334334
for _, eps := range masterEndpointSlices {
335335
if !helper.HasAnnotation(eps.ObjectMeta, ServiceExportLabelKey) {
336336
klog.V(4).Infof("ServiceEndpointSlice %s/%s has not been exported in master, ignore it", namespace, eps.Name)
337-
return
337+
continue
338338
}
339339
for _, endpoint := range eps.Endpoints {
340340
for _, address := range endpoint.Addresses {
@@ -448,7 +448,7 @@ func (c *ServiceImportController) syncClientServiceImport() {
448448
for _, eps := range masterEndpointSlices {
449449
if !helper.HasAnnotation(eps.ObjectMeta, ServiceExportLabelKey) {
450450
klog.V(4).Infof("ServiceEndpointSlice %s/%s has not been exported in master, ignore it", namespace, eps.Name)
451-
return
451+
continue
452452
}
453453
for _, endpoint := range eps.Endpoints {
454454
for _, address := range endpoint.Addresses {
@@ -590,7 +590,7 @@ func clearEndpointSlice(slice *discoveryv1.EndpointSlice, disconnectedAddress []
590590
newAddresses = append(newAddresses, address)
591591
}
592592
}
593-
// 只添加非空地址的endpoint
593+
// Only add non-empty addresses from endpoints
594594
if len(newAddresses) > 0 {
595595
endpoint.Addresses = newAddresses
596596
newEndpoints = append(newEndpoints, endpoint)

0 commit comments

Comments
 (0)