@@ -710,7 +710,8 @@ vubr_backend_recv_cb(int sock, void *ctx)
int buflen = sizeof(buf);
int len;
- if (!dev->ready) {
+ if (!dev->ready || !rx_vq->enable) {
+ DPRINT("\n NOT READY: dev: %d, rx: %d\n", dev->ready, rx_vq->enable);
return;
}
@@ -747,8 +748,11 @@ vubr_kick_cb(int sock, void *ctx)
if (rc == -1) {
vubr_die("eventfd_read()");
} else {
- DPRINT("Got kick_data: %016"PRIx64"\n", kick_data);
- vubr_process_avail(dev, &dev->vq[1]);
+ DPRINT("Got kick_data: %016"PRIx64", vq enabled: %d\n",
+ kick_data, dev->vq[1].enable);
+ if (dev->vq[1].enable) {
+ vubr_process_avail(dev, &dev->vq[1]);
+ }
}
}