9eb798
From 6fbf5891e9169142fc0ea37eb8f897a645b82d6f Mon Sep 17 00:00:00 2001
9eb798
From: Alexander Bokovoy <abokovoy@redhat.com>
9eb798
Date: Wed, 1 Nov 2017 10:29:41 +0200
9eb798
Subject: [PATCH 16/17] schema-compat: add support for timeout-based NSS
9eb798
 queries with libsss_nss_idmap
9eb798
9eb798
In case libsss_nss_idmap provides timeout-enabled NSS API, use it.
9eb798
This solves a problem of too long queries to an NSS backend with
9eb798
traditional POSIX NSS API. In case SSSD takes too long to respond
9eb798
to a query, corresponding 389-ds thread running schema-compat plugin
9eb798
would stuck waiting that response. It can lead to an exhaustion of
9eb798
389-ds threads.
9eb798
9eb798
A refactored interface to NSS backends is introduced with this commit.
9eb798
A backend API looks like an API an NSS plugin has to implement in glibc
9eb798
but also allows to handle timeout-based requests internally.
9eb798
9eb798
If backend implements timeout-enabled calls, then
9eb798
backend_nss_set_timeout() function can be used to modify a per-context
9eb798
state. There is no need for a caller to know whether backend supports
9eb798
timeout-enabled calls because either way these calls are synchronous
9eb798
and backend choice is done at compile-time.
9eb798
9eb798
schema-compat plugin uses 10 seconds as its default timeout. One can
9eb798
change it via 'slapi-nss-timeout' attribute in the plugin config entry.
9eb798
---
9eb798
 src/Makefile.am          |  11 ++-
9eb798
 src/back-sch-nss.c       | 187 +++++-------------------------------
9eb798
 src/back-sch-nss.h       |  70 ++++++++++++++
9eb798
 src/back-sch-nss_sss.c   | 231 +++++++++++++++++++++++++++++++++++++++++++++
9eb798
 src/back-sch-sss_idmap.c | 239 +++++++++++++++++++++++++++++++++++++++++++++++
9eb798
 src/back-sch.h           |   9 +-
9eb798
 src/plug-sch.c           |   7 ++
9eb798
 7 files changed, 588 insertions(+), 166 deletions(-)
9eb798
 create mode 100644 src/back-sch-nss.h
9eb798
 create mode 100644 src/back-sch-nss_sss.c
9eb798
 create mode 100644 src/back-sch-sss_idmap.c
