#include <embuffer.h>

Public Member Functions
	em_buffer (const unsigned short i, const unsigned long bs, const unsigned int ar)

	em_buffer (const em_buffer &buf)

	~em_buffer ()

unsigned short	get_level () const

AMI_STREAM< T > *	get_stream (unsigned int i)

AMI_STREAM< T > **	get_streams ()

void	put_stream (unsigned int i)

void	put_streams ()

long *	get_bos () const

unsigned int	laststream () const

unsigned int	nextstream () const

void	incr_nextstream ()

unsigned int	get_nbstreams () const

unsigned int	get_arity () const

long	total_deleted () const

void	incr_deleted (unsigned int i)

unsigned long	get_stream_maxlen () const

unsigned long	get_stream_len (unsigned int i)

unsigned long	get_buf_len ()

unsigned long	get_buf_maxlen ()

bool	is_empty ()

bool	is_full () const

void	reset ()

void	cleanup ()

AMI_STREAM< T > *	sort ()

long	insert (T *a, long n)

long	insert (AMI_STREAM< T > *str, long bos=0)

void	print_range ()

void	print ()

void	print_stream_sizes ()

Friends
ostream &	operator<< (ostream &s, em_buffer &b)

Detailed Description

template<class T, class Key>
class em_buffer< T, Key >

Definition at line 211 of file embuffer.h.

Constructor & Destructor Documentation

◆ em_buffer() [1/2]

template<class T , class Key >

em_buffer< T, Key >::em_buffer	(	const unsigned short	i,
		const unsigned long	bs,
		const unsigned int	ar
	)

Definition at line 448 of file embuffer.h.

References assert, MEMORY_LOG(), and NULL.

◆ em_buffer() [2/2]

template<class T , class Key >

em_buffer< T, Key >::em_buffer ( const em_buffer< T, Key > & buf )

Definition at line 510 of file embuffer.h.

References assert, em_buffer< T, Key >::get_streams(), MEMORY_LOG(), NULL, and em_buffer< T, Key >::put_streams().

◆ ~em_buffer()

template<class T , class Key >

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

Definition at line 544 of file embuffer.h.

References assert, em_buffer< T, Key >::get_streams(), and NULL.

Member Function Documentation

◆ cleanup()

template<class T , class Key >

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

Definition at line 786 of file embuffer.h.

References assert, em_buffer< T, Key >::get_stream_len(), em_buffer< T, Key >::get_streams(), MY_LOG_DEBUG_ID, NULL, em_buffer< T, Key >::print_stream_sizes(), and em_buffer< T, Key >::put_streams().

◆ get_arity()

template<class T, class Key>

unsigned int em_buffer< T, Key >::get_arity ( ) const

inline

Definition at line 291 of file embuffer.h.

◆ get_bos()

template<class T, class Key>

long* em_buffer< T, Key >::get_bos ( ) const

inline

Definition at line 276 of file embuffer.h.

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

◆ get_buf_len()

template<class T, class Key>

unsigned long em_buffer< T, Key >::get_buf_len ( )

inline

Definition at line 324 of file embuffer.h.

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

◆ get_buf_maxlen()

template<class T, class Key>

unsigned long em_buffer< T, Key >::get_buf_maxlen ( )

inline

Definition at line 333 of file embuffer.h.

◆ get_level()

template<class T, class Key>

unsigned short em_buffer< T, Key >::get_level ( ) const

inline

Definition at line 260 of file embuffer.h.

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

◆ get_nbstreams()

template<class T, class Key>

unsigned int em_buffer< T, Key >::get_nbstreams ( ) const

inline

Definition at line 288 of file embuffer.h.

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

◆ get_stream()

template<class T , class Key >

AMI_STREAM< T > * em_buffer< T, Key >::get_stream ( unsigned int i )

Definition at line 604 of file embuffer.h.

References assert, MY_LOG_DEBUG_ID, and NULL.

Referenced by em_buffer< T, Key >::get_streams().

◆ get_stream_len()

template<class T, class Key>

unsigned long em_buffer< T, Key >::get_stream_len ( unsigned int i )

inline

Definition at line 317 of file embuffer.h.

Referenced by em_buffer< T, Key >::cleanup(), em_buffer< T, Key >::print(), em_buffer< T, Key >::print_range(), and em_buffer< T, Key >::print_stream_sizes().

◆ get_stream_maxlen()

template<class T, class Key>

unsigned long em_buffer< T, Key >::get_stream_maxlen ( ) const

inline

Definition at line 311 of file embuffer.h.

◆ get_streams()

template<class T , class Key >

AMI_STREAM< T > ** em_buffer< T, Key >::get_streams ( )

Definition at line 705 of file embuffer.h.

References assert, em_buffer< T, Key >::get_stream(), and MY_LOG_DEBUG_ID.

Referenced by em_buffer< T, Key >::cleanup(), em_buffer< T, Key >::em_buffer(), em_pqueue< T, Key >::merge_buffer(), em_buffer< T, Key >::print(), em_buffer< T, Key >::print_range(), em_buffer< T, Key >::reset(), em_buffer< T, Key >::sort(), and em_buffer< T, Key >::~em_buffer().

◆ incr_deleted()

template<class T, class Key>

void em_buffer< T, Key >::incr_deleted ( unsigned int i )

inline

Definition at line 303 of file embuffer.h.

References assert.

◆ incr_nextstream()

template<class T, class Key>

void em_buffer< T, Key >::incr_nextstream ( )

inline

