diff options
author | Volker Lendecke <vl@samba.org> | 2017-11-17 11:35:19 +0100 |
---|---|---|
committer | Jeremy Allison <jra@samba.org> | 2017-11-18 00:09:16 +0100 |
commit | 7e83d1489406cd53d72097e40bf02295c88ea61e (patch) | |
tree | 7f610cce56c77fcf3594b8c0751b1d3ee9e904ce /source3/winbindd/winbindd.c | |
parent | d27f38d35bf111a5c0a898a5ef8b7dd0b320da0d (diff) | |
download | samba-7e83d1489406cd53d72097e40bf02295c88ea61e.tar.gz |
winbind: Replace winbind_event_context with server_event_context
There's no point in having two global event contexts
BUG: https://bugzilla.samba.org/show_bug.cgi?id=13150
Signed-off-by: Volker Lendecke <vl@samba.org>
Reviewed-by: Jeremy Allison <jra@samba.org>
Diffstat (limited to 'source3/winbindd/winbindd.c')
-rw-r--r-- | source3/winbindd/winbindd.c | 58 |
1 files changed, 29 insertions, 29 deletions
diff --git a/source3/winbindd/winbindd.c b/source3/winbindd/winbindd.c index f24451649b6..981888068c1 100644 --- a/source3/winbindd/winbindd.c +++ b/source3/winbindd/winbindd.c @@ -91,7 +91,7 @@ struct messaging_context *winbind_messaging_context(void) * Note we MUST use the NULL context here, not the autofree context, * to avoid side effects in forked children exiting. */ - msg = messaging_init(NULL, winbind_event_context()); + msg = messaging_init(NULL, server_event_context()); if (msg == NULL) { smb_panic("Could not init winbindd's messaging context.\n"); } @@ -124,7 +124,7 @@ struct imessaging_context *winbind_imessaging_context(void) * Note we MUST use the NULL context here, not the autofree context, * to avoid side effects in forked children exiting. */ - msg = imessaging_init(NULL, lp_ctx, myself, winbind_event_context()); + msg = imessaging_init(NULL, lp_ctx, myself, server_event_context()); talloc_unlink(NULL, lp_ctx); if (msg == NULL) { @@ -307,14 +307,14 @@ bool winbindd_setup_sig_term_handler(bool parent) struct tevent_signal *se; bool *is_parent; - is_parent = talloc(winbind_event_context(), bool); + is_parent = talloc(server_event_context(), bool); if (!is_parent) { return false; } *is_parent = parent; - se = tevent_add_signal(winbind_event_context(), + se = tevent_add_signal(server_event_context(), is_parent, SIGTERM, 0, winbindd_sig_term_handler, @@ -325,7 +325,7 @@ bool winbindd_setup_sig_term_handler(bool parent) return false; } - se = tevent_add_signal(winbind_event_context(), + se = tevent_add_signal(server_event_context(), is_parent, SIGINT, 0, winbindd_sig_term_handler, @@ -336,7 +336,7 @@ bool winbindd_setup_sig_term_handler(bool parent) return false; } - se = tevent_add_signal(winbind_event_context(), + se = tevent_add_signal(server_event_context(), is_parent, SIGQUIT, 0, winbindd_sig_term_handler, @@ -357,7 +357,7 @@ bool winbindd_setup_stdin_handler(bool parent, bool foreground) if (foreground) { struct stat st; - is_parent = talloc(winbind_event_context(), bool); + is_parent = talloc(server_event_context(), bool); if (!is_parent) { return false; } @@ -373,7 +373,7 @@ bool winbindd_setup_stdin_handler(bool parent, bool foreground) return false; } if (S_ISFIFO(st.st_mode) || S_ISSOCK(st.st_mode)) { - tevent_add_fd(winbind_event_context(), + tevent_add_fd(server_event_context(), is_parent, 0, TEVENT_FD_READ, @@ -405,15 +405,15 @@ bool winbindd_setup_sig_hup_handler(const char *lfile) char *file = NULL; if (lfile) { - file = talloc_strdup(winbind_event_context(), + file = talloc_strdup(server_event_context(), lfile); if (!file) { return false; } } - se = tevent_add_signal(winbind_event_context(), - winbind_event_context(), + se = tevent_add_signal(server_event_context(), + server_event_context(), SIGHUP, 0, winbindd_sig_hup_handler, file); @@ -442,8 +442,8 @@ static bool winbindd_setup_sig_chld_handler(void) { struct tevent_signal *se; - se = tevent_add_signal(winbind_event_context(), - winbind_event_context(), + se = tevent_add_signal(server_event_context(), + server_event_context(), SIGCHLD, 0, winbindd_sig_chld_handler, NULL); @@ -468,8 +468,8 @@ static bool winbindd_setup_sig_usr2_handler(void) { struct tevent_signal *se; - se = tevent_add_signal(winbind_event_context(), - winbind_event_context(), + se = tevent_add_signal(server_event_context(), + server_event_context(), SIGUSR2, 0, winbindd_sig_usr2_handler, NULL); @@ -734,7 +734,7 @@ static void process_request(struct winbindd_cli_state *state) DEBUG(10, ("process_request: Handling async request %d:%s\n", (int)state->pid, state->cmd_name)); - req = atable->send_req(state->mem_ctx, winbind_event_context(), + req = atable->send_req(state->mem_ctx, server_event_context(), state, state->request); if (req == NULL) { DEBUG(0, ("process_request: atable->send failed for " @@ -828,7 +828,7 @@ static void request_finished(struct winbindd_cli_state *state) TALLOC_FREE(state->request); - req = wb_resp_write_send(state, winbind_event_context(), + req = wb_resp_write_send(state, server_event_context(), state->out_queue, state->sock, state->response); if (req == NULL) { @@ -869,7 +869,7 @@ static void winbind_client_response_written(struct tevent_req *req) state->cmd_name = "no request"; state->recv_fn = NULL; - req = wb_req_read_send(state, winbind_event_context(), state->sock, + req = wb_req_read_send(state, server_event_context(), state->sock, WINBINDD_MAX_EXTRA_DATA); if (req == NULL) { remove_client(state); @@ -937,7 +937,7 @@ static void new_connection(int listen_sock, bool privileged) state->privileged = privileged; - req = wb_req_read_send(state, winbind_event_context(), state->sock, + req = wb_req_read_send(state, server_event_context(), state->sock, WINBINDD_MAX_EXTRA_DATA); if (req == NULL) { TALLOC_FREE(state); @@ -977,7 +977,7 @@ static void winbind_client_request_read(struct tevent_req *req) return; } - req = wait_for_read_send(state, winbind_event_context(), state->sock, + req = wait_for_read_send(state, server_event_context(), state->sock, true); if (req == NULL) { DEBUG(0, ("winbind_client_request_read[%d:%s]:" @@ -1239,7 +1239,7 @@ static bool winbindd_setup_listeners(void) int rc; char *socket_path; - pub_state = talloc(winbind_event_context(), + pub_state = talloc(server_event_context(), struct winbindd_listen_state); if (!pub_state) { goto failed; @@ -1256,7 +1256,7 @@ static bool winbindd_setup_listeners(void) goto failed; } - fde = tevent_add_fd(winbind_event_context(), pub_state, pub_state->fd, + fde = tevent_add_fd(server_event_context(), pub_state, pub_state->fd, TEVENT_FD_READ, winbindd_listen_fde_handler, pub_state); if (fde == NULL) { @@ -1265,7 +1265,7 @@ static bool winbindd_setup_listeners(void) } tevent_fd_set_auto_close(fde); - priv_state = talloc(winbind_event_context(), + priv_state = talloc(server_event_context(), struct winbindd_listen_state); if (!priv_state) { goto failed; @@ -1288,7 +1288,7 @@ static bool winbindd_setup_listeners(void) goto failed; } - fde = tevent_add_fd(winbind_event_context(), priv_state, + fde = tevent_add_fd(server_event_context(), priv_state, priv_state->fd, TEVENT_FD_READ, winbindd_listen_fde_handler, priv_state); if (fde == NULL) { @@ -1297,7 +1297,7 @@ static bool winbindd_setup_listeners(void) } tevent_fd_set_auto_close(fde); - winbindd_scrub_clients_handler(winbind_event_context(), NULL, + winbindd_scrub_clients_handler(server_event_context(), NULL, timeval_current(), NULL); return true; failed: @@ -1412,7 +1412,7 @@ static void winbindd_register_handlers(struct messaging_context *msg_ctx, smb_nscd_flush_group_cache(); if (lp_allow_trusted_domains()) { - if (tevent_add_timer(winbind_event_context(), NULL, timeval_zero(), + if (tevent_add_timer(server_event_context(), NULL, timeval_zero(), rescan_trusted_domains, NULL) == NULL) { DEBUG(0, ("Could not trigger rescan_trusted_domains()\n")); exit(1); @@ -1777,7 +1777,7 @@ int main(int argc, const char **argv) */ status = reinit_after_fork(winbind_messaging_context(), - winbind_event_context(), + server_event_context(), false, NULL); if (!NT_STATUS_IS_OK(status)) { exit_daemon("Winbindd reinit_after_fork() failed", map_errno_from_nt_status(status)); @@ -1807,7 +1807,7 @@ int main(int argc, const char **argv) rpc_lsarpc_init(NULL); rpc_samr_init(NULL); - winbindd_init_addrchange(NULL, winbind_event_context(), + winbindd_init_addrchange(NULL, server_event_context(), winbind_messaging_context()); /* setup listen sockets */ @@ -1828,7 +1828,7 @@ int main(int argc, const char **argv) while (1) { frame = talloc_stackframe(); - if (tevent_loop_once(winbind_event_context()) == -1) { + if (tevent_loop_once(server_event_context()) == -1) { DEBUG(1, ("tevent_loop_once() failed: %s\n", strerror(errno))); return 1; |