Attachment #19322 for bug #41254

View | Details | Raw Unified | Return to bug 41254
Collapse All | Expand All




APU_DECLARE(apr_status_t) apr_queue_trypop(apr_queue_t *queue, void **data);

/**
 * Manually blocks pushing/adding onto the queue.
 *
 * @param queue the queue
 * @returns APR_SUCCESS if blocking was successful
 * @returns APR_EINTR the blocking was interrupted (try again)
 * @returns APR_EOF if the queue has been terminated
 */
APU_DECLARE(apr_status_t) apr_queue_blockpush(apr_queue_t *queue);

/**
 * Manually unblocks pushing/adding onto the queue.
 *
 * @param queue the queue
 * @returns APR_EOF if the queue has been terminated
 * @returns APR_SUCCESS if unblocking was successful
 */
APU_DECLARE(apr_status_t) apr_queue_unblockpush(apr_queue_t *queue);

/**
 * Manually blocks popping/getting from the queue.
 *
 * @param queue the queue
 * @returns APR_EINTR the blocking was interrupted (try again)
 * @returns APR_EOF if the queue has been terminated
 * @returns APR_SUCCESS if blocking was successful
 */
APU_DECLARE(apr_status_t) apr_queue_blockpop(apr_queue_t *queue);

/**
 * Manually unblocks popping/getting from the queue.
 *
 * @param queue the queue
 * @returns APR_EOF if the queue has been terminated
 * @returns APR_SUCCESS if unblocking was successful
 */
APU_DECLARE(apr_status_t) apr_queue_unblockpop(apr_queue_t *queue);

/**
 * Blocks until the queue is empty.
 *
 * @param queue the queue
 * @returns APR_EINTR the blocking was interrupted (try again)
 * @returns APR_EOF if the queue has been terminated
 * @returns APR_SUCCESS if the queue is empty
 */
APU_DECLARE(apr_status_t) apr_queue_isempty(apr_queue_t *queue);

/**
 * returns the size of the queue.
 *
 * @warning this is not threadsafe, and is intended for reporting/monitoring

Return to bug 41254

Lines 102-107 Link Here

(-)/usr/local/src/apr-util-1.2.7/include/apr_queue.h (+48 lines)
102	APU_DECLARE(apr_status_t) apr_queue_trypop(apr_queue_t queue, void *data);	102	APU_DECLARE(apr_status_t) apr_queue_trypop(apr_queue_t queue, void *data);
103		103
104	/**	104	/**
		105	* Manually blocks pushing/adding onto the queue.
		106	*
		107	* @param queue the queue
		108	* @returns APR_SUCCESS if blocking was successful
		109	* @returns APR_EINTR the blocking was interrupted (try again)
		110	* @returns APR_EOF if the queue has been terminated
		111	*/
		112	APU_DECLARE(apr_status_t) apr_queue_blockpush(apr_queue_t *queue);
		113
		114	/**
		115	* Manually unblocks pushing/adding onto the queue.
		116	*
		117	* @param queue the queue
		118	* @returns APR_EOF if the queue has been terminated
		119	* @returns APR_SUCCESS if unblocking was successful
		120	*/
		121	APU_DECLARE(apr_status_t) apr_queue_unblockpush(apr_queue_t *queue);
		122
		123	/**
		124	* Manually blocks popping/getting from the queue.
		125	*
		126	* @param queue the queue
		127	* @returns APR_EINTR the blocking was interrupted (try again)
		128	* @returns APR_EOF if the queue has been terminated
		129	* @returns APR_SUCCESS if blocking was successful
		130	*/
		131	APU_DECLARE(apr_status_t) apr_queue_blockpop(apr_queue_t *queue);
		132
		133	/**
		134	* Manually unblocks popping/getting from the queue.
		135	*
		136	* @param queue the queue
		137	* @returns APR_EOF if the queue has been terminated
		138	* @returns APR_SUCCESS if unblocking was successful
		139	*/
		140	APU_DECLARE(apr_status_t) apr_queue_unblockpop(apr_queue_t *queue);
		141
		142	/**
		143	* Blocks until the queue is empty.
		144	*
		145	* @param queue the queue
		146	* @returns APR_EINTR the blocking was interrupted (try again)
		147	* @returns APR_EOF if the queue has been terminated
		148	* @returns APR_SUCCESS if the queue is empty
		149	*/
		150	APU_DECLARE(apr_status_t) apr_queue_isempty(apr_queue_t *queue);
		151
		152	/**
105	* returns the size of the queue.	153	* returns the size of the queue.
106	*	154	*
107	* @warning this is not threadsafe, and is intended for reporting/monitoring	155	* @warning this is not threadsafe, and is intended for reporting/monitoring