Changeset 2472 in kBuild for trunk/src/lib

Timestamp:

Jul 12, 2011 2:12:57 PM (14 years ago)

Author:

bird

Message:

2nd attempt at reproducing it...

File:

• trunk/src/lib/test-eintr-bug-2.c (copied) (copied from trunk/src/lib/test-eintr-bug-1.c ) (4 diffs)

trunk/src/lib/test-eintr-bug-2.c

@@ -4 +4 @@
 *   Header Files                                                               *
 *******************************************************************************/
-#define _XOPEN_SOURCE
 #define _BSD_SOURCE
+#define _GNU_SOURCE
 #include <sys/time.h>
 #include <sys/stat.h>
+#include <time.h>
 #include <stdio.h>
-#include <signal.h>
 #include <string.h>
 #include <errno.h>
+#include <pthread.h>
+#include <signal.h>
 
 
-static void SigAlaramHandler(int iSig)
+/*******************************************************************************
+*   Global Variables                                                           *
+*******************************************************************************/
+/** The number of signals. */
+static volatile long    g_cSigs = 0;
+/** Whether to shutdown or not. */
+static volatile int     g_fShutdown = 0;
+/** The handle of the main thread. */
+static pthread_t        g_hMainThread;
+
+
+static void SigHandler(int iSig)
 {
-    /* ignore */
+    g_cSigs++;
+
     (void)iSig;
+}
+
+
+static void NanoSleep(unsigned long cNanoSecs)
+{
+    struct timespec Ts;
+    Ts.tv_sec  = 0;
+    Ts.tv_nsec = cNanoSecs;
+    nanosleep(&Ts, NULL);
+}
+
+
+static void *ThreadProc(void *pvIgnored)
+{
+    while (!g_fShutdown)
+    {
+        NanoSleep(850);
+        if (g_fShutdown)
+            break;
+
+        pthread_kill(g_hMainThread, SIGALRM);
+    }
+    return NULL;
 }
 
@@ -23 +60 @@
 int main(int argc, char **argv)
 {
-    struct itimerval TmrVal;
     void (*rcSig)(int);
+    pthread_t hThread;
+    char szName[1024];
     int i;
     int rc;
 
     /*
-     * Set up the timer signal.
+     * Set up the signal handlers.
      */
-    rcSig = bsd_signal(SIGALRM, SigAlaramHandler);
+    rcSig = bsd_signal(SIGALRM, SigHandler);
+    if (rcSig != SIG_ERR)
+        rcSig = bsd_signal(SIGCHLD, SigHandler);
     if (rcSig == SIG_ERR)
     {
@@ -38 +78 @@
     }
     if (argc == 2) /* testing... */
+    {
         siginterrupt(SIGALRM, 1);
+        siginterrupt(SIGCHLD, 1);
+    }
 
-    memset(&TmrVal, '\0', sizeof(TmrVal));
-    TmrVal.it_interval.tv_sec  = TmrVal.it_value.tv_sec  = 0;
-    TmrVal.it_interval.tv_usec = TmrVal.it_value.tv_usec = 1000;
-    rc = setitimer(ITIMER_REAL, &TmrVal, NULL);
+    /*
+     * Kick off a thread that will signal us like there was no tomorrow.
+     */
+    g_hMainThread = pthread_self();
+    rc = pthread_create(&hThread, NULL, ThreadProc, NULL);
     if (rc != 0)
     {
-        fprintf(stderr, "setitimer failed: %s\n", strerror(errno));
+        fprintf(stderr, "pthread_create failed: %s\n", strerror(rc));
         return 1;
     }
@@ -53 +97 @@
      * Do path related stuff.
      */
+    snprintf(szName, sizeof(szName), "%s-test2", argv[0]);
     for (i = 0; i < 100*1000*1000; i++)
     {
         struct stat St;
+
         rc = stat(argv[0], &St);
-        if (rc != 0)
+        if (rc == 0 || errno != EINTR)
+            rc = stat(szName, &St);
+        if (errno == EINTR && rc != 0)
         {
             printf("iteration %d: stat: %u\n", i, errno);
             break;
         }
+        if ((i % 100000) == 0)
+        {
+            printf(".");
+            if ((i % 1000000) == 0)
+                printf("[%d/%ld]", i, g_cSigs);
+            fflush(stdout);
+        }
     }
 
+    g_fShutdown = 1;
     if (rc)
         printf("No EINTR in %d iterations - system is working nicely!\n", i);
-
-    TmrVal.it_interval.tv_sec  = TmrVal.it_value.tv_sec  = 0;
-    TmrVal.it_interval.tv_usec = TmrVal.it_value.tv_usec = 0;
-    setitimer(ITIMER_REAL, &TmrVal, NULL);
+    NanoSleep(10000000);
 
     return rc ? 1 : 0;