2 * Unix SMB/CIFS implementation.
4 * SMBD RPC service callbacks
6 * Copyright (c) 2011 Andreas Schneider <asn@samba.org>
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 3 of the License, or
11 * (at your option) any later version.
13 * This program is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 * GNU General Public License for more details.
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, see <http://www.gnu.org/licenses/>.
28 #include "librpc/rpc/dcerpc_ep.h"
29 #include "../librpc/gen_ndr/srv_epmapper.h"
30 #include "rpc_server/rpc_server.h"
31 #include "rpc_server/rpc_sock_helper.h"
32 #include "rpc_server/epmapper/srv_epmapper.h"
34 #define DAEMON_NAME "epmd"
36 void start_epmd(struct tevent_context *ev_ctx,
37 struct messaging_context *msg_ctx);
39 static void epmd_reopen_logs(void)
41 char *lfile = lp_logfile(talloc_tos());
44 if (lfile == NULL || lfile[0] == '\0') {
45 rc = asprintf(&lfile, "%s/log.%s", get_dyn_LOGFILEBASE(), DAEMON_NAME);
47 lp_set_logfile(lfile);
51 if (strstr(lfile, DAEMON_NAME) == NULL) {
52 rc = asprintf(&lfile, "%s.%s",
53 lp_logfile(talloc_tos()), DAEMON_NAME);
55 lp_set_logfile(lfile);
64 static void epmd_smb_conf_updated(struct messaging_context *msg,
67 struct server_id server_id,
70 DEBUG(10, ("Got message saying smb.conf was updated. Reloading.\n"));
71 change_to_root_user();
75 static void epmd_sig_term_handler(struct tevent_context *ev,
76 struct tevent_signal *se,
82 rpc_epmapper_shutdown();
84 exit_server_cleanly("termination signal");
87 static void epmd_setup_sig_term_handler(struct tevent_context *ev_ctx)
89 struct tevent_signal *se;
91 se = tevent_add_signal(ev_ctx,
94 epmd_sig_term_handler,
97 exit_server("failed to setup SIGTERM handler");
101 static void epmd_sig_hup_handler(struct tevent_context *ev,
102 struct tevent_signal *se,
108 change_to_root_user();
110 DEBUG(1,("Reloading printers after SIGHUP\n"));
114 static void epmd_setup_sig_hup_handler(struct tevent_context *ev_ctx,
115 struct messaging_context *msg_ctx)
117 struct tevent_signal *se;
119 se = tevent_add_signal(ev_ctx,
122 epmd_sig_hup_handler,
125 exit_server("failed to setup SIGHUP handler");
129 static bool epmapper_shutdown_cb(void *ptr) {
130 srv_epmapper_cleanup();
135 void start_epmd(struct tevent_context *ev_ctx,
136 struct messaging_context *msg_ctx)
138 struct rpc_srv_callbacks epmapper_cb;
144 epmapper_cb.init = NULL;
145 epmapper_cb.shutdown = epmapper_shutdown_cb;
146 epmapper_cb.private_data = NULL;
148 DEBUG(1, ("Forking Endpoint Mapper Daemon\n"));
153 DEBUG(0, ("Failed to fork Endpoint Mapper [%s], aborting ...\n",
163 status = reinit_after_fork(msg_ctx,
166 if (!NT_STATUS_IS_OK(status)) {
167 DEBUG(0,("reinit_after_fork() failed\n"));
168 smb_panic("reinit_after_fork() failed");
173 epmd_setup_sig_term_handler(ev_ctx);
174 epmd_setup_sig_hup_handler(ev_ctx, msg_ctx);
176 ok = serverid_register(procid_self(),
178 FLAG_MSG_PRINT_GENERAL);
180 DEBUG(0, ("Failed to register serverid in epmd!\n"));
184 messaging_register(msg_ctx,
186 MSG_SMB_CONF_UPDATED,
187 epmd_smb_conf_updated);
189 status = rpc_epmapper_init(&epmapper_cb);
190 if (!NT_STATUS_IS_OK(status)) {
191 DEBUG(0, ("Failed to register epmd rpc inteface! (%s)\n",
196 status = rpc_setup_tcpip_sockets(ev_ctx,
201 if (!NT_STATUS_IS_OK(status)) {
202 DEBUG(0, ("Failed to open epmd tcpip sockets!\n"));
206 ok = setup_dcerpc_ncalrpc_socket(ev_ctx,
209 srv_epmapper_delete_endpoints);
211 DEBUG(0, ("Failed to open epmd ncalrpc pipe!\n"));
215 ok = setup_named_pipe_socket("epmapper", ev_ctx, msg_ctx);
217 DEBUG(0, ("Failed to open epmd named pipe!\n"));
221 DEBUG(1, ("Endpoint Mapper Daemon Started (%d)\n", getpid()));
224 rc = tevent_loop_wait(ev_ctx);
226 /* should not be reached */
227 DEBUG(0,("background_queue: tevent_loop_wait() exited with %d - %s\n",
228 rc, (rc == 0) ? "out of events" : strerror(errno)));
233 /* vim: set ts=8 sw=8 noet cindent ft=c.doxygen: */