Lines Matching refs:sf
183 struct s390_cpumsf *sf; member
196 static int s390_cpumcf_dumpctr(struct s390_cpumsf *sf, in s390_cpumcf_dumpctr() argument
203 if (!sf->use_logfile || sf->queues.nr_queues <= sample->cpu) in s390_cpumcf_dumpctr()
206 q = &sf->queues.queue_array[sample->cpu]; in s390_cpumcf_dumpctr()
214 rc = (sf->logdir) in s390_cpumcf_dumpctr()
216 sf->logdir, sample->cpu) in s390_cpumcf_dumpctr()
433 static void s390_cpumsf_dump(struct s390_cpumsf *sf, in s390_cpumsf_dump() argument
446 if (!s390_cpumsf_validate(sf->machine_type, buf, len, &bsdes, in s390_cpumsf_dump()
450 len, sf->machine_type, bsdes, dsdes); in s390_cpumsf_dump()
494 static void s390_cpumsf_dump_event(struct s390_cpumsf *sf, unsigned char *buf, in s390_cpumsf_dump_event() argument
498 s390_cpumsf_dump(sf, buf, len); in s390_cpumsf_dump_event()
539 if (perf_session__deliver_synth_event(sfq->sf->session, &event, in s390_cpumsf_make_event()
602 struct s390_cpumsf *sf = sfq->sf; in s390_cpumsf_samples() local
611 if (!s390_cpumsf_validate(sf->machine_type, buf, len, &bsdes, in s390_cpumsf_samples()
701 queue = &sfq->sf->queues.queue_array[sfq->queue_nr]; in s390_cpumsf_run_decoder()
731 int fd = perf_data__fd(sfq->sf->session->data); in s390_cpumsf_run_decoder()
768 s390_cpumsf_alloc_queue(struct s390_cpumsf *sf, unsigned int queue_nr) in s390_cpumsf_alloc_queue() argument
776 sfq->sf = sf; in s390_cpumsf_alloc_queue()
779 if (sf->use_logfile) { in s390_cpumsf_alloc_queue()
783 rc = (sf->logdir) in s390_cpumsf_alloc_queue()
785 sf->logdir, queue_nr) in s390_cpumsf_alloc_queue()
792 sf->use_logfile = false; in s390_cpumsf_alloc_queue()
799 static int s390_cpumsf_setup_queue(struct s390_cpumsf *sf, in s390_cpumsf_setup_queue() argument
809 sfq = s390_cpumsf_alloc_queue(sf, queue_nr); in s390_cpumsf_setup_queue()
817 return auxtrace_heap__add(&sf->heap, queue_nr, ts); in s390_cpumsf_setup_queue()
820 static int s390_cpumsf_setup_queues(struct s390_cpumsf *sf, u64 ts) in s390_cpumsf_setup_queues() argument
825 for (i = 0; i < sf->queues.nr_queues; i++) { in s390_cpumsf_setup_queues()
826 ret = s390_cpumsf_setup_queue(sf, &sf->queues.queue_array[i], in s390_cpumsf_setup_queues()
834 static int s390_cpumsf_update_queues(struct s390_cpumsf *sf, u64 ts) in s390_cpumsf_update_queues() argument
836 if (!sf->queues.new_data) in s390_cpumsf_update_queues()
839 sf->queues.new_data = false; in s390_cpumsf_update_queues()
840 return s390_cpumsf_setup_queues(sf, ts); in s390_cpumsf_update_queues()
843 static int s390_cpumsf_process_queues(struct s390_cpumsf *sf, u64 timestamp) in s390_cpumsf_process_queues() argument
853 if (!sf->heap.heap_cnt) in s390_cpumsf_process_queues()
856 if (sf->heap.heap_array[0].ordinal >= timestamp) in s390_cpumsf_process_queues()
859 queue_nr = sf->heap.heap_array[0].queue_nr; in s390_cpumsf_process_queues()
860 queue = &sf->queues.queue_array[queue_nr]; in s390_cpumsf_process_queues()
863 auxtrace_heap__pop(&sf->heap); in s390_cpumsf_process_queues()
864 if (sf->heap.heap_cnt) { in s390_cpumsf_process_queues()
865 ts = sf->heap.heap_array[0].ordinal + 1; in s390_cpumsf_process_queues()
874 auxtrace_heap__add(&sf->heap, queue_nr, ts); in s390_cpumsf_process_queues()
878 ret = auxtrace_heap__add(&sf->heap, queue_nr, ts); in s390_cpumsf_process_queues()
886 static int s390_cpumsf_synth_error(struct s390_cpumsf *sf, int code, int cpu, in s390_cpumsf_synth_error() argument
897 err = perf_session__deliver_synth_event(sf->session, &event, NULL); in s390_cpumsf_synth_error()
904 static int s390_cpumsf_lost(struct s390_cpumsf *sf, struct perf_sample *sample) in s390_cpumsf_lost() argument
906 return s390_cpumsf_synth_error(sf, 1, sample->cpu, in s390_cpumsf_lost()
917 struct s390_cpumsf *sf = container_of(session->auxtrace, in s390_cpumsf_process_event() local
939 err = s390_cpumcf_dumpctr(sf, sample); in s390_cpumsf_process_event()
945 return s390_cpumsf_lost(sf, sample); in s390_cpumsf_process_event()
948 err = s390_cpumsf_update_queues(sf, timestamp); in s390_cpumsf_process_event()
950 err = s390_cpumsf_process_queues(sf, timestamp); in s390_cpumsf_process_event()
965 struct s390_cpumsf *sf = container_of(session->auxtrace, in s390_cpumsf_process_auxtrace_event() local
974 if (sf->data_queued) in s390_cpumsf_process_auxtrace_event()
985 err = auxtrace_queues__add_event(&sf->queues, session, event, in s390_cpumsf_process_auxtrace_event()
993 s390_cpumsf_dump_event(sf, buffer->data, in s390_cpumsf_process_auxtrace_event()
1013 struct s390_cpumsf *sf = container_of(session->auxtrace, in s390_cpumsf_free_queues() local
1016 struct auxtrace_queues *queues = &sf->queues; in s390_cpumsf_free_queues()
1040 struct s390_cpumsf *sf = container_of(session->auxtrace, in s390_cpumsf_free() local
1044 auxtrace_heap__free(&sf->heap); in s390_cpumsf_free()
1047 zfree(&sf->logdir); in s390_cpumsf_free()
1048 free(sf); in s390_cpumsf_free()
1097 struct s390_cpumsf *sf = cb; in s390_cpumsf__config() local
1103 sf->logdir = strdup(value); in s390_cpumsf__config()
1104 if (sf->logdir == NULL) { in s390_cpumsf__config()
1109 rc = stat(sf->logdir, &stbuf); in s390_cpumsf__config()
1113 zfree(&sf->logdir); in s390_cpumsf__config()
1122 struct s390_cpumsf *sf; in s390_cpumsf_process_auxtrace_info() local
1128 sf = zalloc(sizeof(struct s390_cpumsf)); in s390_cpumsf_process_auxtrace_info()
1129 if (sf == NULL) in s390_cpumsf_process_auxtrace_info()
1136 sf->use_logfile = session->itrace_synth_opts->log; in s390_cpumsf_process_auxtrace_info()
1137 if (sf->use_logfile) in s390_cpumsf_process_auxtrace_info()
1138 perf_config(s390_cpumsf__config, sf); in s390_cpumsf_process_auxtrace_info()
1140 err = auxtrace_queues__init(&sf->queues); in s390_cpumsf_process_auxtrace_info()
1144 sf->session = session; in s390_cpumsf_process_auxtrace_info()
1145 sf->machine = &session->machines.host; /* No kvm support */ in s390_cpumsf_process_auxtrace_info()
1146 sf->auxtrace_type = auxtrace_info->type; in s390_cpumsf_process_auxtrace_info()
1147 sf->pmu_type = PERF_TYPE_RAW; in s390_cpumsf_process_auxtrace_info()
1148 sf->machine_type = s390_cpumsf_get_type(session->evlist->env->cpuid); in s390_cpumsf_process_auxtrace_info()
1150 sf->auxtrace.process_event = s390_cpumsf_process_event; in s390_cpumsf_process_auxtrace_info()
1151 sf->auxtrace.process_auxtrace_event = s390_cpumsf_process_auxtrace_event; in s390_cpumsf_process_auxtrace_info()
1152 sf->auxtrace.flush_events = s390_cpumsf_flush; in s390_cpumsf_process_auxtrace_info()
1153 sf->auxtrace.free_events = s390_cpumsf_free_events; in s390_cpumsf_process_auxtrace_info()
1154 sf->auxtrace.free = s390_cpumsf_free; in s390_cpumsf_process_auxtrace_info()
1155 sf->auxtrace.evsel_is_auxtrace = s390_cpumsf_evsel_is_auxtrace; in s390_cpumsf_process_auxtrace_info()
1156 session->auxtrace = &sf->auxtrace; in s390_cpumsf_process_auxtrace_info()
1161 err = auxtrace_queues__process_index(&sf->queues, session); in s390_cpumsf_process_auxtrace_info()
1165 if (sf->queues.populated) in s390_cpumsf_process_auxtrace_info()
1166 sf->data_queued = true; in s390_cpumsf_process_auxtrace_info()
1171 auxtrace_queues__free(&sf->queues); in s390_cpumsf_process_auxtrace_info()
1174 zfree(&sf->logdir); in s390_cpumsf_process_auxtrace_info()
1175 free(sf); in s390_cpumsf_process_auxtrace_info()