mirror of
https://github.com/ceph/ceph-csi.git
synced 2024-09-19 23:19:52 +00:00
c4a3675cec
As detailed in issue #279, current lock scheme has hash buckets that are count of CPUs. This causes a lot of contention when parallel requests are made to the CSI plugin. To reduce lock contention, this commit introduces granular locks per identifier. The commit also changes the timeout for gRPC requests to Create and Delete volumes, as the current timeout is 10s (kubernetes documentation says 15s but code defaults are 10s). A virtual setup takes about 12-15s to complete a request at times, that leads to unwanted retries of the same request, hence the increased timeout to enable operation completion with minimal retries. Tests to create PVCs before and after these changes look like so, Before: Default master code + sidecar provisioner --timeout option set to 30 seconds 20 PVCs Creation: 3 runs, 396/391/400 seconds Deletion: 3 runs, 218/271/118 seconds - Once was stalled for more than 8 minutes and cancelled the run After: Current commit + sidecar provisioner --timeout option set to 30 sec 20 PVCs Creation: 3 runs, 42/59/65 seconds Deletion: 3 runs, 32/32/31 seconds Fixes: #279 Signed-off-by: ShyamsundarR <srangana@redhat.com>
78 lines
1.5 KiB
Go
78 lines
1.5 KiB
Go
/*
|
|
Copyright 2019 ceph-csi authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package util
|
|
|
|
import (
|
|
"sync"
|
|
)
|
|
|
|
/*
|
|
IDLock is a per identifier lock with a use counter that retains a number of users of the lock.
|
|
IDLocker is a map of IDLocks holding the IDLocks based on a passed in identifier.
|
|
Typical usage (post creating an IDLocker) is to Lock/Unlock based on identifiers as per the API.
|
|
*/
|
|
type (
|
|
IDLock struct {
|
|
mtx sync.Mutex
|
|
useCount int
|
|
}
|
|
|
|
IDLocker struct {
|
|
lMutex sync.Mutex
|
|
lMap map[string]*IDLock
|
|
}
|
|
)
|
|
|
|
func NewIDLocker() *IDLocker {
|
|
return &IDLocker{
|
|
lMap: make(map[string]*IDLock),
|
|
}
|
|
}
|
|
|
|
func (lkr *IDLocker) Lock(identifier string) *IDLock {
|
|
var (
|
|
lk *IDLock
|
|
ok bool
|
|
)
|
|
|
|
newlk := new(IDLock)
|
|
|
|
lkr.lMutex.Lock()
|
|
|
|
if lk, ok = lkr.lMap[identifier]; !ok {
|
|
lk = newlk
|
|
lkr.lMap[identifier] = lk
|
|
}
|
|
lk.useCount++
|
|
lkr.lMutex.Unlock()
|
|
|
|
lk.mtx.Lock()
|
|
|
|
return lk
|
|
}
|
|
|
|
func (lkr *IDLocker) Unlock(lk *IDLock, identifier string) {
|
|
lk.mtx.Unlock()
|
|
|
|
lkr.lMutex.Lock()
|
|
lk.useCount--
|
|
if lk.useCount == 0 {
|
|
delete(lkr.lMap, identifier)
|
|
}
|
|
lkr.lMutex.Unlock()
|
|
}
|