X-Git-Url: http://git.lttng.org/?a=blobdiff_plain;f=liblttng-ust%2Flttng-context-pthread-id.c;h=65f77d9be5b3d1709225f9b31da2dfd9fae8f6e7;hb=eae3c72949135b48639440468dc78ea1d5e937e9;hp=49a72ee15955934943ac30799c50cc734d9477f9;hpb=218deb69baab57ee2f6728eef18e84697f21197b;p=lttng-ust.git diff --git a/liblttng-ust/lttng-context-pthread-id.c b/liblttng-ust/lttng-context-pthread-id.c index 49a72ee1..65f77d9b 100644 --- a/liblttng-ust/lttng-context-pthread-id.c +++ b/liblttng-ust/lttng-context-pthread-id.c @@ -1,23 +1,9 @@ /* - * lttng-context-pthread-id.c - * - * LTTng UST pthread_id context. + * SPDX-License-Identifier: LGPL-2.1-only * * Copyright (C) 2009-2011 Mathieu Desnoyers * - * This library is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License as published by the Free Software Foundation; only - * version 2.1 of the License. - * - * This library is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - * Lesser General Public License for more details. - * - * You should have received a copy of the GNU Lesser General Public - * License along with this library; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA + * LTTng UST pthread_id context. */ #define _LGPL_SOURCE @@ -25,10 +11,12 @@ #include #include #include -#include +#include + +#include "context-internal.h" static -size_t pthread_id_get_size(struct lttng_ctx_field *field, size_t offset) +size_t pthread_id_get_size(struct lttng_ust_ctx_field *field, size_t offset) { size_t size = 0; @@ -38,9 +26,9 @@ size_t pthread_id_get_size(struct lttng_ctx_field *field, size_t offset) } static -void pthread_id_record(struct lttng_ctx_field *field, +void pthread_id_record(struct lttng_ust_ctx_field *field, struct lttng_ust_lib_ring_buffer_ctx *ctx, - struct lttng_channel *chan) + struct lttng_ust_channel_buffer *chan) { unsigned long pthread_id; @@ -50,34 +38,49 @@ void pthread_id_record(struct lttng_ctx_field *field, } static -void pthread_id_get_value(struct lttng_ctx_field *field, - struct lttng_ctx_value *value) +void pthread_id_get_value(struct lttng_ust_ctx_field *field, + struct lttng_ust_ctx_value *value) { value->u.s64 = (unsigned long) pthread_self(); } -int lttng_add_pthread_id_to_ctx(struct lttng_ctx **ctx) +int lttng_add_pthread_id_to_ctx(struct lttng_ust_ctx **ctx) { - struct lttng_ctx_field *field; + struct lttng_ust_ctx_field *field; + struct lttng_ust_type_common *type; + int ret; - field = lttng_append_context(ctx); - if (!field) + type = lttng_ust_create_type_integer(sizeof(unsigned long) * CHAR_BIT, + lttng_alignof(unsigned long) * CHAR_BIT, + lttng_ust_is_signed_type(unsigned long), + BYTE_ORDER, 10); + if (!type) return -ENOMEM; + field = lttng_append_context(ctx); + if (!field) { + ret = -ENOMEM; + goto error_context; + } if (lttng_find_context(*ctx, "pthread_id")) { - lttng_remove_context_field(ctx, field); - return -EEXIST; + ret = -EEXIST; + goto error_find_context; } - field->event_field.name = "pthread_id"; - field->event_field.type.atype = atype_integer; - field->event_field.type.u.integer.size = sizeof(unsigned long) * CHAR_BIT; - field->event_field.type.u.integer.alignment = lttng_alignof(unsigned long) * CHAR_BIT; - field->event_field.type.u.integer.signedness = lttng_is_signed_type(unsigned long); - field->event_field.type.u.integer.reverse_byte_order = 0; - field->event_field.type.u.integer.base = 10; - field->event_field.type.u.integer.encoding = lttng_encode_none; + field->event_field->name = strdup("pthread_id"); + if (!field->event_field->name) { + ret = -ENOMEM; + goto error_name; + } + field->event_field->type = type; field->get_size = pthread_id_get_size; field->record = pthread_id_record; field->get_value = pthread_id_get_value; lttng_context_update(*ctx); return 0; + +error_name: +error_find_context: + lttng_remove_context_field(ctx, field); +error_context: + lttng_ust_destroy_type(type); + return ret; }