[ViewVC] Diff of: cvs/libeio/etp.c

Comparing libeio/etp.c (file contents):
Revision 1.7 by root, Thu Jun 25 18:12:53 2015 UTC vs.
Revision 1.8 by root, Thu Jun 25 18:14:19 2015 UTC

 {
   ETP_REQ *qs[ETP_NUM_PRI], *qe[ETP_NUM_PRI]; /* qstart, qend */
   int size;
 } etp_reqq;
+typedef struct etp_pool *etp_pool;
+typedef struct etp_worker
+{
+  etp_pool pool;
+  struct etp_tmpbuf tmpbuf;
+  /* locked by pool->wrklock */
+  struct etp_worker *prev, *next;
+  xthread_t tid;
+#ifdef ETP_WORKER_COMMON
+  ETP_WORKER_COMMON
+#endif
+} etp_worker;
 struct etp_pool
 {
    void *userdata;
    etp_reqq req_queue;
    xmutex_t reqlock;
    xcond_t  reqwait;
    etp_worker wrk_first;
 };
-typedef struct etp_pool *etp_pool;
-typedef struct etp_worker
-{
-  etp_pool pool;
-  struct etp_tmpbuf tmpbuf;
-  /* locked by pool->wrklock */
-  struct etp_worker *prev, *next;
-  xthread_t tid;
-#ifdef ETP_WORKER_COMMON
-  ETP_WORKER_COMMON
-#endif
-} etp_worker;
 #define ETP_WORKER_LOCK(wrk)   X_LOCK   (pool->wrklock)
 #define ETP_WORKER_UNLOCK(wrk) X_UNLOCK (pool->wrklock)
 /* worker threads management */
   X_LOCK (pool->wrklock);
   if (xthread_create (&wrk->tid, etp_proc, (void *)wrk))
     {
-      wrk->prev = &wpool->rk_first;
+      wrk->prev = &pool->wrk_first;
       wrk->next = pool->wrk_first.next;
       pool->wrk_first.next->prev = wrk;
       pool->wrk_first.next = wrk;
       ++pool->started;
     }

-–
+Removed lines
-+
+Added lines
-<
+Changed lines
->
+Changed lines