moab::ParallelComm::Buffer Class Reference

#include <ParallelComm.hpp>

Public Member Functions
	Buffer (unsigned int sz=0)
	Buffer (const Buffer &)
	~Buffer ()
void	reset_buffer (size_t buff_pos=0)
void	reset_ptr (size_t buff_pos=0)
void	reserve (unsigned int new_size)
void	set_stored_size ()
int	get_stored_size ()
int	get_current_size ()
void	check_space (unsigned int addl_space)

Public Attributes
unsigned char *	mem_ptr
unsigned char *	buff_ptr
unsigned int	alloc_size

Detailed Description

Definition at line 786 of file ParallelComm.hpp.

Constructor & Destructor Documentation

Buffer() [1/2]

moab::ParallelComm::Buffer::Buffer ( unsigned int  sz = 0 )

inline

Definition at line 1492 of file ParallelComm.hpp.

 : mem_ptr( NULL ), buff_ptr( NULL ), alloc_size( 0 )
{
 if( new_size ) this->reserve( new_size );
}

References reserve().

Buffer() [2/2]

moab::ParallelComm::Buffer::Buffer ( const Buffer &  other_buff )

inline

Definition at line 1484 of file ParallelComm.hpp.

{
 alloc_size = other_buff.alloc_size;
 mem_ptr = (unsigned char*)malloc( alloc_size );
 memcpy( mem_ptr, other_buff.mem_ptr, alloc_size );
 buff_ptr = mem_ptr + ( other_buff.buff_ptr - other_buff.mem_ptr );
}

References alloc_size, buff_ptr, and mem_ptr.

~Buffer()

moab::ParallelComm::Buffer::~Buffer ( )

inline

Definition at line 1497 of file ParallelComm.hpp.

{
 if( mem_ptr )
 {
 free( mem_ptr );
 mem_ptr = NULL;
 }
}

Member Function Documentation

check_space()

void moab::ParallelComm::Buffer::check_space ( unsigned int  addl_space )

inline

Definition at line 1541 of file ParallelComm.hpp.

{
 assert( buff_ptr >= mem_ptr && buff_ptr <= mem_ptr + alloc_size );
 unsigned int new_size = buff_ptr - mem_ptr + addl_space;
 if( new_size > alloc_size ) reserve( 3 * new_size / 2 );
}

Referenced by moab::ParallelComm::pack_buffer(), moab::ParallelComm::pack_entities(), moab::ParallelComm::pack_entity_seq(), moab::ParallelComm::pack_remote_handles(), moab::ParallelComm::pack_sets(), moab::ParallelComm::pack_tag(), moab::ParallelComm::pack_tags(), and moab::ParallelComm::settle_intersection_points().

get_current_size()

int moab::ParallelComm::Buffer::get_current_size ( )

inline

Definition at line 815 of file ParallelComm.hpp.

 {
 return (int)( buff_ptr - mem_ptr );
 }

References buff_ptr, and mem_ptr.

Referenced by moab::ParallelComm::pack_entity_seq().

get_stored_size()

int moab::ParallelComm::Buffer::get_stored_size ( )

inline

Definition at line 811 of file ParallelComm.hpp.

 {
 return *( (int*)mem_ptr );
 }

References mem_ptr.

Referenced by moab::ParallelComm::recv_buffer(), and moab::ParallelComm::send_buffer().

reserve()

void moab::ParallelComm::Buffer::reserve ( unsigned int  new_size )

inline

Definition at line 1508 of file ParallelComm.hpp.

