tests/libtest/lib3026.c: try to implement test for Windows

Work in Progress - untested - do not merge - PR for testing
curl · Jun 14, 2022 · d2510b4 · d2510b4
1 parent 4572489
commit d2510b4
Show file tree

Hide file tree

Showing 2 changed files with 55 additions and 7 deletions.
diff --git a/tests/data/test3026 b/tests/data/test3026
@@ -19,7 +19,6 @@ slow
 # be used for it
 <features>
 threaded-resolver
-!win32
 </features>
 <server>
 none

diff --git a/tests/libtest/lib3026.c b/tests/libtest/lib3026.c
@@ -26,10 +26,6 @@
 #include "testutil.h"
 #include "warnless.h"
 
-#ifdef HAVE_PTHREAD_H
-#include <pthread.h>
-#include <unistd.h>
-
 #define NUM_THREADS 1000
 
 static void *run_thread(void *ptr)
@@ -43,13 +39,65 @@ static void *run_thread(void *ptr)
   return NULL;
 }
 
+#ifdef WIN32
+int test(char *URL)
+{
+  CURLcode results[NUM_THREADS];
+  HANDLE tids[NUM_THREADS];
+  unsigned tid_count = NUM_THREADS, i;
+  int test_failure = 0;
+  curl_version_info_data *ver;
+  HANDLE tid;
+  (void) URL;
+
+  ver = curl_version_info(CURLVERSION_NOW);
+  if((ver->features & CURL_VERSION_THREADSAFE) == 0) {
+    fprintf(stderr, "%s:%d On Windows but the "
+            "CURL_VERSION_THREADSAFE feature flag is not set\n",
+            __FILE__, __LINE__);
+    return -1;
+  }
+
+  for(i = 0; i < tid_count; i++) {
+    results[i] = CURL_LAST;
+    tid = CreateThread(NULL, 0, run_thread, &results[i], 0, NULL);
+    if(tid == NULL) {
+      fprintf(stderr, "%s:%d Couldn't create thread, errno %d\n",
+              __FILE__, __LINE__, res);
+      tid_count = i;
+      test_failure = -1;
+      goto cleanup;
+    }
+    tids[i] = tid;
+  }
+
+cleanup:
+  for(i = 0; i < tid_count; i++) {
+    WaitForSingleObject(tids[i], INFINITE);
+    CloseHandle(tids[i]);
+    if(results[i] != CURLE_OK) {
+      fprintf(stderr, "%s:%d thread[%u]: curl_global_init() failed,"
+              "with code %d (%s)\n", __FILE__, __LINE__,
+              i, (int) results[i], curl_easy_strerror(results[i]));
+      test_failure = -1;
+    }
+  }
+
+  return test_failure;
+}
+
+#elif defined(HAVE_PTHREAD_H)
+#include <pthread.h>
+#include <unistd.h>
+
 int test(char *URL)
 {
   CURLcode results[NUM_THREADS];
   pthread_t tids[NUM_THREADS];
   unsigned tid_count = NUM_THREADS, i;
   int test_failure = 0;
   curl_version_info_data *ver;
+  int res;
   (void) URL;
 
   ver = curl_version_info(CURLVERSION_NOW);
@@ -61,7 +109,8 @@ int test(char *URL)
   }
 
   for(i = 0; i < tid_count; i++) {
-    int res = pthread_create(&tids[i], NULL, run_thread, &results[i]);
+    results[i] = CURL_LAST;
+    res = pthread_create(&tids[i], NULL, run_thread, &results[i]);
     if(res) {
       fprintf(stderr, "%s:%d Couldn't create thread, errno %d\n",
               __FILE__, __LINE__, res);
@@ -85,7 +134,7 @@ int test(char *URL)
   return test_failure;
 }
 
-#else /* without pthread, this test doesn't work */
+#else /* without pthread or Windows, this test doesn't work */
 int test(char *URL)
 {
   curl_version_info_data *ver;