@@ -31,13 +31,20 @@ static char buffer[20] = {};
31
31
static const size_t data_size = 5 ;
32
32
static size_t actual_size = 0 ;
33
33
static const size_t buffer_size = 20 ;
34
+
35
+ /* Adjust number of threads/keys dependent on platform memory resource */
36
+ #if defined(TARGET_NUMAKER_M252KG)
37
+ static const int num_of_threads = 2 ;
38
+ static const char num_of_keys = 2 ;
39
+ static const char *keys[] = {" key1" , " key2" };
40
+ #else
34
41
static const int num_of_threads = 3 ;
35
42
static const char num_of_keys = 3 ;
43
+ static const char *keys[] = {" key1" , " key2" , " key3" };
44
+ #endif
36
45
37
46
static const int heap_alloc_threshold_size = 4096 ;
38
47
39
- static const char *keys[] = {" key1" , " key2" , " key3" };
40
-
41
48
static int init_res = MBED_ERROR_NOT_READY;
42
49
43
50
kv_info_t info;
@@ -147,10 +154,9 @@ static void set_several_keys_multithreaded()
147
154
rtos::Thread kvstore_thread[num_of_threads];
148
155
osStatus threadStatus;
149
156
150
- kvstore_thread[0 ].start (callback (test_thread_set, (char *) keys[0 ]));
151
- kvstore_thread[1 ].start (callback (test_thread_set, (char *) keys[1 ]));
152
- kvstore_thread[2 ].start (callback (test_thread_set, (char *) keys[2 ]));
153
-
157
+ for (int i = 0 ; i < num_of_threads; i++) {
158
+ kvstore_thread[i].start (callback (test_thread_set, (char *) keys[i]));
159
+ }
154
160
155
161
for (int i = 0 ; i < num_of_threads; i++) {
156
162
threadStatus = kvstore_thread[i].join ();
@@ -473,9 +479,9 @@ static void get_several_keys_multithreaded()
473
479
TEST_ASSERT_EQUAL_ERROR_CODE (MBED_SUCCESS, res);
474
480
}
475
481
476
- kvstore_thread[ 0 ]. start ( callback (test_thread_get, " key1 " ));
477
- kvstore_thread[1 ].start (callback (test_thread_get, " key2 " ));
478
- kvstore_thread[ 2 ]. start ( callback (test_thread_get, " key3 " ));
482
+ for (i = 0 ; i < num_of_threads; i++) {
483
+ kvstore_thread[i ].start (callback (test_thread_get, ( char *) keys[i] ));
484
+ }
479
485
480
486
for (i = 0 ; i < num_of_threads; i++) {
481
487
threadStatus = kvstore_thread[i].join ();
0 commit comments