github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 12:43:23 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #98760 from wzshiming/ut/speed-up-operationexecutor

Browse Source 
Speed up pkg/volume/util/operationexecutor unit tests
This commit is contained in:
Kubernetes Prow Robot 2021-02-09 00:45:35 -08:00 committed by GitHub
commit 5eeaa562b1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
pkg/volume/util/operationexecutor/operation_executor_test.go
View File

@ -77,6 +77,8 @@ func TestOperationExecutor_MountVolume_ConcurrentMountForNonAttachableAndNonDevi
} }
func TestOperationExecutor_MountVolume_ConcurrentMountForAttachablePlugins(t *testing.T) { func TestOperationExecutor_MountVolume_ConcurrentMountForAttachablePlugins(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
volumesToMount := make([]VolumeToMount, numVolumesToAttach) volumesToMount := make([]VolumeToMount, numVolumesToAttach)
@ -102,6 +104,8 @@ func TestOperationExecutor_MountVolume_ConcurrentMountForAttachablePlugins(t *te
} }
func TestOperationExecutor_MountVolume_ConcurrentMountForDeviceMountablePlugins(t *testing.T) { func TestOperationExecutor_MountVolume_ConcurrentMountForDeviceMountablePlugins(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
volumesToMount := make([]VolumeToMount, numVolumesToAttach) volumesToMount := make([]VolumeToMount, numVolumesToAttach)
@ -161,6 +165,8 @@ func TestOperationExecutor_UnmountVolume_ConcurrentUnmountForAllPlugins(t *testi
} }
func TestOperationExecutor_UnmountDeviceConcurrently(t *testing.T) { func TestOperationExecutor_UnmountDeviceConcurrently(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
attachedVolumes := make([]AttachedVolume, numDevicesToUnmount) attachedVolumes := make([]AttachedVolume, numDevicesToUnmount)
@ -182,6 +188,8 @@ func TestOperationExecutor_UnmountDeviceConcurrently(t *testing.T) {
} }
func TestOperationExecutor_AttachSingleNodeVolumeConcurrentlyToSameNode(t *testing.T) { func TestOperationExecutor_AttachSingleNodeVolumeConcurrentlyToSameNode(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
volumesToAttach := make([]VolumeToAttach, numVolumesToAttach) volumesToAttach := make([]VolumeToAttach, numVolumesToAttach)
@ -210,6 +218,8 @@ func TestOperationExecutor_AttachSingleNodeVolumeConcurrentlyToSameNode(t *testi
} }
func TestOperationExecutor_AttachMultiNodeVolumeConcurrentlyToSameNode(t *testing.T) { func TestOperationExecutor_AttachMultiNodeVolumeConcurrentlyToSameNode(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
volumesToAttach := make([]VolumeToAttach, numVolumesToAttach) volumesToAttach := make([]VolumeToAttach, numVolumesToAttach)
@ -238,6 +248,8 @@ func TestOperationExecutor_AttachMultiNodeVolumeConcurrentlyToSameNode(t *testin
} }
func TestOperationExecutor_AttachSingleNodeVolumeConcurrentlyToDifferentNodes(t *testing.T) { func TestOperationExecutor_AttachSingleNodeVolumeConcurrentlyToDifferentNodes(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
volumesToAttach := make([]VolumeToAttach, numVolumesToAttach) volumesToAttach := make([]VolumeToAttach, numVolumesToAttach)
@ -294,6 +306,8 @@ func TestOperationExecutor_AttachMultiNodeVolumeConcurrentlyToDifferentNodes(t *
} }
func TestOperationExecutor_DetachSingleNodeVolumeConcurrentlyFromSameNode(t *testing.T) { func TestOperationExecutor_DetachSingleNodeVolumeConcurrentlyFromSameNode(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
attachedVolumes := make([]AttachedVolume, numVolumesToDetach) attachedVolumes := make([]AttachedVolume, numVolumesToDetach)
@ -322,6 +336,8 @@ func TestOperationExecutor_DetachSingleNodeVolumeConcurrentlyFromSameNode(t *tes
} }
func TestOperationExecutor_DetachMultiNodeVolumeConcurrentlyFromSameNode(t *testing.T) { func TestOperationExecutor_DetachMultiNodeVolumeConcurrentlyFromSameNode(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
attachedVolumes := make([]AttachedVolume, numVolumesToDetach) attachedVolumes := make([]AttachedVolume, numVolumesToDetach)
@ -411,6 +427,8 @@ func TestOperationExecutor_VerifyVolumesAreAttachedConcurrentlyOnDifferentNodes(
} }
func TestOperationExecutor_VerifyControllerAttachedVolumeConcurrently(t *testing.T) { func TestOperationExecutor_VerifyControllerAttachedVolumeConcurrently(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
volumesToMount := make([]VolumeToMount, numVolumesToVerifyControllerAttached) volumesToMount := make([]VolumeToMount, numVolumesToVerifyControllerAttached)
@ -460,6 +478,8 @@ func TestOperationExecutor_MountVolume_ConcurrentMountForNonAttachablePlugins_Vo
} }
func TestOperationExecutor_MountVolume_ConcurrentMountForAttachablePlugins_VolumeMode_Block(t *testing.T) { func TestOperationExecutor_MountVolume_ConcurrentMountForAttachablePlugins_VolumeMode_Block(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
volumesToMount := make([]VolumeToMount, numVolumesToAttach) volumesToMount := make([]VolumeToMount, numVolumesToAttach)
@ -527,6 +547,8 @@ func TestOperationExecutor_UnmountVolume_ConcurrentUnmountForAllPlugins_VolumeMo
} }
func TestOperationExecutor_UnmountDeviceConcurrently_VolumeMode_Block(t *testing.T) { func TestOperationExecutor_UnmountDeviceConcurrently_VolumeMode_Block(t *testing.T) {
t.Parallel()
// Arrange // Arrange
ch, quit, oe := setup() ch, quit, oe := setup()
attachedVolumes := make([]AttachedVolume, numDevicesToUnmap) attachedVolumes := make([]AttachedVolume, numDevicesToUnmap)