Lines Matching refs:sf
182 struct s390_cpumsf *sf;
195 static int s390_cpumcf_dumpctr(struct s390_cpumsf *sf,
202 if (!sf->use_logfile || sf->queues.nr_queues <= sample->cpu)
205 q = &sf->queues.queue_array[sample->cpu];
213 rc = (sf->logdir)
215 sf->logdir, sample->cpu)
432 static void s390_cpumsf_dump(struct s390_cpumsf *sf,
445 if (!s390_cpumsf_validate(sf->machine_type, buf, len, &bsdes,
449 len, sf->machine_type, bsdes, dsdes);
493 static void s390_cpumsf_dump_event(struct s390_cpumsf *sf, unsigned char *buf,
497 s390_cpumsf_dump(sf, buf, len);
538 if (perf_session__deliver_synth_event(sfq->sf->session, &event,
601 struct s390_cpumsf *sf = sfq->sf;
610 if (!s390_cpumsf_validate(sf->machine_type, buf, len, &bsdes,
700 queue = &sfq->sf->queues.queue_array[sfq->queue_nr];
730 int fd = perf_data__fd(sfq->sf->session->data);
767 s390_cpumsf_alloc_queue(struct s390_cpumsf *sf, unsigned int queue_nr)
775 sfq->sf = sf;
778 if (sf->use_logfile) {
782 rc = (sf->logdir)
784 sf->logdir, queue_nr)
791 sf->use_logfile = false;
798 static int s390_cpumsf_setup_queue(struct s390_cpumsf *sf,
808 sfq = s390_cpumsf_alloc_queue(sf, queue_nr);
816 return auxtrace_heap__add(&sf->heap, queue_nr, ts);
819 static int s390_cpumsf_setup_queues(struct s390_cpumsf *sf, u64 ts)
824 for (i = 0; i < sf->queues.nr_queues; i++) {
825 ret = s390_cpumsf_setup_queue(sf, &sf->queues.queue_array[i],
833 static int s390_cpumsf_update_queues(struct s390_cpumsf *sf, u64 ts)
835 if (!sf->queues.new_data)
838 sf->queues.new_data = false;
839 return s390_cpumsf_setup_queues(sf, ts);
842 static int s390_cpumsf_process_queues(struct s390_cpumsf *sf, u64 timestamp)
852 if (!sf->heap.heap_cnt)
855 if (sf->heap.heap_array[0].ordinal >= timestamp)
858 queue_nr = sf->heap.heap_array[0].queue_nr;
859 queue = &sf->queues.queue_array[queue_nr];
862 auxtrace_heap__pop(&sf->heap);
863 if (sf->heap.heap_cnt) {
864 ts = sf->heap.heap_array[0].ordinal + 1;
873 auxtrace_heap__add(&sf->heap, queue_nr, ts);
877 ret = auxtrace_heap__add(&sf->heap, queue_nr, ts);
885 static int s390_cpumsf_synth_error(struct s390_cpumsf *sf, int code, int cpu,
896 err = perf_session__deliver_synth_event(sf->session, &event, NULL);
903 static int s390_cpumsf_lost(struct s390_cpumsf *sf, struct perf_sample *sample)
905 return s390_cpumsf_synth_error(sf, 1, sample->cpu,
916 struct s390_cpumsf *sf = container_of(session->auxtrace,
938 err = s390_cpumcf_dumpctr(sf, sample);
944 return s390_cpumsf_lost(sf, sample);
947 err = s390_cpumsf_update_queues(sf, timestamp);
949 err = s390_cpumsf_process_queues(sf, timestamp);
964 struct s390_cpumsf *sf = container_of(session->auxtrace,
973 if (sf->data_queued)
984 err = auxtrace_queues__add_event(&sf->queues, session, event,
992 s390_cpumsf_dump_event(sf, buffer->data,
1012 struct s390_cpumsf *sf = container_of(session->auxtrace,
1015 struct auxtrace_queues *queues = &sf->queues;
1039 struct s390_cpumsf *sf = container_of(session->auxtrace,
1043 auxtrace_heap__free(&sf->heap);
1046 zfree(&sf->logdir);
1047 free(sf);
1096 struct s390_cpumsf *sf = cb;
1102 sf->logdir = strdup(value);
1103 if (sf->logdir == NULL) {
1108 rc = stat(sf->logdir, &stbuf);
1112 zfree(&sf->logdir);
1121 struct s390_cpumsf *sf;
1127 sf = zalloc(sizeof(struct s390_cpumsf));
1128 if (sf == NULL)
1135 sf->use_logfile = session->itrace_synth_opts->log;
1136 if (sf->use_logfile)
1137 perf_config(s390_cpumsf__config, sf);
1139 err = auxtrace_queues__init(&sf->queues);
1143 sf->session = session;
1144 sf->machine = &session->machines.host; /* No kvm support */
1145 sf->auxtrace_type = auxtrace_info->type;
1146 sf->pmu_type = PERF_TYPE_RAW;
1147 sf->machine_type = s390_cpumsf_get_type(session->evlist->env->cpuid);
1149 sf->auxtrace.process_event = s390_cpumsf_process_event;
1150 sf->auxtrace.process_auxtrace_event = s390_cpumsf_process_auxtrace_event;
1151 sf->auxtrace.flush_events = s390_cpumsf_flush;
1152 sf->auxtrace.free_events = s390_cpumsf_free_events;
1153 sf->auxtrace.free = s390_cpumsf_free;
1154 sf->auxtrace.evsel_is_auxtrace = s390_cpumsf_evsel_is_auxtrace;
1155 session->auxtrace = &sf->auxtrace;
1160 err = auxtrace_queues__process_index(&sf->queues, session);
1164 if (sf->queues.populated)
1165 sf->data_queued = true;
1170 auxtrace_queues__free(&sf->queues);
1173 zfree(&sf->logdir);
1174 free(sf);