#define pr_fmt(fmt) "xen:" KBUILD_MODNAME ": " fmt #include #include #include #include #include static void enable_hotplug_cpu(int cpu) { if (!cpu_present(cpu)) xen_arch_register_cpu(cpu); set_cpu_present(cpu, true); } static void disable_hotplug_cpu(int cpu) { if (cpu_online(cpu)) { lock_device_hotplug(); device_offline(get_cpu_device(cpu)); unlock_device_hotplug(); } if (cpu_present(cpu)) xen_arch_unregister_cpu(cpu); set_cpu_present(cpu, false); } static int vcpu_online(unsigned int cpu) { int err; char dir[16], state[16]; sprintf(dir, "cpu/%u", cpu); err = xenbus_scanf(XBT_NIL, dir, "availability", "%15s", state); if (err != 1) { if (!xen_initial_domain()) pr_err("Unable to read cpu state\n"); return err; } if (strcmp(state, "online") == 0) return 1; else if (strcmp(state, "offline") == 0) return 0; pr_err("unknown state(%s) on CPU%d\n", state, cpu); return -EINVAL; } static void vcpu_hotplug(unsigned int cpu) { if (!cpu_possible(cpu)) return; switch (vcpu_online(cpu)) { case 1: enable_hotplug_cpu(cpu); break; case 0: disable_hotplug_cpu(cpu); break; default: break; } } static void handle_vcpu_hotplug_event(struct xenbus_watch *watch, const char **vec, unsigned int len) { unsigned int cpu; char *cpustr; const char *node = vec[XS_WATCH_PATH]; cpustr = strstr(node, "cpu/"); if (cpustr != NULL) { sscanf(cpustr, "cpu/%u", &cpu); vcpu_hotplug(cpu); } } static int setup_cpu_watcher(struct notifier_block *notifier, unsigned long event, void *data) { int cpu; static struct xenbus_watch cpu_watch = { .node = "cpu", .callback = handle_vcpu_hotplug_event}; (void)register_xenbus_watch(&cpu_watch); for_each_possible_cpu(cpu) { if (vcpu_online(cpu) == 0) { (void)cpu_down(cpu); set_cpu_present(cpu, false); } } return NOTIFY_DONE; } static int __init setup_vcpu_hotplug_event(void) { static struct notifier_block xsn_cpu = { .notifier_call = setup_cpu_watcher }; #ifdef CONFIG_X86 if (!xen_pv_domain()) #else if (!xen_domain()) #endif return -ENODEV; register_xenstore_notifier(&xsn_cpu); return 0; } arch_initcall(setup_vcpu_hotplug_event); pe='hidden' name='h' value='nds-private-remove'/>

path: root/net/sched

Age	Commit message (Expand)	Author	Files	Lines
2017-02-14	net_sched: nla_memdup_cookie() can be static	Wei Yongjun	1	-1/+1
2017-02-14	sched: Fix accidental removal of errout goto	Jiri Pirko	1	-0/+1
2017-02-11	net_sched: fix error recovery at qdisc creation	Eric Dumazet	5	-23/+19
2017-02-10	net/act_pedit: Introduce 'add' operation	Amir Vadai	1	-4/+26
2017-02-10	net/act_pedit: Support using offset relative to the conventional network headers	Amir Vadai	1	-16/+180
2017-02-10	sched: check negative err value to safe one level of indent	Jiri Pirko	1	-13/+9
2017-02-10	sched: add missing curly braces in else branch in tc_ctl_tfilter	Jiri Pirko	1	-1/+2
2017-02-10	sched: move err set right before goto errout in tc_ctl_tfilter	Jiri Pirko	1	-10/+19
2017-02-10	sched: push TC filter protocol creation into a separate function	Jiri Pirko	1	-51/+59
2017-02-10	sched: move tcf_proto_destroy and tcf_destroy_chain helpers into cls_api	Jiri Pirko	13	-24/+32
2017-02-10	sched: rename tcf_destroy to tcf_destroy_proto	Jiri Pirko	2	-6/+6
2017-02-07	net/sched: act_mirred: remove duplicated include from act_mirred.c	Wei Yongjun	1	-2/+0
2017-02-03	Merge git://git.kernel.org/pub/scm/linux/kernel/git/pablo/nf-next	David S. Miller	1	-1/+1
2017-02-03	sched: cls_flower: expose priority to offloading netdevice	Jiri Pirko	1	-0/+3
2017-02-03	net/sched: act_ife: Change to use ife module	Yotam Gigi	2	-78/+33
2017-02-03	net/sched: act_ife: Unexport ife_tlv_meta_encode	Yotam Gigi	1	-2/+2
2017-02-02	Merge git://git.kernel.org/pub/scm/linux/kernel/git/davem/net	David S. Miller	2	-85/+48
2017-02-02	skbuff: add and use skb_nfct helper	Florian Westphal	1	-1/+1