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/>.
27 #include "librpc/rpc/dcerpc_ep.h"
28 #include "../librpc/gen_ndr/srv_epmapper.h"
29 #include "rpc_server/rpc_server.h"
30 #include "rpc_server/rpc_sock_helper.h"
31 #include "rpc_server/epmapper/srv_epmapper.h"
32 #include "rpc_server/epmd.h"
34 #define DAEMON_NAME "epmd"
36 static void epmd_reopen_logs(void)
38 char *lfile
= lp_logfile(talloc_tos());
41 if (lfile
== NULL
|| lfile
[0] == '\0') {
42 rc
= asprintf(&lfile
, "%s/log.%s", get_dyn_LOGFILEBASE(), DAEMON_NAME
);
44 lp_set_logfile(lfile
);
48 if (strstr(lfile
, DAEMON_NAME
) == NULL
) {
49 rc
= asprintf(&lfile
, "%s.%s",
50 lp_logfile(talloc_tos()), DAEMON_NAME
);
52 lp_set_logfile(lfile
);
61 static void epmd_smb_conf_updated(struct messaging_context
*msg
,
64 struct server_id server_id
,
67 DEBUG(10, ("Got message saying smb.conf was updated. Reloading.\n"));
68 change_to_root_user();
72 static void epmd_sig_term_handler(struct tevent_context
*ev
,
73 struct tevent_signal
*se
,
79 rpc_epmapper_shutdown();
81 exit_server_cleanly("termination signal");
84 static void epmd_setup_sig_term_handler(struct tevent_context
*ev_ctx
)
86 struct tevent_signal
*se
;
88 se
= tevent_add_signal(ev_ctx
,
91 epmd_sig_term_handler
,
94 exit_server("failed to setup SIGTERM handler");
98 static void epmd_sig_hup_handler(struct tevent_context
*ev
,
99 struct tevent_signal
*se
,
105 change_to_root_user();
107 DEBUG(1,("Reloading printers after SIGHUP\n"));
111 static void epmd_setup_sig_hup_handler(struct tevent_context
*ev_ctx
,
112 struct messaging_context
*msg_ctx
)
114 struct tevent_signal
*se
;
116 se
= tevent_add_signal(ev_ctx
,
119 epmd_sig_hup_handler
,
122 exit_server("failed to setup SIGHUP handler");
126 static bool epmapper_shutdown_cb(void *ptr
) {
127 srv_epmapper_cleanup();
132 void start_epmd(struct tevent_context
*ev_ctx
,
133 struct messaging_context
*msg_ctx
)
135 struct rpc_srv_callbacks epmapper_cb
;
141 epmapper_cb
.init
= NULL
;
142 epmapper_cb
.shutdown
= epmapper_shutdown_cb
;
143 epmapper_cb
.private_data
= NULL
;
145 DEBUG(1, ("Forking Endpoint Mapper Daemon\n"));
150 DEBUG(0, ("Failed to fork Endpoint Mapper [%s], aborting ...\n",
160 status
= smbd_reinit_after_fork(msg_ctx
, ev_ctx
, true, "epmd");
161 if (!NT_STATUS_IS_OK(status
)) {
162 DEBUG(0,("reinit_after_fork() failed\n"));
163 smb_panic("reinit_after_fork() failed");
168 epmd_setup_sig_term_handler(ev_ctx
);
169 epmd_setup_sig_hup_handler(ev_ctx
, msg_ctx
);
171 messaging_register(msg_ctx
,
173 MSG_SMB_CONF_UPDATED
,
174 epmd_smb_conf_updated
);
176 status
= rpc_epmapper_init(&epmapper_cb
);
177 if (!NT_STATUS_IS_OK(status
)) {
178 DEBUG(0, ("Failed to register epmd rpc interface! (%s)\n",
183 status
= rpc_setup_tcpip_sockets(ev_ctx
,
188 if (!NT_STATUS_IS_OK(status
)) {
189 DEBUG(0, ("Failed to open epmd tcpip sockets!\n"));
193 ok
= setup_dcerpc_ncalrpc_socket(ev_ctx
,
196 srv_epmapper_delete_endpoints
);
198 DEBUG(0, ("Failed to open epmd ncalrpc pipe!\n"));
202 ok
= dcesrv_setup_ncacn_np_socket("epmapper", ev_ctx
, msg_ctx
);
204 DEBUG(0, ("Failed to open epmd named pipe!\n"));
208 DEBUG(1, ("Endpoint Mapper Daemon Started (%u)\n", (unsigned int)getpid()));
211 rc
= tevent_loop_wait(ev_ctx
);
213 /* should not be reached */
214 DEBUG(0,("background_queue: tevent_loop_wait() exited with %d - %s\n",
215 rc
, (rc
== 0) ? "out of events" : strerror(errno
)));
220 /* vim: set ts=8 sw=8 noet cindent ft=c.doxygen: */