#include <empq.h>

Public Member Functions
	em_pqueue (long pq_sz, long buf_sz, unsigned short nb_buf, unsigned int buf_ar)

	em_pqueue ()

	em_pqueue (long N)

	em_pqueue (MinMaxHeap< T > im, AMI_STREAM< T > amis)

	em_pqueue (const em_pqueue &ep)

	~em_pqueue ()

unsigned long	size ()

bool	is_empty ()

bool	is_full ()

bool	min (T &elt)

bool	extract_min (T &elt)

bool	extract_all_min (T &elt)

bool	insert (const T &elt)

long	maxlen (unsigned short i)

long	maxlen ()

void	clear ()

void	print_range ()

void	print ()

void	print_size ()

Protected Member Functions
int	active_streams ()

bool	empty_buff_0 ()

void	empty_buff (unsigned short i)

AMI_err	merge_buffer (em_buffer< T, Key > buf, AMI_STREAM< ExtendedEltMergeType< T, Key > > outstr, long K)

AMI_err	merge_streams (AMI_STREAM< ExtendedEltMergeType< T, Key > > *instr, unsigned short arity, AMI_STREAM< ExtendedEltMergeType< T, Key > > outstr, long K)

void	delete_str_elt (unsigned short buf_id, unsigned int stream_id)

void	merge_bufs2pq (AMI_STREAM< ExtendedEltMergeType< T, Key > > *minstream)

void	cleanup ()

bool	fillpq ()

void	print_stream_sizes ()

Friends
ostream &	operator<< (ostream &s, const em_pqueue &empq)

Detailed Description

template<class T, class Key>
class em_pqueue< T, Key >

Definition at line 124 of file empq.h.

Constructor & Destructor Documentation

◆ em_pqueue() [1/5]

template<class T , class Key >

em_pqueue< T, Key >::em_pqueue	(	long	pq_sz,
		long	buf_sz,
		unsigned short	nb_buf,
		unsigned int	buf_ar
	)

Definition at line 136 of file empq_impl.h.

References AMI_ERROR_NO_ERROR, assert, getAvailableMemory(), AMI_STREAM< T >::main_memory_usage(), MEMORY_LOG(), MM_STREAM_USAGE_MAXIMUM, and NULL.

◆ em_pqueue() [2/5]

template<class T , class Key >

em_pqueue< T, Key >::em_pqueue ( )

Definition at line 224 of file empq_impl.h.

References AMI_ERROR_NO_ERROR, AMI_STREAM< T >::AMI_STREAM(), assert, getAvailableMemory(), AMI_STREAM< T >::main_memory_usage(), MEMORY_LOG(), MM_STREAM_USAGE_MAXIMUM, MY_LOG_DEBUG_ID, and NULL.

◆ em_pqueue() [3/5]

template<class T , class Key >

em_pqueue< T, Key >::em_pqueue ( long N )

inline

Definition at line 164 of file empq.h.

References em_pqueue< T, Key >::em_pqueue().

Referenced by em_pqueue< T, Key >::em_pqueue().

◆ em_pqueue() [4/5]

template<class T , class Key >

em_pqueue< T, Key >::em_pqueue	(	MinMaxHeap< T > *	im,
		AMI_STREAM< T > *	amis
	)

Definition at line 353 of file empq_impl.h.

References AMI_ERROR_NO_ERROR, AMI_STREAM< T >::AMI_STREAM(), assert, getAvailableMemory(), LOG_avail_memo(), AMI_STREAM< T >::main_memory_usage(), MAX_STREAMS_OPEN, MEMORY_LOG(), MM_STREAM_USAGE_MAXIMUM, NULL, AMI_STREAM< T >::read_item(), AMI_STREAM< T >::seek(), AMI_STREAM< T >::stream_len(), AMI_STREAM< T >::write_item(), and x.

◆ em_pqueue() [5/5]

template<class T , class Key >

em_pqueue< T, Key >::em_pqueue ( const em_pqueue< T, Key > & ep )

◆ ~em_pqueue()

template<class T , class Key >

em_pqueue< T, Key >::~em_pqueue ( )

