X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=liblttng-ustconsumer%2Flttng-ustconsumer.c;fp=liblttng-ustconsumer%2Flttng-ustconsumer.c;h=f938d3548d9e8ed4ef049333efe1fc1aa16d1a0c;hp=ed4a27c9da927d47ed52cadf129a6592d17fca48;hb=7ad0a0cb283d4004cf9274df8eec4e3530864fc7;hpb=464dd62d5617322366e321877b440951e00a0152

diff --git a/liblttng-ustconsumer/lttng-ustconsumer.c b/liblttng-ustconsumer/lttng-ustconsumer.c
index ed4a27c9d..f938d3548 100644
--- a/liblttng-ustconsumer/lttng-ustconsumer.c
+++ b/liblttng-ustconsumer/lttng-ustconsumer.c
@@ -209,7 +209,7 @@ int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
 		DBG("consumer_add_stream %s (%d,%d)", msg.u.stream.path_name,
 			fds[0], fds[1]);
 		assert(msg.u.stream.output == LTTNG_EVENT_MMAP);
-		new_stream = consumer_allocate_stream(msg.u.stream.channel_key,
+		new_stream = consumer_allocate_stream(msg.u.channel.channel_key,
 				msg.u.stream.stream_key,
 				fds[0], fds[1],
 				msg.u.stream.state,
@@ -234,6 +234,8 @@ int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
 	}
 	case LTTNG_CONSUMER_UPDATE_STREAM:
 	{
+		return -ENOSYS;
+#if 0
 		if (ctx->on_update_stream != NULL) {
 			ret = ctx->on_update_stream(msg.u.stream.stream_key, msg.u.stream.state);
 			if (ret == 0) {
@@ -245,6 +247,7 @@ int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
 			consumer_change_stream_state(msg.u.stream.stream_key,
 				msg.u.stream.state);
 		}
+#endif
 		break;
 	}
 	default: