44 |
|
* @file SimCreator.cpp |
45 |
|
* @author tlin |
46 |
|
* @date 11/03/2004 |
47 |
– |
* @time 13:51am |
47 |
|
* @version 1.0 |
48 |
|
*/ |
49 |
|
#include <exception> |
254 |
|
std::string mdRawData; |
255 |
|
int metaDataBlockStart = -1; |
256 |
|
int metaDataBlockEnd = -1; |
257 |
< |
int i; |
257 |
> |
int i, j; |
258 |
|
streamoff mdOffset; |
259 |
|
int mdFileVersion; |
260 |
+ |
|
261 |
+ |
// Create a string for embedding the version information in the MetaData |
262 |
+ |
std::string version; |
263 |
+ |
version.assign("## Last run using OpenMD Version: "); |
264 |
+ |
version.append(OPENMD_VERSION_MAJOR); |
265 |
+ |
version.append("."); |
266 |
+ |
version.append(OPENMD_VERSION_MINOR); |
267 |
|
|
268 |
+ |
std::string svnrev; |
269 |
+ |
//convert a macro from compiler to a string in c++ |
270 |
+ |
STR_DEFINE(svnrev, SVN_REV ); |
271 |
+ |
version.append(" Revision: "); |
272 |
+ |
// If there's no SVN revision, just call this the RELEASE revision. |
273 |
+ |
if (!svnrev.empty()) { |
274 |
+ |
version.append(svnrev); |
275 |
+ |
} else { |
276 |
+ |
version.append("RELEASE"); |
277 |
+ |
} |
278 |
+ |
|
279 |
|
#ifdef IS_MPI |
280 |
|
const int masterNode = 0; |
281 |
|
if (worldRank == masterNode) { |
282 |
|
#endif |
283 |
|
|
284 |
< |
std::ifstream mdFile_(mdFileName.c_str()); |
284 |
> |
std::ifstream mdFile_; |
285 |
> |
mdFile_.open(mdFileName.c_str(), ifstream::in | ifstream::binary); |
286 |
|
|
287 |
|
if (mdFile_.fail()) { |
288 |
|
sprintf(painCave.errMsg, |
370 |
|
|
371 |
|
mdRawData.clear(); |
372 |
|
|
373 |
+ |
bool foundVersion = false; |
374 |
+ |
|
375 |
|
for (int i = 0; i < metaDataBlockEnd - metaDataBlockStart - 1; ++i) { |
376 |
|
mdFile_.getline(buffer, bufferSize); |
377 |
< |
mdRawData += buffer; |
377 |
> |
std::string line = trimLeftCopy(buffer); |
378 |
> |
j = CaseInsensitiveFind(line, "## Last run using OpenMD Version"); |
379 |
> |
if (static_cast<size_t>(j) != string::npos) { |
380 |
> |
foundVersion = true; |
381 |
> |
mdRawData += version; |
382 |
> |
} else { |
383 |
> |
mdRawData += buffer; |
384 |
> |
} |
385 |
|
mdRawData += "\n"; |
386 |
|
} |
387 |
< |
|
387 |
> |
|
388 |
> |
if (!foundVersion) mdRawData += version + "\n"; |
389 |
> |
|
390 |
|
mdFile_.close(); |
391 |
|
|
392 |
|
#ifdef IS_MPI |
534 |
|
int nGlobalMols = info->getNGlobalMolecules(); |
535 |
|
std::vector<int> molToProcMap(nGlobalMols, -1); // default to an error condition: |
536 |
|
|
537 |
< |
MPI_Comm_size(MPI_COMM_WORLD, &nProcessors); |
537 |
> |
nProcessors = MPI::COMM_WORLD.Get_size(); |
538 |
|
|
539 |
|
if (nProcessors > nGlobalMols) { |
540 |
|
sprintf(painCave.errMsg, |
572 |
|
nTarget = (int)(precast + 0.5); |
573 |
|
|
574 |
|
for(i = 0; i < nGlobalMols; i++) { |
575 |
+ |
|
576 |
|
done = 0; |
577 |
|
loops = 0; |
578 |
|
|
597 |
|
// and be done with it. |
598 |
|
|
599 |
|
if (loops > 100) { |
600 |
+ |
|
601 |
|
sprintf(painCave.errMsg, |
602 |
< |
"I've tried 100 times to assign molecule %d to a " |
603 |
< |
" processor, but can't find a good spot.\n" |
604 |
< |
"I'm assigning it at random to processor %d.\n", |
605 |
< |
i, which_proc); |
606 |
< |
|
602 |
> |
"There have been 100 attempts to assign molecule %d to an\n" |
603 |
> |
"\tunderworked processor, but there's no good place to\n" |
604 |
> |
"\tleave it. OpenMD is assigning it at random to processor %d.\n", |
605 |
> |
i, which_proc); |
606 |
> |
|
607 |
|
painCave.isFatal = 0; |
608 |
+ |
painCave.severity = OPENMD_INFO; |
609 |
|
simError(); |
610 |
|
|
611 |
|
molToProcMap[i] = which_proc; |
650 |
|
} |
651 |
|
|
652 |
|
delete myRandom; |
653 |
< |
|
653 |
> |
|
654 |
|
// Spray out this nonsense to all other processors: |
655 |
< |
|
624 |
< |
MPI_Bcast(&molToProcMap[0], nGlobalMols, MPI_INT, 0, MPI_COMM_WORLD); |
655 |
> |
MPI::COMM_WORLD.Bcast(&molToProcMap[0], nGlobalMols, MPI::INT, 0); |
656 |
|
} else { |
657 |
|
|
658 |
|
// Listen to your marching orders from processor 0: |
659 |
< |
|
660 |
< |
MPI_Bcast(&molToProcMap[0], nGlobalMols, MPI_INT, 0, MPI_COMM_WORLD); |
659 |
> |
MPI::COMM_WORLD.Bcast(&molToProcMap[0], nGlobalMols, MPI::INT, 0); |
660 |
> |
|
661 |
|
} |
662 |
|
|
663 |
|
info->setMolToProcMap(molToProcMap); |
704 |
|
set<AtomType*>::iterator i; |
705 |
|
bool hasDirectionalAtoms = false; |
706 |
|
bool hasFixedCharge = false; |
707 |
< |
bool hasMultipoles = false; |
707 |
> |
bool hasDipoles = false; |
708 |
> |
bool hasQuadrupoles = false; |
709 |
|
bool hasPolarizable = false; |
710 |
|
bool hasFluctuatingCharge = false; |
711 |
|
bool hasMetallic = false; |
727 |
|
if (da.isDirectional()){ |
728 |
|
hasDirectionalAtoms = true; |
729 |
|
} |
730 |
< |
if (ma.isMultipole()){ |
731 |
< |
hasMultipoles = true; |
730 |
> |
if (ma.isDipole()){ |
731 |
> |
hasDipoles = true; |
732 |
|
} |
733 |
+ |
if (ma.isQuadrupole()){ |
734 |
+ |
hasQuadrupoles = true; |
735 |
+ |
} |
736 |
|
if (ea.isEAM() || sca.isSuttonChen()){ |
737 |
|
hasMetallic = true; |
738 |
|
} |
756 |
|
storageLayout |= DataStorage::dslTorque; |
757 |
|
} |
758 |
|
} |
759 |
< |
if (hasMultipoles) { |
760 |
< |
storageLayout |= DataStorage::dslElectroFrame; |
759 |
> |
if (hasDipoles) { |
760 |
> |
storageLayout |= DataStorage::dslDipole; |
761 |
|
} |
762 |
+ |
if (hasQuadrupoles) { |
763 |
+ |
storageLayout |= DataStorage::dslQuadrupole; |
764 |
+ |
} |
765 |
|
if (hasFixedCharge || hasFluctuatingCharge) { |
766 |
|
storageLayout |= DataStorage::dslSkippedCharge; |
767 |
|
} |
799 |
|
if (simParams->getOutputElectricField()) { |
800 |
|
storageLayout |= DataStorage::dslElectricField; |
801 |
|
} |
802 |
+ |
|
803 |
|
if (simParams->getOutputFluctuatingCharges()) { |
804 |
|
storageLayout |= DataStorage::dslFlucQPosition; |
805 |
|
storageLayout |= DataStorage::dslFlucQVelocity; |
823 |
|
int beginRigidBodyIndex; |
824 |
|
int beginCutoffGroupIndex; |
825 |
|
int nGlobalAtoms = info->getNGlobalAtoms(); |
826 |
+ |
int nGlobalRigidBodies = info->getNGlobalRigidBodies(); |
827 |
|
|
828 |
|
beginAtomIndex = 0; |
829 |
|
//rigidbody's index begins right after atom's |
890 |
|
// This would be prettier if we could use MPI_IN_PLACE like the MPI-2 |
891 |
|
// docs said we could. |
892 |
|
std::vector<int> tmpGroupMembership(info->getNGlobalAtoms(), 0); |
893 |
< |
MPI_Allreduce(&globalGroupMembership[0], &tmpGroupMembership[0], nGlobalAtoms, |
894 |
< |
MPI_INT, MPI_SUM, MPI_COMM_WORLD); |
893 |
> |
MPI::COMM_WORLD.Allreduce(&globalGroupMembership[0], |
894 |
> |
&tmpGroupMembership[0], nGlobalAtoms, |
895 |
> |
MPI::INT, MPI::SUM); |
896 |
|
info->setGlobalGroupMembership(tmpGroupMembership); |
897 |
|
#else |
898 |
|
info->setGlobalGroupMembership(globalGroupMembership); |
899 |
|
#endif |
900 |
|
|
901 |
|
//fill molMembership |
902 |
< |
std::vector<int> globalMolMembership(info->getNGlobalAtoms(), 0); |
902 |
> |
std::vector<int> globalMolMembership(info->getNGlobalAtoms() + |
903 |
> |
info->getNGlobalRigidBodies(), 0); |
904 |
|
|
905 |
< |
for(mol = info->beginMolecule(mi); mol != NULL; mol = info->nextMolecule(mi)) { |
905 |
> |
for(mol = info->beginMolecule(mi); mol != NULL; |
906 |
> |
mol = info->nextMolecule(mi)) { |
907 |
|
for(atom = mol->beginAtom(ai); atom != NULL; atom = mol->nextAtom(ai)) { |
908 |
|
globalMolMembership[atom->getGlobalIndex()] = mol->getGlobalIndex(); |
909 |
|
} |
910 |
+ |
for (rb = mol->beginRigidBody(ri); rb != NULL; |
911 |
+ |
rb = mol->nextRigidBody(ri)) { |
912 |
+ |
globalMolMembership[rb->getGlobalIndex()] = mol->getGlobalIndex(); |
913 |
+ |
} |
914 |
|
} |
915 |
|
|
916 |
|
#ifdef IS_MPI |
917 |
< |
std::vector<int> tmpMolMembership(info->getNGlobalAtoms(), 0); |
917 |
> |
std::vector<int> tmpMolMembership(info->getNGlobalAtoms() + |
918 |
> |
info->getNGlobalRigidBodies(), 0); |
919 |
> |
MPI::COMM_WORLD.Allreduce(&globalMolMembership[0], &tmpMolMembership[0], |
920 |
> |
nGlobalAtoms + nGlobalRigidBodies, |
921 |
> |
MPI::INT, MPI::SUM); |
922 |
|
|
872 |
– |
MPI_Allreduce(&globalMolMembership[0], &tmpMolMembership[0], nGlobalAtoms, |
873 |
– |
MPI_INT, MPI_SUM, MPI_COMM_WORLD); |
874 |
– |
|
923 |
|
info->setGlobalMolMembership(tmpMolMembership); |
924 |
|
#else |
925 |
|
info->setGlobalMolMembership(globalMolMembership); |
929 |
|
// here the molecules are listed by their global indices. |
930 |
|
|
931 |
|
std::vector<int> nIOPerMol(info->getNGlobalMolecules(), 0); |
932 |
< |
for (mol = info->beginMolecule(mi); mol != NULL; mol = info->nextMolecule(mi)) { |
932 |
> |
for (mol = info->beginMolecule(mi); mol != NULL; |
933 |
> |
mol = info->nextMolecule(mi)) { |
934 |
|
nIOPerMol[mol->getGlobalIndex()] = mol->getNIntegrableObjects(); |
935 |
|
} |
936 |
|
|
937 |
|
#ifdef IS_MPI |
938 |
|
std::vector<int> numIntegrableObjectsPerMol(info->getNGlobalMolecules(), 0); |
939 |
< |
MPI_Allreduce(&nIOPerMol[0], &numIntegrableObjectsPerMol[0], |
940 |
< |
info->getNGlobalMolecules(), MPI_INT, MPI_SUM, MPI_COMM_WORLD); |
939 |
> |
MPI::COMM_WORLD.Allreduce(&nIOPerMol[0], &numIntegrableObjectsPerMol[0], |
940 |
> |
info->getNGlobalMolecules(), MPI::INT, MPI::SUM); |
941 |
|
#else |
942 |
|
std::vector<int> numIntegrableObjectsPerMol = nIOPerMol; |
943 |
|
#endif |
951 |
|
} |
952 |
|
|
953 |
|
std::vector<StuntDouble*> IOIndexToIntegrableObject(info->getNGlobalIntegrableObjects(), (StuntDouble*)NULL); |
954 |
< |
for (mol = info->beginMolecule(mi); mol != NULL; mol = info->nextMolecule(mi)) { |
954 |
> |
for (mol = info->beginMolecule(mi); mol != NULL; |
955 |
> |
mol = info->nextMolecule(mi)) { |
956 |
|
int myGlobalIndex = mol->getGlobalIndex(); |
957 |
|
int globalIO = startingIOIndexForMol[myGlobalIndex]; |
958 |
|
for (StuntDouble* sd = mol->beginIntegrableObject(ioi); sd != NULL; |