248 	struct cl_conn *nc;	/* Server network connection */  member
946 static int net_get_header(struct cl_conn *nc, struct blktrace_net_hdr *bnh)  in net_get_header()  argument
949 	int fl = fcntl(nc->fd, F_GETFL);  in net_get_header()
951 	fcntl(nc->fd, F_SETFL, fl | O_NONBLOCK);  in net_get_header()
952 	bytes_read = __net_recv_data(nc->fd, bnh, sizeof(*bnh));  in net_get_header()
953 	fcntl(nc->fd, F_SETFL, fl & ~O_NONBLOCK);  in net_get_header()
1574 		struct cl_conn *nc = iop->nc;  in iop_open()  local
1578 			       nc->ch->hostname);  in iop_open()
2270 	struct cl_conn *nc;  in ch_add_connection()  local
2272 	nc = malloc(sizeof(*nc));  in ch_add_connection()
2273 	memset(nc, 0, sizeof(*nc));  in ch_add_connection()
2275 	time(&nc->connect_time);  in ch_add_connection()
2276 	nc->ch = ch;  in ch_add_connection()
2277 	nc->fd = fd;  in ch_add_connection()
2278 	nc->ncpus = -1;  in ch_add_connection()
2280 	list_add_tail(&nc->ch_head, &ch->conn_list);  in ch_add_connection()
2283 	list_add_tail(&nc->ns_head, &ns->conn_list);  in ch_add_connection()
2289 			      struct cl_conn *nc)  in ch_rem_connection()  argument
2291 	net_close_connection(&nc->fd);  in ch_rem_connection()
2293 	list_del(&nc->ch_head);  in ch_rem_connection()
2296 	list_del(&nc->ns_head);  in ch_rem_connection()
2300 	free(nc);  in ch_rem_connection()
2363 		struct cl_conn *nc = list_entry(p, struct cl_conn, ch_head);  in net_ch_remove()  local
2365 		ch_rem_connection(ns, ch, nc);  in net_ch_remove()
2398 static struct devpath *nc_add_dpp(struct cl_conn *nc,  in nc_add_dpp()  argument
2412 	dpp->ch = nc->ch;  in nc_add_dpp()
2415 	dpp->ncpus = nc->ncpus;  in nc_add_dpp()
2419 	list_add_tail(&dpp->head, &nc->ch->devpaths);  in nc_add_dpp()
2420 	nc->ch->ndevs++;  in nc_add_dpp()
2422 	dpp->ios = calloc(nc->ncpus, sizeof(*iop));  in nc_add_dpp()
2425 	for (cpu = 0, iop = dpp->ios; cpu < nc->ncpus; cpu++, iop++) {  in nc_add_dpp()
2427 		iop->nc = nc;  in nc_add_dpp()
2447 static struct devpath *nc_find_dpp(struct cl_conn *nc,  in nc_find_dpp()  argument
2451 	time_t connect_time = nc->connect_time;  in nc_find_dpp()
2453 	__list_for_each(p, &nc->ch->devpaths) {  in nc_find_dpp()
2463 	return nc_add_dpp(nc, bnh, 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
2475 			nc->ch->hostname, nc->fd);  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()
2492 static int net_client_data(struct cl_conn *nc)  in net_client_data()  argument
2498 	ret = net_get_header(nc, &bnh);  in net_client_data()
2503 		fprintf(stderr, "ncd(%d): header read failed\n", nc->fd);  in net_client_data()
2508 		fprintf(stderr, "ncd(%d): received data is bad\n", nc->fd);  in net_client_data()
2525 			nc->ch->hostname, nc->fd);  in net_client_data()
2529 	if (nc->ncpus == -1)  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()
2541 		ack_open_close(nc->fd, dpp->buts_name);  in net_client_data()
2542 		nc->ch->cl_opens++;  in net_client_data()
2549 		ack_open_close(nc->fd, dpp->buts_name);  in net_client_data()
2550 		if (--nc->ch->cl_opens == 0) {  in net_client_data()
2551 			show_stats(&nc->ch->devpaths);  in net_client_data()
2552 			net_ch_remove(nc->ch, nc->ncpus);  in net_client_data()
2556 		net_client_read_data(nc, dpp, &bnh);  in net_client_data()
2563 	struct cl_conn *nc;  in handle_client_data()  local
2570 			nc = list_entry(p, struct cl_conn, ns_head);  in handle_client_data()
2572 			if (net_client_data(nc) || --events == 0)  in handle_client_data()
2589 		struct cl_conn *nc = list_entry(p, struct cl_conn, ns_head);  in net_setup_pfds()  local
2591 		pfd->fd = nc->fd;  in net_setup_pfds()