Searched refs:q_ptr (Results 1 – 12 of 12) sorted by relevance
68 VOID posix_reset_queue(POSIX_MSG_QUEUE * q_ptr) in posix_reset_queue() argument71 q_ptr->in_use = TX_FALSE; in posix_reset_queue()74 q_ptr -> name = NULL; in posix_reset_queue()77 q_ptr -> open_count = 0; in posix_reset_queue()80 q_ptr -> storage = NULL; in posix_reset_queue()83 if (tx_byte_pool_delete(&(q_ptr ->vq_message_area))) in posix_reset_queue()89 q_ptr -> px_queue_id = 0; in posix_reset_queue()92 q_ptr -> unlink_flag = TX_FALSE; in posix_reset_queue()
77 POSIX_MSG_QUEUE * q_ptr; in mq_close() local81 q_ptr = (POSIX_MSG_QUEUE * )Queue; in mq_close()84 if ( (!q_ptr) || ( (q_ptr -> px_queue_id) != PX_QUEUE_ID)) in mq_close()119 if( q_ptr->open_count ) in mq_close()121 q_ptr ->open_count--; in mq_close()125 if( (! q_ptr ->open_count ) && (q_ptr->unlink_flag == TX_TRUE)) in mq_close()128 if( posix_queue_delete( q_ptr )) in mq_close()
70 POSIX_MSG_QUEUE *q_ptr; in posix_find_queue() local77 q_ptr = (POSIX_MSG_QUEUE*)NULL; in posix_find_queue()80 for(index = 0,q_ptr = posix_queue_pool;index < POSIX_MAX_QUEUES ;index ++,q_ptr ++) in posix_find_queue()84 if(q_ptr->in_use == TX_TRUE) in posix_find_queue()86 dummy_queue_name = q_ptr->name; in posix_find_queue()109 return(q_ptr); in posix_find_queue()111 q_ptr = (POSIX_MSG_QUEUE*)NULL; in posix_find_queue()112 return (q_ptr); in posix_find_queue()
73 POSIX_MSG_QUEUE *q_ptr; in posix_get_new_queue() local94 for (i = 0, q_ptr = &(posix_queue_pool[0]); in posix_get_new_queue()96 i++, q_ptr++) in posix_get_new_queue()99 if (q_ptr->in_use == TX_FALSE) in posix_get_new_queue()102 q_ptr->in_use = TX_TRUE; in posix_get_new_queue()105 q_ptr->storage = bp; in posix_get_new_queue()107 q_ptr->px_queue_id = PX_QUEUE_ID; in posix_get_new_queue()120 return(q_ptr); in posix_get_new_queue()
73 POSIX_MSG_QUEUE *q_ptr; in mq_unlink() local90 if(!(q_ptr = posix_find_queue(mqName))) in mq_unlink()100 if(q_ptr) in mq_unlink()102 q_ptr->unlink_flag = TX_TRUE; in mq_unlink()105 if(q_ptr->open_count == 0) in mq_unlink()108 temp1 = posix_queue_delete( q_ptr ); in mq_unlink()
75 POSIX_MSG_QUEUE *q_ptr; in posix_priority_search() local83 q_ptr = (POSIX_MSG_QUEUE * )queue; in posix_priority_search()86 numMsgs = q_ptr -> queue.tx_queue_enqueued; in posix_priority_search()89 source = q_ptr->queue.tx_queue_read; in posix_priority_search()99 if(source == q_ptr->queue.tx_queue_end) in posix_priority_search()100 source = q_ptr->queue.tx_queue_start; in posix_priority_search()
70 POSIX_MSG_QUEUE * q_ptr; in posix_putback_queue() local73 q_ptr = MAKE_POSIX_QUEUE(qid); in posix_putback_queue()76 posix_memory_release(q_ptr->storage); in posix_putback_queue()79 q_ptr->in_use = TX_FALSE; in posix_putback_queue()
70 INT posix_queue_delete(POSIX_MSG_QUEUE * q_ptr) in posix_queue_delete() argument75 queue = &(q_ptr->queue); in posix_queue_delete()87 posix_reset_queue(q_ptr); in posix_queue_delete()88 q_ptr = NULL; in posix_queue_delete()
86 POSIX_MSG_QUEUE *q_ptr; in mq_send() local96 q_ptr = (POSIX_MSG_QUEUE * )mqdes->f_data; in mq_send()99 if ( (!q_ptr) || ( (q_ptr -> px_queue_id) != PX_QUEUE_ID)) in mq_send()121 if ( (!q_ptr) || ( (q_ptr->queue.tx_queue_id) != TX_QUEUE_ID)) in mq_send()160 if ( msg_len > (q_ptr->q_attr.mq_msgsize ) ) in mq_send()172 temp1 = tx_byte_allocate((TX_BYTE_POOL * )&(q_ptr->vq_message_area), &bp, in mq_send()
83 POSIX_MSG_QUEUE * q_ptr; in mq_receive() local94 q_ptr = (POSIX_MSG_QUEUE * )mqdes->f_data; in mq_receive()97 if ((!q_ptr) || ( (q_ptr -> px_queue_id) != PX_QUEUE_ID)) in mq_receive()117 if( msgLen < q_ptr -> q_attr.mq_msgsize ) in mq_receive()
69 struct mq_des * posix_get_queue_des(POSIX_MSG_QUEUE * q_ptr) in posix_get_queue_des() argument86 q_des->f_data = q_ptr; in posix_get_queue_des()
152 struct mq_des *posix_get_queue_des(POSIX_MSG_QUEUE * q_ptr);154 VOID posix_reset_queue(POSIX_MSG_QUEUE * q_ptr);164 INT posix_queue_delete(POSIX_MSG_QUEUE * q_ptr);
