|
 |
ad412c |
From 570b15e0ea71950ff14ddc2bf667e9e361720939 Mon Sep 17 00:00:00 2001
|
|
|
ad412c |
From: Frediano Ziglio <freddy77@gmail.com>
|
|
|
ad412c |
Date: Thu, 24 Sep 2020 12:13:44 +0100
|
|
|
ad412c |
Subject: [PATCH vd_agent_linux 15/17] vdagentd: Limit number of agents per
|
|
|
ad412c |
session to 1
|
|
|
ad412c |
|
|
|
ad412c |
Signed-off-by: Frediano Ziglio <freddy77@gmail.com>
|
|
|
ad412c |
Acked-by: Uri Lublin <uril@redhat.com>
|
|
|
ad412c |
---
|
|
|
ad412c |
src/vdagentd/vdagentd.c | 24 ++++++++++++++++++++++++
|
|
|
ad412c |
1 file changed, 24 insertions(+)
|
|
|
ad412c |
|
|
|
ad412c |
diff --git a/src/vdagentd/vdagentd.c b/src/vdagentd/vdagentd.c
|
|
|
ad412c |
index bb39340..5ef547e 100644
|
|
|
ad412c |
--- a/src/vdagentd/vdagentd.c
|
|
|
ad412c |
+++ b/src/vdagentd/vdagentd.c
|
|
|
ad412c |
@@ -955,6 +955,20 @@ static gboolean remove_active_xfers(gpointer key, gpointer value, gpointer conn)
|
|
|
ad412c |
return 0;
|
|
|
ad412c |
}
|
|
|
ad412c |
|
|
|
ad412c |
+/* Check if this connection matches the passed session */
|
|
|
ad412c |
+static int connection_matches_session(UdscsConnection *conn, void *priv)
|
|
|
ad412c |
+{
|
|
|
ad412c |
+ const char *session = priv;
|
|
|
ad412c |
+ const struct agent_data *agent_data = g_object_get_data(G_OBJECT(conn), "agent_data");
|
|
|
ad412c |
+
|
|
|
ad412c |
+ if (!agent_data || !agent_data->session ||
|
|
|
ad412c |
+ strcmp(agent_data->session, session) != 0) {
|
|
|
ad412c |
+ return 0;
|
|
|
ad412c |
+ }
|
|
|
ad412c |
+
|
|
|
ad412c |
+ return 1;
|
|
|
ad412c |
+}
|
|
|
ad412c |
+
|
|
|
ad412c |
/* Check a given process has a given UID */
|
|
|
ad412c |
static bool check_uid_of_pid(pid_t pid, uid_t uid)
|
|
|
ad412c |
{
|
|
|
ad412c |
@@ -1007,6 +1021,16 @@ static void agent_connect(UdscsConnection *conn)
|
|
|
ad412c |
udscs_server_destroy_connection(server, conn);
|
|
|
ad412c |
return;
|
|
|
ad412c |
}
|
|
|
ad412c |
+
|
|
|
ad412c |
+ // Check there are no other connection for this session
|
|
|
ad412c |
+ // Note that "conn" is not counted as "agent_data" is still not attached to it
|
|
|
ad412c |
+ if (udscs_server_for_all_clients(server, connection_matches_session,
|
|
|
ad412c |
+ agent_data->session) > 0) {
|
|
|
ad412c |
+ syslog(LOG_ERR, "An agent is already connected for this session");
|
|
|
ad412c |
+ agent_data_destroy(agent_data);
|
|
|
ad412c |
+ udscs_server_destroy_connection(server, conn);
|
|
|
ad412c |
+ return;
|
|
|
ad412c |
+ }
|
|
|
ad412c |
}
|
|
|
ad412c |
|
|
|
ad412c |
g_object_set_data_full(G_OBJECT(conn), "agent_data", agent_data,
|
|
|
ad412c |
--
|
|
|
ad412c |
2.26.2
|
|
|
ad412c |
|