Lines Matching refs:bnh
924 static int net_get_header(struct cl_conn *nc, struct blktrace_net_hdr *bnh) in net_get_header() argument
930 bytes_read = __net_recv_data(nc->fd, bnh, sizeof(*bnh)); in net_get_header()
933 if (bytes_read == sizeof(*bnh)) in net_get_header()
2297 struct blktrace_net_hdr *bnh, in nc_add_dpp() argument
2307 dpp->buts_name = strdup(bnh->buts_name); in nc_add_dpp()
2308 dpp->path = strdup(bnh->buts_name); in nc_add_dpp()
2311 dpp->cl_id = bnh->cl_id; in nc_add_dpp()
2346 struct blktrace_net_hdr *bnh) in nc_find_dpp() argument
2354 if (!strcmp(dpp->buts_name, bnh->buts_name)) in nc_find_dpp()
2357 if (dpp->cl_id == bnh->cl_id) in nc_find_dpp()
2361 return nc_add_dpp(nc, bnh, connect_time); in nc_find_dpp()
2365 struct blktrace_net_hdr *bnh) in net_client_read_data() argument
2368 struct io_info *iop = &dpp->ios[bnh->cpu]; in net_client_read_data()
2371 if (setup_mmap(iop->ofd, bnh->len, &iop->mmap_info)) { in net_client_read_data()
2377 ret = net_recv_data(nc->fd, mip->fs_buf + mip->fs_off, bnh->len); in net_client_read_data()
2379 pdc_dr_update(dpp, bnh->cpu, ret); in net_client_read_data()
2394 struct blktrace_net_hdr bnh; in net_client_data() local
2396 ret = net_get_header(nc, &bnh); in net_client_data()
2405 if (data_is_native == -1 && check_data_endianness(bnh.magic)) { in net_client_data()
2411 bnh.magic = be32_to_cpu(bnh.magic); in net_client_data()
2412 bnh.cpu = be32_to_cpu(bnh.cpu); in net_client_data()
2413 bnh.max_cpus = be32_to_cpu(bnh.max_cpus); in net_client_data()
2414 bnh.len = be32_to_cpu(bnh.len); in net_client_data()
2415 bnh.cl_id = be32_to_cpu(bnh.cl_id); in net_client_data()
2416 bnh.buf_size = be32_to_cpu(bnh.buf_size); in net_client_data()
2417 bnh.buf_nr = be32_to_cpu(bnh.buf_nr); in net_client_data()
2418 bnh.page_size = be32_to_cpu(bnh.page_size); in net_client_data()
2421 if ((bnh.magic & 0xffffff00) != BLK_IO_TRACE_MAGIC) { in net_client_data()
2428 nc->ncpus = bnh.max_cpus; in net_client_data()
2434 dpp = nc_find_dpp(nc, &bnh); in net_client_data()
2435 if (bnh.len == 0) { in net_client_data()
2441 } else if (bnh.len == 1) { in net_client_data()
2445 dpp->drops = bnh.cpu; in net_client_data()
2454 net_client_read_data(nc, dpp, &bnh); in net_client_data()