kernel_consumer_send_channel_stream() sends _all_ streams of
a given channel. It is renamed kernel_consumer_send_channel_streams()
to ensure its name is no longer misleading.
Signed-off-by: Jérémie Galarneau <jeremie.galarneau@efficios.com>
*
* The consumer socket lock must be held by the caller.
*/
*
* The consumer socket lock must be held by the caller.
*/
-int kernel_consumer_send_channel_stream(struct consumer_socket *sock,
+int kernel_consumer_send_channel_streams(struct consumer_socket *sock,
struct ltt_kernel_channel *channel, struct ltt_kernel_session *session,
unsigned int monitor)
{
struct ltt_kernel_channel *channel, struct ltt_kernel_session *session,
unsigned int monitor)
{
/* Send channel and streams of it */
cds_list_for_each_entry(chan, &session->channel_list.head, list) {
/* Send channel and streams of it */
cds_list_for_each_entry(chan, &session->channel_list.head, list) {
- ret = kernel_consumer_send_channel_stream(sock, chan, session,
+ ret = kernel_consumer_send_channel_streams(sock, chan, session,
monitor);
if (ret < 0) {
goto error;
monitor);
if (ret < 0) {
goto error;
#include "trace-kernel.h"
#include "trace-kernel.h"
-int kernel_consumer_send_channel_stream(struct consumer_socket *sock,
+int kernel_consumer_send_channel_streams(struct consumer_socket *sock,
struct ltt_kernel_channel *channel, struct ltt_kernel_session *session,
unsigned int monitor);
struct ltt_kernel_channel *channel, struct ltt_kernel_session *session,
unsigned int monitor);
cds_lfht_for_each_entry(ksess->consumer->socks->ht,
&iter.iter, socket, node.node) {
pthread_mutex_lock(socket->lock);
cds_lfht_for_each_entry(ksess->consumer->socks->ht,
&iter.iter, socket, node.node) {
pthread_mutex_lock(socket->lock);
- ret = kernel_consumer_send_channel_stream(socket,
+ ret = kernel_consumer_send_channel_streams(socket,
channel, ksess,
session->output_traces ? 1 : 0);
pthread_mutex_unlock(socket->lock);
channel, ksess,
session->output_traces ? 1 : 0);
pthread_mutex_unlock(socket->lock);