diff --git a/opm/core/wells/WellsManager.cpp b/opm/core/wells/WellsManager.cpp index 64bb62338..20594ab34 100644 --- a/opm/core/wells/WellsManager.cpp +++ b/opm/core/wells/WellsManager.cpp @@ -308,13 +308,13 @@ namespace Opm /// Default constructor. WellsManager::WellsManager() - : w_(0) + : w_(0), is_parallel_run_() { } /// Construct from existing wells object. WellsManager::WellsManager(struct Wells* W) - : w_(clone_wells(W)) + : w_(clone_wells(W)), is_parallel_run_() { } @@ -323,7 +323,7 @@ namespace Opm const size_t timeStep, const UnstructuredGrid& grid, const double* permeability) - : w_(0) + : w_(0), is_parallel_run_() { init(eclipseState, timeStep, UgGridHelpers::numCells(grid), UgGridHelpers::globalCell(grid), UgGridHelpers::cartDims(grid), diff --git a/opm/core/wells/WellsManager.hpp b/opm/core/wells/WellsManager.hpp index 2d024a43b..0094f2114 100644 --- a/opm/core/wells/WellsManager.hpp +++ b/opm/core/wells/WellsManager.hpp @@ -81,7 +81,8 @@ namespace Opm int dimensions, const F2C& f2c, FC begin_face_centroids, - const double* permeability); + const double* permeability, + bool is_parallel_run=false); WellsManager(const Opm::EclipseStateConstPtr eclipseState, const size_t timeStep, @@ -177,6 +178,8 @@ namespace Opm // Data Wells* w_; WellCollection well_collection_; + // Whether this is a parallel simulation + bool is_parallel_run_; }; } // namespace Opm diff --git a/opm/core/wells/WellsManager_impl.hpp b/opm/core/wells/WellsManager_impl.hpp index 7840efc71..fe0e85c1d 100644 --- a/opm/core/wells/WellsManager_impl.hpp +++ b/opm/core/wells/WellsManager_impl.hpp @@ -8,6 +8,7 @@ #include #include #include +#include namespace WellsManagerDetail { @@ -121,7 +122,9 @@ void WellsManager::createWellsFromSpecs(std::vector& wells, size_t } std::vector > wellperf_data; + std::vector well_on_proc; wellperf_data.resize(wells.size()); + well_on_proc.resize(wells.size(), 1); int well_index = 0; for (auto wellIter= wells.begin(); wellIter != wells.end(); ++wellIter) { @@ -131,23 +134,9 @@ void WellsManager::createWellsFromSpecs(std::vector& wells, size_t continue; } - { // WELSPECS handling - well_names_to_index[well->name()] = well_index; - well_names.push_back(well->name()); - { - WellData wd; - wd.reference_bhp_depth = well->getRefDepth(); - wd.welspecsline = -1; - if (well->isInjector( timeStep )) - wd.type = INJECTOR; - else - wd.type = PRODUCER; - well_data.push_back(wd); - } - } - { // COMPDAT handling CompletionSetConstPtr completionSet = well->getCompletions(timeStep); + std::vector completion_on_proc(completionSet->size(), 1); for (size_t c=0; csize(); c++) { CompletionConstPtr completion = completionSet->get(c); if (completion->getState() == WellCompletion::OPEN) { @@ -159,6 +148,15 @@ void WellsManager::createWellsFromSpecs(std::vector& wells, size_t int cart_grid_indx = i + cpgdim[0]*(j + cpgdim[1]*k); std::map::const_iterator cgit = cartesian_to_compressed.find(cart_grid_indx); if (cgit == cartesian_to_compressed.end()) { + if ( is_parallel_run_ ) + { + // \todo remove hack for parallel runs! HACK! + std::cerr<<" Warning: Cell with i,j,k indices " << i << ' ' << j << ' ' + << k << " not found in grid (well = " << well->name() + << ") Assuming a parallel run and ignoring it"<name()] = well_index; + well_names.push_back(well->name()); + { + WellData wd; + wd.reference_bhp_depth = well->getRefDepth(); + wd.welspecsline = -1; + if (well->isInjector( timeStep )) + wd.type = INJECTOR; + else + wd.type = PRODUCER; + well_data.push_back(wd); + } + } + well_index++; } @@ -260,8 +289,9 @@ WellsManager(const Opm::EclipseStateConstPtr eclipseState, int dimensions, const C2F& cell_to_faces, FC begin_face_centroids, - const double* permeability) - : w_(0) + const double* permeability, + bool is_parallel_run) + : w_(0), is_parallel_run_(is_parallel_run) { init(eclipseState, timeStep, number_of_cells, global_cell, cart_dims, dimensions,