scottk/vault
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/vault.git synced 2025-10-30 18:17:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

add fragment locks to GetActiveLocalFragment and GetActiveFragment (#28862)

Browse Source 
* add fragment locks to GetActiveLocalFragment and GetActiveFragment

* update locks for all functions
This commit is contained in:
akshya96
2024-11-07 17:30:08 -08:00
committed by GitHub
parent 2cd0e14b7e
commit 73702dbc8b
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
vault/activity_log_testing_util.go
View File

@@ -265,17 +265,25 @@ func (c *Core) GetActivityLog() *ActivityLog {
} }
func (c *Core) GetActiveGlobalFragment() *activity.LogFragment { func (c *Core) GetActiveGlobalFragment() *activity.LogFragment {
c.activityLog.globalFragmentLock.RLock()
defer c.activityLog.globalFragmentLock.RUnlock()
return c.activityLog.currentGlobalFragment return c.activityLog.currentGlobalFragment
} }
func (c *Core) GetSecondaryGlobalFragments() []*activity.LogFragment { func (c *Core) GetSecondaryGlobalFragments() []*activity.LogFragment {
c.activityLog.globalFragmentLock.RLock()
defer c.activityLog.globalFragmentLock.RUnlock()
return c.activityLog.secondaryGlobalClientFragments return c.activityLog.secondaryGlobalClientFragments
} }
func (c *Core) GetActiveLocalFragment() *activity.LogFragment { func (c *Core) GetActiveLocalFragment() *activity.LogFragment {
c.activityLog.localFragmentLock.RLock()
defer c.activityLog.localFragmentLock.RUnlock()
return c.activityLog.localFragment return c.activityLog.localFragment
} }
func (c *Core) GetActiveFragment() *activity.LogFragment { func (c *Core) GetActiveFragment() *activity.LogFragment {
c.activityLog.fragmentLock.RLock()
defer c.activityLog.fragmentLock.RUnlock()
return c.activityLog.fragment return c.activityLog.fragment
} }