summaryrefslogtreecommitdiffstats
path: root/server/providers/data_provider.c
diff options
context:
space:
mode:
Diffstat (limited to 'server/providers/data_provider.c')
-rw-r--r--server/providers/data_provider.c40
1 files changed, 18 insertions, 22 deletions
diff --git a/server/providers/data_provider.c b/server/providers/data_provider.c
index 43c80128d..df9cfdf6f 100644
--- a/server/providers/data_provider.c
+++ b/server/providers/data_provider.c
@@ -367,48 +367,44 @@ done:
return ret;
}
-void dp_task_init(struct task_server *task)
+int dp_process_init(TALLOC_CTX *mem_ctx,
+ struct event_context *ev,
+ struct confdb_ctx *cdb)
{
struct dp_ctx *dpctx;
int ret;
- task_server_set_title(task, "sssd[datap]");
-
- dpctx = talloc_zero(task, struct dp_ctx);
+ dpctx = talloc_zero(mem_ctx, struct dp_ctx);
if (!dpctx) {
- task_server_terminate(task, "fatal error initializing dp_ctx\n");
- return;
- }
- dpctx->ev = task->event_ctx;
- dpctx->task = task;
-
- ret = confdb_init(task, task->event_ctx, &dpctx->cdb);
- if (ret != EOK) {
- task_server_terminate(task, "fatal error initializing confdb\n");
- return;
+ DEBUG(0, ("fatal error initializing dp_ctx\n"));
+ return ENOMEM;
}
+ dpctx->ev = ev;
+ dpctx->cdb = cdb;
ret = dp_db_init(dpctx);
if (ret != EOK) {
- task_server_terminate(task, "fatal error opening database\n");
- return;
+ DEBUG(0, ("fatal error opening database\n"));
+ return ret;
}
ret = dp_monitor_init(dpctx);
if (ret != EOK) {
- task_server_terminate(task, "fatal error setting up monitor bus\n");
- return;
+ DEBUG(0, ("fatal error setting up monitor bus\n"));
+ return ret;
}
ret = dp_srv_init(dpctx);
if (ret != EOK) {
- task_server_terminate(task, "fatal error setting up server bus\n");
- return;
+ DEBUG(0, ("fatal error setting up server bus\n"));
+ return ret;
}
ret = init_data_providers(dpctx);
if (ret != EOK) {
- task_server_terminate(task, "fatal error initializing data providers\n");
- return;
+ DEBUG(0, ("fatal error initializing data providers\n"));
+ return ret;
}
+
+ return EOK;
}