ReadParallel.hpp

Go to the documentation of this file.

#ifndef READ_PARALLEL_HPP
#define READ_PARALLEL_HPP
 
#include "moab/Forward.hpp"
#include "moab/ReaderIface.hpp"
#include "DebugOutput.hpp"
 
#include <string>
 
namespace moab
{
 
class ReadUtilIface;
class ParallelComm;
class Error;
 
class ReadParallel
{
 
  public:
    static ReaderIface* factory( Interface* );
 
    //! load a file
    ErrorCode load_file( const char* file_name,
                         const EntityHandle* file_set,
                         const FileOptions& opts,
                         const ReaderIface::SubsetList* subset_list = 0,
                         const Tag* file_id_tag                     = 0 );
 
    //! load multiple files
    ErrorCode load_file( const char** file_names,
                         const int num_files,
                         const EntityHandle* file_set,
                         const FileOptions& opts,
                         const ReaderIface::SubsetList* subset_list = 0,
                         const Tag* file_id_tag                     = 0 );
 
    ErrorCode load_file( const char** file_names,
                         const int num_files,
                         const EntityHandle* file_set,
                         int parallel_mode,
                         std::string& partition_tag_name,
                         std::vector< int >& partition_tag_vals,
                         bool distrib,
                         bool partition_by_rank,
                         std::vector< int >& pa_vec,
                         const FileOptions& opts,
                         const ReaderIface::SubsetList* subset_list,
                         const Tag* file_id_tag,
                         const int reader_rank,
                         const bool cputime,
                         const int resolve_dim,
                         const int shared_dim,
                         const int ghost_dim,
                         const int bridge_dim,
                         const int num_layers,
                         const int addl_ents );
    //! Constructor
    ReadParallel( Interface* impl = NULL, ParallelComm* pc = NULL );
 
    //! Destructor
    virtual ~ReadParallel() {}
 
    static const char* parallelOptsNames[];
 
    enum ParallelActions
    {
        PA_READ                     = 0,
        PA_READ_PART                = 1,
        PA_BROADCAST                = 2,
        PA_DELETE_NONLOCAL          = 3,
        PA_CHECK_GIDS_SERIAL        = 4,
        PA_GET_FILESET_ENTS         = 5,
        PA_RESOLVE_SHARED_ENTS      = 6,
        PA_EXCHANGE_GHOSTS          = 7,
        PA_RESOLVE_SHARED_SETS      = 8,
        PA_AUGMENT_SETS_WITH_GHOSTS = 9,
        PA_PRINT_PARALLEL           = 10,
        PA_CREATE_TRIVIAL_PARTITION = 11,
        PA_CORRECT_THIN_GHOSTS      = 12
    };
 
    static const char* ParallelActionsNames[];
 
    enum ParallelOpts
    {
        POPT_NONE = 0,
        POPT_BCAST,
        POPT_BCAST_DELETE,
        POPT_READ_DELETE,
        POPT_READ_PART,
        POPT_DEFAULT
    };
 
    //! PUBLIC TO ALLOW TESTING
    ErrorCode delete_nonlocal_entities( std::string& ptag_name,
                                        std::vector< int >& ptag_vals,
                                        bool distribute,
                                        EntityHandle file_set );
 
    ErrorCode delete_nonlocal_entities( EntityHandle file_set );
 
  protected:
    ErrorCode create_partition_sets( std::string& ptag_name, EntityHandle file_set );
 
  private:
    Interface* mbImpl;
 
    // each reader can keep track of its own pcomm
    ParallelComm* myPcomm;
 
    DebugOutput myDebug;
 
    Error* mError;
};
 
inline ErrorCode ReadParallel::load_file( const char* file_name,
                                          const EntityHandle* file_set,
                                          const FileOptions& opts,
                                          const ReaderIface::SubsetList* subset_list,
                                          const Tag* file_id_tag )
{
    return load_file( &file_name, 1, file_set, opts, subset_list, file_id_tag );
}
 
}  // namespace moab
 
#endif