Lines Matching refs:dpp
136 struct devpath *dpp; member
245 struct devpath *dpp; member
501 static inline void pdc_dr_update(struct devpath *dpp, int cpu, int data_read) in pdc_dr_update() argument
503 dpp->stats[cpu].data_read += data_read; in pdc_dr_update()
506 static inline void pdc_nev_update(struct devpath *dpp, int cpu, int nevents) in pdc_nev_update() argument
508 dpp->stats[cpu].nevents += nevents; in pdc_nev_update()
611 static void dpp_free(struct devpath *dpp) in dpp_free() argument
613 if (dpp->stats) in dpp_free()
614 free(dpp->stats); in dpp_free()
615 if (dpp->ios) in dpp_free()
616 free(dpp->ios); in dpp_free()
617 if (dpp->path) in dpp_free()
618 free(dpp->path); in dpp_free()
619 if (dpp->buts_name) in dpp_free()
620 free(dpp->buts_name); in dpp_free()
621 free(dpp); in dpp_free()
934 struct devpath *dpp = list_entry(p, struct devpath, head); in net_send_drops() local
936 net_send_close(fd, dpp->buts_name, dpp->drops); in net_send_drops()
1076 struct devpath *dpp = list_entry(p, struct devpath, head); in setup_buts() local
1083 if (ioctl(dpp->fd, BLKTRACESETUP, &buts) >= 0) { in setup_buts()
1084 dpp->ncpus = max_cpus; in setup_buts()
1085 dpp->buts_name = strdup(buts.name); in setup_buts()
1086 if (dpp->stats) in setup_buts()
1087 free(dpp->stats); in setup_buts()
1088 dpp->stats = calloc(dpp->ncpus, sizeof(*dpp->stats)); in setup_buts()
1089 memset(dpp->stats, 0, dpp->ncpus * sizeof(*dpp->stats)); in setup_buts()
1092 dpp->path, errno, strerror(errno)); in setup_buts()
1105 struct devpath *dpp = list_entry(p, struct devpath, head); in start_buts() local
1107 if (ioctl(dpp->fd, BLKTRACESTART) < 0) { in start_buts()
1109 dpp->path, errno, strerror(errno)); in start_buts()
1114 static int get_drops(struct devpath *dpp) in get_drops() argument
1120 dpp->buts_name); in get_drops()
1147 struct devpath *dpp = list_entry(p, struct devpath, head); in get_all_drops() local
1149 dpp->drops = get_drops(dpp); in get_all_drops()
1162 tbp->dpp = NULL; /* Will be set when tbp is added */ in alloc_trace_buf()
1167 static void free_tracer_heads(struct devpath *dpp) in free_tracer_heads() argument
1172 for (cpu = 0, hd = dpp->heads; cpu < max_cpus; cpu++, hd++) { in free_tracer_heads()
1178 free(dpp->heads); in free_tracer_heads()
1192 struct devpath *dpp = list_entry(p, struct devpath, head); in setup_tracer_devpaths() local
1194 dpp->heads = calloc(max_cpus, sizeof(struct tracer_devpath_head)); in setup_tracer_devpaths()
1195 for (cpu = 0, hd = dpp->heads; cpu < max_cpus; cpu++, hd++) { in setup_tracer_devpaths()
1205 static inline void add_trace_buf(struct devpath *dpp, int cpu, in add_trace_buf() argument
1209 struct tracer_devpath_head *hd = &dpp->heads[cpu]; in add_trace_buf()
1211 tbp->dpp = dpp; in add_trace_buf()
1249 struct devpath *dpp; in add_devpath() local
1270 dpp = malloc(sizeof(*dpp)); in add_devpath()
1271 memset(dpp, 0, sizeof(*dpp)); in add_devpath()
1272 dpp->path = strdup(path); in add_devpath()
1273 dpp->fd = fd; in add_devpath()
1275 list_add_tail(&dpp->head, &devpaths); in add_devpath()
1285 struct devpath *dpp = list_entry(p, struct devpath, head); in rel_devpaths() local
1287 list_del(&dpp->head); in rel_devpaths()
1288 __stop_trace(dpp->fd); in rel_devpaths()
1289 close(dpp->fd); in rel_devpaths()
1291 if (dpp->heads) in rel_devpaths()
1292 free_tracer_heads(dpp); in rel_devpaths()
1294 dpp_free(dpp); in rel_devpaths()
1302 struct devpath *dpp = tbp->dpp; in flush_subbuf_net() local
1304 if (net_send_header(fd, tbp->cpu, dpp->buts_name, tbp->len)) in flush_subbuf_net()
1405 pdc_nev_update(tbp->dpp, tbp->cpu, nevents); in handle_list_file()
1440 struct devpath *dpp = list_entry(p, struct devpath, head); in __process_trace_bufs() local
1441 struct tracer_devpath_head *hd = dpp->heads; in __process_trace_bufs()
1503 struct devpath *dpp = iop->dpp; in net_sendfile_data() local
1505 if (net_send_header(iop->ofd, tp->cpu, dpp->buts_name, iop->ready)) in net_sendfile_data()
1559 iop->dpp->path, (int)size, errno, in set_vbuf()
1580 gmtime(&iop->dpp->cl_connect_time)); in iop_open()
1586 iop->dpp->buts_name, cpu)) in iop_open()
1633 iop->dpp->drops = get_drops(iop->dpp); in close_ios()
1640 struct devpath *dpp = iop->dpp; in close_ios() local
1642 net_send_close(iop->ofd, dpp->buts_name, dpp->drops); in close_ios()
1667 struct devpath *dpp = list_entry(p, struct devpath, head); in open_ios() local
1669 iop->dpp = dpp; in open_ios()
1672 debugfs_path, dpp->buts_name, tp->cpu); in open_ios()
1692 net_send_open(iop->ofd, tp->cpu, dpp->buts_name); in open_ios()
1701 net_send_open(cl_fds[tp->cpu], tp->cpu, dpp->buts_name); in open_ios()
1737 pdc_dr_update(iop->dpp, tp->cpu, ret); in handle_pfds_file()
1777 pdc_dr_update(iop->dpp, tp->cpu, in handle_pfds_netclient()
1806 pdc_dr_update(iop->dpp, tp->cpu, tbp->len); in handle_pfds_entries()
1807 add_trace_buf(iop->dpp, tp->cpu, &tbp); in handle_pfds_entries()
1908 struct devpath *dpp = list_entry(p, struct devpath, head); in create_output_files() local
1910 if (fill_ofname(fname, sizeof(fname), NULL, dpp->buts_name, in create_output_files()
1962 struct devpath *dpp = list_entry(p, struct devpath, head); in stop_tracers() local
1963 (void)ioctl(dpp->fd, BLKTRACESTOP); in stop_tracers()
2048 struct devpath *dpp = list_entry(p, struct devpath, head); in show_stats() local
2052 dpp->ch->hostname, dpp->buts_name); in show_stats()
2057 fprintf(ofp, "=== %s ===\n", dpp->buts_name); in show_stats()
2058 for (cpu = 0, sp = dpp->stats; cpu < dpp->ncpus; cpu++, sp++) { in show_stats()
2077 dpp->drops, (data_read + 1024) >> 10); in show_stats()
2079 total_drops += dpp->drops; in show_stats()
2080 total_events += (nevents + dpp->drops); in show_stats()
2340 static void device_done(struct devpath *dpp, int ncpus) in device_done() argument
2345 for (cpu = 0, iop = dpp->ios; cpu < ncpus; cpu++, iop++) in device_done()
2348 list_del(&dpp->head); in device_done()
2349 dpp_free(dpp); in device_done()
2358 struct devpath *dpp = list_entry(p, struct devpath, head); in net_ch_remove() local
2359 device_done(dpp, ncpus); in net_ch_remove()
2404 struct devpath *dpp; in nc_add_dpp() local
2406 dpp = malloc(sizeof(*dpp)); in nc_add_dpp()
2407 memset(dpp, 0, sizeof(*dpp)); in nc_add_dpp()
2409 dpp->buts_name = strdup(bnh->buts_name); in nc_add_dpp()
2410 dpp->path = strdup(bnh->buts_name); in nc_add_dpp()
2411 dpp->fd = -1; in nc_add_dpp()
2412 dpp->ch = nc->ch; in nc_add_dpp()
2413 dpp->cl_id = bnh->cl_id; in nc_add_dpp()
2414 dpp->cl_connect_time = connect_time; in nc_add_dpp()
2415 dpp->ncpus = nc->ncpus; in nc_add_dpp()
2416 dpp->stats = calloc(dpp->ncpus, sizeof(*dpp->stats)); in nc_add_dpp()
2417 memset(dpp->stats, 0, dpp->ncpus * sizeof(*dpp->stats)); in nc_add_dpp()
2419 list_add_tail(&dpp->head, &nc->ch->devpaths); in nc_add_dpp()
2422 dpp->ios = calloc(nc->ncpus, sizeof(*iop)); in nc_add_dpp()
2423 memset(dpp->ios, 0, ndevs * sizeof(*iop)); in nc_add_dpp()
2425 for (cpu = 0, iop = dpp->ios; cpu < nc->ncpus; cpu++, iop++) { in nc_add_dpp()
2426 iop->dpp = dpp; in nc_add_dpp()
2434 return dpp; in nc_add_dpp()
2441 close_iop(&dpp->ios[cpu--]); in nc_add_dpp()
2442 dpp_free(dpp); in nc_add_dpp()
2454 struct devpath *dpp = list_entry(p, struct devpath, head); in nc_find_dpp() local
2456 if (!strcmp(dpp->buts_name, bnh->buts_name)) in nc_find_dpp()
2457 return dpp; in nc_find_dpp()
2459 if (dpp->cl_id == bnh->cl_id) in nc_find_dpp()
2460 connect_time = dpp->cl_connect_time; in nc_find_dpp()
2466 static void net_client_read_data(struct cl_conn *nc, struct devpath *dpp, in net_client_read_data() argument
2470 struct io_info *iop = &dpp->ios[bnh->cpu]; in net_client_read_data()
2481 pdc_dr_update(dpp, bnh->cpu, ret); in net_client_read_data()
2495 struct devpath *dpp; in net_client_data() local
2536 dpp = nc_find_dpp(nc, &bnh); in net_client_data()
2541 ack_open_close(nc->fd, dpp->buts_name); in net_client_data()
2547 dpp->drops = bnh.cpu; in net_client_data()
2549 ack_open_close(nc->fd, dpp->buts_name); in net_client_data()
2556 net_client_read_data(nc, dpp, &bnh); in net_client_data()
2817 struct devpath *dpp; in main() local
2821 dpp = list_entry(p, struct devpath, head); in main()
2822 if (__stop_trace(dpp->fd)) { in main()
2825 dpp->path, errno, strerror(errno)); in main()