| 1 | /* | 
| 2 | * Copyright (c) 2005 The University of Notre Dame. All Rights Reserved. | 
| 3 | * | 
| 4 | * The University of Notre Dame grants you ("Licensee") a | 
| 5 | * non-exclusive, royalty free, license to use, modify and | 
| 6 | * redistribute this software in source and binary code form, provided | 
| 7 | * that the following conditions are met: | 
| 8 | * | 
| 9 | * 1. Redistributions of source code must retain the above copyright | 
| 10 | *    notice, this list of conditions and the following disclaimer. | 
| 11 | * | 
| 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. | 
| 16 | * | 
| 17 | * This software is provided "AS IS," without a warranty of any | 
| 18 | * kind. All express or implied conditions, representations and | 
| 19 | * warranties, including any implied warranty of merchantability, | 
| 20 | * fitness for a particular purpose or non-infringement, are hereby | 
| 21 | * excluded.  The University of Notre Dame and its licensors shall not | 
| 22 | * be liable for any damages suffered by licensee as a result of | 
| 23 | * using, modifying or distributing the software or its | 
| 24 | * derivatives. In no event will the University of Notre Dame or its | 
| 25 | * licensors be liable for any lost revenue, profit or data, or for | 
| 26 | * direct, indirect, special, consequential, incidental or punitive | 
| 27 | * damages, however caused and regardless of the theory of liability, | 
| 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, 234107 (2008). | 
| 39 | * [4]  Kuang & Gezelter,  J. Chem. Phys. 133, 164101 (2010). | 
| 40 | * [5]  Vardeman, Stocker & Gezelter, J. Chem. Theory Comput. 7, 834 (2011). | 
| 41 | */ | 
| 42 |  | 
| 43 | #include "math/ParallelRandNumGen.hpp" | 
| 44 | #ifdef IS_MPI | 
| 45 | #include <mpi.h> | 
| 46 | #endif | 
| 47 |  | 
| 48 | namespace OpenMD { | 
| 49 |  | 
| 50 | int ParallelRandNumGen::nCreatedRNG_ = 0; | 
| 51 |  | 
| 52 | ParallelRandNumGen::ParallelRandNumGen(const uint32& oneSeed) { | 
| 53 |  | 
| 54 | unsigned long seed = oneSeed; | 
| 55 |  | 
| 56 | #ifdef IS_MPI | 
| 57 | const int masterNode = 0; | 
| 58 | MPI::COMM_WORLD.Bcast(&seed, 1, MPI::UNSIGNED_LONG, masterNode); | 
| 59 | #endif | 
| 60 |  | 
| 61 | if (seed != oneSeed) { | 
| 62 | sprintf(painCave.errMsg, | 
| 63 | "Using different seed to initialize ParallelRandNumGen.\n"); | 
| 64 | painCave.isFatal = 1;; | 
| 65 | simError(); | 
| 66 | } | 
| 67 |  | 
| 68 | int nProcessors; | 
| 69 | #ifdef IS_MPI | 
| 70 | nProcessors = MPI::COMM_WORLD.Get_size(); | 
| 71 | myRank_ = MPI::COMM_WORLD.Get_rank(); | 
| 72 | #else | 
| 73 | nProcessors = 1; | 
| 74 | myRank_ = 0; | 
| 75 | #endif | 
| 76 | //In order to generate independent random number stream, the | 
| 77 | //actual seed used by random number generator is the seed passed | 
| 78 | //to the constructor plus the number of random number generators | 
| 79 | //which are already created. | 
| 80 | unsigned long newSeed = oneSeed + nCreatedRNG_; | 
| 81 | mtRand_ = new MTRand(newSeed, nProcessors, myRank_); | 
| 82 |  | 
| 83 | ++nCreatedRNG_; | 
| 84 | } | 
| 85 |  | 
| 86 | ParallelRandNumGen::ParallelRandNumGen() { | 
| 87 |  | 
| 88 | int nProcessors; | 
| 89 | #ifdef IS_MPI | 
| 90 | nProcessors = MPI::COMM_WORLD.Get_size(); | 
| 91 | myRank_ = MPI::COMM_WORLD.Get_rank(); | 
| 92 | #else | 
| 93 | nProcessors = 1; | 
| 94 | myRank_ = 0; | 
| 95 | #endif | 
| 96 | mtRand_ = new MTRand(nProcessors, myRank_); | 
| 97 |  | 
| 98 | seed();       /** @todo calling virtual function in constructor is | 
| 99 | not a good design */ | 
| 100 | } | 
| 101 |  | 
| 102 |  | 
| 103 | void ParallelRandNumGen::seed( const uint32 oneSeed ) { | 
| 104 |  | 
| 105 | unsigned long seed = oneSeed; | 
| 106 | #ifdef IS_MPI | 
| 107 | const int masterNode = 0; | 
| 108 | MPI::COMM_WORLD.Bcast(&seed, 1, MPI::UNSIGNED_LONG, masterNode); | 
| 109 | #endif | 
| 110 | if (seed != oneSeed) { | 
| 111 | sprintf(painCave.errMsg, | 
| 112 | "Using different seed to initialize ParallelRandNumGen.\n"); | 
| 113 | painCave.isFatal = 1;; | 
| 114 | simError(); | 
| 115 | } | 
| 116 |  | 
| 117 | unsigned long newSeed = oneSeed +nCreatedRNG_; | 
| 118 | mtRand_->seed(newSeed); | 
| 119 |  | 
| 120 | ++nCreatedRNG_; | 
| 121 | } | 
| 122 |  | 
| 123 | void ParallelRandNumGen::seed() { | 
| 124 |  | 
| 125 | std::vector<uint32> bigSeed; | 
| 126 |  | 
| 127 | #ifdef IS_MPI | 
| 128 | int size; | 
| 129 | const int masterNode = 0; | 
| 130 | if (worldRank == masterNode) { | 
| 131 | #endif | 
| 132 |  | 
| 133 | bigSeed = mtRand_->generateSeeds(); | 
| 134 |  | 
| 135 | #ifdef IS_MPI | 
| 136 | size = bigSeed.size(); | 
| 137 | MPI::COMM_WORLD.Bcast(&size, 1, MPI::INT, masterNode); | 
| 138 | MPI::COMM_WORLD.Bcast(&bigSeed[0], size, MPI::UNSIGNED_LONG, masterNode); | 
| 139 | }else { | 
| 140 | MPI::COMM_WORLD.Bcast(&size, 1, MPI::INT, masterNode); | 
| 141 | bigSeed.resize(size); | 
| 142 | MPI::COMM_WORLD.Bcast(&bigSeed[0], size, MPI::UNSIGNED_LONG, masterNode); | 
| 143 | } | 
| 144 | #endif | 
| 145 |  | 
| 146 | if (bigSeed.size() == 1) { | 
| 147 | mtRand_->seed(bigSeed[0]); | 
| 148 | } else { | 
| 149 | mtRand_->seed(&bigSeed[0], bigSeed.size()); | 
| 150 | } | 
| 151 |  | 
| 152 | ++nCreatedRNG_; | 
| 153 | } | 
| 154 | } |