Definition at line 285 of file embuffer.h.

◆ insert() [1/2]

template<class T , class Key >

long em_buffer< T, Key >::insert	(	T *	a,
		long	n
	)

Definition at line 1089 of file embuffer.h.

◆ insert() [2/2]

template<class T , class Key >

long em_buffer< T, Key >::insert	(	AMI_STREAM< T > *	str,
		long	bos = `0`
	)

Definition at line 1139 of file embuffer.h.

References AMI_ERROR_NO_ERROR, assert, em_buffer< T, Key >::is_full(), em_buffer< T, Key >::nextstream(), NULL, AMI_STREAM< T >::read_item(), AMI_STREAM< T >::seek(), and AMI_STREAM< T >::stream_len().

◆ is_empty()

template<class T, class Key>

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

inline

Definition at line 338 of file embuffer.h.

◆ is_full()

template<class T, class Key>

bool em_buffer< T, Key >::is_full ( ) const

inline

Definition at line 343 of file embuffer.h.

Referenced by em_buffer< T, Key >::insert().

◆ laststream()

template<class T, class Key>

unsigned int em_buffer< T, Key >::laststream ( ) const

inline

Definition at line 279 of file embuffer.h.

◆ nextstream()

template<class T, class Key>

unsigned int em_buffer< T, Key >::nextstream ( ) const

inline

Definition at line 282 of file embuffer.h.

Referenced by em_buffer< T, Key >::insert().

◆ print()

template<class T , class Key >

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

Definition at line 1285 of file embuffer.h.

References AMI_ERROR_NO_ERROR, assert, em_buffer< T, Key >::get_stream_len(), em_buffer< T, Key >::get_streams(), em_buffer< T, Key >::put_streams(), and x.

◆ print_range()

template<class T , class Key >

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

Definition at line 1250 of file embuffer.h.

References AMI_ERROR_NO_ERROR, assert, em_buffer< T, Key >::get_stream_len(), em_buffer< T, Key >::get_streams(), max, min, and em_buffer< T, Key >::put_streams().

◆ print_stream_sizes()

template<class T , class Key >

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

Definition at line 1315 of file embuffer.h.

References em_buffer< T, Key >::get_stream_len().

Referenced by em_buffer< T, Key >::cleanup().

◆ put_stream()

template<class T , class Key >

void em_buffer< T, Key >::put_stream ( unsigned int i )

Definition at line 665 of file embuffer.h.

References assert, MY_LOG_DEBUG_ID, NULL, and PERSIST_PERSISTENT.

Referenced by em_buffer< T, Key >::put_streams().

◆ put_streams()

template<class T , class Key >

void em_buffer< T, Key >::put_streams ( )

Definition at line 732 of file embuffer.h.

References assert, MY_LOG_DEBUG_ID, NULL, and em_buffer< T, Key >::put_stream().

Referenced by em_buffer< T, Key >::cleanup(), em_buffer< T, Key >::em_buffer(), em_pqueue< T, Key >::merge_buffer(), em_buffer< T, Key >::print(), em_buffer< T, Key >::print_range(), and em_buffer< T, Key >::sort().

◆ reset()

template<class T , class Key >

void em_buffer< T, Key >::reset ( )

Definition at line 903 of file embuffer.h.

References assert, em_buffer< T, Key >::get_streams(), NULL, and PERSIST_DELETE.

◆ sort()

template<class T , class Key >

AMI_STREAM< T > * em_buffer< T, Key >::sort ( )

Definition at line 937 of file embuffer.h.

References AMI_ERROR_END_OF_STREAM, AMI_ERROR_NO_ERROR, assert, pqheap_t1< T >::delete_min(), pqheap_t1< T >::delete_min_and_insert(), pqheap_t1< T >::empty(), em_buffer< T, Key >::get_streams(), MEMORY_LOG(), pqheap_t1< T >::min(), NULL, em_buffer< T, Key >::put_streams(), AMI_STREAM< T >::seek(), merge_key< KEY >::set(), merge_key< KEY >::stream_id(), and AMI_STREAM< T >::write_item().

◆ total_deleted()

template<class T, class Key>

long em_buffer< T, Key >::total_deleted ( ) const

inline

Definition at line 294 of file embuffer.h.

Friends And Related Function Documentation

◆ operator<<

template<class T, class Key>

ostream& operator<<	(	ostream &	s,
		em_buffer< T, Key > &	b
	)

friend

Definition at line 395 of file embuffer.h.

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

embuffer.h

Public Member Functions

Friends

Detailed Description

template<class T, class Key> class em_buffer< T, Key >

Constructor & Destructor Documentation

◆ em_buffer() [1/2]

◆ em_buffer() [2/2]

◆ ~em_buffer()

Member Function Documentation

◆ cleanup()

◆ get_arity()

◆ get_bos()

◆ get_buf_len()

◆ get_buf_maxlen()

◆ get_level()

◆ get_nbstreams()

◆ get_stream()

◆ get_stream_len()

◆ get_stream_maxlen()

◆ get_streams()

◆ incr_deleted()

◆ incr_nextstream()

◆ insert() [1/2]

◆ insert() [2/2]

◆ is_empty()

◆ is_full()

◆ laststream()

◆ nextstream()

◆ print()

◆ print_range()

◆ print_stream_sizes()

◆ put_stream()

◆ put_streams()

◆ reset()

◆ sort()

◆ total_deleted()

Friends And Related Function Documentation

◆ operator<<

template<class T, class Key>
class em_buffer< T, Key >