X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=liblttng-ust%2Flttng-ust-comm.c;h=59f14050f1b5dfdd4d53dc73d3730d9387a96142;hb=8406222c45d29b23064d688e33be84894a51baac;hp=bb22a8a9d8af068de6b77145c5ca61fe228e9f90;hpb=49faeca7301c4081d16ef360636bc79077c9943f;p=lttng-ust.git

diff --git a/liblttng-ust/lttng-ust-comm.c b/liblttng-ust/lttng-ust-comm.c
index bb22a8a9..59f14050 100644
--- a/liblttng-ust/lttng-ust-comm.c
+++ b/liblttng-ust/lttng-ust-comm.c
@@ -1216,6 +1216,48 @@ int handle_message(struct sock_info *sock_info,
 			ret = -ENOSYS;
 		break;
 	}
+	case LTTNG_UST_EVENT_NOTIFIER_CREATE:
+	{
+		/* Receive struct lttng_ust_event_notifier */
+		struct lttng_ust_event_notifier event_notifier;
+
+		if (sizeof(event_notifier) != lum->u.event_notifier.len) {
+			DBG("incorrect event notifier data message size: %u", lum->u.event_notifier.len);
+			ret = -EINVAL;
+			goto error;
+		}
+		len = ustcomm_recv_unix_sock(sock, &event_notifier, sizeof(event_notifier));
+		switch (len) {
+		case 0:	/* orderly shutdown */
+			ret = 0;
+			goto error;
+		default:
+			if (len == sizeof(event_notifier)) {
+				DBG("event notifier data received");
+				break;
+			} else if (len < 0) {
+				DBG("Receive failed from lttng-sessiond with errno %d", (int) -len);
+				if (len == -ECONNRESET) {
+					ERR("%s remote end closed connection", sock_info->name);
+					ret = len;
+					goto error;
+				}
+				ret = len;
+				goto error;
+			} else {
+				DBG("incorrect event notifier data message size: %zd", len);
+				ret = -EINVAL;
+				goto error;
+			}
+		}
+		if (ops->cmd)
+			ret = ops->cmd(lum->handle, lum->cmd,
+					(unsigned long) &event_notifier,
+					&args, sock_info);
+		else
+			ret = -ENOSYS;
+		break;
+	}
 
 	default:
 		if (ops->cmd)