X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;ds=sidebyside;f=src%2Fcommon%2Fust-consumer%2Fust-consumer.c;fp=src%2Fcommon%2Fust-consumer%2Fust-consumer.c;h=87c121464e332656eafb27813c900acbdf8f3a26;hb=3f505e4b7709766f5953a994f5425f74a48300e3;hp=473c94b2313a3ee23ffd71b80a1e880827c9834c;hpb=82b4cfcce55624cb2560144a5b1d160083bc6ba2;p=lttng-tools.git

diff --git a/src/common/ust-consumer/ust-consumer.c b/src/common/ust-consumer/ust-consumer.c
index 473c94b23..87c121464 100644
--- a/src/common/ust-consumer/ust-consumer.c
+++ b/src/common/ust-consumer/ust-consumer.c
@@ -1948,6 +1948,25 @@ int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
 		}
 		break;
 	}
+	case LTTNG_CONSUMER_CLEAR_SESSION:
+	{
+		uint64_t session_id = msg.u.clear_session.session_id;
+
+		ret = lttng_consumer_clear_session(session_id);
+		if (ret) {
+			ERR("Clear session failed session_id %" PRIu64, session_id);
+			ret_code = ret;
+		}
+
+		health_code_update();
+		ret = consumer_send_status_msg(sock, ret_code);
+		if (ret < 0) {
+			/* Somehow, the session daemon is not responding anymore. */
+			goto end_nosignal;
+		}
+		break;
+	}
+
 	default:
 		break;
 	}