search for: hrtimer_mode_rel

...ug(vdebug, "%s: before calling kick %d\n", __FUNCTION__, __LINE__); vi->svq->vq_ops->kick(vi->svq); vi->out_num = 0; - } else { - vi->stats.hrtimer_starts++; - hrtimer_start(&vi->tx_timer, ktime_set(0,500000), - HRTIMER_MODE_REL); + } else if (!hrtimer_is_queued(&vi->tx_timer)) { + vi->stats.hrtimer_starts++; + hrtimer_start(&vi->tx_timer, ktime_set(0,500000), + HRTIMER_MODE_REL); } return 0; }

...ug(vdebug, "%s: before calling kick %d\n", __FUNCTION__, __LINE__); vi->svq->vq_ops->kick(vi->svq); vi->out_num = 0; - } else { - vi->stats.hrtimer_starts++; - hrtimer_start(&vi->tx_timer, ktime_set(0,500000), - HRTIMER_MODE_REL); + } else if (!hrtimer_is_queued(&vi->tx_timer)) { + vi->stats.hrtimer_starts++; + hrtimer_start(&vi->tx_timer, ktime_set(0,500000), + HRTIMER_MODE_REL); } return 0; }

...virtio_net.c @@ -392,10 +392,10 @@ again: vi->stats.sendq_kicks++; vi->svq->vq_ops->kick(vi->svq); vi->out_num = 0; - } else { - vi->stats.hrtimer_starts++; - hrtimer_start(&vi->tx_timer, ktime_set(0,500000), - HRTIMER_MODE_REL); + } else if (!hrtimer_is_queued(&vi->tx_timer)) { + vi->stats.hrtimer_starts++; + hrtimer_start(&vi->tx_timer, ktime_set(0,500000), + HRTIMER_MODE_REL); } return 0; } -- 1.5.3.3

...virtio_net.c @@ -392,10 +392,10 @@ again: vi->stats.sendq_kicks++; vi->svq->vq_ops->kick(vi->svq); vi->out_num = 0; - } else { - vi->stats.hrtimer_starts++; - hrtimer_start(&vi->tx_timer, ktime_set(0,500000), - HRTIMER_MODE_REL); + } else if (!hrtimer_is_queued(&vi->tx_timer)) { + vi->stats.hrtimer_starts++; + hrtimer_start(&vi->tx_timer, ktime_set(0,500000), + HRTIMER_MODE_REL); } return 0; } -- 1.5.3.3

...ps->kick(vi->svq); + if (++vi->out_num == vi->out_max) { + hrtimer_cancel(&vi->tx_timer); + vi->svq->vq_ops->kick(vi->svq); + vi->out_num = 0; + } else + hrtimer_start(&vi->tx_timer, ktime_set(0,500000), + HRTIMER_MODE_REL); return 0; } @@ -363,6 +398,10 @@ static int virtnet_probe(struct virtio_device *vdev) netif_napi_add(dev, &vi->napi, virtnet_poll, 16); vi->dev = dev; vi->vdev = vdev; + hrtimer_init(&vi->tx_timer, CLOCK_REALTIME, HRTIMER_MODE_REL); + vi->tx_tim...

...ps->kick(vi->svq); + if (++vi->out_num == vi->out_max) { + hrtimer_cancel(&vi->tx_timer); + vi->svq->vq_ops->kick(vi->svq); + vi->out_num = 0; + } else + hrtimer_start(&vi->tx_timer, ktime_set(0,500000), + HRTIMER_MODE_REL); return 0; } @@ -363,6 +398,10 @@ static int virtnet_probe(struct virtio_device *vdev) netif_napi_add(dev, &vi->napi, virtnet_poll, 16); vi->dev = dev; vi->vdev = vdev; + hrtimer_init(&vi->tx_timer, CLOCK_REALTIME, HRTIMER_MODE_REL); + vi->tx_tim...

...t.c @@ -434,9 +434,9 @@ static int virtnet_probe(struct virtio_device *vdev) netif_napi_add(dev, &vi->napi, virtnet_poll, napi_weight); vi->dev = dev; vi->vdev = vdev; + memset(&vi->tx_timer, 0, sizeof(vi->tx_timer)); hrtimer_init(&vi->tx_timer, CLOCK_REALTIME, HRTIMER_MODE_REL); vi->tx_timer.function = kick_xmit; - vi->tx_timer.cb_mode = HRTIMER_CB_SOFTIRQ; vi->out_max = -1U; tasklet_init(&vi->xmit_free, xmit_free, (unsigned long)vi);

...t.c @@ -434,9 +434,9 @@ static int virtnet_probe(struct virtio_device *vdev) netif_napi_add(dev, &vi->napi, virtnet_poll, napi_weight); vi->dev = dev; vi->vdev = vdev; + memset(&vi->tx_timer, 0, sizeof(vi->tx_timer)); hrtimer_init(&vi->tx_timer, CLOCK_REALTIME, HRTIMER_MODE_REL); vi->tx_timer.function = kick_xmit; - vi->tx_timer.cb_mode = HRTIMER_CB_SOFTIRQ; vi->out_max = -1U; tasklet_init(&vi->xmit_free, xmit_free, (unsigned long)vi);

...>host_resp); 1382 vm->vdev = vdev; 1383 INIT_WORK(&vm->wq, virtio_mem_run_wq); 1384 mutex_init(&vm->hotplug_mutex); 1385 INIT_LIST_HEAD(&vm->next); 1386 spin_lock_init(&vm->removal_lock); 1387 hrtimer_init(&vm->retry_timer, CLOCK_MONOTONIC, HRTIMER_MODE_REL); 1388 vm->retry_timer.function = virtio_mem_timer_expired; 1389 1390 /* register the virtqueue */ > 1391 rc = virtio_mem_init_vq(vm); 1392 if (rc) 1393 goto out_free_vm; 1394 1395 /* initialize the device by querying the config */ 1396 rc = virtio_mem_init(vm); 13...

...>host_resp); 1380 vm->vdev = vdev; 1381 INIT_WORK(&vm->wq, virtio_mem_run_wq); 1382 mutex_init(&vm->hotplug_mutex); 1383 INIT_LIST_HEAD(&vm->next); 1384 spin_lock_init(&vm->removal_lock); 1385 hrtimer_init(&vm->retry_timer, CLOCK_MONOTONIC, HRTIMER_MODE_REL); 1386 vm->retry_timer.function = virtio_mem_timer_expired; 1387 1388 /* register the virtqueue */ 1389 rc = virtio_mem_init_vq(vm); 1390 if (rc) 1391 goto out_free_vm; 1392 1393 /* initialize the device by querying the config */ 1394 rc = virtio_mem_init(vm); 1395...

...>host_resp); 1380 vm->vdev = vdev; 1381 INIT_WORK(&vm->wq, virtio_mem_run_wq); 1382 mutex_init(&vm->hotplug_mutex); 1383 INIT_LIST_HEAD(&vm->next); 1384 spin_lock_init(&vm->removal_lock); 1385 hrtimer_init(&vm->retry_timer, CLOCK_MONOTONIC, HRTIMER_MODE_REL); 1386 vm->retry_timer.function = virtio_mem_timer_expired; 1387 1388 /* register the virtqueue */ 1389 rc = virtio_mem_init_vq(vm); 1390 if (rc) 1391 goto out_free_vm; 1392 1393 /* initialize the device by querying the config */ 1394 rc = virtio_mem_init(vm); 1395...

...= wait_event_interruptible_timeout( - priv->waiting, - nouveau_fence_done(fence), - timeout); - } else { - ret = wait_event_timeout(priv->waiting, - nouveau_fence_done(fence), - timeout); - } - } + kt = ktime_set(0, sleep_time); + schedule_hrtimeout(&kt, HRTIMER_MODE_REL); + sleep_time *= 2; + if (sleep_time > NSEC_PER_MSEC) + sleep_time = NSEC_PER_MSEC; - if (ret >= 0) { - fence->timeout = jiffies + ret; - if (time_after_eq(jiffies, fence->timeout)) - ret = -EBUSY; - } - } else { - if (intr) { - ret = wait_event_interruptible(priv-&gt...

Hi: This is a new version of trying to enable tx interrupts for virtio-net. We used to try to avoid tx interrupts and orphan packets before transmission for virtio-net. This breaks socket accounting and can lead serveral other side effects e.g: - Several other functions which depends on socket accounting can not work correctly (e.g TCP Small Queue) - No tx completion which make BQL or

Hi: This is a new version of trying to enable tx interrupts for virtio-net. We used to try to avoid tx interrupts and orphan packets before transmission for virtio-net. This breaks socket accounting and can lead serveral other side effects e.g: - Several other functions which depends on socket accounting can not work correctly (e.g TCP Small Queue) - No tx completion which make BQL or

...detector->vdev, ticks); > + > + /* Pet the stall detector at half of its expiration timeout > + * to prevent spurious resets. > + */ > + ping_timeout_ms = vcpu_stall_config.stall_timeout_sec * > + MSEC_PER_SEC / 2; > + > + hrtimer_init(vcpu_hrtimer, CLOCK_MONOTONIC, HRTIMER_MODE_REL); > + vcpu_hrtimer->function = vcpu_stall_detect_timer_fn; > + > + vcpu_stall->pet_event.is_initialized = true; > + > + spin_lock(&vcpu_stall->lock); > + vcpu_stall->pet_event.cpu_id = cpu; > + sg_init_one(&sg, &vcpu_stall->pet_event, sizeof(vcpu_stal...

Hello: We used to orphan packets before transmission for virtio-net. This breaks socket accounting and can lead serveral functions won't work, e.g: - Byte Queue Limit depends on tx completion nofication to work. - Packet Generator depends on tx completion nofication for the last transmitted packet to complete. - TCP Small Queue depends on proper accounting of sk_wmem_alloc to work. This

Hello: We used to orphan packets before transmission for virtio-net. This breaks socket accounting and can lead serveral functions won't work, e.g: - Byte Queue Limit depends on tx completion nofication to work. - Packet Generator depends on tx completion nofication for the last transmitted packet to complete. - TCP Small Queue depends on proper accounting of sk_wmem_alloc to work. This

Hi: This is a new version of trying to enable tx interrupts for virtio-net. We used to try to avoid tx interrupts and orphan packets before transmission for virtio-net. This breaks socket accounting and can lead serveral other side effects e.g: - Several other functions which depends on socket accounting can not work correctly (e.g TCP Small Queue) - No tx completion which make BQL or packet

Hi: This is a new version of trying to enable tx interrupts for virtio-net. We used to try to avoid tx interrupts and orphan packets before transmission for virtio-net. This breaks socket accounting and can lead serveral other side effects e.g: - Several other functions which depends on socket accounting can not work correctly (e.g TCP Small Queue) - No tx completion which make BQL or packet

...*/ + break; + case -EBUSY: + /* + * The hypervisor cannot process our request right now + * (e.g., out of memory, migrating). + */ + case -ENOMEM: + /* Out of memory, try again later. */ + hrtimer_start(&vm->retry_timer, + ms_to_ktime(VIRTIO_MEM_RETRY_TIMER_MS), + HRTIMER_MODE_REL); + break; + case -EAGAIN: + /* Retry immediately (e.g., the config changed). */ + goto retry; + default: + /* Unknown error, mark as broken */ + dev_err(&vm->vdev->dev, + "unknown error, marking device broken: %d\n", rc); + vm->broken = true; + } +} + +static enum hr...