6 |
|
* redistribute this software in source and binary code form, provided |
7 |
|
* that the following conditions are met: |
8 |
|
* |
9 |
< |
* 1. Acknowledgement of the program authors must be made in any |
10 |
< |
* publication of scientific results based in part on use of the |
11 |
< |
* program. An acceptable form of acknowledgement is citation of |
12 |
< |
* the article in which the program was described (Matthew |
13 |
< |
* A. Meineke, Charles F. Vardeman II, Teng Lin, Christopher |
14 |
< |
* J. Fennell and J. Daniel Gezelter, "OOPSE: An Object-Oriented |
15 |
< |
* Parallel Simulation Engine for Molecular Dynamics," |
16 |
< |
* J. Comput. Chem. 26, pp. 252-271 (2005)) |
17 |
< |
* |
18 |
< |
* 2. Redistributions of source code must retain the above copyright |
9 |
> |
* 1. Redistributions of source code must retain the above copyright |
10 |
|
* notice, this list of conditions and the following disclaimer. |
11 |
|
* |
12 |
< |
* 3. Redistributions in binary form must reproduce the above copyright |
12 |
> |
* 2. Redistributions in binary form must reproduce the above copyright |
13 |
|
* notice, this list of conditions and the following disclaimer in the |
14 |
|
* documentation and/or other materials provided with the |
15 |
|
* distribution. |
28 |
|
* arising out of the use of or inability to use software, even if the |
29 |
|
* University of Notre Dame has been advised of the possibility of |
30 |
|
* such damages. |
31 |
+ |
* |
32 |
+ |
* SUPPORT OPEN SCIENCE! If you use OpenMD or its source code in your |
33 |
+ |
* research, please cite the appropriate papers when you publish your |
34 |
+ |
* work. Good starting points are: |
35 |
+ |
* |
36 |
+ |
* [1] Meineke, et al., J. Comp. Chem. 26, 252-271 (2005). |
37 |
+ |
* [2] Fennell & Gezelter, J. Chem. Phys. 124, 234104 (2006). |
38 |
+ |
* [3] Sun, Lin & Gezelter, J. Chem. Phys. 128, 24107 (2008). |
39 |
+ |
* [4] Vardeman & Gezelter, in progress (2009). |
40 |
|
*/ |
41 |
|
|
42 |
|
/** |
79 |
|
#include "math/ParallelRandNumGen.hpp" |
80 |
|
#endif |
81 |
|
|
82 |
< |
namespace oopse { |
82 |
> |
namespace OpenMD { |
83 |
|
|
84 |
|
Globals* SimCreator::parseFile(std::istream& rawMetaDataStream, const std::string& filename, int startOfMetaDataBlock ){ |
85 |
|
Globals* simParams = NULL; |
214 |
|
painCave.isFatal = 1; |
215 |
|
simError(); |
216 |
|
} |
217 |
< |
catch (OOPSEException& e) { |
217 |
> |
catch (OpenMDException& e) { |
218 |
|
sprintf(painCave.errMsg, |
219 |
|
"%s\n", |
220 |
|
e.getMessage().c_str()); |
234 |
|
|
235 |
|
SimInfo* SimCreator::createSim(const std::string & mdFileName, |
236 |
|
bool loadInitCoords) { |
237 |
< |
|
237 |
> |
|
238 |
|
const int bufferSize = 65535; |
239 |
|
char buffer[bufferSize]; |
240 |
|
int lineNo = 0; |
262 |
|
mdFile_.getline(buffer, bufferSize); |
263 |
|
++lineNo; |
264 |
|
std::string line = trimLeftCopy(buffer); |
265 |
< |
i = CaseInsensitiveFind(line, "<OOPSE"); |
265 |
> |
i = CaseInsensitiveFind(line, "<OpenMD"); |
266 |
> |
if (static_cast<size_t>(i) == string::npos) { |
267 |
> |
// try the older file strings to see if that works: |
268 |
> |
i = CaseInsensitiveFind(line, "<OOPSE"); |
269 |
> |
} |
270 |
> |
|
271 |
|
if (static_cast<size_t>(i) == string::npos) { |
272 |
+ |
// still no luck! |
273 |
|
sprintf(painCave.errMsg, |
274 |
< |
"SimCreator: File: %s is not an OOPSE file!\n", |
274 |
> |
"SimCreator: File: %s is not a valid OpenMD file!\n", |
275 |
|
mdFileName.c_str()); |
276 |
|
painCave.isFatal = 1; |
277 |
|
simError(); |
369 |
|
} |
370 |
|
|
371 |
|
ff->parse(forcefieldFileName); |
366 |
– |
ff->setFortranForceOptions(); |
372 |
|
//create SimInfo |
373 |
|
SimInfo * info = new SimInfo(ff, simParams); |
374 |
|
|
386 |
|
//create the molecules |
387 |
|
createMolecules(info); |
388 |
|
|
384 |
– |
|
389 |
|
//allocate memory for DataStorage(circular reference, need to |
390 |
|
//break it) |
391 |
|
info->setSnapshotManager(new SimSnapshotManager(info)); |
411 |
|
|
412 |
|
if (loadInitCoords) |
413 |
|
loadCoordinates(info, mdFileName); |
410 |
– |
|
414 |
|
return info; |
415 |
|
} |
416 |
|
|
474 |
|
"\tthe number of molecules. This will not result in a \n" |
475 |
|
"\tusable division of atoms for force decomposition.\n" |
476 |
|
"\tEither try a smaller number of processors, or run the\n" |
477 |
< |
"\tsingle-processor version of OOPSE.\n", nProcessors, nGlobalMols); |
477 |
> |
"\tsingle-processor version of OpenMD.\n", nProcessors, nGlobalMols); |
478 |
|
|
479 |
|
painCave.isFatal = 1; |
480 |
|
simError(); |
589 |
|
MPI_Bcast(&molToProcMap[0], nGlobalMols, MPI_INT, 0, MPI_COMM_WORLD); |
590 |
|
} |
591 |
|
|
592 |
+ |
cerr << "molToProcMap:\n"; |
593 |
+ |
for (int i = 0; i < molToProcMap.size(); i++) { |
594 |
+ |
cerr << "m = " << i << " mtpr[m] = " << molToProcMap[i] <<"\n"; |
595 |
+ |
} |
596 |
+ |
|
597 |
|
info->setMolToProcMap(molToProcMap); |
598 |
|
sprintf(checkPointMsg, |
599 |
|
"Successfully divided the molecules among the processors.\n"); |
614 |
|
#endif |
615 |
|
|
616 |
|
stampId = info->getMoleculeStampId(i); |
617 |
< |
Molecule * mol = molCreator.createMolecule(info->getForceField(), info->getMoleculeStamp(stampId), |
618 |
< |
stampId, i, info->getLocalIndexManager()); |
617 |
> |
Molecule * mol = molCreator.createMolecule(info->getForceField(), |
618 |
> |
info->getMoleculeStamp(stampId), |
619 |
> |
stampId, i, |
620 |
> |
info->getLocalIndexManager()); |
621 |
|
|
622 |
|
info->addMolecule(mol); |
623 |
|
|
644 |
|
int beginRigidBodyIndex; |
645 |
|
int beginCutoffGroupIndex; |
646 |
|
int nGlobalAtoms = info->getNGlobalAtoms(); |
637 |
– |
|
638 |
– |
/**@todo fixme */ |
639 |
– |
#ifndef IS_MPI |
647 |
|
|
648 |
|
beginAtomIndex = 0; |
649 |
|
beginRigidBodyIndex = 0; |
650 |
|
beginCutoffGroupIndex = 0; |
651 |
< |
|
652 |
< |
#else |
646 |
< |
|
647 |
< |
int nproc; |
648 |
< |
int myNode; |
649 |
< |
|
650 |
< |
myNode = worldRank; |
651 |
< |
MPI_Comm_size(MPI_COMM_WORLD, &nproc); |
652 |
< |
|
653 |
< |
std::vector < int > tmpAtomsInProc(nproc, 0); |
654 |
< |
std::vector < int > tmpRigidBodiesInProc(nproc, 0); |
655 |
< |
std::vector < int > tmpCutoffGroupsInProc(nproc, 0); |
656 |
< |
std::vector < int > NumAtomsInProc(nproc, 0); |
657 |
< |
std::vector < int > NumRigidBodiesInProc(nproc, 0); |
658 |
< |
std::vector < int > NumCutoffGroupsInProc(nproc, 0); |
659 |
< |
|
660 |
< |
tmpAtomsInProc[myNode] = info->getNAtoms(); |
661 |
< |
tmpRigidBodiesInProc[myNode] = info->getNRigidBodies(); |
662 |
< |
tmpCutoffGroupsInProc[myNode] = info->getNCutoffGroups(); |
663 |
< |
|
664 |
< |
//do MPI_ALLREDUCE to exchange the total number of atoms, rigidbodies and cutoff groups |
665 |
< |
MPI_Allreduce(&tmpAtomsInProc[0], &NumAtomsInProc[0], nproc, MPI_INT, |
666 |
< |
MPI_SUM, MPI_COMM_WORLD); |
667 |
< |
MPI_Allreduce(&tmpRigidBodiesInProc[0], &NumRigidBodiesInProc[0], nproc, |
668 |
< |
MPI_INT, MPI_SUM, MPI_COMM_WORLD); |
669 |
< |
MPI_Allreduce(&tmpCutoffGroupsInProc[0], &NumCutoffGroupsInProc[0], nproc, |
670 |
< |
MPI_INT, MPI_SUM, MPI_COMM_WORLD); |
671 |
< |
|
672 |
< |
beginAtomIndex = 0; |
673 |
< |
beginRigidBodyIndex = 0; |
674 |
< |
beginCutoffGroupIndex = 0; |
675 |
< |
|
676 |
< |
for(int i = 0; i < myNode; i++) { |
677 |
< |
beginAtomIndex += NumAtomsInProc[i]; |
678 |
< |
beginRigidBodyIndex += NumRigidBodiesInProc[i]; |
679 |
< |
beginCutoffGroupIndex += NumCutoffGroupsInProc[i]; |
680 |
< |
} |
681 |
< |
|
682 |
< |
#endif |
683 |
< |
|
684 |
< |
//rigidbody's index begins right after atom's |
685 |
< |
beginRigidBodyIndex += info->getNGlobalAtoms(); |
686 |
< |
|
687 |
< |
for(mol = info->beginMolecule(mi); mol != NULL; |
688 |
< |
mol = info->nextMolecule(mi)) { |
651 |
> |
|
652 |
> |
for(int i = 0; i < info->getNGlobalMolecules(); i++) { |
653 |
|
|
654 |
< |
//local index(index in DataStorge) of atom is important |
655 |
< |
for(atom = mol->beginAtom(ai); atom != NULL; atom = mol->nextAtom(ai)) { |
656 |
< |
atom->setGlobalIndex(beginAtomIndex++); |
654 |
> |
#ifdef IS_MPI |
655 |
> |
if (info->getMolToProc(i) == worldRank) { |
656 |
> |
#endif |
657 |
> |
// stuff to do if I own this molecule |
658 |
> |
mol = info->getMoleculeByGlobalIndex(i); |
659 |
> |
|
660 |
> |
//local index(index in DataStorge) of atom is important |
661 |
> |
for(atom = mol->beginAtom(ai); atom != NULL; atom = mol->nextAtom(ai)) { |
662 |
> |
atom->setGlobalIndex(beginAtomIndex++); |
663 |
> |
} |
664 |
> |
|
665 |
> |
for(rb = mol->beginRigidBody(ri); rb != NULL; |
666 |
> |
rb = mol->nextRigidBody(ri)) { |
667 |
> |
rb->setGlobalIndex(beginRigidBodyIndex++); |
668 |
> |
} |
669 |
> |
|
670 |
> |
//local index of cutoff group is trivial, it only depends on |
671 |
> |
//the order of travesing |
672 |
> |
for(cg = mol->beginCutoffGroup(ci); cg != NULL; |
673 |
> |
cg = mol->nextCutoffGroup(ci)) { |
674 |
> |
cg->setGlobalIndex(beginCutoffGroupIndex++); |
675 |
> |
} |
676 |
> |
|
677 |
> |
#ifdef IS_MPI |
678 |
> |
} else { |
679 |
> |
|
680 |
> |
// stuff to do if I don't own this molecule |
681 |
> |
|
682 |
> |
int stampId = info->getMoleculeStampId(i); |
683 |
> |
MoleculeStamp* stamp = info->getMoleculeStamp(stampId); |
684 |
> |
|
685 |
> |
beginAtomIndex += stamp->getNAtoms(); |
686 |
> |
beginRigidBodyIndex += stamp->getNRigidBodies(); |
687 |
> |
beginCutoffGroupIndex += stamp->getNCutoffGroups() + stamp->getNFreeAtoms(); |
688 |
|
} |
689 |
< |
|
690 |
< |
for(rb = mol->beginRigidBody(ri); rb != NULL; |
691 |
< |
rb = mol->nextRigidBody(ri)) { |
692 |
< |
rb->setGlobalIndex(beginRigidBodyIndex++); |
698 |
< |
} |
699 |
< |
|
700 |
< |
//local index of cutoff group is trivial, it only depends on the order of travesing |
701 |
< |
for(cg = mol->beginCutoffGroup(ci); cg != NULL; |
702 |
< |
cg = mol->nextCutoffGroup(ci)) { |
703 |
< |
cg->setGlobalIndex(beginCutoffGroupIndex++); |
704 |
< |
} |
705 |
< |
} |
706 |
< |
|
689 |
> |
#endif |
690 |
> |
|
691 |
> |
} //end for(int i=0) |
692 |
> |
|
693 |
|
//fill globalGroupMembership |
694 |
|
std::vector<int> globalGroupMembership(info->getNGlobalAtoms(), 0); |
695 |
|
for(mol = info->beginMolecule(mi); mol != NULL; mol = info->nextMolecule(mi)) { |
701 |
|
|
702 |
|
} |
703 |
|
} |
704 |
< |
|
704 |
> |
|
705 |
|
#ifdef IS_MPI |
706 |
|
// Since the globalGroupMembership has been zero filled and we've only |
707 |
|
// poked values into the atoms we know, we can do an Allreduce |
712 |
|
MPI_Allreduce(&globalGroupMembership[0], &tmpGroupMembership[0], nGlobalAtoms, |
713 |
|
MPI_INT, MPI_SUM, MPI_COMM_WORLD); |
714 |
|
info->setGlobalGroupMembership(tmpGroupMembership); |
715 |
+ |
|
716 |
+ |
cerr << "ggm:\n"; |
717 |
+ |
for (int i = 0; i < tmpGroupMembership.size(); i++) |
718 |
+ |
cerr << "i = " << i << "\t ggm(i) = " << tmpGroupMembership[i] << "\n"; |
719 |
+ |
|
720 |
|
#else |
721 |
|
info->setGlobalGroupMembership(globalGroupMembership); |
722 |
|
#endif |
776 |
|
globalIO++; |
777 |
|
} |
778 |
|
} |
779 |
< |
|
779 |
> |
cerr << "ioi2io:\n"; |
780 |
> |
for (int i = 0; i < IOIndexToIntegrableObject.size(); i++) { |
781 |
> |
if (IOIndexToIntegrableObject[i] != NULL) { |
782 |
> |
cerr << "i = " << i << "globalIOindex = " << IOIndexToIntegrableObject[i]->getGlobalIntegrableObjectIndex() << "\n"; |
783 |
> |
} |
784 |
> |
} |
785 |
> |
|
786 |
|
info->setIOIndexToIntegrableObject(IOIndexToIntegrableObject); |
787 |
|
|
788 |
|
} |
789 |
|
|
790 |
|
void SimCreator::loadCoordinates(SimInfo* info, const std::string& mdFileName) { |
791 |
|
Globals* simParams; |
792 |
+ |
|
793 |
|
simParams = info->getSimParams(); |
794 |
|
|
797 |
– |
|
795 |
|
DumpReader reader(info, mdFileName); |
796 |
|
int nframes = reader.getNFrames(); |
797 |
< |
|
797 |
> |
|
798 |
|
if (nframes > 0) { |
799 |
|
reader.readFrame(nframes - 1); |
800 |
|
} else { |
805 |
|
painCave.isFatal = 1; |
806 |
|
simError(); |
807 |
|
} |
811 |
– |
|
808 |
|
//copy the current snapshot to previous snapshot |
809 |
|
info->getSnapshotManager()->advance(); |
810 |
|
} |
811 |
|
|
812 |
< |
} //end namespace oopse |
812 |
> |
} //end namespace OpenMD |
813 |
|
|
814 |
|
|