netfilter/ipvs/ip_vs_sync.c

1652 	struct ip_vs_sync_thread_data *tinfo = data;
1653 	struct netns_ipvs *ipvs = tinfo->ipvs;
1654 	struct ipvs_master_sync_state *ms = &ipvs->ms[tinfo->id];
1655 	struct sock *sk = tinfo->sock->sk;
1660 		ipvs->mcfg.mcast_ifn, ipvs->mcfg.syncid, tinfo->id);
1670 		while (ip_vs_send_sync_msg(tinfo->sock, sb->mesg) < 0) {
1704 	struct ip_vs_sync_thread_data *tinfo = data;
1705 	struct netns_ipvs *ipvs = tinfo->ipvs;
1706 	struct sock *sk = tinfo->sock->sk;
1712 		ipvs->bcfg.mcast_ifn, ipvs->bcfg.syncid, tinfo->id);
1723 			len = ip_vs_receive(tinfo->sock, tinfo->buf,
1731 			ip_vs_process_message(ipvs, tinfo->buf, len);
1742 	struct ip_vs_sync_thread_data *ti = NULL, *tinfo;
1851 		tinfo = &ti[id];
1852 		tinfo->ipvs = ipvs;
1855 			tinfo->buf = kmalloc(ipvs->bcfg.sync_maxlen,
1857 			if (!tinfo->buf)
1860 		tinfo->id = id;
1862 			result = make_send_sock(ipvs, id, dev, &tinfo->sock);
1864 			result = make_receive_sock(ipvs, id, dev, &tinfo->sock);
1868 		task = kthread_run(threadfn, tinfo, name, ipvs->gen, id);
1873 		tinfo->task = task;
1898 		for (tinfo = ti + id; tinfo >= ti; tinfo--) {
1899 			if (tinfo->task)
1900 				kthread_stop(tinfo->task);
1911 		for (tinfo = ti + id; tinfo >= ti; tinfo--) {
1912 			if (tinfo->sock)
1913 				sock_release(tinfo->sock);
1914 			kfree(tinfo->buf);
1935 	struct ip_vs_sync_thread_data *ti, *tinfo;
1965 			tinfo = &ti[id];
1967 				task_pid_nr(tinfo->task));
1969 			ret = kthread_stop(tinfo->task);
1987 			tinfo = &ti[id];
1989 				task_pid_nr(tinfo->task));
1990 			ret = kthread_stop(tinfo->task);
2002 	for (tinfo = ti + id; tinfo >= ti; tinfo--) {
2003 		if (tinfo->sock)
2004 			sock_release(tinfo->sock);
2005 		kfree(tinfo->buf);