diff --git a/samgr/adapter/posix/queue_adapter.c b/samgr/adapter/posix/queue_adapter.c index da7f0319479d0f14a33acb55adcde10e8b8018d9..43416caddf81d6460786720d8e55e39191a705f6 100644 --- a/samgr/adapter/posix/queue_adapter.c +++ b/samgr/adapter/posix/queue_adapter.c @@ -66,10 +66,6 @@ int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout) LockFreeBlockQueue *queue = (LockFreeBlockQueue *)queueId; pthread_mutex_lock(&queue->rMutex); - if (LFQUE_Pop(queue->queue, element, pri) == EC_SUCCESS) { - return EC_SUCCESS; - } - while (LFQUE_Pop(queue->queue, element, pri) != EC_SUCCESS) { pthread_cond_wait(&queue->cond, &queue->rMutex); }