MOAB: Mesh Oriented datABase  (version 5.4.1)
Public Member Functions | Public Attributes
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

moab::ParallelComm::Buffer::Buffer ( unsigned int  sz = 0) [inline]

Definition at line 1492 of file ParallelComm.hpp.

References reserve().

                                                         : mem_ptr( NULL ), buff_ptr( NULL ), alloc_size( 0 )
{
    if( new_size ) this->reserve( new_size );
}
moab::ParallelComm::Buffer::Buffer ( const Buffer &  other_buff) [inline]

Definition at line 1484 of file ParallelComm.hpp.

References alloc_size, buff_ptr, and mem_ptr.

{
    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 );
}
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

void moab::ParallelComm::Buffer::check_space ( unsigned int  addl_space) [inline]

Definition at line 1541 of file ParallelComm.hpp.

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().

{
    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 );
}
int moab::ParallelComm::Buffer::get_current_size ( ) [inline]

Definition at line 815 of file ParallelComm.hpp.

References buff_ptr, and mem_ptr.

Referenced by moab::ParallelComm::pack_entity_seq(), and moab::ParCommGraph::send_mesh_parts().

        {
            return (int)( buff_ptr - mem_ptr );
        }
int moab::ParallelComm::Buffer::get_stored_size ( ) [inline]

Definition at line 811 of file ParallelComm.hpp.

References mem_ptr.

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

        {
            return *( (int*)mem_ptr );
        }
void moab::ParallelComm::Buffer::reserve ( unsigned int  new_size) [inline]

Definition at line 1508 of file ParallelComm.hpp.

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

{

#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
}
void moab::ParallelComm::Buffer::reset_buffer ( size_t  buff_pos = 0) [inline]

Definition at line 796 of file ParallelComm.hpp.

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

        {
            reset_ptr( buff_pos );
            reserve( INITIAL_BUFF_SIZE );
        }
void moab::ParallelComm::Buffer::reset_ptr ( size_t  buff_pos = 0) [inline]

Definition at line 801 of file ParallelComm.hpp.

References alloc_size, buff_ptr, and mem_ptr.

Referenced by moab::ParallelComm::broadcast_entities(), pack_unpack_noremoteh(), moab::ParCommGraph::receive_mesh(), moab::ParCommGraph::receive_tag_values(), moab::ParallelComm::recv_buffer(), reset_buffer(), moab::ParallelComm::scatter_entities(), moab::ParCommGraph::send_mesh_parts(), moab::ParCommGraph::send_tag_values(), moab::ParallelComm::settle_intersection_points(), and test_packing().

        {
            assert( ( !mem_ptr && !buff_pos ) || ( alloc_size >= buff_pos ) );
            buff_ptr = mem_ptr + buff_pos;
        }
void moab::ParallelComm::Buffer::set_stored_size ( ) [inline]

Definition at line 807 of file ParallelComm.hpp.

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(), pack_unpack_noremoteh(), moab::ParallelComm::scatter_entities(), and moab::ParallelComm::settle_intersection_points().

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

Member Data Documentation

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().

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(), pack_unpack_noremoteh(), moab::ParCommGraph::receive_mesh(), moab::ParCommGraph::receive_tag_values(), reset_ptr(), moab::ParallelComm::scatter_entities(), moab::ParCommGraph::send_tag_values(), set_stored_size(), moab::ParallelComm::settle_intersection_points(), and test_packing().

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::ParCommGraph::receive_mesh(), moab::ParCommGraph::receive_tag_values(), moab::ParallelComm::recv_buffer(), reset_ptr(), moab::ParallelComm::scatter_entities(), moab::ParallelComm::send_buffer(), moab::ParCommGraph::send_mesh_parts(), moab::ParCommGraph::send_tag_values(), and set_stored_size().

List of all members.

The documentation for this class was generated from the following file:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines