summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
7bd3904)
Signed-off-by: David Goulet <dgoulet@efficios.com>
int tmp2;
struct lttng_consumer_local_data *ctx = data;
int tmp2;
struct lttng_consumer_local_data *ctx = data;
+ rcu_register_thread();
+
local_stream = zmalloc(sizeof(struct lttng_consumer_stream));
while (1) {
local_stream = zmalloc(sizeof(struct lttng_consumer_stream));
while (1) {
free(local_stream);
local_stream = NULL;
}
free(local_stream);
local_stream = NULL;
}
+ rcu_unregister_thread();
struct pollfd consumer_sockpoll[2];
struct lttng_consumer_local_data *ctx = data;
struct pollfd consumer_sockpoll[2];
struct lttng_consumer_local_data *ctx = data;
+ rcu_register_thread();
+
DBG("Creating command socket %s", ctx->consumer_command_sock_path);
unlink(ctx->consumer_command_sock_path);
client_socket = lttcomm_create_unix_sock(ctx->consumer_command_sock_path);
DBG("Creating command socket %s", ctx->consumer_command_sock_path);
unlink(ctx->consumer_command_sock_path);
client_socket = lttcomm_create_unix_sock(ctx->consumer_command_sock_path);
if (ret < 0) {
perror("poll pipe write");
}
if (ret < 0) {
perror("poll pipe write");
}
+ rcu_unregister_thread();