Lines Matching refs:dpp
136 struct devpath *dpp; member
245 struct devpath *dpp; member
484 static inline void pdc_dr_update(struct devpath *dpp, int cpu, int data_read) in pdc_dr_update() argument
486 dpp->stats[cpu].data_read += data_read; in pdc_dr_update()
489 static inline void pdc_nev_update(struct devpath *dpp, int cpu, int nevents) in pdc_nev_update() argument
491 dpp->stats[cpu].nevents += nevents; in pdc_nev_update()
594 static void dpp_free(struct devpath *dpp) in dpp_free() argument
596 if (dpp->stats) in dpp_free()
597 free(dpp->stats); in dpp_free()
598 if (dpp->ios) in dpp_free()
599 free(dpp->ios); in dpp_free()
600 if (dpp->path) in dpp_free()
601 free(dpp->path); in dpp_free()
602 if (dpp->buts_name) in dpp_free()
603 free(dpp->buts_name); in dpp_free()
604 free(dpp); in dpp_free()
912 struct devpath *dpp = list_entry(p, struct devpath, head); in net_send_drops() local
914 net_send_close(fd, dpp->buts_name, dpp->drops); in net_send_drops()
1045 struct devpath *dpp = list_entry(p, struct devpath, head); in setup_buts() local
1051 if (ioctl(dpp->fd, BLKTRACESETUP, &buts) >= 0) { in setup_buts()
1052 dpp->ncpus = ncpus; in setup_buts()
1053 dpp->buts_name = strdup(buts.name); in setup_buts()
1054 if (dpp->stats) in setup_buts()
1055 free(dpp->stats); in setup_buts()
1056 dpp->stats = calloc(dpp->ncpus, sizeof(*dpp->stats)); in setup_buts()
1057 memset(dpp->stats, 0, dpp->ncpus * sizeof(*dpp->stats)); in setup_buts()
1060 dpp->path, errno, strerror(errno)); in setup_buts()
1069 struct devpath *dpp = list_entry(p, struct devpath, head); in start_buts() local
1071 if (ioctl(dpp->fd, BLKTRACESTART) < 0) { in start_buts()
1073 dpp->path, errno, strerror(errno)); in start_buts()
1078 static int get_drops(struct devpath *dpp) in get_drops() argument
1084 dpp->buts_name); in get_drops()
1111 struct devpath *dpp = list_entry(p, struct devpath, head); in get_all_drops() local
1113 dpp->drops = get_drops(dpp); in get_all_drops()
1126 tbp->dpp = NULL; /* Will be set when tbp is added */ in alloc_trace_buf()
1131 static void free_tracer_heads(struct devpath *dpp) in free_tracer_heads() argument
1136 for (cpu = 0, hd = dpp->heads; cpu < ncpus; cpu++, hd++) { in free_tracer_heads()
1142 free(dpp->heads); in free_tracer_heads()
1156 struct devpath *dpp = list_entry(p, struct devpath, head); in setup_tracer_devpaths() local
1158 dpp->heads = calloc(ncpus, sizeof(struct tracer_devpath_head)); in setup_tracer_devpaths()
1159 for (cpu = 0, hd = dpp->heads; cpu < ncpus; cpu++, hd++) { in setup_tracer_devpaths()
1169 static inline void add_trace_buf(struct devpath *dpp, int cpu, in add_trace_buf() argument
1173 struct tracer_devpath_head *hd = &dpp->heads[cpu]; in add_trace_buf()
1175 tbp->dpp = dpp; in add_trace_buf()
1213 struct devpath *dpp; in add_devpath() local
1225 dpp = malloc(sizeof(*dpp)); in add_devpath()
1226 memset(dpp, 0, sizeof(*dpp)); in add_devpath()
1227 dpp->path = strdup(path); in add_devpath()
1228 dpp->fd = fd; in add_devpath()
1229 dpp->idx = ndevs++; in add_devpath()
1230 list_add_tail(&dpp->head, &devpaths); in add_devpath()
1240 struct devpath *dpp = list_entry(p, struct devpath, head); in rel_devpaths() local
1242 list_del(&dpp->head); in rel_devpaths()
1243 __stop_trace(dpp->fd); in rel_devpaths()
1244 close(dpp->fd); in rel_devpaths()
1246 if (dpp->heads) in rel_devpaths()
1247 free_tracer_heads(dpp); in rel_devpaths()
1249 dpp_free(dpp); in rel_devpaths()
1257 struct devpath *dpp = tbp->dpp; in flush_subbuf_net() local
1259 if (net_send_header(fd, tbp->cpu, dpp->buts_name, tbp->len)) in flush_subbuf_net()
1360 pdc_nev_update(tbp->dpp, tbp->cpu, nevents); in handle_list_file()
1395 struct devpath *dpp = list_entry(p, struct devpath, head); in __process_trace_bufs() local
1396 struct tracer_devpath_head *hd = dpp->heads; in __process_trace_bufs()
1458 struct devpath *dpp = iop->dpp; in net_sendfile_data() local
1460 if (net_send_header(iop->ofd, tp->cpu, dpp->buts_name, iop->ready)) in net_sendfile_data()
1481 gmtime(&iop->dpp->cl_connect_time)); in fill_ofname()
1509 iop->dpp->buts_name, cpu); in fill_ofname()
1519 iop->dpp->path, (int)size, errno, in set_vbuf()
1578 iop->dpp->drops = get_drops(iop->dpp); in close_ios()
1585 struct devpath *dpp = iop->dpp; in close_ios() local
1587 net_send_close(iop->ofd, dpp->buts_name, dpp->drops); in close_ios()
1612 struct devpath *dpp = list_entry(p, struct devpath, head); in open_ios() local
1614 iop->dpp = dpp; in open_ios()
1617 debugfs_path, dpp->buts_name, tp->cpu); in open_ios()
1637 net_send_open(iop->ofd, tp->cpu, dpp->buts_name); in open_ios()
1646 net_send_open(cl_fds[tp->cpu], tp->cpu, dpp->buts_name); in open_ios()
1682 pdc_dr_update(iop->dpp, tp->cpu, ret); in handle_pfds_file()
1723 pdc_dr_update(iop->dpp, tp->cpu, in handle_pfds_netclient()
1752 pdc_dr_update(iop->dpp, tp->cpu, tbp->len); in handle_pfds_entries()
1753 add_trace_buf(iop->dpp, tp->cpu, &tbp); in handle_pfds_entries()
1875 struct devpath *dpp = list_entry(p, struct devpath, head); in stop_tracers() local
1876 (void)ioctl(dpp->fd, BLKTRACESTOP); in stop_tracers()
1960 struct devpath *dpp = list_entry(p, struct devpath, head); in show_stats() local
1964 dpp->ch->hostname, dpp->buts_name); in show_stats()
1969 fprintf(ofp, "=== %s ===\n", dpp->buts_name); in show_stats()
1970 for (cpu = 0, sp = dpp->stats; cpu < dpp->ncpus; cpu++, sp++) { in show_stats()
1989 dpp->drops, (data_read + 1024) >> 10); in show_stats()
1991 total_drops += dpp->drops; in show_stats()
1992 total_events += (nevents + dpp->drops); in show_stats()
2238 static void device_done(struct devpath *dpp, int ncpus) in device_done() argument
2243 for (cpu = 0, iop = dpp->ios; cpu < ncpus; cpu++, iop++) in device_done()
2246 list_del(&dpp->head); in device_done()
2247 dpp_free(dpp); in device_done()
2256 struct devpath *dpp = list_entry(p, struct devpath, head); in net_ch_remove() local
2257 device_done(dpp, ncpus); in net_ch_remove()
2302 struct devpath *dpp; in nc_add_dpp() local
2304 dpp = malloc(sizeof(*dpp)); in nc_add_dpp()
2305 memset(dpp, 0, sizeof(*dpp)); in nc_add_dpp()
2307 dpp->buts_name = strdup(bnh->buts_name); in nc_add_dpp()
2308 dpp->path = strdup(bnh->buts_name); in nc_add_dpp()
2309 dpp->fd = -1; in nc_add_dpp()
2310 dpp->ch = nc->ch; in nc_add_dpp()
2311 dpp->cl_id = bnh->cl_id; in nc_add_dpp()
2312 dpp->cl_connect_time = connect_time; in nc_add_dpp()
2313 dpp->ncpus = nc->ncpus; in nc_add_dpp()
2314 dpp->stats = calloc(dpp->ncpus, sizeof(*dpp->stats)); in nc_add_dpp()
2315 memset(dpp->stats, 0, dpp->ncpus * sizeof(*dpp->stats)); in nc_add_dpp()
2317 list_add_tail(&dpp->head, &nc->ch->devpaths); in nc_add_dpp()
2320 dpp->ios = calloc(nc->ncpus, sizeof(*iop)); in nc_add_dpp()
2321 memset(dpp->ios, 0, ndevs * sizeof(*iop)); in nc_add_dpp()
2323 for (cpu = 0, iop = dpp->ios; cpu < nc->ncpus; cpu++, iop++) { in nc_add_dpp()
2324 iop->dpp = dpp; in nc_add_dpp()
2332 return dpp; in nc_add_dpp()
2339 close_iop(&dpp->ios[cpu--]); in nc_add_dpp()
2340 dpp_free(dpp); in nc_add_dpp()
2352 struct devpath *dpp = list_entry(p, struct devpath, head); in nc_find_dpp() local
2354 if (!strcmp(dpp->buts_name, bnh->buts_name)) in nc_find_dpp()
2355 return dpp; in nc_find_dpp()
2357 if (dpp->cl_id == bnh->cl_id) in nc_find_dpp()
2358 connect_time = dpp->cl_connect_time; in nc_find_dpp()
2364 static void net_client_read_data(struct cl_conn *nc, struct devpath *dpp, in net_client_read_data() argument
2368 struct io_info *iop = &dpp->ios[bnh->cpu]; in net_client_read_data()
2379 pdc_dr_update(dpp, bnh->cpu, ret); in net_client_read_data()
2393 struct devpath *dpp; in net_client_data() local
2434 dpp = nc_find_dpp(nc, &bnh); in net_client_data()
2439 ack_open_close(nc->fd, dpp->buts_name); in net_client_data()
2445 dpp->drops = bnh.cpu; in net_client_data()
2447 ack_open_close(nc->fd, dpp->buts_name); in net_client_data()
2454 net_client_read_data(nc, dpp, &bnh); in net_client_data()
2639 struct devpath *dpp; in main() local
2643 dpp = list_entry(p, struct devpath, head); in main()
2644 if (__stop_trace(dpp->fd)) { in main()
2647 dpp->path, errno, strerror(errno)); in main()