This is an automated email from the ASF dual-hosted git repository.
pbacsko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/yunikorn-core.git
The following commit(s) were added to refs/heads/master by this push:
new e4d2d002 [YUNIKORN-2427] [ADDENDUM] Use r-lock instead of rw-lock in
user_tracker.go#getGroupForApp (#809)
e4d2d002 is described below
commit e4d2d002069369e002dc4239e0d8b792e7057200
Author: Manikandan R <[email protected]>
AuthorDate: Wed Feb 21 11:52:24 2024 +0100
[YUNIKORN-2427] [ADDENDUM] Use r-lock instead of rw-lock in
user_tracker.go#getGroupForApp (#809)
Closes: #809
Signed-off-by: Peter Bacsko <[email protected]>
---
pkg/scheduler/ugm/user_tracker.go | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/pkg/scheduler/ugm/user_tracker.go
b/pkg/scheduler/ugm/user_tracker.go
index b93b5396..61e49a97 100644
--- a/pkg/scheduler/ugm/user_tracker.go
+++ b/pkg/scheduler/ugm/user_tracker.go
@@ -122,8 +122,8 @@ func (ut *UserTracker) setLimits(hierarchy []string,
resource *resources.Resourc
}
func (ut *UserTracker) headroom(hierarchy []string) *resources.Resource {
- ut.Lock()
- defer ut.Unlock()
+ ut.RLock()
+ defer ut.RUnlock()
return ut.queueTracker.headroom(hierarchy, user)
}
@@ -168,7 +168,7 @@ func (ut *UserTracker) canBeRemoved() bool {
}
func (ut *UserTracker) canRunApp(hierarchy []string, applicationID string)
bool {
- ut.Lock()
- defer ut.Unlock()
+ ut.RLock()
+ defer ut.RUnlock()
return ut.queueTracker.canRunApp(hierarchy, applicationID, user)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
