|
@@ -80,9 +80,8 @@ void vchiu_queue_push(VCHIU_QUEUE_T *queue, VCHIQ_HEADER_T *header)
|
|
|
return;
|
|
|
|
|
|
while (queue->write == queue->read + queue->size) {
|
|
|
- if (down_interruptible(&queue->pop) != 0) {
|
|
|
+ if (down_interruptible(&queue->pop) != 0)
|
|
|
flush_signals(current);
|
|
|
- }
|
|
|
}
|
|
|
|
|
|
/*
|
|
@@ -107,9 +106,8 @@ void vchiu_queue_push(VCHIU_QUEUE_T *queue, VCHIQ_HEADER_T *header)
|
|
|
VCHIQ_HEADER_T *vchiu_queue_peek(VCHIU_QUEUE_T *queue)
|
|
|
{
|
|
|
while (queue->write == queue->read) {
|
|
|
- if (down_interruptible(&queue->push) != 0) {
|
|
|
+ if (down_interruptible(&queue->push) != 0)
|
|
|
flush_signals(current);
|
|
|
- }
|
|
|
}
|
|
|
|
|
|
up(&queue->push); // We haven't removed anything from the queue.
|
|
@@ -128,9 +126,8 @@ VCHIQ_HEADER_T *vchiu_queue_pop(VCHIU_QUEUE_T *queue)
|
|
|
VCHIQ_HEADER_T *header;
|
|
|
|
|
|
while (queue->write == queue->read) {
|
|
|
- if (down_interruptible(&queue->push) != 0) {
|
|
|
+ if (down_interruptible(&queue->push) != 0)
|
|
|
flush_signals(current);
|
|
|
- }
|
|
|
}
|
|
|
|
|
|
/*
|