Revert "vfs_aio_pthread: use event context and threadpool from user_vfs_evg"

This reverts commit cd37badc02b3e56f974168b28447444cd54ee541.

See the discussion in

https://lists.samba.org/archive/samba-technical/2018-December/131731.html

for the reasoning behind this revert.

Signed-off-by: Ralph Boehme <slow@samba.org>
Reviewed-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Stefan Metzmacher <metze@samba.org>

diff --git a/source3/modules/vfs_aio_pthread.c b/source3/modules/vfs_aio_pthread.c
index cf5b7f61d5b09cbb94dc646380d2aeb262512026..da1ca534907f16d8c96a64d43d8235339a0b9433 100644 (file)
--- a/source3/modules/vfs_aio_pthread.c
+++ b/source3/modules/vfs_aio_pthread.c
@@ -51,6 +51,7 @@ struct aio_open_private_data {
        const char *fname;
        char *dname;
        struct smbd_server_connection *sconn;
        const char *fname;
        char *dname;
        struct smbd_server_connection *sconn;

+       const struct security_unix_token *ux_tok;

        uint64_t initial_allocation_size;
        /* Returns. */
        int ret_fd;
        uint64_t initial_allocation_size;
        /* Returns. */
        int ret_fd;


@@ -139,6 +140,16 @@ static void aio_open_worker(void *private_data)
        struct aio_open_private_data *opd =
                (struct aio_open_private_data *)private_data;
 
        struct aio_open_private_data *opd =
                (struct aio_open_private_data *)private_data;
 

+       /* Become the correct credential on this thread. */
+       if (set_thread_credentials(opd->ux_tok->uid,
+                               opd->ux_tok->gid,
+                               (size_t)opd->ux_tok->ngroups,
+                               opd->ux_tok->groups) != 0) {
+               opd->ret_fd = -1;
+               opd->ret_errno = errno;
+               return;
+       }
+

        opd->ret_fd = openat(opd->dir_fd,
                        opd->fname,
                        opd->flags,
        opd->ret_fd = openat(opd->dir_fd,
                        opd->fname,
                        opd->flags,


@@ -208,6 +219,13 @@ static struct aio_open_private_data *create_private_open_data(const files_struct
        opd->sconn = fsp->conn->sconn;
        opd->initial_allocation_size = fsp->initial_allocation_size;
 
        opd->sconn = fsp->conn->sconn;
        opd->initial_allocation_size = fsp->initial_allocation_size;
 

+       /* Copy our current credentials. */
+       opd->ux_tok = copy_unix_token(opd, get_current_utok(fsp->conn));
+       if (opd->ux_tok == NULL) {
+               TALLOC_FREE(opd);
+               return NULL;
+       }
+

        /*
         * Copy the parent directory name and the
         * relative path within it.
        /*
         * Copy the parent directory name and the
         * relative path within it.


@@ -250,10 +268,6 @@ static int open_async(const files_struct *fsp,
 {
        struct aio_open_private_data *opd = NULL;
        struct tevent_req *subreq = NULL;
 {
        struct aio_open_private_data *opd = NULL;
        struct tevent_req *subreq = NULL;

-       const struct smb_vfs_ev_glue *evg = NULL;
-       struct tevent_context *ev = NULL;
-       struct pthreadpool_tevent *tp = NULL;
-       uid_t uid = -1;

 
        opd = create_private_open_data(fsp, flags, mode);
        if (opd == NULL) {
 
        opd = create_private_open_data(fsp, flags, mode);
        if (opd == NULL) {


@@ -261,20 +275,10 @@ static int open_async(const files_struct *fsp,
                return -1;
        }
 
                return -1;
        }
 

-       evg = fsp->conn->user_vfs_evg;
-
-       uid = get_current_uid(fsp->conn);
-       if (uid == 0) {
-               /*
-                * If we're already running as root,
-                * so the root glue.
-                */
-               evg = smb_vfs_ev_glue_get_root_glue(evg);
-       }
-       ev = smb_vfs_ev_glue_ev_ctx(fsp->conn->user_vfs_evg);
-       tp = smb_vfs_ev_glue_tp_path_safe(fsp->conn->user_vfs_evg);
-
-       subreq = pthreadpool_tevent_job_send(opd, ev, tp, aio_open_worker, opd);
+       subreq = pthreadpool_tevent_job_send(opd,
+                                            fsp->conn->user_ev_ctx,
+                                            fsp->conn->sconn->raw_thread_pool,
+                                            aio_open_worker, opd);

        if (subreq == NULL) {
                return -1;
        }
        if (subreq == NULL) {
                return -1;
        }