9eb798
9eb798
diff --git a/src/Makefile.am b/src/Makefile.am
9eb798
index 6f4926e..cd1efc2 100644
9eb798
--- a/src/Makefile.am
9eb798
+++ b/src/Makefile.am
9eb798
@@ -68,8 +68,17 @@ schemacompat_plugin_la_LIBADD = $(LDAP_LIBS) $(RUNTIME_LIBS) $(LIBPTHREAD) $(CON
9eb798
 
9eb798
 if USE_NSSWITCH
9eb798
 schemacompat_plugin_la_CFLAGS += $(SSS_NSS_IDMAP_CFLAGS)
9eb798
-schemacompat_plugin_la_SOURCES += back-sch-nss.c
9eb798
+schemacompat_plugin_la_SOURCES += back-sch-nss.c back-sch-nss.h
9eb798
 schemacompat_plugin_la_LIBADD += $(SSS_NSS_IDMAP_LIBS)
9eb798
+# We have two backends for nss operations:
9eb798
+# (1) directly loading nss_sss.so.2
9eb798
+# (2) using timeout-enabled API from libsss_nss_idmap
9eb798
+# We prefer (2) if available
9eb798
+if USE_SSS_NSS_TIMEOUT
9eb798
+schemacompat_plugin_la_SOURCES += back-sch-sss_idmap.c
9eb798
+else
9eb798
+schemacompat_plugin_la_SOURCES += back-sch-nss_sss.c
9eb798
+endif
9eb798
 endif
9eb798
 
9eb798
 if USE_PAM
9eb798
diff --git a/src/back-sch-nss.c b/src/back-sch-nss.c
9eb798
index e4d027e..e5f91b2 100644
9eb798
--- a/src/back-sch-nss.c
9eb798
+++ b/src/back-sch-nss.c
9eb798
@@ -28,7 +28,6 @@
9eb798
 #include <string.h>
9eb798
 #include <time.h>
9eb798
 #include <unistd.h>
9eb798
-#include <dlfcn.h>
9eb798
 #include <errno.h>
9eb798
 #include <pwd.h>
9eb798
 #include <grp.h>
9eb798
@@ -52,6 +51,7 @@
9eb798
 #include "map.h"
9eb798
 #include "back-sch.h"
9eb798
 #include "format.h"
9eb798
+#include "back-sch-nss.h"
9eb798
 
9eb798
 static int
9eb798
 bvstrprefix(const struct berval *bval, const char *s)
9eb798
@@ -294,143 +294,6 @@ backend_make_user_entry_from_nsswitch_passwd(struct passwd *pwd,
9eb798
 	return entry;
9eb798
 }
9eb798
 
9eb798
-/* Possible results of lookup using a nss_* function.
9eb798
- * Note: don't include nss.h as its path gets overriden by NSS library */
9eb798
-enum nss_status
9eb798
-{
9eb798
-  NSS_STATUS_TRYAGAIN = -2,
9eb798
-  NSS_STATUS_UNAVAIL,
9eb798
-  NSS_STATUS_NOTFOUND,
9eb798
-  NSS_STATUS_SUCCESS,
9eb798
-  NSS_STATUS_RETURN
9eb798
-};
9eb798
-
9eb798
-struct nss_ops_ctx {
9eb798
-	void *dl_handle;
9eb798
-
9eb798
-	enum nss_status (*getpwnam_r)(const char *name, struct passwd *result,
9eb798
-			  char *buffer, size_t buflen, int *errnop);
9eb798
-	enum nss_status (*getpwuid_r)(uid_t uid, struct passwd *result,
9eb798
-			  char *buffer, size_t buflen, int *errnop);
9eb798
-	enum nss_status (*setpwent)(void);
9eb798
-	enum nss_status (*getpwent_r)(struct passwd *result,
9eb798
-			  char *buffer, size_t buflen, int *errnop);
9eb798
-	enum nss_status (*endpwent)(void);
9eb798
-
9eb798
-	enum nss_status (*getgrnam_r)(const char *name, struct group *result,
9eb798
-			  char *buffer, size_t buflen, int *errnop);
9eb798
-	enum nss_status (*getgrgid_r)(gid_t gid, struct group *result,
9eb798
-			  char *buffer, size_t buflen, int *errnop);
9eb798
-	enum nss_status (*setgrent)(void);
9eb798
-	enum nss_status (*getgrent_r)(struct group *result,
9eb798
-			  char *buffer, size_t buflen, int *errnop);
9eb798
-	enum nss_status (*endgrent)(void);
9eb798
-
9eb798
-	enum nss_status (*initgroups_dyn)(const char *user, gid_t group,
9eb798
-			      long int *start, long int *size,
9eb798
-			      gid_t **groups, long int limit,
9eb798
-			      int *errnop);
9eb798
-};
9eb798
-
9eb798
-void backend_nss_init_context(struct nss_ops_ctx **nss_context)
9eb798
-{
9eb798
-	struct nss_ops_ctx *ctx = NULL;
9eb798
-
9eb798
-	if (nss_context == NULL) {
9eb798
-		return;
9eb798
-	}
9eb798
-
9eb798
-	ctx = calloc(1, sizeof(struct nss_ops_ctx));
9eb798
-
9eb798
-	*nss_context = ctx;
9eb798
-	if (ctx == NULL) {
9eb798
-		return;
9eb798
-	}
9eb798
-
9eb798
-	ctx->dl_handle = dlopen("libnss_sss.so.2", RTLD_NOW);
9eb798
-	if (ctx->dl_handle == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->getpwnam_r = dlsym(ctx->dl_handle, "_nss_sss_getpwnam_r");
9eb798
-	if (ctx->getpwnam_r == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->getpwuid_r = dlsym(ctx->dl_handle, "_nss_sss_getpwuid_r");
9eb798
-	if (ctx->getpwuid_r == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->setpwent = dlsym(ctx->dl_handle, "_nss_sss_setpwent");
9eb798
-	if (ctx->setpwent == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->getpwent_r = dlsym(ctx->dl_handle, "_nss_sss_getpwent_r");
9eb798
-	if (ctx->getpwent_r == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->endpwent = dlsym(ctx->dl_handle, "_nss_sss_endpwent");
9eb798
-	if (ctx->endpwent == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->getgrnam_r = dlsym(ctx->dl_handle, "_nss_sss_getgrnam_r");
9eb798
-	if (ctx->getgrnam_r == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->getgrgid_r = dlsym(ctx->dl_handle, "_nss_sss_getgrgid_r");
9eb798
-	if (ctx->getgrgid_r == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->setgrent = dlsym(ctx->dl_handle, "_nss_sss_setgrent");
9eb798
-	if (ctx->setgrent == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->getgrent_r = dlsym(ctx->dl_handle, "_nss_sss_getgrent_r");
9eb798
-	if (ctx->getgrent_r == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->endgrent = dlsym(ctx->dl_handle, "_nss_sss_endgrent");
9eb798
-	if (ctx->endgrent == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	ctx->initgroups_dyn = dlsym(ctx->dl_handle, "_nss_sss_initgroups_dyn");
9eb798
-	if (ctx->initgroups_dyn == NULL) {
9eb798
-		goto fail;
9eb798
-	}
9eb798
-
9eb798
-	return;
9eb798
-
9eb798
-fail:
9eb798
-	backend_nss_free_context(nss_context);
9eb798
-
9eb798
-	return;
9eb798
-}
9eb798
-
9eb798
-void
9eb798
-backend_nss_free_context(struct nss_ops_ctx **nss_context)
9eb798
-{
9eb798
-	if (nss_context == NULL) {
9eb798
-		return;
9eb798
-	}
9eb798
-
9eb798
-	if ((*nss_context)->dl_handle != NULL) {
9eb798
-		dlclose((*nss_context)->dl_handle);
9eb798
-	}
9eb798
-
9eb798
-	free((*nss_context));
9eb798
-	*nss_context = NULL;
9eb798
-}
9eb798
-
9eb798
-
9eb798
 
9eb798
 static Slapi_Entry **
9eb798
 backend_retrieve_user_entry_from_nsswitch(char *user_name, bool_t is_uid,
9eb798
@@ -456,13 +319,13 @@ repeat:
9eb798
 	}
9eb798
 
9eb798
 	if (is_uid) {
9eb798
-		rc = ctx->getpwuid_r((uid_t) atoll(user_name), &pwd,
9eb798
-				     cbdata->nsswitch_buffer,
9eb798
-				     cbdata->nsswitch_buffer_len, &lerrno);
9eb798
+		rc = backend_nss_getpwuid(ctx, (uid_t) atoll(user_name), &pwd,
9eb798
+					  cbdata->nsswitch_buffer,
9eb798
+					  cbdata->nsswitch_buffer_len, &result, &lerrno);
9eb798
 	} else {
9eb798
-		rc = ctx->getpwnam_r(user_name, &pwd,
9eb798
-				     cbdata->nsswitch_buffer,
9eb798
-				     cbdata->nsswitch_buffer_len, &lerrno);
9eb798
+		rc = backend_nss_getpwnam(ctx, user_name, &pwd,
9eb798
+					  cbdata->nsswitch_buffer,
9eb798
+					  cbdata->nsswitch_buffer_len, &result, &lerrno);
9eb798
 	}
9eb798
 
9eb798
 	if ((rc != NSS_STATUS_SUCCESS)) {
9eb798
@@ -591,13 +454,13 @@ repeat:
9eb798
 	}
9eb798
 
9eb798
 	if (is_gid) {
9eb798
-		rc = ctx->getgrgid_r((gid_t) atoll(group_name), &grp,
9eb798
-				     cbdata->nsswitch_buffer,
9eb798
-				     cbdata->nsswitch_buffer_len, &lerrno);
9eb798
+		rc = backend_nss_getgrgid(ctx, (gid_t) atoll(group_name), &grp,
9eb798
+					  cbdata->nsswitch_buffer,
9eb798
+					  cbdata->nsswitch_buffer_len, &result, &lerrno);
9eb798
 	} else {
9eb798
-		rc = ctx->getgrnam_r(group_name, &grp,
9eb798
-				     cbdata->nsswitch_buffer,
9eb798
-				     cbdata->nsswitch_buffer_len, &lerrno);
9eb798
+		rc = backend_nss_getgrnam(ctx, group_name, &grp,
9eb798
+					  cbdata->nsswitch_buffer,
9eb798
+					  cbdata->nsswitch_buffer_len, &result, &lerrno);
9eb798
 	}
9eb798
 	if ((rc != NSS_STATUS_SUCCESS)) {
9eb798
 		if (lerrno == ERANGE) {
9eb798
@@ -651,9 +514,9 @@ repeat:
9eb798
 		return NULL;
9eb798
 	}
9eb798
 
9eb798
-	rc = ctx->getgrgid_r(gid, &grp,
9eb798
-			     cbdata->nsswitch_buffer,
9eb798
-			     cbdata->nsswitch_buffer_len, &lerrno);
9eb798
+	rc = backend_nss_getgrgid(ctx, gid, &grp,
9eb798
+				  cbdata->nsswitch_buffer,
9eb798
+				  cbdata->nsswitch_buffer_len, &result, &lerrno);
9eb798
 
9eb798
 	if ((rc != NSS_STATUS_SUCCESS)) {
9eb798
 		if (lerrno == ERANGE) {
9eb798
@@ -689,7 +552,7 @@ backend_retrieve_group_list_from_nsswitch(char *user_name, char *container_sdn,
9eb798
 	int i, idx;
9eb798
 	struct nss_ops_ctx *ctx = NULL;
9eb798
 	int lerrno = 0;
9eb798
-	long int ngroups = 0;
9eb798
+	int ngroups = 0;
9eb798
 	long int start = 0;
9eb798
 	enum nss_status rc;
9eb798
 
9eb798
@@ -702,9 +565,9 @@ repeat:
9eb798
 		return NULL;
9eb798
 	}
9eb798
 
9eb798
-	rc = ctx->getpwnam_r(user_name, &pwd,
9eb798
-			     cbdata->nsswitch_buffer,
9eb798
-			     cbdata->nsswitch_buffer_len, &lerrno);
9eb798
+	rc = backend_nss_getpwnam(ctx, user_name, &pwd,
9eb798
+				  cbdata->nsswitch_buffer,
9eb798
+				  cbdata->nsswitch_buffer_len, &pwd_result, &lerrno);
9eb798
 
9eb798
 	if ((rc != NSS_STATUS_SUCCESS)) {
9eb798
 		if (lerrno == ERANGE) {
9eb798
@@ -723,19 +586,15 @@ repeat:
9eb798
 	}
9eb798
 
9eb798
 	ngroups = 32;
9eb798
-	start = 0;
9eb798
 	grouplist = malloc(sizeof(gid_t) * ngroups);
9eb798
 	if (grouplist == NULL) {
9eb798
 		return NULL;
9eb798
 	}
9eb798
 
9eb798
-	grouplist[0] = pwd.pw_gid;
9eb798
-	start++;
9eb798
-
9eb798
 	do {
9eb798
-		rc = ctx->initgroups_dyn(user_name, pwd.pw_gid,
9eb798
-					 &start, &ngroups, &grouplist,
9eb798
-					 -1, &lerrno);
9eb798
+		rc = backend_nss_getgrouplist(ctx, user_name, pwd.pw_gid,
9eb798
+					      grouplist, &ngroups,
9eb798
+					      &lerrno);
9eb798
 		if ((rc != NSS_STATUS_SUCCESS)) {
9eb798
 			tmp_list = realloc(grouplist, ngroups * sizeof(gid_t));
9eb798
 			if (tmp_list == NULL) {
9eb798
diff --git a/src/back-sch-nss.h b/src/back-sch-nss.h
9eb798
new file mode 100644
9eb798
index 0000000..54a3c07
9eb798
--- /dev/null
9eb798
+++ b/src/back-sch-nss.h
9eb798
@@ -0,0 +1,70 @@
9eb798
+/*
9eb798
+ * Copyright 2017 Red Hat, Inc.
9eb798
+ *
9eb798
+ * This Program is free software; you can redistribute it and/or modify
9eb798
+ * it under the terms of the GNU General Public License as published by
9eb798
+ * the Free Software Foundation; version 2 of the License.
9eb798
+ *
9eb798
+ * This Program is distributed in the hope that it will be useful, but
9eb798
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
9eb798
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
9eb798
+ * General Public License for more details.
9eb798
+ *
9eb798
+ * You should have received a copy of the GNU General Public License
9eb798
+ * along with this Program; if not, write to the
9eb798
+ *
9eb798
+ *   Free Software Foundation, Inc.
9eb798
+ *   59 Temple Place, Suite 330
9eb798
+ *   Boston, MA 02111-1307 USA
9eb798
+ *
9eb798
+ */
9eb798
+
9eb798
+#ifndef back_sch_nss_h
9eb798
+#define back_sch_nss_h
9eb798
+#include <unistd.h>
9eb798
+#include <pwd.h>
9eb798
+#include <grp.h>
9eb798
+
9eb798
+/* Possible results of lookup using a nss_* function.
9eb798
+ * Note: don't include nss.h as its path gets overriden by NSS library */
9eb798
+enum nss_status
9eb798
+{
9eb798
+  NSS_STATUS_TRYAGAIN = -2,
9eb798
+  NSS_STATUS_UNAVAIL,
9eb798
+  NSS_STATUS_NOTFOUND,
9eb798
+  NSS_STATUS_SUCCESS,
9eb798
+  NSS_STATUS_RETURN
9eb798
+};
9eb798
+
9eb798
+struct nss_ops_ctx;
9eb798
+
9eb798
+enum nss_status backend_nss_getpwnam(struct nss_ops_ctx *nss_context,
9eb798
+				     const char *name, struct passwd *pwd,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct passwd **result,
9eb798
+				     int *lerrno);
9eb798
+
9eb798
+enum nss_status backend_nss_getpwuid(struct nss_ops_ctx *nss_context,
9eb798
+				     uid_t uid, struct passwd *pwd,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct passwd **result,
9eb798
+				     int *lerrno);
9eb798
+
9eb798
+enum nss_status backend_nss_getgrnam(struct nss_ops_ctx *nss_context,
9eb798
+				     const char *name, struct group *grp,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct group **result,
9eb798
+				     int *lerrno);
9eb798
+
9eb798
+enum nss_status backend_nss_getgrgid(struct nss_ops_ctx *nss_context,
9eb798
+				     gid_t gid, struct group *grp,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct group **result,
9eb798
+				     int *lerrno);
9eb798
+
9eb798
+enum nss_status backend_nss_getgrouplist(struct nss_ops_ctx *nss_context,
9eb798
+					 const char *name, gid_t group,
9eb798
+					 gid_t *groups, int *ngroups,
9eb798
+					 int *lerrno);
9eb798
+
9eb798
+#endif /* back_sch_nss_h */
9eb798
diff --git a/src/back-sch-nss_sss.c b/src/back-sch-nss_sss.c
9eb798
new file mode 100644
9eb798
index 0000000..e3e6628
9eb798
--- /dev/null
9eb798
+++ b/src/back-sch-nss_sss.c
9eb798
@@ -0,0 +1,231 @@
9eb798
+/*
9eb798
+ * Copyright 2013-2017 Red Hat, Inc.
9eb798
+ *
9eb798
+ * This Program is free software; you can redistribute it and/or modify
9eb798
+ * it under the terms of the GNU General Public License as published by
9eb798
+ * the Free Software Foundation; version 2 of the License.
9eb798
+ *
9eb798
+ * This Program is distributed in the hope that it will be useful, but
9eb798
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
9eb798
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
9eb798
+ * General Public License for more details.
9eb798
+ *
9eb798
+ * You should have received a copy of the GNU General Public License
9eb798
+ * along with this Program; if not, write to the
9eb798
+ *
9eb798
+ *   Free Software Foundation, Inc.
9eb798
+ *   59 Temple Place, Suite 330
9eb798
+ *   Boston, MA 02111-1307 USA
9eb798
+ *
9eb798
+ */
9eb798
+
9eb798
+#ifdef HAVE_CONFIG_H
9eb798
+#include "config.h"
9eb798
+#endif
9eb798
+
9eb798
+#include <sys/types.h>
9eb798
+#include <stdlib.h>
9eb798
+#include <string.h>
9eb798
+#include <time.h>
9eb798
+#include <unistd.h>
9eb798
+#include <dlfcn.h>
9eb798
+#include <errno.h>
9eb798
+#include <pwd.h>
9eb798
+#include <grp.h>
9eb798
+#include "back-sch-nss.h"
9eb798
+
9eb798
+struct nss_ops_ctx {
9eb798
+	void *dl_handle;
9eb798
+	long int initgroups_start;
9eb798
+
9eb798
+	enum nss_status (*getpwnam_r)(const char *name, struct passwd *result,
9eb798
+			  char *buffer, size_t buflen, int *errnop);
9eb798
+	enum nss_status (*getpwuid_r)(uid_t uid, struct passwd *result,
9eb798
+			  char *buffer, size_t buflen, int *errnop);
9eb798
+	enum nss_status (*getgrnam_r)(const char *name, struct group *result,
9eb798
+			  char *buffer, size_t buflen, int *errnop);
9eb798
+	enum nss_status (*getgrgid_r)(gid_t gid, struct group *result,
9eb798
+			  char *buffer, size_t buflen, int *errnop);
9eb798
+	enum nss_status (*initgroups_dyn)(const char *user, gid_t group,
9eb798
+			      long int *start, long int *size,
9eb798
+			      gid_t **groups, long int limit,
9eb798
+			      int *errnop);
9eb798
+};
9eb798
+
9eb798
+void backend_nss_init_context(struct nss_ops_ctx **nss_context)
9eb798
+{
9eb798
+	struct nss_ops_ctx *ctx = NULL;
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return;
9eb798
+	}
9eb798
+
9eb798
+	ctx = calloc(1, sizeof(struct nss_ops_ctx));
9eb798
+
9eb798
+	*nss_context = ctx;
9eb798
+	if (ctx == NULL) {
9eb798
+		return;
9eb798
+	}
9eb798
+
9eb798
+	ctx->dl_handle = dlopen("libnss_sss.so.2", RTLD_NOW);
9eb798
+	if (ctx->dl_handle == NULL) {
9eb798
+		goto fail;
9eb798
+	}
9eb798
+
9eb798
+	ctx->getpwnam_r = dlsym(ctx->dl_handle, "_nss_sss_getpwnam_r");
9eb798
+	if (ctx->getpwnam_r == NULL) {
9eb798
+		goto fail;
9eb798
+	}
9eb798
+
9eb798
+	ctx->getpwuid_r = dlsym(ctx->dl_handle, "_nss_sss_getpwuid_r");
9eb798
+	if (ctx->getpwuid_r == NULL) {
9eb798
+		goto fail;
9eb798
+	}
9eb798
+
9eb798
+	ctx->getgrnam_r = dlsym(ctx->dl_handle, "_nss_sss_getgrnam_r");
9eb798
+	if (ctx->getgrnam_r == NULL) {
9eb798
+		goto fail;
9eb798
+	}
9eb798
+
9eb798
+	ctx->getgrgid_r = dlsym(ctx->dl_handle, "_nss_sss_getgrgid_r");
9eb798
+	if (ctx->getgrgid_r == NULL) {
9eb798
+		goto fail;
9eb798
+	}
9eb798
+
9eb798
+	ctx->initgroups_dyn = dlsym(ctx->dl_handle, "_nss_sss_initgroups_dyn");
9eb798
+	if (ctx->initgroups_dyn == NULL) {
9eb798
+		goto fail;
9eb798
+	}
9eb798
+
9eb798
+	return;
9eb798
+
9eb798
+fail:
9eb798
+	backend_nss_free_context(nss_context);
9eb798
+
9eb798
+	return;
9eb798
+}
9eb798
+
9eb798
+void
9eb798
+backend_nss_free_context(struct nss_ops_ctx **nss_context)
9eb798
+{
9eb798
+	if (nss_context == NULL) {
9eb798
+		return;
9eb798
+	}
9eb798
+
9eb798
+	if ((*nss_context)->dl_handle != NULL) {
9eb798
+		dlclose((*nss_context)->dl_handle);
9eb798
+	}
9eb798
+
9eb798
+	free((*nss_context));
9eb798
+	*nss_context = NULL;
9eb798
+}
9eb798
+
9eb798
+
9eb798
+/* Following three functions cannot be implemented with nss_sss.so.2
9eb798
+ * As result, we simply do nothing here */
9eb798
+
9eb798
+void backend_nss_set_timeout(struct nss_ops_ctx **nss_context,
9eb798
+			     unsigned int timeout) {
9eb798
+	/* no operation */
9eb798
+}
9eb798
+
9eb798
+void backend_nss_evict_user(struct nss_ops_ctx **nss_context,
9eb798
+			    const char *name) {
9eb798
+	/* no operation */
9eb798
+}
9eb798
+
9eb798
+void backend_nss_evict_group(struct nss_ops_ctx **nss_context,
9eb798
+			     const char *name) {
9eb798
+	/* no operation */
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getpwnam(struct nss_ops_ctx *nss_context,
9eb798
+				     const char *name, struct passwd *pwd,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct passwd **result,
9eb798
+				     int *lerrno) {
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	return (enum nss_status)
9eb798
+		nss_context->getpwnam_r(name, pwd,
9eb798
+					buffer, buflen,
9eb798
+					result, lerrno);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getpwuid(struct nss_ops_ctx *nss_context,
9eb798
+				     uid_t uid, struct passwd *pwd,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct passwd **result,
9eb798
+				     int *lerrno) {
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	return (enum nss_status)
9eb798
+		nss_context->getpwuid_r(uid, pwd,
9eb798
+					buffer, buflen,
9eb798
+					result, lerrno);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getgrnam(struct nss_ops_ctx *nss_context,
9eb798
+				     const char *name, struct group *grp,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct group **result,
9eb798
+				     int *lerrno) {
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	return (enum nss_status)
9eb798
+		nss_context->getgrnam_r(name, grp,
9eb798
+					buffer, buflen,
9eb798
+					result, lerrno);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getgrgid(struct nss_ops_ctx *nss_context,
9eb798
+				     gid_t gid, struct group *grp,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct group **result,
9eb798
+				     int *lerrno) {
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	return (enum nss_status)
9eb798
+		nss_context->getgrgid_r(gid, grp,
9eb798
+					buffer, buflen,
9eb798
+					result, lerrno);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getgrouplist(struct nss_ops_ctx *nss_context,
9eb798
+					 const char *name, gid_t group,
9eb798
+					 gid_t *groups, int *ngroups,
9eb798
+					 int *lerrno) {
9eb798
+	enum nss_status ret = NSS_STATUS_UNAVAIL;
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	if (nss_context->initgroups_start == 0) {
9eb798
+		groups[0] = group;
9eb798
+		nss_context->initgroups_start++;
9eb798
+	}
9eb798
+
9eb798
+	ret = nss_context->initgroups_dyn(name, group,
9eb798
+					  &nss_context->initgroups_start,
9eb798
+					  &ngroups, &groups,
9eb798
+					  -1, &lerrno);
9eb798
+	if (ret == NSS_STATUS_SUCCESS) {
9eb798
+		nss_context->initgroups_start = 0;
9eb798
+	}
9eb798
+
9eb798
+	return ret;
9eb798
+}
9eb798
+
9eb798
diff --git a/src/back-sch-sss_idmap.c b/src/back-sch-sss_idmap.c
9eb798
new file mode 100644
9eb798
index 0000000..6a31267
9eb798
--- /dev/null
9eb798
+++ b/src/back-sch-sss_idmap.c
9eb798
@@ -0,0 +1,239 @@
9eb798
+/*
9eb798
+ * Copyright 2013-2017 Red Hat, Inc.
9eb798
+ *
9eb798
+ * This Program is free software; you can redistribute it and/or modify
9eb798
+ * it under the terms of the GNU General Public License as published by
9eb798
+ * the Free Software Foundation; version 2 of the License.
9eb798
+ *
9eb798
+ * This Program is distributed in the hope that it will be useful, but
9eb798
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
9eb798
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
9eb798
+ * General Public License for more details.
9eb798
+ *
9eb798
+ * You should have received a copy of the GNU General Public License
9eb798
+ * along with this Program; if not, write to the
9eb798
+ *
9eb798
+ *   Free Software Foundation, Inc.
9eb798
+ *   59 Temple Place, Suite 330
9eb798
+ *   Boston, MA 02111-1307 USA
9eb798
+ *
9eb798
+ */
9eb798
+
9eb798
+#ifdef HAVE_CONFIG_H
9eb798
+#include "config.h"
9eb798
+#endif
9eb798
+
9eb798
+#include <sys/types.h>
9eb798
+#include <stdlib.h>
9eb798
+#include <string.h>
9eb798
+#include <time.h>
9eb798
+#include <unistd.h>
9eb798
+#include <errno.h>
9eb798
+#include <pwd.h>
9eb798
+#include <grp.h>
9eb798
+#include "back-sch-nss.h"
9eb798
+
9eb798
+/* SSSD only exposes *_timeout() variants if the following symbol is defined */
9eb798
+#define IPA_389DS_PLUGIN_HELPER_CALLS
9eb798
+#include <sss_nss_idmap.h>
9eb798
+
9eb798
+struct nss_ops_ctx {
9eb798
+	unsigned int timeout;
9eb798
+};
9eb798
+
9eb798
+static enum nss_status __convert_sss_nss2nss_status(int errcode) {
9eb798
+	enum nss_status ret = NSS_STATUS_UNAVAIL;
9eb798
+
9eb798
+	if (errcode == 0) {
9eb798
+		ret = NSS_STATUS_SUCCESS;
9eb798
+	} else if (errcode == ENOENT) {
9eb798
+		ret = NSS_STATUS_NOTFOUND;
9eb798
+	} else if(errcode == ERANGE) {
9eb798
+		ret = NSS_STATUS_TRYAGAIN;
9eb798
+	} else if(errcode == ETIMEDOUT) {
9eb798
+		ret = NSS_STATUS_UNAVAIL;
9eb798
+	} else if(errcode == ETIME) {
9eb798
+		ret = NSS_STATUS_TRYAGAIN;
9eb798
+	};
9eb798
+
9eb798
+	return ret;
9eb798
+}
9eb798
+
9eb798
+void backend_nss_init_context(struct nss_ops_ctx **nss_context)
9eb798
+{
9eb798
+	struct nss_ops_ctx *ctx = NULL;
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return;
9eb798
+	}
9eb798
+
9eb798
+	ctx = calloc(1, sizeof(struct nss_ops_ctx));
9eb798
+
9eb798
+	*nss_context = ctx;
9eb798
+}
9eb798
+
9eb798
+void backend_nss_free_context(struct nss_ops_ctx **nss_context)
9eb798
+{
9eb798
+	if (nss_context == NULL) {
9eb798
+		return;
9eb798
+	}
9eb798
+
9eb798
+	free((*nss_context));
9eb798
+	*nss_context = NULL;
9eb798
+}
9eb798
+
9eb798
+
9eb798
+void backend_nss_set_timeout(struct nss_ops_ctx *nss_context,
9eb798
+			     unsigned int timeout) {
9eb798
+	if (nss_context == NULL) {
9eb798
+		return;
9eb798
+	}
9eb798
+
9eb798
+	nss_context->timeout = timeout;
9eb798
+}
9eb798
+
9eb798
+/* TODO: handle buffers and memory allocation in this function */
9eb798
+void backend_nss_evict_user(struct nss_ops_ctx *nss_context,
9eb798
+			    const char *name) {
9eb798
+	if (nss_context == NULL) {
9eb798
+		return;
9eb798
+	}
9eb798
+
9eb798
+	(void) sss_nss_getpwnam_timeout(name, NULL,
9eb798
+					NULL, 0,
9eb798
+					NULL,
9eb798
+					SSS_NSS_EX_FLAG_INVALIDATE_CACHE,
9eb798
+					nss_context->timeout);
9eb798
+}
9eb798
+
9eb798
+/* TODO: handle buffers and memory allocation in this function */
9eb798
+void backend_nss_evict_group(struct nss_ops_ctx *nss_context,
9eb798
+			     const char *name) {
9eb798
+	if (nss_context == NULL) {
9eb798
+		return;
9eb798
+	}
9eb798
+
9eb798
+	(void) sss_nss_getgrnam_timeout(name, NULL,
9eb798
+					NULL, 0,
9eb798
+					NULL,
9eb798
+					SSS_NSS_EX_FLAG_INVALIDATE_CACHE,
9eb798
+					nss_context->timeout);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getpwnam(struct nss_ops_ctx *nss_context,
9eb798
+				     const char *name, struct passwd *pwd,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct passwd **result,
9eb798
+				     int *lerrno) {
9eb798
+	int ret = 0;
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	ret = sss_nss_getpwnam_timeout(name, pwd,
9eb798
+				       buffer, buflen,
9eb798
+				       result,
9eb798
+				       SSS_NSS_EX_FLAG_NO_FLAGS,
9eb798
+				       nss_context->timeout);
9eb798
+
9eb798
+	if (ret != 0 && lerrno != NULL) {
9eb798
+		/* SSSD translates errno into return code */
9eb798
+		*lerrno = ret;
9eb798
+	}
9eb798
+	return __convert_sss_nss2nss_status(ret);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getpwuid(struct nss_ops_ctx *nss_context,
9eb798
+				     uid_t uid, struct passwd *pwd,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct passwd **result,
9eb798
+				     int *lerrno) {
9eb798
+
9eb798
+	int ret = 0;
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	ret = sss_nss_getpwuid_timeout(uid, pwd,
9eb798
+				       buffer, buflen,
9eb798
+				       result,
9eb798
+				       SSS_NSS_EX_FLAG_NO_FLAGS,
9eb798
+				       nss_context->timeout);
9eb798
+	if (ret != 0 && lerrno != NULL) {
9eb798
+		/* SSSD translates errno into return code */
9eb798
+		*lerrno = ret;
9eb798
+	}
9eb798
+	return __convert_sss_nss2nss_status(ret);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getgrnam(struct nss_ops_ctx *nss_context,
9eb798
+				     const char *name, struct group *grp,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct group **result,
9eb798
+				     int *lerrno) {
9eb798
+
9eb798
+	int ret = 0;
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	ret = sss_nss_getgrnam_timeout(name, grp,
9eb798
+				       buffer, buflen,
9eb798
+				       result,
9eb798
+				       SSS_NSS_EX_FLAG_NO_FLAGS,
9eb798
+				       nss_context->timeout);
9eb798
+	if (ret != 0 && lerrno != NULL) {
9eb798
+		/* SSSD translates errno into return code */
9eb798
+		*lerrno = ret;
9eb798
+	}
9eb798
+	return __convert_sss_nss2nss_status(ret);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getgrgid(struct nss_ops_ctx *nss_context,
9eb798
+				     gid_t gid, struct group *grp,
9eb798
+				     char *buffer, size_t buflen,
9eb798
+				     struct group **result,
9eb798
+				     int *lerrno) {
9eb798
+
9eb798
+	int ret = 0;
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	ret = sss_nss_getgrgid_timeout(gid, grp,
9eb798
+				       buffer, buflen,
9eb798
+				       result,
9eb798
+				       SSS_NSS_EX_FLAG_NO_FLAGS,
9eb798
+				       nss_context->timeout);
9eb798
+	if (ret != 0 && lerrno != NULL) {
9eb798
+		/* SSSD translates errno into return code */
9eb798
+		*lerrno = ret;
9eb798
+	}
9eb798
+	return __convert_sss_nss2nss_status(ret);
9eb798
+}
9eb798
+
9eb798
+enum nss_status backend_nss_getgrouplist(struct nss_ops_ctx *nss_context,
9eb798
+					 const char *name, gid_t group,
9eb798
+					 gid_t *groups, int *ngroups,
9eb798
+					 int *lerrno) {
9eb798
+	int ret = 0;
9eb798
+
9eb798
+	if (nss_context == NULL) {
9eb798
+		return NSS_STATUS_UNAVAIL;
9eb798
+	}
9eb798
+
9eb798
+	ret = sss_nss_getgrouplist_timeout(name, group,
9eb798
+					   groups, ngroups,
9eb798
+					   SSS_NSS_EX_FLAG_NO_FLAGS,
9eb798
+					   nss_context->timeout);
9eb798
+	if (ret != 0 && lerrno != NULL) {
9eb798
+		/* SSSD translates errno into return code */
9eb798
+		*lerrno = ret;
9eb798
+	}
9eb798
+	return __convert_sss_nss2nss_status(ret);
9eb798
+}
9eb798
+
9eb798
diff --git a/src/back-sch.h b/src/back-sch.h
9eb798
index 9a9abc7..a400419 100644
9eb798
--- a/src/back-sch.h
9eb798
+++ b/src/back-sch.h
9eb798
@@ -152,10 +152,17 @@ typedef struct backend_extop_handlers {
9eb798
 
9eb798
 int backend_analyze_search_filter(Slapi_Filter *filter, struct backend_search_filter_config *config);
9eb798
 
9eb798
-/* Operations against nsswitch API */
9eb798
+/* NSS backend operations implemented using either nss_sss.so.2 or libsss_nss_idmap API */
9eb798
 struct nss_ops_ctx;
9eb798
+
9eb798
 void backend_nss_init_context(struct nss_ops_ctx **nss_context);
9eb798
 void backend_nss_free_context(struct nss_ops_ctx **nss_context);
9eb798
+void backend_nss_set_timeout(struct nss_ops_ctx **nss_context,
9eb798
+			     unsigned int timeout);
9eb798
+void backend_nss_evict_user(struct nss_ops_ctx **nss_context,
9eb798
+			    const char *name);
9eb798
+void backend_nss_evict_group(struct nss_ops_ctx **nss_context,
9eb798
+			     const char *name);
9eb798
 
9eb798
 void backend_search_nsswitch(struct backend_set_data *set_data,
9eb798
 			     struct backend_search_cbdata *cbdata);
9eb798
diff --git a/src/plug-sch.c b/src/plug-sch.c
9eb798
index 00e7041..6ee4042 100644
9eb798
--- a/src/plug-sch.c
9eb798
+++ b/src/plug-sch.c
9eb798
@@ -104,6 +104,7 @@ plugin_startup(Slapi_PBlock *pb)
9eb798
 	struct plugin_state *state;
9eb798
 	Slapi_Entry *plugin_entry = NULL;
9eb798
 	Slapi_DN *pluginsdn = NULL;
9eb798
+	unsigned int nss_timeout = 10000;
9eb798
 
9eb798
 	slapi_pblock_get(pb, SLAPI_PLUGIN_PRIVATE, &state);
9eb798
 	slapi_pblock_get(pb, SLAPI_TARGET_SDN, &pluginsdn);
9eb798
@@ -130,7 +131,13 @@ plugin_startup(Slapi_PBlock *pb)
9eb798
 		state->use_entry_cache = backend_shr_get_vattr_boolean(state, plugin_entry,
9eb798
 									"slapi-entry-cache",
9eb798
 									1);
9eb798
+		nss_timeout = backend_shr_get_vattr_uint(state, plugin_entry,
9eb798
+							 "slapi-nss-timeout",
9eb798
+							 10000);
9eb798
+
9eb798
 	}
9eb798
+	backend_nss_set_timeout(state->nss_context, nss_timeout);
9eb798
+
9eb798
 	state->cached_entries_lock = wrap_new_rwlock();
9eb798
 	wrap_rwlock_wrlock(state->cached_entries_lock);
9eb798
 	state->cached_entries = PL_NewHashTable(0, PL_HashString, PL_CompareStrings, PL_CompareValues, 0, 0);
9eb798
-- 
9eb798
2.13.6
9eb798