aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGravatar Oleksandr Redko <Oleksandr_Redko@epam.com> 2023-06-26 15:13:16 +0300
committerGravatar GitHub <noreply@github.com> 2023-06-26 14:13:16 +0200
commitd2299592162aab9a7d0936b621b9ca362deb9b7f (patch)
tree15d46c88d8318fca7d4fbf9c99cf79906d2ad8f5
parentUse timeout in TCPDialer to resolveTCPAddrs (#1582) (diff)
downloadfasthttp-d2299592162aab9a7d0936b621b9ca362deb9b7f.tar.gz
fasthttp-d2299592162aab9a7d0936b621b9ca362deb9b7f.tar.bz2
fasthttp-d2299592162aab9a7d0936b621b9ca362deb9b7f.zip
Remove unnecessary indent blocks (#1586)
-rw-r--r--client.go34
-rw-r--r--server.go15
2 files changed, 21 insertions, 28 deletions
diff --git a/client.go b/client.go
index e47d4be..fa399af 100644
--- a/client.go
+++ b/client.go
@@ -944,15 +944,13 @@ func clientGetURLDeadline(dst []byte, url string, deadline time.Time, c clientDo
statusCodeCopy, bodyCopy, errCopy := doRequestFollowRedirectsBuffer(req, dst, url, c)
mu.Lock()
- {
- if !timedout {
- ch <- clientURLResponse{
- statusCode: statusCodeCopy,
- body: bodyCopy,
- err: errCopy,
- }
- responded = true
+ if !timedout {
+ ch <- clientURLResponse{
+ statusCode: statusCodeCopy,
+ body: bodyCopy,
+ err: errCopy,
}
+ responded = true
}
mu.Unlock()
@@ -967,17 +965,15 @@ func clientGetURLDeadline(dst []byte, url string, deadline time.Time, c clientDo
err = resp.err
case <-tc.C:
mu.Lock()
- {
- if responded {
- resp := <-ch
- statusCode = resp.statusCode
- body = resp.body
- err = resp.err
- } else {
- timedout = true
- err = ErrTimeout
- body = dst
- }
+ if responded {
+ resp := <-ch
+ statusCode = resp.statusCode
+ body = resp.body
+ err = resp.err
+ } else {
+ timedout = true
+ err = ErrTimeout
+ body = dst
}
mu.Unlock()
}
diff --git a/server.go b/server.go
index 5d7b17e..9189da6 100644
--- a/server.go
+++ b/server.go
@@ -1788,15 +1788,12 @@ func (s *Server) Serve(ln net.Listener) error {
maxWorkersCount := s.getConcurrency()
s.mu.Lock()
- {
- s.ln = append(s.ln, ln)
- if s.done == nil {
- s.done = make(chan struct{})
- }
-
- if s.concurrencyCh == nil {
- s.concurrencyCh = make(chan struct{}, maxWorkersCount)
- }
+ s.ln = append(s.ln, ln)
+ if s.done == nil {
+ s.done = make(chan struct{})
+ }
+ if s.concurrencyCh == nil {
+ s.concurrencyCh = make(chan struct{}, maxWorkersCount)
}
s.mu.Unlock()