libaitsched/src/hooks.c - diff

Return to hooks.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitsched / src

Diff for /libaitsched/src/hooks.c between versions 1.13.2.2 and 1.14.2.6

-version 1.13.2.2, 2012/08/21 11:45:35
+version 1.14.2.6, 2012/08/23 02:09:54
  Line 110  sched_hook_cancel(void *task, void *arg __unused)
  #ifdef AIO_SUPPORT
          struct aiocb *acb;
  #ifdef EVFILT_LIO
+         register int i = 0;
          struct aiocb **acbs;
-         register int i;
  #endif  /* EVFILT_LIO */
  #endif  /* AIO_SUPPORT */
  Line 218  sched_hook_cancel(void *task, void *arg __unused)
          kevent(TASK_ROOT(t)->root_kq, chg, 1, NULL, 0, &timeout);
          return NULL;
  }
+ #ifdef HAVE_LIBPTHREAD
+ /*
+  * sched_hook_thread() - Default THREAD hook
+  *
+  * @task = current task
+  * @arg = pthread attributes
+  * return: <0 errors and 0 ok
+  */
+ void *
+ sched_hook_thread(void *task, void *arg)
+ {
+         sched_task_t *t = task;
+         pthread_t tid;
+         sigset_t s, o;
+         if (!t || !TASK_ROOT(t))
+                 return (void*) -1;
+         sigfillset(&s);
+         pthread_sigmask(SIG_BLOCK, &s, &o);
+         if (pthread_create(&tid, (pthread_attr_t*) arg,
+                                 (void *(*)(void*)) _sched_threadWrapper, t)) {
+                 LOGERR;
+                 pthread_sigmask(SIG_SETMASK, &o, NULL);
+                 return (void*) -1;
+         } else
+                 TASK_VAL(t) = (u_long) tid;
+         if (!TASK_ISLOCKED(t))
+                 TASK_LOCK(t);
+         pthread_sigmask(SIG_SETMASK, &o, NULL);
+         return NULL;
+ }
+ #endif
  /*
   * sched_hook_read() - Default READ hook

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.13.2.2
changed lines
	Added in v.1.14.2.6