channel->channel->name,
channel->stream_count);
+ health_code_update();
+
ret = consumer_send_channel(sock, &lkm);
if (ret < 0) {
goto error;
}
+ health_code_update();
+
error:
return ret;
}
session->metadata->fd,
session->metadata->conf->attr.subbuf_size,
0, /* for kernel */
- "metadata",
+ DEFAULT_METADATA_NAME,
1);
+ health_code_update();
+
ret = consumer_send_channel(sock, &lkm);
if (ret < 0) {
goto error;
}
+ health_code_update();
+
/* Prep stream message structure */
consumer_init_stream_comm_msg(&lkm,
LTTNG_CONSUMER_ADD_STREAM,
session->gid,
consumer->net_seq_index,
1, /* Metadata flag set */
- "metadata",
+ DEFAULT_METADATA_NAME,
pathname,
session->id);
+ health_code_update();
+
/* Send stream and file descriptor */
ret = consumer_send_stream(sock, consumer, &lkm,
&session->metadata_stream_fd, 1);
goto error;
}
+ health_code_update();
+
error:
return ret;
}
pathname,
session->id);
+ health_code_update();
+
/* Send stream and file descriptor */
ret = consumer_send_stream(sock, consumer, &lkm, &stream->fd, 1);
if (ret < 0) {
goto error;
}
+ health_code_update();
+
error:
return ret;
}