@@ -10,6 +10,8 @@ const buffer_utils = require('../../../util/buffer_utils');
10
10
const { TMP_PATH } = require ( '../../system_tests/test_utils' ) ;
11
11
const { crypto_random_string } = require ( '../../../util/string_utils' ) ;
12
12
const endpoint_stats_collector = require ( '../../../sdk/endpoint_stats_collector' ) ;
13
+ const SECONDS = 1000 ;
14
+ const test_timeout = SECONDS * 60 ;
13
15
14
16
function make_dummy_object_sdk ( nsfs_config , uid , gid ) {
15
17
return {
@@ -68,7 +70,7 @@ describe('test versioning concurrency', () => {
68
70
expect ( failed_operations ) . toHaveLength ( 0 ) ;
69
71
const versions = await nsfs . list_object_versions ( { bucket : bucket } , DUMMY_OBJECT_SDK ) ;
70
72
expect ( versions . objects . length ) . toBe ( num_of_concurrency ) ;
71
- } ) ;
73
+ } , test_timeout ) ;
72
74
73
75
it ( 'multiple delete version id and key' , async ( ) => {
74
76
const bucket = 'bucket1' ;
@@ -88,7 +90,7 @@ describe('test versioning concurrency', () => {
88
90
await P . delay ( 1000 ) ;
89
91
expect ( successful_operations ) . toHaveLength ( num_of_concurrency ) ;
90
92
expect ( failed_operations ) . toHaveLength ( 0 ) ;
91
- } ) ;
93
+ } , test_timeout ) ;
92
94
93
95
// same as s3tests_boto3/functional/test_s3.py::test_versioning_concurrent_multi_object_delete,
94
96
// this test has a bug, it tries to create the bucket twice and fails
@@ -130,7 +132,7 @@ describe('test versioning concurrency', () => {
130
132
}
131
133
const list_res = await nsfs . list_objects ( { bucket : bucket } , DUMMY_OBJECT_SDK ) ;
132
134
expect ( list_res . objects . length ) . toBe ( 0 ) ;
133
- } , 8000 ) ;
135
+ } , test_timeout ) ;
134
136
135
137
it ( 'concurrent delete of latest version' , async ( ) => {
136
138
const bucket = 'bucket1' ;
@@ -154,7 +156,7 @@ describe('test versioning concurrency', () => {
154
156
expect ( versions . objects . length ) . toBe ( 8 ) ; // 5 versions before + 3 delete markers concurrent
155
157
const delete_marker_arr = versions . objects . filter ( object => object . delete_marker === true ) ;
156
158
expect ( delete_marker_arr . length ) . toBe ( 3 ) ;
157
- } ) ;
159
+ } , test_timeout ) ;
158
160
159
161
it ( 'concurrent put object and head object latest version' , async ( ) => {
160
162
const bucket = 'bucket1' ;
@@ -182,7 +184,7 @@ describe('test versioning concurrency', () => {
182
184
expect ( successful_head_operations . length ) . toBe ( number_of_iterations ) ;
183
185
const versions = await nsfs . list_object_versions ( { bucket : bucket } , DUMMY_OBJECT_SDK ) ;
184
186
expect ( versions . objects . length ) . toBe ( number_of_iterations + 1 ) ; // 1 version before + 10 versions concurrent
185
- } ) ;
187
+ } , test_timeout ) ;
186
188
187
189
it ( 'concurrent puts & delete latest objects' , async ( ) => {
188
190
const bucket = 'bucket1' ;
@@ -216,7 +218,7 @@ describe('test versioning concurrency', () => {
216
218
expect ( num_of_delete_markers ) . toBe ( num_of_concurrency ) ;
217
219
const num_of_latest_versions = ( versions . objects . filter ( version => version . is_latest === true ) ) . length ;
218
220
expect ( num_of_latest_versions ) . toBe ( 1 ) ;
219
- } , 6000 ) ;
221
+ } , test_timeout ) ;
220
222
221
223
it ( 'concurrent puts & delete objects by version id' , async ( ) => {
222
224
const bucket = 'bucket1' ;
@@ -250,7 +252,7 @@ describe('test versioning concurrency', () => {
250
252
expect ( num_of_delete_markers ) . toBe ( 0 ) ;
251
253
const num_of_latest_versions = ( versions . objects . filter ( version => version . is_latest === true ) ) . length ;
252
254
expect ( num_of_latest_versions ) . toBe ( 1 ) ;
253
- } , 6000 ) ;
255
+ } , test_timeout ) ;
254
256
255
257
it ( 'concurrent delete objects by version id/latest' , async ( ) => {
256
258
const bucket = 'bucket1' ;
@@ -283,7 +285,7 @@ describe('test versioning concurrency', () => {
283
285
expect ( num_of_delete_markers ) . toBe ( num_of_concurrency ) ;
284
286
const num_of_latest_versions = ( versions . objects . filter ( version => version . is_latest === true ) ) . length ;
285
287
expect ( num_of_latest_versions ) . toBe ( 1 ) ;
286
- } , 6000 ) ;
288
+ } , test_timeout ) ;
287
289
288
290
it ( 'nested key - concurrent delete multiple objects' , async ( ) => {
289
291
const bucket = 'bucket1' ;
@@ -320,8 +322,7 @@ describe('test versioning concurrency', () => {
320
322
}
321
323
const list_res = await nsfs . list_objects ( { bucket : bucket } , DUMMY_OBJECT_SDK ) ;
322
324
expect ( list_res . objects ) . toHaveLength ( 0 ) ;
323
- } , 8000 ) ;
324
-
325
+ } , test_timeout ) ;
325
326
326
327
it ( 'nested key - concurrent puts & deletes' , async ( ) => {
327
328
const bucket = 'bucket1' ;
@@ -349,7 +350,7 @@ describe('test versioning concurrency', () => {
349
350
expect ( upload_failed_operations ) . toHaveLength ( 0 ) ;
350
351
expect ( delete_successful_operations ) . toHaveLength ( num_of_concurrency ) ;
351
352
expect ( delete_failed_operations ) . toHaveLength ( 0 ) ;
352
- } , 6000 ) ;
353
+ } , test_timeout ) ;
353
354
354
355
it ( 'concurrent puts & list versions' , async ( ) => {
355
356
const bucket = 'bucket1' ;
@@ -389,7 +390,7 @@ describe('test versioning concurrency', () => {
389
390
expect ( num_of_delete_markers ) . toBe ( 0 ) ;
390
391
const num_of_latest_versions = ( versions . objects . filter ( version => version . is_latest === true ) ) . length ;
391
392
expect ( num_of_latest_versions ) . toBe ( initial_num_of_objects ) ;
392
- } , 60000 ) ;
393
+ } , test_timeout ) ;
393
394
394
395
it ( 'concurrent puts & list versions - version id paging' , async ( ) => {
395
396
const bucket = 'bucket1' ;
@@ -432,7 +433,7 @@ describe('test versioning concurrency', () => {
432
433
expect ( num_of_delete_markers ) . toBe ( 0 ) ;
433
434
const num_of_latest_versions = ( merged_versions . filter ( version => version . is_latest === true ) ) . length ;
434
435
expect ( num_of_latest_versions ) . toBe ( initial_num_of_objects ) ;
435
- } , 50000 ) ;
436
+ } , test_timeout ) ;
436
437
} ) ;
437
438
438
439
/**
0 commit comments