Definition at line 490 of file empq_impl.h.

References NULL.

Member Function Documentation

◆ active_streams()

template<class T , class Key >

int em_pqueue< T, Key >::active_streams ( )

inlineprotected

Definition at line 237 of file empq.h.

◆ cleanup()

template<class T , class Key >

void em_pqueue< T, Key >::cleanup ( )

protected

Definition at line 968 of file empq_impl.h.

References MY_LOG_DEBUG_ID.

◆ clear()

template<class T , class Key >

void em_pqueue< T, Key >::clear ( )

Definition at line 1482 of file empq_impl.h.

References NULL.

◆ delete_str_elt()

template<class T , class Key >

void em_pqueue< T, Key >::delete_str_elt	(	unsigned short	buf_id,
		unsigned int	stream_id
	)

protected

Definition at line 954 of file empq_impl.h.

References assert.

◆ empty_buff()

template<class T , class Key >

void em_pqueue< T, Key >::empty_buff ( unsigned short i )

protected

Definition at line 1155 of file empq_impl.h.

References AMI_ERROR_NO_ERROR, AMI_STREAM< T >::AMI_STREAM(), assert, MEMORY_LOG(), MY_LOG_DEBUG_ID, AMI_STREAM< T >::read_item(), AMI_STREAM< T >::seek(), AMI_STREAM< T >::stream_len(), and x.

◆ empty_buff_0()

template<class T , class Key >

bool em_pqueue< T, Key >::empty_buff_0 ( )

protected

Definition at line 1086 of file empq_impl.h.

References AMI_STREAM< T >::AMI_STREAM(), assert, MEMORY_LOG(), and MY_LOG_DEBUG_ID.

◆ extract_all_min()

template<class T , class Key >

bool em_pqueue< T, Key >::extract_all_min ( T & elt )

Definition at line 802 of file empq_impl.h.

References AMI_STREAM< T >::AMI_STREAM(), min, and MY_LOG_DEBUG_ID.

◆ extract_min()

template<class T , class Key >

bool em_pqueue< T, Key >::extract_min ( T & elt )

Definition at line 727 of file empq_impl.h.

References AMI_STREAM< T >::AMI_STREAM(), assert, MY_LOG_DEBUG_ID, x, and XXX.

◆ fillpq()

template<class T , class Key >

bool em_pqueue< T, Key >::fillpq ( )

protected

Definition at line 574 of file empq_impl.h.

References AMI_ERROR_NO_ERROR, AMI_STREAM< T >::AMI_STREAM(), assert, ExtendedMergeStream, MEMORY_LOG(), MY_LOG_DEBUG_ID, NULL, AMI_STREAM< T >::stream_len(), and XXX.

◆ insert()

template<class T , class Key >

bool em_pqueue< T, Key >::insert ( const T & elt )

Definition at line 1000 of file empq_impl.h.

References AMI_STREAM< T >::AMI_STREAM(), assert, MY_LOG_DEBUG_ID, and x.

◆ is_empty()

template<class T , class Key >

bool em_pqueue< T, Key >::is_empty ( )

Definition at line 563 of file empq_impl.h.

◆ is_full()

template<class T , class Key >

bool em_pqueue< T, Key >::is_full ( )

inline

Definition at line 185 of file empq.h.

◆ maxlen() [1/2]

template<class T , class Key >

long em_pqueue< T, Key >::maxlen ( )

Definition at line 538 of file empq_impl.h.

◆ maxlen() [2/2]

template<class T , class Key >

long em_pqueue< T, Key >::maxlen ( unsigned short i )

Definition at line 513 of file empq_impl.h.

References AMI_STREAM< T >::AMI_STREAM().

◆ merge_buffer()

template<class T , class Key >

AMI_err em_pqueue< T, Key >::merge_buffer	(	em_buffer< T, Key > *	buf,
		AMI_STREAM< ExtendedEltMergeType< T, Key > > *	outstr,
		long	K
	)

protected

!! KEYS BELONGS NOW TO MERGEHEAP, AND WILL BE DELETED BY THE

Definition at line 1257 of file empq_impl.h.

