//wait_queue_head_t *(*get_hp_wait_queue)(struct channel *chan);
int (*is_finalized)(struct channel *chan);
int (*is_disabled)(struct channel *chan);
- int (*flush_buffers)(struct channel *chan, struct shm_handle *handle);
+ int (*flush_buffer)(struct channel *chan, struct shm_handle *handle);
};
struct ltt_channel {
/* Event and Channel FD commands */
#define LTTNG_UST_CONTEXT \
_UST_CMDW(0x70, struct lttng_ust_context)
-#define LTTNG_UST_FLUSH_BUFFERS \
+#define LTTNG_UST_FLUSH_BUFFER \
_UST_CMD(0x71)
/* Event, Channel and Session commands */
int ustctl_wait_quiescent(int sock);
/* Flush each buffers in this channel */
-int ustctl_flush_buffers(int sock, struct object_data *channel_data);
+int ustctl_flush_buffer(int sock, struct object_data *channel_data);
/* not implemented yet */
struct lttng_ust_calibrate;
}
static
-int ltt_flush_buffers(struct channel *chan, struct shm_handle *handle)
+int ltt_flush_buffer(struct channel *chan, struct shm_handle *handle)
{
struct lib_ring_buffer *buf;
int cpu;
//.get_hp_wait_queue = ltt_get_hp_wait_queue,
.is_finalized = ltt_is_finalized,
.is_disabled = ltt_is_disabled,
- .flush_buffers = ltt_flush_buffers,
+ .flush_buffer = ltt_flush_buffer,
},
};
}
static
-int ltt_flush_buffers(struct channel *chan, struct shm_handle *handle)
+int ltt_flush_buffer(struct channel *chan, struct shm_handle *handle)
{
struct lib_ring_buffer *buf;
int shm_fd, wait_fd;
//.get_hp_wait_queue = ltt_get_hp_wait_queue,
.is_finalized = ltt_is_finalized,
.is_disabled = ltt_is_disabled,
- .flush_buffers = ltt_flush_buffers,
+ .flush_buffer = ltt_flush_buffer,
},
};
return ltt_channel_enable(channel);
case LTTNG_UST_DISABLE:
return ltt_channel_disable(channel);
- case LTTNG_UST_FLUSH_BUFFERS:
- return channel->ops->flush_buffers(channel->chan, channel->handle);
+ case LTTNG_UST_FLUSH_BUFFER:
+ return channel->ops->flush_buffer(channel->chan, channel->handle);
default:
return -EINVAL;
}
/* stream used as output */
return lttng_abi_open_stream(objd, stream);
}
- case LTTNG_UST_FLUSH_BUFFERS:
- return channel->ops->flush_buffers(channel->chan, channel->handle);
+ case LTTNG_UST_FLUSH_BUFFER:
+ return channel->ops->flush_buffer(channel->chan, channel->handle);
default:
return -EINVAL;
}
return 0;
}
-int ustctl_flush_buffers(int sock, struct object_data *channel_data)
+int ustctl_flush_buffer(int sock, struct object_data *channel_data)
{
struct ustcomm_ust_msg lum;
struct ustcomm_ust_reply lur;
memset(&lum, 0, sizeof(lum));
lum.handle = channel_data->handle;
- lum.cmd = LTTNG_UST_FLUSH_BUFFERS;
+ lum.cmd = LTTNG_UST_FLUSH_BUFFER;
return ustcomm_send_app_cmd(sock, &lum, &lur);
}