[lttng-dev] [PATCH lttng-tools 2.2] Fix: consumer: use uint64_t for all sessiond_id

David Goulet dgoulet at efficios.com
Mon Jul 8 15:21:52 EDT 2013


I confirmed that this is already in stable-2.2

bcfa3ff
77c5447
98cf381

Mathieu Desnoyers:
> * Mathieu Desnoyers (mathieu.desnoyers at efficios.com) wrote:
>> Ping ? This is still not merged.
> 
> As a precision: this bugfix applies to both master and stable-2.2.
> 
> It's only merged in stable-2.2, but should also be pulled into master.
> 
> Thanks,
> 
> Mathieu
> 
>>
>> * Mathieu Desnoyers (mathieu.desnoyers at efficios.com) wrote:
>>> Signed-off-by: Mathieu Desnoyers <mathieu.desnoyers at efficios.com>
>>> ---
>>> diff --git a/src/common/consumer.c b/src/common/consumer.c
>>> index d810de1..a1a99b4 100644
>>> --- a/src/common/consumer.c
>>> +++ b/src/common/consumer.c
>>> @@ -1162,7 +1162,7 @@ struct lttng_consumer_local_data *lttng_consumer_create(
>>>  			struct lttng_consumer_local_data *ctx),
>>>  		int (*recv_channel)(struct lttng_consumer_channel *channel),
>>>  		int (*recv_stream)(struct lttng_consumer_stream *stream),
>>> -		int (*update_stream)(int stream_key, uint32_t state))
>>> +		int (*update_stream)(uint64_t stream_key, uint32_t state))
>>>  {
>>>  	int ret;
>>>  	struct lttng_consumer_local_data *ctx;
>>> @@ -3074,7 +3074,7 @@ void lttng_consumer_init(void)
>>>  int consumer_add_relayd_socket(uint64_t net_seq_idx, int sock_type,
>>>  		struct lttng_consumer_local_data *ctx, int sock,
>>>  		struct pollfd *consumer_sockpoll,
>>> -		struct lttcomm_relayd_sock *relayd_sock, unsigned int sessiond_id)
>>> +		struct lttcomm_relayd_sock *relayd_sock, uint64_t sessiond_id)
>>>  {
>>>  	int fd = -1, ret = -1, relayd_created = 0;
>>>  	enum lttng_error_code ret_code = LTTNG_OK;
>>> @@ -3095,7 +3095,7 @@ int consumer_add_relayd_socket(uint64_t net_seq_idx, int sock_type,
>>>  			ret_code = LTTCOMM_CONSUMERD_ENOMEM;
>>>  			ret = -ENOMEM;
>>>  		} else {
>>> -			relayd->sessiond_session_id = (uint64_t) sessiond_id;
>>> +			relayd->sessiond_session_id = sessiond_id;
>>>  			relayd_created = 1;
>>>  		}
>>>  
>>> diff --git a/src/common/consumer.h b/src/common/consumer.h
>>> index 3cfcb87..a5a758b 100644
>>> --- a/src/common/consumer.h
>>> +++ b/src/common/consumer.h
>>> @@ -340,7 +340,7 @@ struct lttng_consumer_local_data {
>>>  	 *   == 0 (success, FD is left to library)
>>>  	 *    < 0 (error)
>>>  	 */
>>> -	int (*on_update_stream)(int sessiond_key, uint32_t state);
>>> +	int (*on_update_stream)(uint64_t sessiond_key, uint32_t state);
>>>  	enum lttng_consumer_type type;
>>>  	/* socket to communicate errors with sessiond */
>>>  	int consumer_error_socket;
>>> @@ -502,7 +502,7 @@ struct lttng_consumer_local_data *lttng_consumer_create(
>>>  			struct lttng_consumer_local_data *ctx),
>>>  		int (*recv_channel)(struct lttng_consumer_channel *channel),
>>>  		int (*recv_stream)(struct lttng_consumer_stream *stream),
>>> -		int (*update_stream)(int sessiond_key, uint32_t state));
>>> +		int (*update_stream)(uint64_t sessiond_key, uint32_t state));
>>>  void lttng_consumer_destroy(struct lttng_consumer_local_data *ctx);
>>>  ssize_t lttng_consumer_on_read_subbuffer_mmap(
>>>  		struct lttng_consumer_local_data *ctx,
>>> @@ -528,7 +528,7 @@ int lttng_consumer_on_recv_stream(struct lttng_consumer_stream *stream);
>>>  int consumer_add_relayd_socket(uint64_t net_seq_idx, int sock_type,
>>>  		struct lttng_consumer_local_data *ctx, int sock,
>>>  		struct pollfd *consumer_sockpoll, struct lttcomm_relayd_sock *relayd_sock,
>>> -		unsigned int sessiond_id);
>>> +		uint64_t sessiond_id);
>>>  void consumer_flag_relayd_for_destroy(
>>>  		struct consumer_relayd_sock_pair *relayd);
>>>  int consumer_data_pending(uint64_t id);
>>>
>>> -- 
>>> Mathieu Desnoyers
>>> EfficiOS Inc.
>>> http://www.efficios.com
>>>
>>> _______________________________________________
>>> lttng-dev mailing list
>>> lttng-dev at lists.lttng.org
>>> http://lists.lttng.org/cgi-bin/mailman/listinfo/lttng-dev
>>
>> -- 
>> Mathieu Desnoyers
>> EfficiOS Inc.
>> http://www.efficios.com
>>
>> _______________________________________________
>> lttng-dev mailing list
>> lttng-dev at lists.lttng.org
>> http://lists.lttng.org/cgi-bin/mailman/listinfo/lttng-dev
> 



More information about the lttng-dev mailing list