946 static int net_get_header(struct cl_conn *nc, struct blktrace_net_hdr *bnh)  in net_get_header()  argument
952 	bytes_read = __net_recv_data(nc->fd, bnh, sizeof(*bnh));  in net_get_header()
955 	if (bytes_read == sizeof(*bnh))  in net_get_header()
2399 				  struct blktrace_net_hdr *bnh,  in nc_add_dpp()  argument
2409 	dpp->buts_name = strdup(bnh->buts_name);  in nc_add_dpp()
2410 	dpp->path = strdup(bnh->buts_name);  in nc_add_dpp()
2413 	dpp->cl_id = bnh->cl_id;  in nc_add_dpp()
2448 				   struct blktrace_net_hdr *bnh)  in nc_find_dpp()  argument
2456 		if (!strcmp(dpp->buts_name, bnh->buts_name))  in nc_find_dpp()
2459 		if (dpp->cl_id == bnh->cl_id)  in nc_find_dpp()
2463 	return nc_add_dpp(nc, bnh, connect_time);  in nc_find_dpp()
2467 				 struct blktrace_net_hdr *bnh)  in net_client_read_data()  argument
2470 	struct io_info *iop = &dpp->ios[bnh->cpu];  in net_client_read_data()
2473 	if (setup_mmap(iop->ofd, bnh->len, &iop->mmap_info, NULL)) {  in net_client_read_data()
2479 	ret = net_recv_data(nc->fd, mip->fs_buf + mip->fs_off, bnh->len);  in net_client_read_data()
2481 		pdc_dr_update(dpp, bnh->cpu, ret);  in net_client_read_data()
2496 	struct blktrace_net_hdr bnh;  in net_client_data()  local
2498 	ret = net_get_header(nc, &bnh);  in net_client_data()
2507 	if (data_is_native == -1 && check_data_endianness(bnh.magic)) {  in net_client_data()
2513 		bnh.magic = be32_to_cpu(bnh.magic);  in net_client_data()
2514 		bnh.cpu = be32_to_cpu(bnh.cpu);  in net_client_data()
2515 		bnh.max_cpus = be32_to_cpu(bnh.max_cpus);  in net_client_data()
2516 		bnh.len = be32_to_cpu(bnh.len);  in net_client_data()
2517 		bnh.cl_id = be32_to_cpu(bnh.cl_id);  in net_client_data()
2518 		bnh.buf_size = be32_to_cpu(bnh.buf_size);  in net_client_data()
2519 		bnh.buf_nr = be32_to_cpu(bnh.buf_nr);  in net_client_data()
2520 		bnh.page_size = be32_to_cpu(bnh.page_size);  in net_client_data()
2523 	if ((bnh.magic & 0xffffff00) != BLK_IO_TRACE_MAGIC) {  in net_client_data()
2530 		nc->ncpus = bnh.max_cpus;  in net_client_data()
2536 	dpp = nc_find_dpp(nc, &bnh);  in net_client_data()
2537 	if (bnh.len == 0) {  in net_client_data()
2543 	} else if (bnh.len == 1) {  in net_client_data()
2547 		dpp->drops = bnh.cpu;  in net_client_data()
2556 		net_client_read_data(nc, dpp, &bnh);  in net_client_data()