New upstream version 1.2.4

[quagga-debian.git] / lib / thread.c

diff --git a/lib/thread.c b/lib/thread.c
index de4d76d615227f8475fa87b428f1e196091087c3..f7d1a5ff9aa40a661430283d5d82d780a9215dcc 100644 (file)
--- a/lib/thread.c
+++ b/lib/thread.c
@@ -601,13 +601,13 @@ thread_add_fd (struct thread **thread_array, struct thread *thread)
 
 /* Move thread to unuse list. */
 static void
 
 /* Move thread to unuse list. */
 static void

-thread_add_unuse (struct thread_master *m, struct thread *thread)
+thread_add_unuse (struct thread *thread)

 {
 {

-  assert (m != NULL && thread != NULL);
+  thread->type = THREAD_UNUSED;
+  assert (thread->master != NULL && thread != NULL);

   assert (thread->next == NULL);
   assert (thread->prev == NULL);
   assert (thread->next == NULL);
   assert (thread->prev == NULL);

-  assert (thread->type == THREAD_UNUSED);
-  thread_list_add (&m->unuse, thread);
+  thread_list_add (&thread->master->unuse, thread);

 }
 
 /* Free all unused thread. */
 }
 
 /* Free all unused thread. */


@@ -995,8 +995,7 @@ thread_cancel (struct thread *thread)
       assert(!"Thread should be either in queue or list or array!");
     }
 
       assert(!"Thread should be either in queue or list or array!");
     }
 

-  thread->type = THREAD_UNUSED;
-  thread_add_unuse (thread->master, thread);
+  thread_add_unuse (thread);

 }
 
 /* Delete all events which has argument value arg. */
 }
 
 /* Delete all events which has argument value arg. */


@@ -1018,8 +1017,7 @@ thread_cancel_event (struct thread_master *m, void *arg)
         {
           ret++;
           thread_list_delete (&m->event, t);
         {
           ret++;
           thread_list_delete (&m->event, t);

-          t->type = THREAD_UNUSED;
-          thread_add_unuse (m, t);
+          thread_add_unuse (t);

         }
     }
 
         }
     }
 


@@ -1036,8 +1034,7 @@ thread_cancel_event (struct thread_master *m, void *arg)
         {
           ret++;
           thread_list_delete (&m->ready, t);
         {
           ret++;
           thread_list_delete (&m->ready, t);

-          t->type = THREAD_UNUSED;
-          thread_add_unuse (m, t);
+          thread_add_unuse (t);

         }
     }
   return ret;
         }
     }
   return ret;


@@ -1055,16 +1052,6 @@ thread_timer_wait (struct pqueue *queue, struct timeval *timer_val)
   return NULL;
 }
 
   return NULL;
 }
 

-static struct thread *
-thread_run (struct thread_master *m, struct thread *thread,
-           struct thread *fetch)
-{
-  *fetch = *thread;
-  thread->type = THREAD_UNUSED;
-  thread_add_unuse (m, thread);
-  return fetch;
-}
-

 static int
 thread_process_fds_helper (struct thread_master *m, struct thread *thread, thread_fd_set *fdset)
 {
 static int
 thread_process_fds_helper (struct thread_master *m, struct thread *thread, thread_fd_set *fdset)
 {


@@ -1148,10 +1135,9 @@ thread_process (struct thread_list *list)
   return ready;
 }
 
   return ready;
 }
 

-

 /* Fetch next ready thread. */
 /* Fetch next ready thread. */

-struct thread *
-thread_fetch (struct thread_master *m, struct thread *fetch)
+static struct thread *
+thread_fetch (struct thread_master *m)

 {
   struct thread *thread;
   thread_fd_set readfd;
 {
   struct thread *thread;
   thread_fd_set readfd;


@@ -1173,7 +1159,7 @@ thread_fetch (struct thread_master *m, struct thread *fetch)
        * more.
        */
       if ((thread = thread_trim_head (&m->ready)) != NULL)
        * more.
        */
       if ((thread = thread_trim_head (&m->ready)) != NULL)

-        return thread_run (m, thread, fetch);
+        return thread;

       
       /* To be fair to all kinds of threads, and avoid starvation, we
        * need to be careful to consider all thread types for scheduling
       
       /* To be fair to all kinds of threads, and avoid starvation, we
        * need to be careful to consider all thread types for scheduling


@@ -1227,14 +1213,14 @@ thread_fetch (struct thread_master *m, struct thread *fetch)
         list at this time.  If this is code is uncommented, then background
         timer threads will not run unless there is nothing else to do. */
       if ((thread = thread_trim_head (&m->ready)) != NULL)
         list at this time.  If this is code is uncommented, then background
         timer threads will not run unless there is nothing else to do. */
       if ((thread = thread_trim_head (&m->ready)) != NULL)

-        return thread_run (m, thread, fetch);
+        return thread;

 #endif
 
       /* Background timer/events, lowest priority */
       thread_timer_process (m->background, &relative_time);
       
       if ((thread = thread_trim_head (&m->ready)) != NULL)
 #endif
 
       /* Background timer/events, lowest priority */
       thread_timer_process (m->background, &relative_time);
       
       if ((thread = thread_trim_head (&m->ready)) != NULL)

-        return thread_run (m, thread, fetch);
+        return thread;

     }
 }
 
     }
 }
 


@@ -1290,13 +1276,18 @@ struct thread *thread_current = NULL;
 
 /* We check thread consumed time. If the system has getrusage, we'll
    use that to get in-depth stats on the performance of the thread in addition
 
 /* We check thread consumed time. If the system has getrusage, we'll
    use that to get in-depth stats on the performance of the thread in addition

-   to wall clock time stats from gettimeofday. */
-void
+   to wall clock time stats from gettimeofday. 
+ 
+   'Dummy' threads (e.g.  see funcname_thread_execute) must have
+   thread->master == NULL.
+ */
+   
+static void

 thread_call (struct thread *thread)
 {
   unsigned long realtime, cputime;
   RUSAGE_T before, after;
 thread_call (struct thread *thread)
 {
   unsigned long realtime, cputime;
   RUSAGE_T before, after;

-
+ 

  /* Cache a pointer to the relevant cpu history thread, if the thread
   * does not have it yet.
   *
  /* Cache a pointer to the relevant cpu history thread, if the thread
   * does not have it yet.
   *


@@ -1350,6 +1341,10 @@ thread_call (struct thread *thread)
                 realtime/1000, cputime/1000);
     }
 #endif /* CONSUMED_TIME_CHECK */
                 realtime/1000, cputime/1000);
     }
 #endif /* CONSUMED_TIME_CHECK */

+
+  
+  if (thread->master)
+    thread_add_unuse (thread);

 }
 
 /* Execute thread */
 }
 
 /* Execute thread */


@@ -1379,3 +1374,12 @@ funcname_thread_execute (struct thread_master *m,
 
   return NULL;
 }
 
   return NULL;
 }

+
+/* Co-operative thread main loop */
+void
+thread_main (struct thread_master *master)
+{
+  struct thread *t;
+  while ((t = thread_fetch (master)))
+    thread_call (t);
+}