summaryrefslogtreecommitdiffstats
path: root/src/responder/common
diff options
context:
space:
mode:
authorSimo Sorce <simo@redhat.com>2012-03-07 18:05:06 -0500
committerStephen Gallagher <sgallagh@redhat.com>2012-03-08 08:09:56 -0500
commit65976ea5e9767bfaced81dfb97dc87d59f50b57e (patch)
treedd26f9d109a837f698133f2a218f6269e31d0fb9 /src/responder/common
parentbd72b3510105599b5bdaf00c203df1164b304238 (diff)
downloadsssd-65976ea5e9767bfaced81dfb97dc87d59f50b57e.tar.gz
sssd-65976ea5e9767bfaced81dfb97dc87d59f50b57e.tar.xz
sssd-65976ea5e9767bfaced81dfb97dc87d59f50b57e.zip
Use the correct hash table for pending requests
The function that handled pending requests on reconnect was checking an orphaned global variable that was never used, redenring the whole function uselsess. This fixes a very nasty bug that was causing requests for which we never received an answer for (for example because the backend failed and was restarted) to be never removed and therefore causing a black hole effect for any other request of the same type. Fixes: https://fedorahosted.org/sssd/ticket/1229
Diffstat (limited to 'src/responder/common')
-rw-r--r--src/responder/common/responder.h6
-rw-r--r--src/responder/common/responder_common.c1
-rw-r--r--src/responder/common/responder_dp.c9
3 files changed, 10 insertions, 6 deletions
diff --git a/src/responder/common/responder.h b/src/responder/common/responder.h
index 619ae46ef..1309c14da 100644
--- a/src/responder/common/responder.h
+++ b/src/responder/common/responder.h
@@ -56,10 +56,14 @@ struct cli_protocol_version {
const char *description;
};
+struct resp_ctx;
+
struct be_conn {
struct be_conn *next;
struct be_conn *prev;
+ struct resp_ctx *rctx;
+
const char *cli_name;
struct sss_domain_info *domain;
@@ -188,7 +192,7 @@ struct dp_callback_ctx {
struct cli_ctx *cctx;
};
-void handle_requests_after_reconnect(void);
+void handle_requests_after_reconnect(struct resp_ctx *rctx);
int responder_logrotate(DBusMessage *message,
struct sbus_connection *conn);
diff --git a/src/responder/common/responder_common.c b/src/responder/common/responder_common.c
index a9b5d56b0..52b271b95 100644
--- a/src/responder/common/responder_common.c
+++ b/src/responder/common/responder_common.c
@@ -326,6 +326,7 @@ static int sss_dp_init(struct resp_ctx *rctx,
be_conn->cli_name = cli_name;
be_conn->domain = domain;
be_conn->intf = intf;
+ be_conn->rctx = rctx;
/* Set up SBUS connection to the monitor */
ret = dp_get_sbus_address(be_conn, &be_conn->sbus_address, domain->name);
diff --git a/src/responder/common/responder_dp.c b/src/responder/common/responder_dp.c
index a116fedd8..a54c68d7e 100644
--- a/src/responder/common/responder_dp.c
+++ b/src/responder/common/responder_dp.c
@@ -28,8 +28,6 @@
#include "providers/data_provider.h"
#include "sbus/sbus_client.h"
-hash_table_t *dp_requests = NULL;
-
struct sss_dp_req;
struct sss_dp_callback {
@@ -120,19 +118,19 @@ static int sss_dp_req_destructor(void *ptr)
return 0;
}
-void handle_requests_after_reconnect(void)
+void handle_requests_after_reconnect(struct resp_ctx *rctx)
{
int ret;
hash_value_t *values;
unsigned long count, i;
struct sss_dp_req *sdp_req;
- if (!dp_requests) {
+ if (!rctx->dp_request_table) {
DEBUG(7, ("No requests to handle after reconnect\n"));
return;
}
- ret = hash_values(dp_requests, &count, &values);
+ ret = hash_values(rctx->dp_request_table, &count, &values);
if (ret != HASH_SUCCESS) {
DEBUG(1, ("hash_values failed, "
"not all request might be handled after reconnect.\n"));
@@ -145,6 +143,7 @@ void handle_requests_after_reconnect(void)
talloc_free(sdp_req);
}
}
+
static int sss_dp_get_reply(DBusPendingCall *pending,
dbus_uint16_t *dp_err,
dbus_uint32_t *dp_ret,