{
 
#ifdef DEBUG_BUFFER
 int tmp_pos = 0;
 if( mem_ptr )
 {
 tmp_pos = buff_ptr - mem_ptr;
 }
 buff_ptr = (unsigned char*)malloc( new_size );
 assert( 0 <= tmp_pos && tmp_pos <= (int)alloc_size );
 if( tmp_pos ) memcpy( buff_ptr, mem_ptr, tmp_pos );
 if( mem_ptr ) free( mem_ptr );
 mem_ptr = buff_ptr;
 alloc_size = new_size;
 buff_ptr = mem_ptr + tmp_pos;
#else
 if( mem_ptr && alloc_size < new_size )
 {
 size_t tmp_pos = mem_ptr ? buff_ptr - mem_ptr : 0;
 mem_ptr = (unsigned char*)realloc( mem_ptr, new_size );
 alloc_size = new_size;
 buff_ptr = mem_ptr + tmp_pos;
 }
 else if( !mem_ptr )
 {
 mem_ptr = (unsigned char*)malloc( new_size );
 alloc_size = new_size;
 buff_ptr = mem_ptr;
 }
#endif
}

Referenced by moab::ParallelComm::broadcast_entities(), Buffer(), moab::ParallelComm::recv_buffer(), reset_buffer(), and moab::ParallelComm::scatter_entities().

reset_buffer()

void moab::ParallelComm::Buffer::reset_buffer ( size_t  buff_pos = 0 )

inline

Definition at line 796 of file ParallelComm.hpp.

 {
 reset_ptr( buff_pos );
 reserve( INITIAL_BUFF_SIZE );
 }

References moab::ParallelComm::INITIAL_BUFF_SIZE, reserve(), and reset_ptr().

reset_ptr()

void moab::ParallelComm::Buffer::reset_ptr ( size_t  buff_pos = 0 )

inline

Definition at line 801 of file ParallelComm.hpp.

 {
 assert( ( !mem_ptr && !buff_pos ) || ( alloc_size >= buff_pos ) );
 buff_ptr = mem_ptr + buff_pos;
 }

References alloc_size, buff_ptr, and mem_ptr.

Referenced by moab::ParallelComm::broadcast_entities(), moab::ParallelComm::recv_buffer(), reset_buffer(), moab::ParallelComm::scatter_entities(), and moab::ParallelComm::settle_intersection_points().

set_stored_size()

void moab::ParallelComm::Buffer::set_stored_size ( )

inline

Definition at line 807 of file ParallelComm.hpp.

 {
 *( (int*)mem_ptr ) = (int)( buff_ptr - mem_ptr );
 }

References buff_ptr, and mem_ptr.

Referenced by moab::ParallelComm::broadcast_entities(), moab::ParallelComm::pack_buffer(), moab::ParallelComm::pack_entities(), moab::ParallelComm::pack_remote_handles(), moab::ParallelComm::pack_sets(), moab::ParallelComm::pack_tags(), moab::ParallelComm::scatter_entities(), and moab::ParallelComm::settle_intersection_points().

Member Data Documentation

alloc_size

unsigned int moab::ParallelComm::Buffer::alloc_size

Definition at line 791 of file ParallelComm.hpp.

Referenced by Buffer(), moab::ParallelComm::recv_buffer(), reset_ptr(), and moab::ParallelComm::send_buffer().

buff_ptr

unsigned char* moab::ParallelComm::Buffer::buff_ptr

Definition at line 790 of file ParallelComm.hpp.

Referenced by moab::ParallelComm::broadcast_entities(), Buffer(), get_current_size(), moab::ParallelComm::pack_buffer(), moab::ParallelComm::pack_entities(), moab::ParallelComm::pack_entity_seq(), moab::ParallelComm::pack_remote_handles(), moab::ParallelComm::pack_sets(), moab::ParallelComm::pack_tag(), moab::ParallelComm::pack_tags(), reset_ptr(), moab::ParallelComm::scatter_entities(), set_stored_size(), and moab::ParallelComm::settle_intersection_points().

mem_ptr

unsigned char* moab::ParallelComm::Buffer::mem_ptr

Definition at line 789 of file ParallelComm.hpp.

Referenced by moab::ParallelComm::broadcast_entities(), Buffer(), get_current_size(), get_stored_size(), moab::ParallelComm::recv_buffer(), reset_ptr(), moab::ParallelComm::scatter_entities(), moab::ParallelComm::send_buffer(), and set_stored_size().

---

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

• ParallelComm.hpp