--- /dev/null
+/*
+ * Unix SMB/CIFS implementation.
+ *
+ * SMBD RPC modules
+ *
+ * Copyright (c) 2015 Ralph Boehme <slow@samba.org>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include "includes.h"
+#include "rpc_server/rpc_modules.h"
+
+static struct rpc_module *rpc_modules;
+
+struct rpc_module {
+ struct rpc_module *prev, *next;
+ char *name;
+ struct rpc_module_fns *fns;
+};
+
+static struct rpc_module *find_rpc_module(const char *name)
+{
+ struct rpc_module *module = NULL;
+
+ for (module = rpc_modules; module != NULL; module = module->next) {
+ if (strequal(module->name, name)) {
+ return module;
+ }
+ }
+
+ return NULL;
+}
+
+NTSTATUS register_rpc_module(struct rpc_module_fns *fns,
+ const char *name)
+{
+ struct rpc_module *module = find_rpc_module(name);
+
+ if (module != NULL) {
+ DBG_ERR("RPC module %s already loaded!\n", name);
+ return NT_STATUS_OBJECT_NAME_COLLISION;
+ }
+
+ module = SMB_XMALLOC_P(struct rpc_module);
+ module->name = smb_xstrdup(name);
+ module->fns = fns;
+
+ DLIST_ADD(rpc_modules, module);
+ DBG_NOTICE("Successfully added RPC module '%s'\n", name);
+
+ return NT_STATUS_OK;
+}
+
+bool setup_rpc_module(struct tevent_context *ev_ctx,
+ struct messaging_context *msg_ctx,
+ const char *name)
+{
+ bool ok;
+ struct rpc_module *module = find_rpc_module(name);
+
+ if (module == NULL) {
+ return false;
+ }
+
+ ok = module->fns->setup(ev_ctx, msg_ctx);
+ if (!ok) {
+ DBG_ERR("calling setup for %s failed\n", name);
+ }
+
+ return true;
+}
+
+bool setup_rpc_modules(struct tevent_context *ev_ctx,
+ struct messaging_context *msg_ctx)
+{
+ bool ok;
+ struct rpc_module *module = rpc_modules;
+
+ for (module = rpc_modules; module; module = module->next) {
+ ok = module->fns->setup(ev_ctx, msg_ctx);
+ if (!ok) {
+ DBG_ERR("calling setup for %s failed\n", module->name);
+ }
+ }
+
+ return true;
+}
+
+bool init_rpc_module(const char *name,
+ const struct rpc_srv_callbacks *rpc_srv_cb)
+{
+ struct rpc_module *module = find_rpc_module(name);
+ NTSTATUS status;
+
+ if (module == NULL) {
+ return false;
+ }
+
+ status = module->fns->init(rpc_srv_cb);
+ if (!NT_STATUS_IS_OK(status)) {
+ DBG_ERR("calling init for %s failed %s\n",
+ name, nt_errstr(status));
+ return false;
+ }
+
+ return true;
+}
+
+bool shutdown_rpc_module(const char *name)
+{
+ struct rpc_module *module = find_rpc_module(name);
+ NTSTATUS status;
+
+ if (module == NULL) {
+ return false;
+ }
+
+ status = module->fns->shutdown();
+ if (!NT_STATUS_IS_OK(status)) {
+ DBG_ERR("calling shutdown for %s failed %s\n",
+ name, nt_errstr(status));
+ return false;
+ }
+
+ return true;
+}
--- /dev/null
+/*
+ * Unix SMB/CIFS implementation.
+ *
+ * SMBD RPC modules
+ *
+ * Copyright (c) 2015 Ralph Boehme <slow@samba.org>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, see <http://www.gnu.org/licenses/>.
+ */
+
+#ifndef _RPC_MODULES_H
+#define _RPC_MODULES_H
+
+struct rpc_srv_callbacks;
+
+struct rpc_module_fns {
+ bool (*setup)(struct tevent_context *ev_ctx, struct messaging_context *msg_ctx);
+ NTSTATUS (*init)(const struct rpc_srv_callbacks *rpc_srv_cb);
+ NTSTATUS (*shutdown)(void);
+};
+
+NTSTATUS register_rpc_module(struct rpc_module_fns *fns,
+ const char *name);
+
+bool setup_rpc_modules(struct tevent_context *ev_ctx,
+ struct messaging_context *msg_ctx);
+
+bool setup_rpc_module(struct tevent_context *ev_ctx,
+ struct messaging_context *msg_ctx,
+ const char *name);
+
+bool init_rpc_module(const char *name,
+ const struct rpc_srv_callbacks *rpc_srv_cb);
+
+bool shutdown_rpc_module(const char *name);
+#endif
#include "rpc_server/rpc_ep_register.h"
#include "rpc_server/rpc_server.h"
#include "rpc_server/rpc_config.h"
+#include "rpc_server/rpc_modules.h"
#include "rpc_server/epmapper/srv_epmapper.h"
+static_decl_rpc;
+
/* Common routine for embedded RPC servers */
-static bool rpc_setup_embedded(struct tevent_context *ev_ctx,
- struct messaging_context *msg_ctx,
- const struct ndr_interface_table *t,
- const char *pipe_name)
+bool rpc_setup_embedded(struct tevent_context *ev_ctx,
+ struct messaging_context *msg_ctx,
+ const struct ndr_interface_table *t,
+ const char *pipe_name)
{
struct dcerpc_binding_vector *v;
enum rpc_service_mode_e epm_mode = rpc_epmapper_mode();
{
TALLOC_CTX *tmp_ctx;
bool ok;
+ init_module_fn *mod_init_fns = NULL;
tmp_ctx = talloc_stackframe();
if (tmp_ctx == NULL) {
}
#endif
+ /* Initialize static subsystems */
+ static_init_rpc;
+
+ /* Initialize shared modules */
+ mod_init_fns = load_samba_modules(tmp_ctx, "rpc");
+ if (mod_init_fns == NULL) {
+ DBG_ERR("Loading shared RPC modules failed\n");
+ goto done;
+ }
+
+ ok = run_init_functions(mod_init_fns);
+ if (!ok) {
+ DBG_ERR("Initializing shared RPC modules failed\n");
+ goto done;
+ }
+
+ ok = setup_rpc_modules(ev_ctx, msg_ctx);
+ if (!ok) {
+ DBG_ERR("Shared RPC modules setup failed\n");
+ goto done;
+ }
+
done:
talloc_free(tmp_ctx);
return ok;
#define _RPC_EP_SETUP_H
struct ndr_interface_table;
+struct rpc_srv_callbacks;
/**
* @brief Register an endpoint at the endpoint mapper.
bool dcesrv_ep_setup(struct tevent_context *ev_ctx,
struct messaging_context *msg_ctx);
+bool rpc_setup_embedded(struct tevent_context *ev_ctx,
+ struct messaging_context *msg_ctx,
+ const struct ndr_interface_table *t,
+ const char *pipe_name);
+
#endif /* _RPC_EP_SETUP_H */
/* vim: set ts=8 sw=8 noet cindent ft=c.doxygen: */
deps='samba-util')
bld.SAMBA3_SUBSYSTEM('RPC_SERVICE',
- source='rpc_service_setup.c',
+ source='rpc_service_setup.c rpc_modules.c',
deps='''
+ rpc
RPC_SERVER
RPC_SERVER_REGISTER
RPC_SAMR
static_list = {}
shared_list = {}
- prefixes = ['vfs', 'pdb', 'auth', 'nss_info', 'charset', 'idmap', 'gpext', 'perfcount']
+ prefixes = ['vfs', 'pdb', 'auth', 'nss_info', 'charset', 'idmap', 'gpext', 'perfcount', 'rpc']
conf.env['MODULE_PREFIXES'] = prefixes
for p in prefixes:
for m in final_static_modules:
git.samba.org / amitay / samba.git / commitdiff