Searched refs:q_ptr (Results 1 – 12 of 12) sorted by relevance
67 VOID posix_reset_queue(POSIX_MSG_QUEUE * q_ptr) in posix_reset_queue() argument70 q_ptr->in_use = TX_FALSE; in posix_reset_queue()73 q_ptr -> name = NULL; in posix_reset_queue()76 q_ptr -> open_count = 0; in posix_reset_queue()79 q_ptr -> storage = NULL; in posix_reset_queue()82 if (tx_byte_pool_delete(&(q_ptr ->vq_message_area))) in posix_reset_queue()88 q_ptr -> px_queue_id = 0; in posix_reset_queue()91 q_ptr -> unlink_flag = TX_FALSE; in posix_reset_queue()
76 POSIX_MSG_QUEUE * q_ptr; in mq_close() local80 q_ptr = (POSIX_MSG_QUEUE * )Queue; in mq_close()83 if ( (!q_ptr) || ( (q_ptr -> px_queue_id) != PX_QUEUE_ID)) in mq_close()118 if( q_ptr->open_count ) in mq_close()120 q_ptr ->open_count--; in mq_close()124 if( (! q_ptr ->open_count ) && (q_ptr->unlink_flag == TX_TRUE)) in mq_close()127 if( posix_queue_delete( q_ptr )) in mq_close()
69 POSIX_MSG_QUEUE *q_ptr; in posix_find_queue() local76 q_ptr = (POSIX_MSG_QUEUE*)NULL; in posix_find_queue()79 for(index = 0,q_ptr = posix_queue_pool;index < POSIX_MAX_QUEUES ;index ++,q_ptr ++) in posix_find_queue()83 if(q_ptr->in_use == TX_TRUE) in posix_find_queue()85 dummy_queue_name = q_ptr->name; in posix_find_queue()108 return(q_ptr); in posix_find_queue()110 q_ptr = (POSIX_MSG_QUEUE*)NULL; in posix_find_queue()111 return (q_ptr); in posix_find_queue()
72 POSIX_MSG_QUEUE *q_ptr; in posix_get_new_queue() local93 for (i = 0, q_ptr = &(posix_queue_pool[0]); in posix_get_new_queue()95 i++, q_ptr++) in posix_get_new_queue()98 if (q_ptr->in_use == TX_FALSE) in posix_get_new_queue()101 q_ptr->in_use = TX_TRUE; in posix_get_new_queue()104 q_ptr->storage = bp; in posix_get_new_queue()106 q_ptr->px_queue_id = PX_QUEUE_ID; in posix_get_new_queue()119 return(q_ptr); in posix_get_new_queue()
72 POSIX_MSG_QUEUE *q_ptr; in mq_unlink() local89 if(!(q_ptr = posix_find_queue(mqName))) in mq_unlink()99 if(q_ptr) in mq_unlink()101 q_ptr->unlink_flag = TX_TRUE; in mq_unlink()104 if(q_ptr->open_count == 0) in mq_unlink()107 temp1 = posix_queue_delete( q_ptr ); in mq_unlink()
74 POSIX_MSG_QUEUE *q_ptr; in posix_priority_search() local82 q_ptr = (POSIX_MSG_QUEUE * )queue; in posix_priority_search()85 numMsgs = q_ptr -> queue.tx_queue_enqueued; in posix_priority_search()88 source = q_ptr->queue.tx_queue_read; in posix_priority_search()98 if(source == q_ptr->queue.tx_queue_end) in posix_priority_search()99 source = q_ptr->queue.tx_queue_start; in posix_priority_search()
69 POSIX_MSG_QUEUE * q_ptr; in posix_putback_queue() local72 q_ptr = MAKE_POSIX_QUEUE(qid); in posix_putback_queue()75 posix_memory_release(q_ptr->storage); in posix_putback_queue()78 q_ptr->in_use = TX_FALSE; in posix_putback_queue()
69 INT posix_queue_delete(POSIX_MSG_QUEUE * q_ptr) in posix_queue_delete() argument74 queue = &(q_ptr->queue); in posix_queue_delete()86 posix_reset_queue(q_ptr); in posix_queue_delete()87 q_ptr = NULL; in posix_queue_delete()
85 POSIX_MSG_QUEUE *q_ptr; in mq_send() local95 q_ptr = (POSIX_MSG_QUEUE * )mqdes->f_data; in mq_send()98 if ( (!q_ptr) || ( (q_ptr -> px_queue_id) != PX_QUEUE_ID)) in mq_send()120 if ( (!q_ptr) || ( (q_ptr->queue.tx_queue_id) != TX_QUEUE_ID)) in mq_send()159 if ( msg_len > (q_ptr->q_attr.mq_msgsize ) ) in mq_send()171 temp1 = tx_byte_allocate((TX_BYTE_POOL * )&(q_ptr->vq_message_area), &bp, in mq_send()
82 POSIX_MSG_QUEUE * q_ptr; in mq_receive() local93 q_ptr = (POSIX_MSG_QUEUE * )mqdes->f_data; in mq_receive()96 if ((!q_ptr) || ( (q_ptr -> px_queue_id) != PX_QUEUE_ID)) in mq_receive()116 if( msgLen < q_ptr -> q_attr.mq_msgsize ) in mq_receive()
68 struct mq_des * posix_get_queue_des(POSIX_MSG_QUEUE * q_ptr) in posix_get_queue_des() argument85 q_des->f_data = q_ptr; in posix_get_queue_des()
151 struct mq_des *posix_get_queue_des(POSIX_MSG_QUEUE * q_ptr);153 VOID posix_reset_queue(POSIX_MSG_QUEUE * q_ptr);163 INT posix_queue_delete(POSIX_MSG_QUEUE * q_ptr);
