Lines Matching refs:th_notify_fd

573 	base->th_notify_fd[0] = -1;  in event_base_new_with_config()
574 base->th_notify_fd[1] = -1; in event_base_new_with_config()
714 if (base->th_notify_fd[0] != -1) { in event_base_free()
716 EVUTIL_CLOSESOCKET(base->th_notify_fd[0]); in event_base_free()
717 if (base->th_notify_fd[1] != -1) in event_base_free()
718 EVUTIL_CLOSESOCKET(base->th_notify_fd[1]); in event_base_free()
719 base->th_notify_fd[0] = -1; in event_base_free()
720 base->th_notify_fd[1] = -1; in event_base_free()
833 if (base->th_notify_fd[0] != -1) { in event_reinit()
843 EVUTIL_CLOSESOCKET(base->th_notify_fd[0]); in event_reinit()
844 if (base->th_notify_fd[1] != -1) in event_reinit()
845 EVUTIL_CLOSESOCKET(base->th_notify_fd[1]); in event_reinit()
846 base->th_notify_fd[0] = -1; in event_reinit()
847 base->th_notify_fd[1] = -1; in event_reinit()
2002 r = send(base->th_notify_fd[1], buf, 1, 0); in evthread_notify_base_default()
2004 r = write(base->th_notify_fd[1], buf, 1); in evthread_notify_base_default()
2018 r = write(base->th_notify_fd[0], (void*) &msg, sizeof(msg)); in evthread_notify_base_eventfd()
2776 if (base->th_notify_fd[0] >= 0) in evthread_make_base_notifiable()
2783 base->th_notify_fd[0] = eventfd(0, EFD_CLOEXEC); in evthread_make_base_notifiable()
2784 if (base->th_notify_fd[0] >= 0) { in evthread_make_base_notifiable()
2785 evutil_make_socket_closeonexec(base->th_notify_fd[0]); in evthread_make_base_notifiable()
2791 if (base->th_notify_fd[0] < 0) { in evthread_make_base_notifiable()
2793 if (pipe(base->th_notify_fd) < 0) { in evthread_make_base_notifiable()
2796 evutil_make_socket_closeonexec(base->th_notify_fd[0]); in evthread_make_base_notifiable()
2797 evutil_make_socket_closeonexec(base->th_notify_fd[1]); in evthread_make_base_notifiable()
2808 if (base->th_notify_fd[0] < 0) { in evthread_make_base_notifiable()
2810 base->th_notify_fd) == -1) { in evthread_make_base_notifiable()
2814 evutil_make_socket_closeonexec(base->th_notify_fd[0]); in evthread_make_base_notifiable()
2815 evutil_make_socket_closeonexec(base->th_notify_fd[1]); in evthread_make_base_notifiable()
2819 evutil_make_socket_nonblocking(base->th_notify_fd[0]); in evthread_make_base_notifiable()
2831 if (base->th_notify_fd[1] > 0) in evthread_make_base_notifiable()
2832 evutil_make_socket_nonblocking(base->th_notify_fd[1]); in evthread_make_base_notifiable()
2835 event_assign(&base->th_notify, base, base->th_notify_fd[0], in evthread_make_base_notifiable()