References AMI_ERROR_END_OF_STREAM, AMI_ERROR_NO_ERROR, AMI_STREAM< T >::AMI_STREAM(), assert, UntypedStream::buf, MEMORY_LOG(), MY_LOG_DEBUG_ID, NULL, AMI_STREAM< T >::read_item(), AMI_STREAM< T >::seek(), AMI_STREAM< T >::stream_len(), and AMI_STREAM< T >::write_item().

◆ merge_bufs2pq()

template<class T , class Key >

void em_pqueue< T, Key >::merge_bufs2pq ( AMI_STREAM< ExtendedEltMergeType< T, Key > > * minstream )

protected

Definition at line 851 of file empq_impl.h.

References AMI_ERROR_END_OF_STREAM, AMI_ERROR_NO_ERROR, AMI_STREAM< T >::AMI_STREAM(), assert, MY_LOG_DEBUG_ID, AMI_STREAM< T >::read_item(), AMI_STREAM< T >::seek(), and XXX.

◆ merge_streams()

template<class T , class Key >

AMI_err em_pqueue< T, Key >::merge_streams	(	AMI_STREAM< ExtendedEltMergeType< T, Key > > **	instr,
		unsigned short	arity,
		AMI_STREAM< ExtendedEltMergeType< T, Key > > *	outstr,
		long	K
	)

protected

!! KEYS BELONGS NOW TO MERGEHEAP, AND WILL BE DELETED BY THE

Definition at line 1380 of file empq_impl.h.

References AMI_ERROR_END_OF_STREAM, AMI_ERROR_NO_ERROR, AMI_STREAM< T >::AMI_STREAM(), assert, MEMORY_LOG(), MY_LOG_DEBUG_ID, AMI_STREAM< T >::read_item(), AMI_STREAM< T >::seek(), and AMI_STREAM< T >::write_item().

◆ min()

template<class T , class Key >

bool em_pqueue< T, Key >::min ( T & elt )

Definition at line 658 of file empq_impl.h.

References AMI_STREAM< T >::AMI_STREAM(), assert, MY_LOG_DEBUG_ID, and XXX.

◆ print()

template<class T , class Key >

void em_pqueue< T, Key >::print ( )

Definition at line 1523 of file empq_impl.h.

◆ print_range()

template<class T , class Key >

void em_pqueue< T, Key >::print_range ( )

Definition at line 1498 of file empq_impl.h.

◆ print_size()

template<class T , class Key >

void em_pqueue< T, Key >::print_size ( )

Definition at line 1546 of file empq_impl.h.

References assert.

◆ print_stream_sizes()

template<class T , class Key >

void em_pqueue< T, Key >::print_stream_sizes ( )

protected

Definition at line 1568 of file empq_impl.h.

◆ size()

template<class T , class Key >

unsigned long em_pqueue< T, Key >::size ( )

Definition at line 550 of file empq_impl.h.

Friends And Related Symbol Documentation

◆ operator<<

template<class T , class Key >

ostream & operator<<	(	ostream &	s,
		const em_pqueue< T, Key > &	empq
	)

friend

Definition at line 221 of file empq.h.

The documentation for this class was generated from the following files:

Public Member Functions

Protected Member Functions

Friends

Detailed Description

Constructor & Destructor Documentation

◆ em_pqueue() [1/5]

◆ em_pqueue() [2/5]

◆ em_pqueue() [3/5]

◆ em_pqueue() [4/5]

◆ em_pqueue() [5/5]

◆ ~em_pqueue()

Member Function Documentation

◆ active_streams()

◆ cleanup()

◆ clear()

◆ delete_str_elt()

◆ empty_buff()

◆ empty_buff_0()

◆ extract_all_min()

◆ extract_min()

◆ fillpq()

◆ insert()

◆ is_empty()

◆ is_full()

◆ maxlen() [1/2]

◆ maxlen() [2/2]

◆ merge_buffer()

◆ merge_bufs2pq()

◆ merge_streams()

◆ min()

◆ print()

◆ print_range()

◆ print_size()

◆ print_stream_sizes()

◆ size()

Friends And Related Symbol Documentation

◆ operator<<