Lines Matching refs:p_queue
1515 txfr_queue_t *p_queue; in xQueueCreate() local
1529 p_queue = txfr_malloc(sizeof(txfr_queue_t)); in xQueueCreate()
1530 if(p_queue == NULL) { in xQueueCreate()
1538 txfr_free(p_queue); in xQueueCreate()
1543 TX_MEMSET(p_queue, 0, sizeof(*p_queue)); in xQueueCreate()
1544 p_queue->allocated = 1u; in xQueueCreate()
1545 p_queue->p_mem = p_mem; in xQueueCreate()
1546 p_queue->id = TX_QUEUE_ID; in xQueueCreate()
1548 p_queue->p_write = (uint8_t *)p_mem; in xQueueCreate()
1549 p_queue->p_read = (uint8_t *)p_mem; in xQueueCreate()
1550 p_queue->msg_size = uxItemSize; in xQueueCreate()
1551 p_queue->queue_length = uxQueueLength; in xQueueCreate()
1553 ret = tx_semaphore_create(&p_queue->read_sem, "", 0u); in xQueueCreate()
1558 ret = tx_semaphore_create(&p_queue->write_sem, "", uxQueueLength); in xQueueCreate()
1563 return p_queue; in xQueueCreate()
2721 txfr_queue_t *p_queue; in xQueueAddToSet() local
2738 p_queue = (txfr_queue_t *)xQueueOrSemaphore; in xQueueAddToSet()
2739 if(p_queue->p_set != NULL) { in xQueueAddToSet()
2744 p_queue->p_set = xQueueSet; in xQueueAddToSet()
2762 txfr_queue_t *p_queue; in xQueueRemoveFromSet() local
2781 p_queue = (txfr_queue_t *)xQueueOrSemaphore; in xQueueRemoveFromSet()
2783 if(p_queue->p_set != xQueueSet) { in xQueueRemoveFromSet()
2787 p_queue->p_set = NULL; in xQueueRemoveFromSet()