async_req: Fix the S4 build
authorKai Blin <kai@samba.org>
Tue, 27 Jan 2009 09:37:35 +0000 (10:37 +0100)
committerKai Blin <kai@samba.org>
Tue, 27 Jan 2009 11:38:11 +0000 (12:38 +0100)
lib/async_req/async_req.c
lib/async_req/async_req.h
source3/configure.in
source3/include/includes.h

index 011948a158cc4e20333573b742c16696ae02a08b..be70a56380fa88607e3b7217c5e5c89ee8df52f2 100644 (file)
 */
 
 #include "includes.h"
+#include "lib/tevent/tevent.h"
+#include "lib/talloc/talloc.h"
+#include "lib/util/dlinklist.h"
+#include "lib/async_req/async_req.h"
+
+#ifndef TALLOC_FREE
+#define TALLOC_FREE(ctx) do { talloc_free(ctx); ctx=NULL; } while(0)
+#endif
 
 /**
  * @brief Print an async_req structure
@@ -53,7 +61,7 @@ struct async_req *async_req_new(TALLOC_CTX *mem_ctx)
 {
        struct async_req *result;
 
-       result = TALLOC_ZERO_P(mem_ctx, struct async_req);
+       result = talloc_zero(mem_ctx, struct async_req);
        if (result == NULL) {
                return NULL;
        }
@@ -107,7 +115,7 @@ void async_req_error(struct async_req *req, NTSTATUS status)
  * @param[in] priv     The async request to be finished
  */
 
