Lines Matching refs:my_kqueue
89 int my_kqueue = *(int *)arg;
99 my_err = kevent( my_kqueue, NULL, 0, my_keventv, 1, NULL );
119 my_err = kevent( my_kqueue, my_keventv, 1, NULL, 0, NULL );
147 int my_kqueue = -1;
254 my_kqueue = kqueue( );
255 if ( my_kqueue == -1 ) {
267 my_err = kevent( my_kqueue, my_keventv, 2, NULL, 0, &my_timeout);
276 my_err = kevent64( my_kqueue, &my_kevent64, 1, NULL, 0, 0, 0);
300 my_err = kevent( my_kqueue, NULL, 0, my_keventv, 1, NULL );
324 my_err = kevent( my_kqueue, my_keventv, 1, my_keventv, 1, NULL );
403 my_err = kevent( my_kqueue, my_keventv, 1, NULL, 0, NULL );
412 my_err = kevent( my_kqueue, my_keventv, 2, NULL, 0, NULL );
423 my_err = pthread_create( &my_threadv[my_index], NULL, kmsg_consumer_thread, (void *)&my_kqueue );
462 my_err = kevent( my_kqueue, my_keventv, 1, NULL, 0, NULL );
483 my_err = kevent( my_kqueue, my_keventv, 1, NULL, 0, NULL );
497 my_err = kevent( my_kqueue, NULL, 0, my_keventv, 1, NULL );
529 if ( my_kqueue != -1 )
530 close( my_kqueue );
532 close( my_kqueue );