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