talloc: use the system pytalloc-util for python3 as well

[sfrench/samba-autobuild/.git] / lib / tevent / tevent_internal.h

diff --git a/lib/tevent/tevent_internal.h b/lib/tevent/tevent_internal.h
index 83627705095bcecd4b75bc0fe7d40f877f6af9fc..a5f1ebdefd53db76c3ba730b7c6b82b7bee0acf4 100644 (file)
--- a/lib/tevent/tevent_internal.h
+++ b/lib/tevent/tevent_internal.h
@@ -228,6 +228,16 @@ struct tevent_signal {
        void *additional_data;
 };
 
+struct tevent_threaded_context {
+       struct tevent_threaded_context *next, *prev;
+
+#ifdef HAVE_PTHREAD
+       pthread_mutex_t event_ctx_mutex;
+#endif
+       struct tevent_context *event_ctx;
+       int wakeup_fd;
+};
+
 struct tevent_debug_ops {
        void (*debug)(void *context, enum tevent_debug_level level,
                      const char *fmt, va_list ap) PRINTF_ATTRIBUTE(3,0);
@@ -241,24 +251,41 @@ struct tevent_context {
        /* the specific events implementation */
        const struct tevent_ops *ops;
 
+       /*
+        * The following three pointers are queried on every loop_once
+        * in the order in which they appear here. Not measured, but
+        * hopefully putting them at the top together with "ops"
+        * should make tevent a *bit* more cache-friendly than before.
+        */
+
+       /* list of signal events - used by common code */
+       struct tevent_signal *signal_events;
+
+       /* List of threaded job indicators */
+       struct tevent_threaded_context *threaded_contexts;
+
+       /* list of immediate events - used by common code */
+       struct tevent_immediate *immediate_events;
+
        /* list of fd events - used by common code */
        struct tevent_fd *fd_events;
 
        /* list of timed events - used by common code */
        struct tevent_timer *timer_events;
 
-       /* list of immediate events - used by common code */
-       struct tevent_immediate *immediate_events;
-
-       /* list of signal events - used by common code */
-       struct tevent_signal *signal_events;
+       /* List of scheduled immediates */
+       pthread_mutex_t scheduled_mutex;
+       struct tevent_immediate *scheduled_immediates;
 
        /* this is private for the events_ops implementation */
        void *additional_data;
 
        /* pipe hack used with signal handlers */
-       struct tevent_fd *pipe_fde;
-       int pipe_fds[2];
+       struct tevent_fd *wakeup_fde;
+       int wakeup_fd;          /* fd to write into */
+#ifndef HAVE_EVENT_FD
+       int wakeup_read_fd;
+#endif
 
        /* debugging operations */
        struct tevent_debug_ops debug_ops;
@@ -282,6 +309,10 @@ struct tevent_context {
         * tevent_common_add_timer_v2()
         */
        struct tevent_timer *last_zero_timer;
+
+#ifdef HAVE_PTHREAD
+       struct tevent_context *prev, *next;
+#endif
 };
 
 const struct tevent_ops *tevent_find_ops_byname(const char *name);
@@ -327,9 +358,11 @@ void tevent_common_schedule_immediate(struct tevent_immediate *im,
                                      const char *handler_name,
                                      const char *location);
 bool tevent_common_loop_immediate(struct tevent_context *ev);
+void tevent_common_threaded_activate_immediate(struct tevent_context *ev);
 
 bool tevent_common_have_events(struct tevent_context *ev);
 int tevent_common_wakeup_init(struct tevent_context *ev);
+int tevent_common_wakeup_fd(int fd);
 int tevent_common_wakeup(struct tevent_context *ev);
 
 struct tevent_signal *tevent_common_add_signal(struct tevent_context *ev,