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 fa6652cfa13656d9289acff8f6cd9b69e41b1d10..a5f1ebdefd53db76c3ba730b7c6b82b7bee0acf4 100644 (file)
--- a/lib/tevent/tevent_internal.h
+++ b/lib/tevent/tevent_internal.h
@@ -73,6 +73,18 @@ struct tevent_req {
         */
        tevent_req_cancel_fn private_cancel;
 
+       /**
+        * @brief A function to cleanup the request
+        *
+        * The implementation might want to set a function
+        * that is called before the tevent_req_done() and tevent_req_error()
+        * trigger the callers callback function.
+        */
+       struct {
+               tevent_req_cleanup_fn fn;
+               enum tevent_req_state state;
+       } private_cleanup;
+
        /**
         * @brief Internal state of the request
         *
@@ -216,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);
@@ -229,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;
@@ -263,6 +302,17 @@ struct tevent_context {
                tevent_trace_callback_t callback;
                void *private_data;
        } tracing;
+
+       /*
+        * an optimization pointer into timer_events
+        * used by used by common code via
+        * 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);
@@ -292,6 +342,13 @@ struct tevent_timer *tevent_common_add_timer(struct tevent_context *ev,
                                             void *private_data,
                                             const char *handler_name,
                                             const char *location);
+struct tevent_timer *tevent_common_add_timer_v2(struct tevent_context *ev,
+                                               TALLOC_CTX *mem_ctx,
+                                               struct timeval next_event,
+                                               tevent_timer_handler_t handler,
+                                               void *private_data,
+                                               const char *handler_name,
+                                               const char *location);
 struct timeval tevent_common_loop_timer_delay(struct tevent_context *);
 
 void tevent_common_schedule_immediate(struct tevent_immediate *im,
@@ -301,6 +358,12 @@ 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,
                                               TALLOC_CTX *mem_ctx,
@@ -316,13 +379,19 @@ void tevent_cleanup_pending_signal_handlers(struct tevent_signal *se);
 bool tevent_standard_init(void);
 bool tevent_select_init(void);
 bool tevent_poll_init(void);
+void tevent_poll_event_add_fd_internal(struct tevent_context *ev,
+                                      struct tevent_fd *fde);
 bool tevent_poll_mt_init(void);
 #ifdef HAVE_EPOLL
 bool tevent_epoll_init(void);
-bool tevent_epoll_set_panic_fallback(struct tevent_context *ev,
+void tevent_epoll_set_panic_fallback(struct tevent_context *ev,
                        bool (*panic_fallback)(struct tevent_context *ev,
                                               bool replay));
 #endif
+#ifdef HAVE_SOLARIS_PORTS
+bool tevent_port_init(void);
+#endif
+
 
 void tevent_trace_point_callback(struct tevent_context *ev,
                                 enum tevent_trace_point);