Send signal once a period size data is received

Set the period size of playback as same as virtio driver suggests.

Author: Cuda-Chen

virtio-snd.c

@@ -551,7 +551,7 @@ static void virtio_snd_read_pcm_prepare(const virtio_snd_pcm_hdr_t *query,
     /* CNFA only accept frame with signed 16-bit data in little-endian. */
     props->audio_host =
         CNFAInit(NULL, "semu-virtio-snd", virtio_snd_cb, rate, 0, channels, 0,
-                 cnfa_period_frames, NULL, NULL, &props->v);
+                 period_bytes / VSND_CNFA_FRAME_SZ, NULL, NULL, &props->v);
     uint32_t sz = props->pp.buffer_bytes;
     props->ring.buffer = (void *) malloc(sizeof(void) * sz);
     props->ring.prod.head = 0;
@@ -709,26 +709,26 @@ static void __virtio_snd_frame_dequeue(short *out,
             "cons_head %" PRIu32 " cons_next %" PRIu32 " prod_tail %" PRIu32
             " mask %" PRIu32 " idx %" PRIu32 "\n",
             cons_head, cons_next, prod_tail, mask, idx);
-    /*if (idx + n < size) {
+    if (idx + n < size) {
         memcpy(out, props->ring.buffer + idx, n);
     } else {
         memcpy(out, props->ring.buffer + idx, size - idx);
         memcpy(out + (size - idx), props->ring.buffer, n - (size - idx));
         fprintf(stderr, "=== start %" PRIu32 " end %" PRIu32 "\n", size - idx,
                 n - (size - idx));
-    }*/
+    }
     VSND_COMPILER_BARRIER;
 
     props->ring.cons.tail = cons_next;
 
-    uint32_t len = 0;
+    /*uint32_t len = 0;
     while (!list_empty(&props->buf_queue_head) && len < n) {
         vsnd_buf_queue_node_t *node =
             list_first_entry(&props->buf_queue_head, vsnd_buf_queue_node_t, q);
         list_del(&node->q);
         memcpy(out, node->addr, node->len);
         len += node->len;
-    }
+    }*/
 
     props->ring.buf_ev_notity--;
     pthread_cond_signal(&props->ring.writable);
@@ -934,15 +934,15 @@ static void __virtio_snd_frame_enqueue(void *payload,
     fwrite(node->addr, sizeof(void), node->len, outfile);
 #endif
 
-    uint32_t period_bytes = props->pp.period_bytes;
+    /*uint32_t period_bytes = props->pp.period_bytes;
     if (prod_next - cons_tail >= period_bytes) {
         fprintf(stderr,
                 "buffer ready for %" PRIu32 " cons_tail %" PRIu32
                 " prod_next %" PRIu32 "\n",
                 prod_next - cons_tail, cons_tail, prod_next);
         props->ring.buf_ev_notity++;
         pthread_cond_signal(&props->ring.readable);
-    }
+    }*/
     pthread_mutex_unlock(&props->ring.lock);
 }
 
@@ -1006,6 +1006,7 @@ static int virtio_snd_tx_desc_handler(virtio_snd_state_t *vsnd,
                 (virtio_snd_pcm_status_t *) (base + addr);
             response->status = VIRTIO_SND_S_OK;
             response->latency_bytes = ret_len;
+            printf("=== TX queue get %" PRIu32 " bytes ===\n", ret_len);
             *plen = sizeof(*response);
             goto early_continue;
         }
@@ -1018,6 +1019,10 @@ static int virtio_snd_tx_desc_handler(virtio_snd_state_t *vsnd,
         idx++;
     }
 
+    virtio_snd_prop_t *props = &vsnd_props[stream_id];
+    props->ring.buf_ev_notity++;
+    pthread_cond_signal(&props->ring.readable);
+
     /* Tear down the descriptor list and free space. */
     virtq_desc_queue_node_t *tmp = NULL;
     list_for_each_entry_safe (node, tmp, &q, q) {