X-Git-Url: http://git.lttng.org/?a=blobdiff_plain;f=libust%2Fbuffers.c;fp=libust%2Fbuffers.c;h=732e03dce7263b33e19958d763607b8ff09f306f;hb=cd6b724338f1156ce7281f00a06ea848bec7213c;hp=4011b64310f6791d12318f7e41dc62cd9825a7f4;hpb=68d96813ccbb41602f92b45e8a5f61dea7525c35;p=ust.git diff --git a/libust/buffers.c b/libust/buffers.c index 4011b64..732e03d 100644 --- a/libust/buffers.c +++ b/libust/buffers.c @@ -254,12 +254,8 @@ unmap_buf: return -1; } -static void ltt_relay_print_buffer_errors(struct ust_channel *chan, int cpu); - static void close_buf(struct ust_buffer *buf) { - struct ust_channel *chan = buf->chan; - int cpu = buf->cpu; int result; result = shmdt(buf->buf_data); @@ -267,8 +263,6 @@ static void close_buf(struct ust_buffer *buf) PERROR("shmdt"); } - free(buf->commit_count); - result = close(buf->data_ready_fd_read); if (result < 0) { PERROR("close"); @@ -278,9 +272,6 @@ static void close_buf(struct ust_buffer *buf) if (result < 0 && errno != EBADF) { PERROR("close"); } - - /* FIXME: This spews out errors, are they real?: - * ltt_relay_print_buffer_errors(chan, cpu); */ } @@ -517,78 +508,6 @@ int ust_buffers_put_subbuf(struct ust_buffer *buf, unsigned long uconsumed_old) return 0; } -static void ltt_relay_print_subbuffer_errors( - struct ust_channel *channel, - long cons_off, int cpu) -{ - struct ust_buffer *ltt_buf = channel->buf[cpu]; - long cons_idx, commit_count, commit_count_sb, write_offset; - - cons_idx = SUBBUF_INDEX(cons_off, channel); - commit_count = uatomic_read(<t_buf->commit_count[cons_idx].cc); - commit_count_sb = uatomic_read(<t_buf->commit_count[cons_idx].cc_sb); - - /* - * No need to order commit_count and write_offset reads because we - * execute after trace is stopped when there are no readers left. - */ - write_offset = uatomic_read(<t_buf->offset); - WARN( "LTT : unread channel %s offset is %ld " - "and cons_off : %ld (cpu %d)\n", - channel->channel_name, write_offset, cons_off, cpu); - /* Check each sub-buffer for non filled commit count */ - if (((commit_count - channel->subbuf_size) & channel->commit_count_mask) - - (BUFFER_TRUNC(cons_off, channel) >> channel->n_subbufs_order) != 0) { - ERR("LTT : %s : subbuffer %lu has non filled " - "commit count [cc, cc_sb] [%lu,%lu].\n", - channel->channel_name, cons_idx, commit_count, commit_count_sb); - } - ERR("LTT : %s : commit count : %lu, subbuf size %zd\n", - channel->channel_name, commit_count, - channel->subbuf_size); -} - -static void ltt_relay_print_errors(struct ust_trace *trace, - struct ust_channel *channel, int cpu) -{ - struct ust_buffer *ltt_buf = channel->buf[cpu]; - long cons_off; - - /* - * Can be called in the error path of allocation when - * trans_channel_data is not yet set. - */ - if (!channel) - return; - -//ust// for (cons_off = 0; cons_off < rchan->alloc_size; -//ust// cons_off = SUBBUF_ALIGN(cons_off, rchan)) -//ust// ust_buffers_print_written(ltt_chan, cons_off, cpu); - for (cons_off = uatomic_read(<t_buf->consumed); - (SUBBUF_TRUNC(uatomic_read(<t_buf->offset), - channel) - - cons_off) > 0; - cons_off = SUBBUF_ALIGN(cons_off, channel)) - ltt_relay_print_subbuffer_errors(channel, cons_off, cpu); -} - -static void ltt_relay_print_buffer_errors(struct ust_channel *channel, int cpu) -{ - struct ust_trace *trace = channel->trace; - struct ust_buffer *ltt_buf = channel->buf[cpu]; - - if (uatomic_read(<t_buf->events_lost)) - ERR("channel %s: %ld events lost (cpu %d)", - channel->channel_name, - uatomic_read(<t_buf->events_lost), cpu); - if (uatomic_read(<t_buf->corrupted_subbuffers)) - ERR("channel %s : %ld corrupted subbuffers (cpu %d)", - channel->channel_name, - uatomic_read(<t_buf->corrupted_subbuffers), cpu); - - ltt_relay_print_errors(trace, channel, cpu); -} - static int map_buf_structs(struct ust_channel *chan) { void *ptr; @@ -721,7 +640,6 @@ static void remove_channel(struct ust_channel *chan) free(chan->buf_struct_shmids); free(chan->buf); - } static void ltt_relay_async_wakeup_chan(struct ust_channel *ltt_channel)