v3rpc: remove redundant locks

2024-09-27 06:25:44 +00:00 · 2016-10-07 15:13:56 -07:00 · 2016-10-07 15:13:56 -07:00 · 6412758177
commit 6412758177
parent 836c8159f6
1 changed files with 0 additions and 4 deletions
--- a/etcdserver/api/v3rpc/watch.go
+++ b/etcdserver/api/v3rpc/watch.go
@ -180,14 +180,10 @@ func (sws *serverWatchStream) recvLoop() error {
 			if id != -1 {
 				sws.mu.Lock()
 				if creq.ProgressNotify {
-					sws.mu.Lock()
 					sws.progress[id] = true
-					sws.mu.Unlock()
 				}
 				if creq.PrevKv {
-					sws.mu.Lock()
 					sws.prevKV[id] = true
-					sws.mu.Unlock()
 				}
 				sws.mu.Unlock()
 			}