Lines Matching refs:be
13 static int connect_data_rings(struct backend_info *be,
15 static void connect(struct backend_info *be);
16 static int read_xenbus_vif_flags(struct backend_info *be);
17 static int backend_create_xenvif(struct backend_info *be);
18 static void unregister_hotplug_status_watch(struct backend_info *be);
20 static void set_backend_state(struct backend_info *be,
206 struct backend_info *be = dev_get_drvdata(&xdev->dev); in netback_uevent() local
208 if (!be) in netback_uevent()
211 if (add_uevent_var(env, "script=%s", be->hotplug_script)) in netback_uevent()
214 if (!be->vif) in netback_uevent()
217 return add_uevent_var(env, "vif=%s", be->vif->dev->name); in netback_uevent()
221 static int backend_create_xenvif(struct backend_info *be) in backend_create_xenvif() argument
225 struct xenbus_device *dev = be->dev; in backend_create_xenvif()
228 if (be->vif != NULL) in backend_create_xenvif()
243 be->vif = vif; in backend_create_xenvif()
244 vif->be = be; in backend_create_xenvif()
250 static void backend_disconnect(struct backend_info *be) in backend_disconnect() argument
252 struct xenvif *vif = be->vif; in backend_disconnect()
280 static void backend_connect(struct backend_info *be) in backend_connect() argument
282 if (be->vif) in backend_connect()
283 connect(be); in backend_connect()
286 static inline void backend_switch_state(struct backend_info *be, in backend_switch_state() argument
289 struct xenbus_device *dev = be->dev; in backend_switch_state()
292 be->state = state; in backend_switch_state()
297 if (!be->have_hotplug_status_watch) in backend_switch_state()
321 static void set_backend_state(struct backend_info *be, in set_backend_state() argument
324 while (be->state != state) { in set_backend_state()
325 switch (be->state) { in set_backend_state()
331 backend_switch_state(be, XenbusStateInitWait); in set_backend_state()
334 backend_switch_state(be, XenbusStateClosed); in set_backend_state()
344 backend_switch_state(be, XenbusStateInitWait); in set_backend_state()
347 backend_switch_state(be, XenbusStateClosing); in set_backend_state()
356 backend_connect(be); in set_backend_state()
357 backend_switch_state(be, XenbusStateConnected); in set_backend_state()
361 backend_switch_state(be, XenbusStateClosing); in set_backend_state()
372 backend_disconnect(be); in set_backend_state()
373 backend_switch_state(be, XenbusStateClosing); in set_backend_state()
384 backend_switch_state(be, XenbusStateClosed); in set_backend_state()
396 static void read_xenbus_frontend_xdp(struct backend_info *be, in read_xenbus_frontend_xdp() argument
399 struct xenvif *vif = be->vif; in read_xenbus_frontend_xdp()
420 struct backend_info *be = dev_get_drvdata(&dev->dev); in frontend_changed() local
424 be->frontend_state = frontend_state; in frontend_changed()
428 set_backend_state(be, XenbusStateInitWait); in frontend_changed()
435 set_backend_state(be, XenbusStateConnected); in frontend_changed()
439 read_xenbus_frontend_xdp(be, dev); in frontend_changed()
444 set_backend_state(be, XenbusStateClosing); in frontend_changed()
448 set_backend_state(be, XenbusStateClosed); in frontend_changed()
453 set_backend_state(be, XenbusStateClosed); in frontend_changed()
650 static void unregister_hotplug_status_watch(struct backend_info *be) in unregister_hotplug_status_watch() argument
652 if (be->have_hotplug_status_watch) { in unregister_hotplug_status_watch()
653 unregister_xenbus_watch(&be->hotplug_status_watch); in unregister_hotplug_status_watch()
654 kfree(be->hotplug_status_watch.node); in unregister_hotplug_status_watch()
656 be->have_hotplug_status_watch = 0; in unregister_hotplug_status_watch()
663 struct backend_info *be = container_of(watch, in hotplug_status_changed() local
669 str = xenbus_read(XBT_NIL, be->dev->nodename, "hotplug-status", &len); in hotplug_status_changed()
674 xenbus_switch_state(be->dev, be->state); in hotplug_status_changed()
677 unregister_hotplug_status_watch(be); in hotplug_status_changed()
678 xenbus_rm(XBT_NIL, be->dev->nodename, "hotplug-status"); in hotplug_status_changed()
683 static int connect_ctrl_ring(struct backend_info *be) in connect_ctrl_ring() argument
685 struct xenbus_device *dev = be->dev; in connect_ctrl_ring()
686 struct xenvif *vif = be->vif; in connect_ctrl_ring()
725 static void connect(struct backend_info *be) in connect() argument
728 struct xenbus_device *dev = be->dev; in connect()
747 err = xen_net_read_mac(dev, be->vif->fe_dev_addr); in connect()
754 xen_unregister_watchers(be->vif); in connect()
755 xen_register_watchers(dev, be->vif); in connect()
756 read_xenbus_vif_flags(be); in connect()
758 err = connect_ctrl_ring(be); in connect()
765 be->vif->queues = vzalloc(array_size(requested_num_queues, in connect()
767 if (!be->vif->queues) { in connect()
773 be->vif->num_queues = requested_num_queues; in connect()
774 be->vif->stalled_queues = requested_num_queues; in connect()
777 queue = &be->vif->queues[queue_index]; in connect()
778 queue->vif = be->vif; in connect()
781 be->vif->dev->name, queue->id); in connect()
791 be->vif->num_queues = queue_index; in connect()
799 err = connect_data_rings(be, queue); in connect()
807 be->vif->num_queues = queue_index; in connect()
813 xenvif_debugfs_addif(be->vif); in connect()
820 netif_set_real_num_tx_queues(be->vif->dev, requested_num_queues); in connect()
821 netif_set_real_num_rx_queues(be->vif->dev, requested_num_queues); in connect()
824 xenvif_carrier_on(be->vif); in connect()
826 unregister_hotplug_status_watch(be); in connect()
828 err = xenbus_watch_pathfmt(dev, &be->hotplug_status_watch, in connect()
834 be->have_hotplug_status_watch = 1; in connect()
837 netif_tx_wake_all_queues(be->vif->dev); in connect()
842 if (be->vif->num_queues > 0) in connect()
843 xenvif_disconnect_data(be->vif); /* Clean up existing queues */ in connect()
844 for (queue_index = 0; queue_index < be->vif->num_queues; ++queue_index) in connect()
845 xenvif_deinit_queue(&be->vif->queues[queue_index]); in connect()
846 vfree(be->vif->queues); in connect()
847 be->vif->queues = NULL; in connect()
848 be->vif->num_queues = 0; in connect()
849 xenvif_disconnect_ctrl(be->vif); in connect()
854 static int connect_data_rings(struct backend_info *be, in connect_data_rings() argument
857 struct xenbus_device *dev = be->dev; in connect_data_rings()
935 static int read_xenbus_vif_flags(struct backend_info *be) in read_xenbus_vif_flags() argument
937 struct xenvif *vif = be->vif; in read_xenbus_vif_flags()
938 struct xenbus_device *dev = be->dev; in read_xenbus_vif_flags()
961 be->vif->drain_timeout = msecs_to_jiffies(30); in read_xenbus_vif_flags()
962 be->vif->stall_timeout = 0; in read_xenbus_vif_flags()
981 read_xenbus_frontend_xdp(be, dev); in read_xenbus_vif_flags()
988 struct backend_info *be = dev_get_drvdata(&dev->dev); in netback_remove() local
990 unregister_hotplug_status_watch(be); in netback_remove()
991 if (be->vif) { in netback_remove()
993 backend_disconnect(be); in netback_remove()
994 xenvif_free(be->vif); in netback_remove()
995 be->vif = NULL; in netback_remove()
997 kfree(be->hotplug_script); in netback_remove()
998 kfree(be); in netback_remove()
1015 struct backend_info *be = kzalloc(sizeof(*be), GFP_KERNEL); in netback_probe() local
1017 if (!be) { in netback_probe()
1023 be->dev = dev; in netback_probe()
1024 dev_set_drvdata(&dev->dev, be); in netback_probe()
1136 backend_switch_state(be, XenbusStateInitWait); in netback_probe()
1145 be->hotplug_script = script; in netback_probe()
1148 err = backend_create_xenvif(be); in netback_probe()