Lines Matching refs:p_queue
1518 txfr_queue_t *p_queue; in xQueueCreate() local
1539 p_queue = txfr_malloc(sizeof(txfr_queue_t)); in xQueueCreate()
1540 if(p_queue == NULL) { in xQueueCreate()
1548 txfr_free(p_queue); in xQueueCreate()
1553 TX_MEMSET(p_queue, 0, sizeof(*p_queue)); in xQueueCreate()
1554 p_queue->allocated = 1u; in xQueueCreate()
1555 p_queue->p_mem = p_mem; in xQueueCreate()
1556 p_queue->id = TX_QUEUE_ID; in xQueueCreate()
1558 p_queue->p_write = (uint8_t *)p_mem; in xQueueCreate()
1559 p_queue->p_read = (uint8_t *)p_mem; in xQueueCreate()
1560 p_queue->msg_size = uxItemSize; in xQueueCreate()
1561 p_queue->queue_length = uxQueueLength; in xQueueCreate()
1563 ret = tx_semaphore_create(&p_queue->read_sem, "", 0u); in xQueueCreate()
1568 ret = tx_semaphore_create(&p_queue->write_sem, "", uxQueueLength); in xQueueCreate()
1573 return p_queue; in xQueueCreate()
2738 txfr_queue_t *p_queue; in xQueueAddToSet() local
2755 p_queue = (txfr_queue_t *)xQueueOrSemaphore; in xQueueAddToSet()
2756 if(p_queue->p_set != NULL) { in xQueueAddToSet()
2761 p_queue->p_set = xQueueSet; in xQueueAddToSet()
2779 txfr_queue_t *p_queue; in xQueueRemoveFromSet() local
2798 p_queue = (txfr_queue_t *)xQueueOrSemaphore; in xQueueRemoveFromSet()
2800 if(p_queue->p_set != xQueueSet) { in xQueueRemoveFromSet()
2804 p_queue->p_set = NULL; in xQueueRemoveFromSet()