summaryrefslogtreecommitdiffstats
path: root/src/monitor
diff options
context:
space:
mode:
authorJakub Hrozek <jhrozek@redhat.com>2011-12-13 15:41:09 +0100
committerStephen Gallagher <sgallagh@redhat.com>2011-12-13 16:06:21 -0500
commit4134936f56911686e908dbd6bc9634767f399e3d (patch)
tree1fd558f692e18daf96cbda649bb96fb58aca0a4a /src/monitor
parent83280d4e8bb021098dab75fc0ab8f88c4c8265f7 (diff)
downloadsssd-4134936f56911686e908dbd6bc9634767f399e3d.tar.gz
sssd-4134936f56911686e908dbd6bc9634767f399e3d.tar.xz
sssd-4134936f56911686e908dbd6bc9634767f399e3d.zip
Cancel ping_check if service goes away
https://fedorahosted.org/sssd/ticket/1090
Diffstat (limited to 'src/monitor')
-rw-r--r--src/monitor/monitor.c15
1 files changed, 14 insertions, 1 deletions
diff --git a/src/monitor/monitor.c b/src/monitor/monitor.c
index a0a0cc2f7..61786ea5e 100644
--- a/src/monitor/monitor.c
+++ b/src/monitor/monitor.c
@@ -91,6 +91,7 @@ struct mt_svc {
int restarts;
time_t last_restart;
int failed_pongs;
+ DBusPendingCall *pending;
int debug_level;
@@ -315,6 +316,11 @@ static int svc_destructor(void *mem)
DLIST_REMOVE(svc->mt_ctx->svc_list, svc);
}
+ /* Cancel any pending pings */
+ if (svc->pending) {
+ dbus_pending_call_cancel(svc->pending);
+ }
+
/* svc is beeing freed, neutralize the spy */
if (svc->conn_spy) {
talloc_set_destructor((TALLOC_CTX *)svc->conn_spy, NULL);
@@ -2190,7 +2196,7 @@ static int service_send_ping(struct mt_svc *svc)
ret = sbus_conn_send(svc->conn, msg,
svc->ping_time * 1000, /* milliseconds */
- ping_check, svc, NULL);
+ ping_check, svc, &svc->pending);
dbus_message_unref(msg);
return ret;
}
@@ -2204,6 +2210,13 @@ static void ping_check(DBusPendingCall *pending, void *data)
int type;
svc = talloc_get_type(data, struct mt_svc);
+ if (!svc) {
+ /* The connection probably went down before the callback fired.
+ * Not much we can do. */
+ DEBUG(SSSDBG_CRIT_FAILURE, ("Invalid service pointer.\n"));
+ return;
+ }
+ svc->pending = NULL;
reply = dbus_pending_call_steal_reply(pending);
if (!reply) {