diff options
Diffstat (limited to 'server/responder')
-rw-r--r-- | server/responder/common/responder.h | 3 | ||||
-rw-r--r-- | server/responder/common/responder_dp.c | 7 | ||||
-rw-r--r-- | server/responder/nss/nsssrv_cmd.c | 22 | ||||
-rw-r--r-- | server/responder/pam/pamsrv_cmd.c | 8 |
4 files changed, 25 insertions, 15 deletions
diff --git a/server/responder/common/responder.h b/server/responder/common/responder.h index a597e68e..9294f402 100644 --- a/server/responder/common/responder.h +++ b/server/responder/common/responder.h @@ -145,7 +145,8 @@ typedef void (*sss_dp_callback_t)(uint16_t err_maj, uint32_t err_min, int sss_dp_send_acct_req(struct resp_ctx *rctx, TALLOC_CTX *callback_memctx, sss_dp_callback_t callback, void *callback_ctx, - int timeout, const char *domain, int type, + int timeout, const char *domain, + bool fast_reply, int type, const char *opt_name, uint32_t opt_id); #endif /* __SSS_RESPONDER_H__ */ diff --git a/server/responder/common/responder_dp.c b/server/responder/common/responder_dp.c index 943b72c5..03e83ec6 100644 --- a/server/responder/common/responder_dp.c +++ b/server/responder/common/responder_dp.c @@ -243,7 +243,8 @@ static int sss_dp_send_acct_req_create(struct resp_ctx *rctx, int sss_dp_send_acct_req(struct resp_ctx *rctx, TALLOC_CTX *callback_memctx, sss_dp_callback_t callback, void *callback_ctx, - int timeout, const char *domain, int type, + int timeout, const char *domain, + bool fast_reply, int type, const char *opt_name, uint32_t opt_id) { int ret, hret; @@ -279,6 +280,10 @@ int sss_dp_send_acct_req(struct resp_ctx *rctx, TALLOC_CTX *callback_memctx, return EINVAL; } + if (fast_reply) { + be_type |= BE_REQ_FAST; + } + if (dp_requests == NULL) { /* Create a hash table to handle queued update requests */ ret = hash_create(10, &dp_requests, NULL); diff --git a/server/responder/nss/nsssrv_cmd.c b/server/responder/nss/nsssrv_cmd.c index 4473e6c8..97178978 100644 --- a/server/responder/nss/nsssrv_cmd.c +++ b/server/responder/nss/nsssrv_cmd.c @@ -351,7 +351,8 @@ static errno_t check_cache(struct nss_dom_ctx *dctx, */ ret = sss_dp_send_acct_req(cctx->rctx, NULL, NULL, NULL, timeout, dctx->domain->name, - req_type, opt_name, opt_id); + true, req_type, + opt_name, opt_id); if (ret != EOK) { DEBUG(3, ("Failed to dispatch request: %d(%s)\n", ret, strerror(ret))); @@ -376,7 +377,8 @@ static errno_t check_cache(struct nss_dom_ctx *dctx, ret = sss_dp_send_acct_req(cctx->rctx, cmdctx, callback, dctx, timeout, - dctx->domain->name, req_type, + dctx->domain->name, + true, req_type, opt_name, opt_id); if (ret != EOK) { DEBUG(3, ("Failed to dispatch request: %d(%s)\n", @@ -1125,8 +1127,8 @@ static void nss_cmd_setpwent_callback(void *ptr, int status, timeout = SSS_CLI_SOCKET_TIMEOUT; ret = sss_dp_send_acct_req(cctx->rctx, cmdctx, nss_cmd_setpw_dp_callback, dctx, - timeout, dom->name, SSS_DP_USER, - NULL, 0); + timeout, dom->name, true, + SSS_DP_USER, NULL, 0); } else { ret = sysdb_get_ctx_from_list(cctx->rctx->db_list, dctx->domain, &sysdb); @@ -1272,8 +1274,8 @@ static int nss_cmd_setpwent_ext(struct cli_ctx *cctx, bool immediate) timeout = SSS_CLI_SOCKET_TIMEOUT; ret = sss_dp_send_acct_req(cctx->rctx, cmdctx, nss_cmd_setpw_dp_callback, dctx, - timeout, dom->name, SSS_DP_USER, - NULL, 0); + timeout, dom->name, true, + SSS_DP_USER, NULL, 0); } else { ret = sysdb_get_ctx_from_list(cctx->rctx->db_list, dctx->domain, &sysdb); @@ -2448,8 +2450,8 @@ static void nss_cmd_setgrent_callback(void *ptr, int status, timeout = SSS_CLI_SOCKET_TIMEOUT; ret = sss_dp_send_acct_req(cctx->rctx, cmdctx, nss_cmd_setgr_dp_callback, dctx, - timeout, dom->name, SSS_DP_GROUP, - NULL, 0); + timeout, dom->name, true, + SSS_DP_GROUP, NULL, 0); } else { ret = sysdb_get_ctx_from_list(cctx->rctx->db_list, dctx->domain, &sysdb); @@ -2595,8 +2597,8 @@ static int nss_cmd_setgrent_ext(struct cli_ctx *cctx, bool immediate) timeout = SSS_CLI_SOCKET_TIMEOUT; ret = sss_dp_send_acct_req(cctx->rctx, cmdctx, nss_cmd_setgr_dp_callback, dctx, - timeout, dom->name, SSS_DP_GROUP, - NULL, 0); + timeout, dom->name, true, + SSS_DP_GROUP, NULL, 0); } else { ret = sysdb_get_ctx_from_list(cctx->rctx->db_list, dctx->domain, &sysdb); diff --git a/server/responder/pam/pamsrv_cmd.c b/server/responder/pam/pamsrv_cmd.c index 8627d5cb..44799266 100644 --- a/server/responder/pam/pamsrv_cmd.c +++ b/server/responder/pam/pamsrv_cmd.c @@ -725,7 +725,8 @@ static int pam_forwarder(struct cli_ctx *cctx, int pam_cmd) ret = sss_dp_send_acct_req(preq->cctx->rctx, preq, pam_check_user_dp_callback, preq, - timeout, preq->domain->name, SSS_DP_INITGROUPS, + timeout, preq->domain->name, + false, SSS_DP_INITGROUPS, preq->pd->user, 0); } else { @@ -840,7 +841,8 @@ static void pam_check_user_callback(void *ptr, int status, ret = sss_dp_send_acct_req(preq->cctx->rctx, preq, pam_check_user_dp_callback, preq, - timeout, preq->domain->name, SSS_DP_USER, + timeout, preq->domain->name, + false, SSS_DP_USER, preq->pd->user, 0); if (ret != EOK) { DEBUG(3, ("Failed to dispatch request: %d(%s)\n", @@ -910,7 +912,7 @@ static void pam_check_user_callback(void *ptr, int status, pam_check_user_dp_callback, preq, timeout, preq->domain->name, - SSS_DP_USER, + false, SSS_DP_USER, preq->pd->user, 0); } else { |