-static void async_trigger(struct event_context *ev, struct timed_event *te,
+static void async_trigger(struct tevent_context *ev, struct tevent_timer *te,
                          struct timeval now, void *priv)
 {
        struct async_req *req = talloc_get_type_abort(priv, struct async_req);
@@ -134,12 +142,12 @@ static void async_trigger(struct event_context *ev, struct timed_event *te,
  * conventions, independent of whether the request was actually deferred.
  */
 
-bool async_post_status(struct async_req *req, struct event_context *ev,
+bool async_post_status(struct async_req *req, struct tevent_context *ev,
                       NTSTATUS status)
 {
        req->status = status;
 
-       if (event_add_timed(ev, req, timeval_zero(),
+       if (tevent_add_timer(ev, req, timeval_zero(),
                            async_trigger, req) == NULL) {
                return false;
        }
@@ -195,8 +203,8 @@ NTSTATUS async_req_simple_recv(struct async_req *req)
        return NT_STATUS_OK;
 }
 
-static void async_req_timedout(struct event_context *ev,
-                              struct timed_event *te,
+static void async_req_timedout(struct tevent_context *ev,
+                              struct tevent_timer *te,
                               struct timeval now,
                               void *priv)
 {
@@ -206,17 +214,17 @@ static void async_req_timedout(struct event_context *ev,
        async_req_error(req, NT_STATUS_IO_TIMEOUT);
 }
 
-bool async_req_set_timeout(struct async_req *req, struct event_context *ev,
+bool async_req_set_timeout(struct async_req *req, struct tevent_context *ev,
                           struct timeval to)
 {
-       return (event_add_timed(ev, req,
+       return (tevent_add_timer(ev, req,
                                timeval_current_ofs(to.tv_sec, to.tv_usec),
                                async_req_timedout, req)
                != NULL);
 }
 
 struct async_req *async_wait_send(TALLOC_CTX *mem_ctx,
-                                 struct event_context *ev,
+                                 struct tevent_context *ev,
                                  struct timeval to)
 {
        struct async_req *result;
@@ -250,7 +258,7 @@ struct async_req_queue {
 
 struct async_req_queue *async_req_queue_init(TALLOC_CTX *mem_ctx)
 {
-       return TALLOC_ZERO_P(mem_ctx, struct async_req_queue);
+       return talloc_zero(mem_ctx, struct async_req_queue);
 }
 
 static int async_queue_entry_destructor(struct async_queue_entry *e)
@@ -266,8 +274,8 @@ static int async_queue_entry_destructor(struct async_queue_entry *e)
        return 0;
 }
 
-static void async_req_immediate_trigger(struct event_context *ev,
-                                       struct timed_event *te,
+static void async_req_immediate_trigger(struct tevent_context *ev,
+                                       struct tevent_timer *te,
                                        struct timeval now,
                                        void *priv)
 {
@@ -278,7 +286,7 @@ static void async_req_immediate_trigger(struct event_context *ev,
        e->trigger(e->req);
 }
 
-bool async_req_enqueue(struct async_req_queue *queue, struct event_context *ev,
+bool async_req_enqueue(struct async_req_queue *queue, struct tevent_context *ev,
                       struct async_req *req,
                       void (*trigger)(struct async_req *req))
 {
@@ -300,9 +308,9 @@ bool async_req_enqueue(struct async_req_queue *queue, struct event_context *ev,
        talloc_set_destructor(e, async_queue_entry_destructor);
 
        if (!busy) {
-               struct timed_event *te;
+               struct tevent_timer *te;
 
-               te = event_add_timed(ev, e, timeval_zero(),
+               te = tevent_add_timer(ev, e, timeval_zero(),
                                     async_req_immediate_trigger,
                                     e);
                if (te == NULL) {
@@ -330,7 +338,7 @@ bool _async_req_setup(TALLOC_CTX *mem_ctx, struct async_req **preq,
                TALLOC_FREE(req);
                return false;
        }
-       talloc_set_name(state, typename);
+       talloc_set_name_const(state, typename);
        req->private_data = state;
 
        *preq = req;
index 3907a08f67cffacab42f6c7324834a925c8c1f30..59f5bd19b2a63b12db6bb4b08594de6472848db0 100644 (file)
@@ -123,7 +123,7 @@ void async_req_done(struct async_req *req);
 
 void async_req_error(struct async_req *req, NTSTATUS status);
 
-bool async_post_status(struct async_req *req, struct event_context *ev,
+bool async_post_status(struct async_req *req, struct tevent_context *ev,
                       NTSTATUS status);
 
 bool async_req_nomem(const void *p, struct async_req *req);
@@ -132,11 +132,11 @@ bool async_req_is_error(struct async_req *req, NTSTATUS *status);
 
 NTSTATUS async_req_simple_recv(struct async_req *req);
 
-bool async_req_set_timeout(struct async_req *req, struct event_context *ev,
+bool async_req_set_timeout(struct async_req *req, struct tevent_context *ev,
                           struct timeval to);
 
 struct async_req *async_wait_send(TALLOC_CTX *mem_ctx,
-                                 struct event_context *ev,
+                                 struct tevent_context *ev,
                                  struct timeval to);
 
 NTSTATUS async_wait_recv(struct async_req *req);
@@ -146,7 +146,7 @@ struct async_req_queue;
 struct async_req_queue *async_req_queue_init(TALLOC_CTX *mem_ctx);
 
 bool async_req_enqueue(struct async_req_queue *queue,
-                      struct event_context *ev,
+                      struct tevent_context *ev,
                       struct async_req *req,
                       void (*trigger)(struct async_req *req));
 
index 321924889aca6b7611f9bee314829fb32e06d417..c63f7c84a8029c0d135d3ca007531be761175bb4 100644 (file)
@@ -63,7 +63,7 @@ SAMBA_CPPFLAGS="${SAMBA_CPPFLAGS} ${TEVENT_CFLAGS}"
 SAMBA_CPPFLAGS="${SAMBA_CPPFLAGS} ${TDB_CFLAGS}"
 SAMBA_CPPFLAGS="${SAMBA_CPPFLAGS} -I${srcdir-.}/libaddns"
 SAMBA_CPPFLAGS="${SAMBA_CPPFLAGS} -I${srcdir-.}/librpc"
-SAMBA_CPPFLAGS="${SAMBA_CPPFLAGS} -I${srcdir-.}/../lib/async_req"
+SAMBA_CPPFLAGS="${SAMBA_CPPFLAGS} -I${srcdir-.}/.."
 
 SAMBA_CONFIGURE_CPPFLAGS="${SAMBA_CPPFLAGS} -I${srcdir-.}/../lib/popt"
 
index 9c7f15b9cbe4d076025fdaecfceb43c89cbf4573..50140c17f72238f6edcf94703faad71fdf167f66 100644 (file)
@@ -647,7 +647,7 @@ struct smb_iconv_convenience *lp_iconv_convenience(void *lp_ctx);
 #include "ctdbd_conn.h"
 #include "../lib/util/talloc_stack.h"
 #include "memcache.h"
-#include "async_req.h"
+#include "../lib/async_req/async_req.h"
 #include "async_smb.h"
 #include "async_sock.h"
 #include "services.h"