- /*
- * If we read high prio channel in this loop, try again
- * for more high prio data.
- */
- if (high_prio) {
- continue;
- }
+ /* Take care of high priority channels first. */
+ /* for (i = 0; i < nb_fd; i++) { */
+ /* DBG("!!! POLL FLAGS: %d", pollfd[i].revents); */
+ /* if (pollfd[i].revents & POLLPRI) { */
+ /* ssize_t len; */
+
+ /* DBG("Urgent read on fd %d", pollfd[i].fd); */
+ /* high_prio = 1; */
+ /* len = ctx->on_buffer_ready(local_stream[i], ctx); */
+ /* /\* it's ok to have an unavailable sub-buffer *\/ */
+ /* if (len < 0 && len != -EAGAIN) { */
+ /* goto end; */
+ /* } else if (len > 0) { */
+ /* local_stream[i]->data_read = 1; */
+ /* } */
+ /* } */
+ /* } */
+
+ /* /\* */
+ /* * If we read high prio channel in this loop, try again */
+ /* * for more high prio data. */
+ /* *\/ */
+ /* if (high_prio) { */
+ /* continue; */
+ /* } */