projects
/
lttng-ust.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Refactoring: struct lttng_ust_channel_ops
[lttng-ust.git]
/
liblttng-ust-ctl
/
ustctl.c
diff --git
a/liblttng-ust-ctl/ustctl.c
b/liblttng-ust-ctl/ustctl.c
index 84476a97966a7eae18f767c6f6683e269b80b603..2a7c7d8a39ca0d3beadecdbab820fd90666b6999 100644
(file)
--- a/
liblttng-ust-ctl/ustctl.c
+++ b/
liblttng-ust-ctl/ustctl.c
@@
-1279,7
+1279,7
@@
struct ustctl_consumer_channel *
if (!chan)
return NULL;
if (!chan)
return NULL;
- chan->chan = transport->ops.channel_create(transport_name, NULL,
+ chan->chan = transport->ops.
priv->
channel_create(transport_name, NULL,
attr->subbuf_size, attr->num_subbuf,
attr->switch_timer_interval,
attr->read_timer_interval,
attr->subbuf_size, attr->num_subbuf,
attr->switch_timer_interval,
attr->read_timer_interval,
@@
-1304,7
+1304,7
@@
void ustctl_destroy_channel(struct ustctl_consumer_channel *chan)
{
(void) ustctl_channel_close_wait_fd(chan);
(void) ustctl_channel_close_wakeup_fd(chan);
{
(void) ustctl_channel_close_wait_fd(chan);
(void) ustctl_channel_close_wakeup_fd(chan);
- chan->chan->ops->channel_destroy(chan->chan);
+ chan->chan->ops->
priv->
channel_destroy(chan->chan);
free(chan);
}
free(chan);
}
@@
-1350,7
+1350,7
@@
int ustctl_write_metadata_to_channel(
for (pos = 0; pos < len; pos += reserve_len) {
reserve_len = min_t(size_t,
for (pos = 0; pos < len; pos += reserve_len) {
reserve_len = min_t(size_t,
- chan->ops->packet_avail_size(chan->chan, chan->handle),
+ chan->ops->p
riv->p
acket_avail_size(chan->chan, chan->handle),
len - pos);
lib_ring_buffer_ctx_init(&ctx, chan->chan, NULL, reserve_len,
sizeof(char), -1, chan->handle);
len - pos);
lib_ring_buffer_ctx_init(&ctx, chan->chan, NULL, reserve_len,
sizeof(char), -1, chan->handle);
@@
-1397,7
+1397,7
@@
ssize_t ustctl_write_one_packet_to_channel(
int ret;
reserve_len = min_t(ssize_t,
int ret;
reserve_len = min_t(ssize_t,
- chan->ops->packet_avail_size(chan->chan, chan->handle),
+ chan->ops->p
riv->p
acket_avail_size(chan->chan, chan->handle),
len);
lib_ring_buffer_ctx_init(&ctx, chan->chan, NULL, reserve_len,
sizeof(char), -1, chan->handle);
len);
lib_ring_buffer_ctx_init(&ctx, chan->chan, NULL, reserve_len,
sizeof(char), -1, chan->handle);
This page took
0.026037 seconds
and
4
git commands to generate.