diff options
| author | Xiang Dai <long0dai@foxmail.com> | 2020-05-13 17:37:39 +0800 |
|---|---|---|
| committer | Xiang Dai <long0dai@foxmail.com> | 2020-05-23 16:27:37 +0800 |
| commit | ef0056fadf76b623e1bc68c369ecb462b4d6b17b (patch) | |
| tree | ed4ff122c79a30652b3fcdc8d301fa750b7314a3 /edgemesh | |
| parent | Merge pull request #1719 from fisherxu/keadm-1.3-docs (diff) | |
| download | kubeedge-ef0056fadf76b623e1bc68c369ecb462b4d6b17b.tar.gz | |
enable gosimple linter
Signed-off-by: Xiang Dai <long0dai@foxmail.com>
Diffstat (limited to 'edgemesh')
| -rw-r--r-- | edgemesh/pkg/dns/dns.go | 5 | ||||
| -rw-r--r-- | edgemesh/pkg/listener/listener.go | 2 | ||||
| -rw-r--r-- | edgemesh/pkg/protocol/http/http.go | 2 |
3 files changed, 2 insertions, 7 deletions
diff --git a/edgemesh/pkg/dns/dns.go b/edgemesh/pkg/dns/dns.go index 2b77e0236..57d4bf00b 100644 --- a/edgemesh/pkg/dns/dns.go +++ b/edgemesh/pkg/dns/dns.go @@ -202,10 +202,7 @@ func parseDNSQuery(req []byte) (que *dnsQuestion, err error) { // isAQuery judges if the dns pkg is a query func (h *dnsHeader) isAQuery() bool { - if h.flags&dnsQR != dnsQR { - return true - } - return false + return h.flags&dnsQR != dnsQR } // getHeader gets dns pkg head diff --git a/edgemesh/pkg/listener/listener.go b/edgemesh/pkg/listener/listener.go index 14c589c57..f1c73130a 100644 --- a/edgemesh/pkg/listener/listener.go +++ b/edgemesh/pkg/listener/listener.go @@ -360,7 +360,6 @@ func MsgProcess(msg model.Message) { klog.Warningf("[EdgeMesh] invalid %s operation on podlist", msg.GetOperation()) } } - return } // addServer adds a server @@ -387,7 +386,6 @@ func addServer(svcName, svcPorts string) { klog.Errorf("[EdgeMesh] add listener %s to edge db error: %v", svcName, err) return } - return } // updateServer updates a server diff --git a/edgemesh/pkg/protocol/http/http.go b/edgemesh/pkg/protocol/http/http.go index a38738c29..9e84921f3 100644 --- a/edgemesh/pkg/protocol/http/http.go +++ b/edgemesh/pkg/protocol/http/http.go @@ -109,7 +109,7 @@ func (p *HTTP) responseCallback(data *invocation.Response) error { StatusCode: http.StatusServiceUnavailable, Proto: p.req.Proto, Request: p.req, - Header: make(http.Header, 0), + Header: make(http.Header), } respBytes, _ = httpResponseToBytes(resp) // send error response back |