OOPSE/libmdtools/InitializeFromFile.cpp

#define _FILE_OFFSET_BITS 64
#include <iostream>
#include <math.h>

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>

#include "ReadWrite.hpp"
#include "simError.h"
#include "GenericData.hpp"

#ifdef IS_MPI
#include <mpi.h>
#include "mpiSimulation.hpp"
#define TAKE_THIS_TAG_CHAR 3134
#define TAKE_THIS_TAG_INT 3135

namespace initFile{
  void nodeZeroError( void );
  void anonymousNodeDie( void );
}

using namespace initFile;

#endif // is_mpi

InitializeFromFile::InitializeFromFile( char *in_name ){

#ifdef IS_MPI
  if (worldRank == 0) {
#endif

  c_in_file = fopen(in_name, "r");
  if(c_in_file == NULL){
    sprintf(painCave.errMsg,
            "Cannot open file: %s\n", in_name);
    painCave.isFatal = 1;
    simError();
  }

  strcpy( c_in_name, in_name);
#ifdef IS_MPI
  }
  else{
          sprintf( c_in_name, "mpiNodeParser_%d", worldRank );
  }
  
  strcpy( checkPointMsg, "Infile opened for reading successfully." );
  MPIcheckPoint();
#endif
  return;
}

InitializeFromFile::~InitializeFromFile( ){
#ifdef IS_MPI
  if (worldRank == 0) {
#endif
  int error;
  error = fclose( c_in_file );
  if( error ){
    sprintf( painCave.errMsg,
             "Error closing %s\n", c_in_name );
    simError();
  }
#ifdef IS_MPI
  }
  strcpy( checkPointMsg, "Infile closed successfully." );
  MPIcheckPoint();
#endif

  return;
}


void InitializeFromFile :: readInit( SimInfo* the_simnfo ){

  int i, j;

#ifdef IS_MPI
  int done, which_node, which_atom; // loop counter
#endif //is_mpi

  const int BUFFERSIZE = 2000; // size of the read buffer
  int nTotObjs; // the number of atoms
  char read_buffer[BUFFERSIZE]; //the line buffer for reading

  char *eof_test; // ptr to see when we reach the end of the file
  char *parseErr;

  vector<StuntDouble*> integrableObjects;

  simnfo = the_simnfo;


#ifndef IS_MPI
  eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
  if( eof_test == NULL ){
    sprintf( painCave.errMsg,
             "InitializeFromFile error: error reading 1st line of \"%s\"\n",
             c_in_name );
    painCave.isFatal = 1;
    simError();
  }

  nTotObjs = atoi( read_buffer );

  if( nTotObjs != simnfo->getTotIntegrableObjects() ){
    sprintf( painCave.errMsg,
             "Initialize from File error. %s n_atoms, %d, "
             "does not match the BASS file's n_atoms, %d.\n",
             c_in_name, nTotObjs, simnfo->getTotIntegrableObjects());
    painCave.isFatal = 1;
    simError();
  }

  //read the box mat from the comment line

  eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
  if(eof_test == NULL){
    sprintf( painCave.errMsg,
             "error in reading commment in %s\n", c_in_name);
    painCave.isFatal = 1;
    simError();
  }

  parseErr = parseCommentLine( read_buffer, simnfo);
  if( parseErr != NULL ){
    strcpy( painCave.errMsg, parseErr );
    painCave.isFatal = 1;
    simError();
  }

  //parse dump lines

  for( i=0; i < simnfo->n_mol; i++){

    integrableObjects = (simnfo->molecules[i]).getIntegrableObjects();

    for(j = 0; j < integrableObjects.size(); j++){

      eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
      if(eof_test == NULL){
        sprintf(painCave.errMsg,
              "error in reading file %s\n"
              "natoms  = %d; index = %d\n"
              "error reading the line from the file.\n",
              c_in_name, nTotObjs, i );
        painCave.isFatal = 1;
        simError();
      }
      
      parseErr = parseDumpLine( read_buffer, integrableObjects[j]);
      if( parseErr != NULL ){
        strcpy( painCave.errMsg, parseErr );
        painCave.isFatal = 1;
        simError();
      }
    }
  }

  // MPI Section of code..........
#else //IS_MPI

  // first thing first, suspend fatalities.
  painCave.isEventLoop = 1;

  int myStatus; // 1 = wakeup & success; 0 = error; -1 = AllDone
  int haveError;

  MPI_Status istatus;
  int *MolToProcMap = mpiSim->getMolToProcMap();
  int localIndex;
  int nCurObj;
  int nItems;

  nTotObjs = simnfo->getTotIntegrableObjects();
  haveError = 0;
  if (worldRank == 0) {

    eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
    if( eof_test == NULL ){
      sprintf( painCave.errMsg,
               "Error reading 1st line of %s \n ",c_in_name);
      haveError = 1;
      simError();
    }

    nItems = atoi( read_buffer );

    // Check to see that the number of integrable objects  in the intial configuration file is the
    // same as declared in simBass.

    if( nTotObjs != nItems){
      sprintf( painCave.errMsg,
               "Initialize from File error. %s n_atoms, %d, "
               "does not match the BASS file's n_atoms, %d.\n",
               c_in_name, nTotObjs, simnfo->getTotIntegrableObjects());
      haveError= 1;
      simError();
    }

    //read the boxMat from the comment line

    eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
    if(eof_test == NULL){
      sprintf( painCave.errMsg,
               "error in reading commment in %s\n", c_in_name);
      haveError = 1;
      simError();
    }

    //Every single processor will parse the comment line by itself
    //By using this way, we might lose some efficiency, but if we want to add
    //more parameters into comment line, we only need to modify function
    //parseCommentLine

    MPI_Bcast(read_buffer, BUFFERSIZE, MPI_CHAR, 0, MPI_COMM_WORLD);

    cerr << "node " << worldRank << " finished  MPI_Bcast" << endl;

    parseErr = parseCommentLine( read_buffer, simnfo);

    if( parseErr != NULL ){
      strcpy( painCave.errMsg, parseErr );
      haveError = 1;
      simError();
    }

    for (i=0 ; i < mpiSim->getTotNmol(); i++) {
      which_node = MolToProcMap[i];
      if(which_node == 0){
       //molecules belong to master node

      localIndex = mpiSim->getGlobalToLocalMol(i);

      if(localIndex == -1) {
        strcpy(painCave.errMsg, "Molecule not found on node 0!");
        haveError = 1;
        simError();
      }

       integrableObjects = (simnfo->molecules[localIndex]).getIntegrableObjects();
       for(j=0; j < integrableObjects.size(); j++){
        
          eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
          if(eof_test == NULL){
                sprintf(painCave.errMsg,
                    "error in reading file %s\n"
                    "natoms  = %d; index = %d\n"
                    "error reading the line from the file.\n",
                    c_in_name, nTotObjs, i );
                haveError= 1;
                simError();
          }
          
          if(haveError) nodeZeroError();

          parseDumpLine(read_buffer, integrableObjects[j]);
           
       }


      }
      else{
      //molecule belongs to slave nodes

        MPI_Recv(&nCurObj, 1, MPI_INT, which_node,
               TAKE_THIS_TAG_INT, MPI_COMM_WORLD, &istatus);
         cerr << "node " << worldRank << " finished  MPI_Send" << endl;  
       for(j=0; j < nCurObj; j++){
        
          eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
          if(eof_test == NULL){
                sprintf(painCave.errMsg,
                    "error in reading file %s\n"
                    "natoms  = %d; index = %d\n"
                    "error reading the line from the file.\n",
                    c_in_name, nTotObjs, i );
                haveError= 1;
                simError();
          }
          
          if(haveError) nodeZeroError();

            MPI_Send(read_buffer, BUFFERSIZE, MPI_CHAR, which_node,
                      TAKE_THIS_TAG_CHAR, MPI_COMM_WORLD);
           cerr << "node " << worldRank << " finished  MPI_Send" << endl;
       }

      }
      
    }
    
  }
  else{
  //actions taken at slave nodes

    MPI_Bcast(read_buffer, BUFFERSIZE, MPI_CHAR, 0, MPI_COMM_WORLD);

    cerr << "node " << worldRank << " finished  MPI_Bcast" << endl;
    parseErr = parseCommentLine( read_buffer, simnfo);

    if( parseErr != NULL ){
      strcpy( painCave.errMsg, parseErr );
      haveError = 1;
      simError();
    }
  
    for (i=0 ; i < mpiSim->getTotNmol(); i++) {
      which_node = MolToProcMap[i];
      
      if(which_node == worldRank){
      //molecule with global index i belongs to this processor
      
        localIndex = mpiSim->getGlobalToLocalMol(i);

        if(localIndex == -1) {
          sprintf(painCave.errMsg, "Molecule not found on node %d\n", worldRank);
          haveError = 1;
          simError();
        }

        integrableObjects = (simnfo->molecules[localIndex]).getIntegrableObjects();        

        nCurObj = integrableObjects.size();
        
        MPI_Send(&nCurObj, 1, MPI_INT, 0,
                        TAKE_THIS_TAG_INT, MPI_COMM_WORLD);

        cerr << "node " << worldRank << " finished  MPI_Send" << endl;
        for(j = 0; j < integrableObjects.size(); j++){

          MPI_Recv(read_buffer, BUFFERSIZE, MPI_CHAR, 0,
                              TAKE_THIS_TAG_CHAR, MPI_COMM_WORLD, &istatus);

        cerr << "node " << worldRank << " finished  MPI_Recv" << endl;
          parseErr = parseDumpLine(read_buffer, integrableObjects[j]);

          if( parseErr != NULL ){
                strcpy( painCave.errMsg, parseErr );
                simError();
          }

        }
          
      }
      
    }

  }
#endif
}

char* InitializeFromFile::parseDumpLine(char* readLine, StuntDouble* sd){

  char *foo; // the pointer to the current string token

  double pos[3]; // position place holders
  double vel[3]; // velocity placeholders
  double q[4]; // the quaternions
  double ji[3]; // angular velocity placeholders;
  double qSqr, qLength; // needed to normalize the quaternion vector.


  // set the string tokenizer

  foo = strtok(readLine, " ,;\t");

  // check the atom name to the current atom

  if( strcmp( foo, sd->getType() ) ){
    sprintf( painCave.errMsg,
             "Initialize from file error.  Does not"
             " match the BASS atom %s.\n",
             sd->getType() );
    return strdup( painCave.errMsg );
  }

  // get the positions

  foo = strtok(NULL, " ,;\t");
  if(foo == NULL){
    sprintf( painCave.errMsg,
             "error in reading postition x from %s\n",
             c_in_name);
    return strdup( painCave.errMsg );
  }
  pos[0] = atof( foo );

  foo = strtok(NULL, " ,;\t");
  if(foo == NULL){
    sprintf( painCave.errMsg,
             "error in reading postition y from %s\n",
             c_in_name);
    return strdup( painCave.errMsg );
  }
  pos[1] = atof( foo );

  foo = strtok(NULL, " ,;\t");
  if(foo == NULL){
    sprintf( painCave.errMsg,
             "error in reading postition z from %s\n",
             c_in_name);
    return strdup( painCave.errMsg );
  }
  pos[2] = atof( foo );


  // get the velocities

  foo = strtok(NULL, " ,;\t");
  if(foo == NULL){
    sprintf( painCave.errMsg,
             "error in reading velocity x from %s\n",
             c_in_name );
    return strdup( painCave.errMsg );
  }
  vel[0] = atof( foo );

  foo = strtok(NULL, " ,;\t");
  if(foo == NULL){
    sprintf( painCave.errMsg,
             "error in reading velocity x from %s\n",
             c_in_name );
    return strdup( painCave.errMsg );
  }
  vel[1] = atof( foo );

  foo = strtok(NULL, " ,;\t");
  if(foo == NULL){
    sprintf( painCave.errMsg,
             "error in reading velocity x from %s\n",
             c_in_name );
    return strdup( painCave.errMsg );
  }
  vel[2] = atof( foo );


  // add the positions and velocities to the atom

  sd->setPos( pos );
  sd->setVel( vel );

  if (!sd->isDirectional())
    return NULL;

  // get the quaternions

  if( sd->isDirectional() ){

    foo = strtok(NULL, " ,;\t");
    if(foo == NULL){
      sprintf( painCave.errMsg,
                     "error in reading velocity x from %s\n",
                      c_in_name );
      return strdup( painCave.errMsg );
    }
    q[0] = atof( foo );

    foo = strtok(NULL, " ,;\t");
    if(foo == NULL){
      sprintf( painCave.errMsg,
                     "error in reading velocity x from %s\n",
                      c_in_name );
      return strdup( painCave.errMsg );
    }
    q[1] = atof( foo );

    foo = strtok(NULL, " ,;\t");
    if(foo == NULL){
      sprintf( painCave.errMsg,
                     "error in reading velocity x from %s\n",
                      c_in_name );
      return strdup( painCave.errMsg );
    }
    q[2] = atof( foo );

    foo = strtok(NULL, " ,;\t");
    if(foo == NULL){
      sprintf( painCave.errMsg,
                     "error in reading velocity x from %s\n",
                      c_in_name );
      return strdup( painCave.errMsg );
    }
    q[3] = atof( foo );

    // get the angular velocities

    foo = strtok(NULL, " ,;\t");
    if(foo == NULL){
      sprintf( painCave.errMsg,
                     "error in reading velocity x from %s\n",
                      c_in_name );
      return strdup( painCave.errMsg );
    }
    ji[0] = atof( foo );

    foo = strtok(NULL, " ,;\t");
    if(foo == NULL){
      sprintf( painCave.errMsg,
                     "error in reading velocity x from %s\n",
                      c_in_name );
      return strdup( painCave.errMsg );
    }
    ji[1] = atof(foo );

    foo = strtok(NULL, " ,;\t");
    if(foo == NULL){
      sprintf( painCave.errMsg,
                     "error in reading velocity x from %s\n",
                      c_in_name );
      return strdup( painCave.errMsg );
    }
    ji[2] = atof( foo );


    // check that the quaternion vector is normalized

    qSqr = (q[0] * q[0]) + (q[1] * q[1]) + (q[2] * q[2]) + (q[3] * q[3]);

    qLength = sqrt( qSqr );
    q[0] = q[0] / qLength;
    q[1] = q[1] / qLength;
    q[2] = q[2] / qLength;
    q[3] = q[3] / qLength;

    // add quaternion and angular velocities

    sd->setQ( q );
    sd->setJ( ji );
  }


  return NULL;
}


char* InitializeFromFile::parseCommentLine(char* readLine, SimInfo* entry_plug){

  double currTime;
  double boxMat[9];
  double theBoxMat3[3][3];
  double chi;
  double integralOfChidt;
  double eta[9];

  char *foo; // the pointer to the current string token

  // set the string tokenizer

  foo = strtok(readLine, " ,;\t");
  // set the timeToken.

  if(foo == NULL){
    sprintf( painCave.errMsg,
             "error in reading Time from %s\n",
             c_in_name );
    return strdup( painCave.errMsg );
  }

  currTime = atof( foo );
  entry_plug->setTime( currTime );

  //get H-Matrix

  for(int i = 0 ; i < 9; i++){
    foo = strtok(NULL, " ,;\t");
    if(foo == NULL){
      sprintf( painCave.errMsg,
               "error in reading H[%d] from %s\n", i, c_in_name );
      return strdup( painCave.errMsg );
    }
    boxMat[i] = atof( foo );
  }

  for(int i=0;i<3;i++)
    for(int j=0;j<3;j++) theBoxMat3[i][j] = boxMat[3*j+i];

  //set H-Matrix
  entry_plug->setBoxM( theBoxMat3 );

  //get chi and integralOfChidt, they should appear by pair

  if( entry_plug->useInitXSstate ){
    foo = strtok(NULL, " ,;\t\n");
    if(foo != NULL){
      chi = atof(foo);
      
      foo = strtok(NULL, " ,;\t\n");
      if(foo == NULL){
        sprintf( painCave.errMsg,
                 "chi and integralOfChidt should appear by pair in %s\n", c_in_name );
        return strdup( painCave.errMsg );
      }
      integralOfChidt = atof( foo );
      
      //push chi and integralOfChidt into SimInfo::properties which can be
      //retrieved by integrator later
      DoubleData* chiValue = new DoubleData();
      chiValue->setID(CHIVALUE_ID);
      chiValue->setData(chi);
      entry_plug->addProperty(chiValue);
      
      DoubleData* integralOfChidtValue = new DoubleData();
      integralOfChidtValue->setID(INTEGRALOFCHIDT_ID);
      integralOfChidtValue->setData(integralOfChidt);
      entry_plug->addProperty(integralOfChidtValue);
      
    }
    else
      return NULL;
    
    //get eta
    foo = strtok(NULL, " ,;\t\n");
    if(foo != NULL ){
  
      for(int i = 0 ; i < 9; i++){
        
        if(foo == NULL){
          sprintf( painCave.errMsg,
                   "error in reading eta[%d] from %s\n", i, c_in_name );
          return strdup( painCave.errMsg );
        }
        eta[i] = atof( foo );
        foo = strtok(NULL, " ,;\t\n");
      }
    }
    else
      return NULL;
    
    //push eta into SimInfo::properties which can be
    //retrieved by integrator later
    
    DoubleArrayData* etaValue = new DoubleArrayData();
    etaValue->setID(ETAVALUE_ID);
    etaValue->setData(eta, 9);
    entry_plug->addProperty(etaValue);
  }

  return NULL;
}

#ifdef IS_MPI

// a couple of functions to let us escape the read loop

void initFile::nodeZeroError( void ){
  int j, myStatus;

  myStatus = 0;
  for (j = 0; j < mpiSim->getNumberProcessors(); j++) {
    MPI_Send( &myStatus, 1, MPI_INT, j,
              TAKE_THIS_TAG_INT, MPI_COMM_WORLD);
  }


  MPI_Finalize();
  exit (0);

}

void initFile::anonymousNodeDie( void ){

  MPI_Finalize();
  exit (0);
}

#endif //is_mpi
Revision:	1130
Committed:	Thu Apr 22 14:55:17 2004 UTC (20 years, 2 months ago) by tim
File size:	16395 byte(s)
Log Message:	fixed another bug in InitFromFile. MPI verion of OOPSE is working again
#	User	Rev	Content
1	gezelter	830	#define _FILE_OFFSET_BITS 64
2	mmeineke	377	#include <iostream>
3	gezelter	829	#include <math.h>
4	mmeineke	377
5			#include <stdio.h>
6			#include <stdlib.h>
7			#include <string.h>
8			#include <unistd.h>
9			#include <sys/types.h>
10			#include <sys/stat.h>
11
12			#include "ReadWrite.hpp"
13			#include "simError.h"
14	tim	837	#include "GenericData.hpp"
15	mmeineke	377
16			#ifdef IS_MPI
17	gezelter	417	#include <mpi.h>
18	mmeineke	377	#include "mpiSimulation.hpp"
19	tim	1130	#define TAKE_THIS_TAG_CHAR 3134
20			#define TAKE_THIS_TAG_INT 3135
21	chuckv	436
22	mmeineke	440	namespace initFile{
23			void nodeZeroError( void );
24			void anonymousNodeDie( void );
25			}
26	chuckv	436
27	mmeineke	440	using namespace initFile;
28
29	mmeineke	377	#endif // is_mpi
30
31	tim	689	InitializeFromFile::InitializeFromFile( char *in_name ){
32
33	mmeineke	377	#ifdef IS_MPI
34			if (worldRank == 0) {
35			#endif
36
37			c_in_file = fopen(in_name, "r");
38			if(c_in_file == NULL){
39			sprintf(painCave.errMsg,
40			"Cannot open file: %s\n", in_name);
41			painCave.isFatal = 1;
42			simError();
43			}
44	tim	837
45	mmeineke	377	strcpy( c_in_name, in_name);
46			#ifdef IS_MPI
47			}
48	mmeineke	874	else{
49			sprintf( c_in_name, "mpiNodeParser_%d", worldRank );
50			}
51
52			strcpy( checkPointMsg, "Infile opened for reading successfully." );
53	mmeineke	377	MPIcheckPoint();
54			#endif
55	tim	837	return;
56	mmeineke	377	}
57
58	tim	689	InitializeFromFile::~InitializeFromFile( ){
59	mmeineke	377	#ifdef IS_MPI
60			if (worldRank == 0) {
61			#endif
62			int error;
63			error = fclose( c_in_file );
64			if( error ){
65			sprintf( painCave.errMsg,
66			"Error closing %s\n", c_in_name );
67			simError();
68			}
69			#ifdef IS_MPI
70			}
71			strcpy( checkPointMsg, "Infile closed successfully." );
72			MPIcheckPoint();
73			#endif
74
75			return;
76			}
77
78
79	mmeineke	641	void InitializeFromFile :: readInit( SimInfo* the_simnfo ){
80	mmeineke	377
81	mmeineke	787	int i, j;
82	tim	837
83	mmeineke	787	#ifdef IS_MPI
84			int done, which_node, which_atom; // loop counter
85			#endif //is_mpi
86	mmeineke	377
87			const int BUFFERSIZE = 2000; // size of the read buffer
88	tim	1108	int nTotObjs; // the number of atoms
89	tim	837	char read_buffer[BUFFERSIZE]; //the line buffer for reading
90	mmeineke	377
91	tim	837	char *eof_test; // ptr to see when we reach the end of the file
92	mmeineke	377	char *parseErr;
93	mmeineke	787
94	tim	1108	vector<StuntDouble*> integrableObjects;
95
96	mmeineke	586	simnfo = the_simnfo;
97	mmeineke	377
98
99			#ifndef IS_MPI
100			eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
101			if( eof_test == NULL ){
102			sprintf( painCave.errMsg,
103			"InitializeFromFile error: error reading 1st line of \"%s\"\n",
104			c_in_name );
105			painCave.isFatal = 1;
106			simError();
107			}
108
109	tim	1108	nTotObjs = atoi( read_buffer );
110	mmeineke	377
111	tim	1108	if( nTotObjs != simnfo->getTotIntegrableObjects() ){
112	mmeineke	377	sprintf( painCave.errMsg,
113			"Initialize from File error. %s n_atoms, %d, "
114			"does not match the BASS file's n_atoms, %d.\n",
115	tim	1108	c_in_name, nTotObjs, simnfo->getTotIntegrableObjects());
116	mmeineke	377	painCave.isFatal = 1;
117			simError();
118			}
119	tim	837
120			//read the box mat from the comment line
121
122	mmeineke	377	eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
123			if(eof_test == NULL){
124			sprintf( painCave.errMsg,
125			"error in reading commment in %s\n", c_in_name);
126			painCave.isFatal = 1;
127			simError();
128			}
129
130	tim	837	parseErr = parseCommentLine( read_buffer, simnfo);
131	mmeineke	586	if( parseErr != NULL ){
132			strcpy( painCave.errMsg, parseErr );
133			painCave.isFatal = 1;
134			simError();
135			}
136
137	tim	837	//parse dump lines
138	mmeineke	586
139	tim	1108	for( i=0; i < simnfo->n_mol; i++){
140	mmeineke	586
141	tim	1108	integrableObjects = (simnfo->molecules[i]).getIntegrableObjects();
142	mmeineke	377
143	tim	1113	for(j = 0; j < integrableObjects.size(); j++){
144	tim	837
145	tim	1108	eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
146			if(eof_test == NULL){
147			sprintf(painCave.errMsg,
148			"error in reading file %s\n"
149			"natoms = %d; index = %d\n"
150			"error reading the line from the file.\n",
151			c_in_name, nTotObjs, i );
152			painCave.isFatal = 1;
153			simError();
154			}
155
156	tim	1113	parseErr = parseDumpLine( read_buffer, integrableObjects[j]);
157	tim	1108	if( parseErr != NULL ){
158			strcpy( painCave.errMsg, parseErr );
159			painCave.isFatal = 1;
160			simError();
161			}
162	tim	1113	}
163	mmeineke	377	}
164
165			// MPI Section of code..........
166			#else //IS_MPI
167
168	chuckv	436	// first thing first, suspend fatalities.
169			painCave.isEventLoop = 1;
170
171			int myStatus; // 1 = wakeup & success; 0 = error; -1 = AllDone
172			int haveError;
173	tim	837
174	mmeineke	447	MPI_Status istatus;
175	tim	1108	int *MolToProcMap = mpiSim->getMolToProcMap();
176			int localIndex;
177			int nCurObj;
178	tim	1129	int nItems;
179	mmeineke	377
180	tim	1129	nTotObjs = simnfo->getTotIntegrableObjects();
181	chuckv	436	haveError = 0;
182	mmeineke	377	if (worldRank == 0) {
183	chuckv	436
184	mmeineke	377	eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
185			if( eof_test == NULL ){
186			sprintf( painCave.errMsg,
187	mmeineke	787	"Error reading 1st line of %s \n ",c_in_name);
188	chuckv	436	haveError = 1;
189	mmeineke	377	simError();
190			}
191	tim	837
192	tim	1129	nItems = atoi( read_buffer );
193	tim	837
194	tim	1108	// Check to see that the number of integrable objects in the intial configuration file is the
195	mmeineke	377	// same as declared in simBass.
196	tim	837
197	tim	1129	if( nTotObjs != nItems){
198	mmeineke	377	sprintf( painCave.errMsg,
199			"Initialize from File error. %s n_atoms, %d, "
200			"does not match the BASS file's n_atoms, %d.\n",
201	tim	1108	c_in_name, nTotObjs, simnfo->getTotIntegrableObjects());
202	chuckv	436	haveError= 1;
203	mmeineke	377	simError();
204			}
205	tim	837
206			//read the boxMat from the comment line
207
208	mmeineke	377	eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
209			if(eof_test == NULL){
210			sprintf( painCave.errMsg,
211			"error in reading commment in %s\n", c_in_name);
212	mmeineke	586	haveError = 1;
213	mmeineke	377	simError();
214			}
215	tim	837
216			//Every single processor will parse the comment line by itself
217			//By using this way, we might lose some efficiency, but if we want to add
218			//more parameters into comment line, we only need to modify function
219			//parseCommentLine
220
221			MPI_Bcast(read_buffer, BUFFERSIZE, MPI_CHAR, 0, MPI_COMM_WORLD);
222
223	tim	1130	cerr << "node " << worldRank << " finished MPI_Bcast" << endl;
224
225	tim	837	parseErr = parseCommentLine( read_buffer, simnfo);
226
227	mmeineke	586	if( parseErr != NULL ){
228			strcpy( painCave.errMsg, parseErr );
229			haveError = 1;
230			simError();
231			}
232
233	tim	1108	for (i=0 ; i < mpiSim->getTotNmol(); i++) {
234			which_node = MolToProcMap[i];
235			if(which_node == 0){
236			//molecules belong to master node
237	gezelter	417
238	tim	1108	localIndex = mpiSim->getGlobalToLocalMol(i);
239
240			if(localIndex == -1) {
241			strcpy(painCave.errMsg, "Molecule not found on node 0!");
242			haveError = 1;
243			simError();
244	mmeineke	377	}
245	tim	837
246	tim	1108	integrableObjects = (simnfo->molecules[localIndex]).getIntegrableObjects();
247			for(j=0; j < integrableObjects.size(); j++){
248
249			eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
250			if(eof_test == NULL){
251			sprintf(painCave.errMsg,
252			"error in reading file %s\n"
253			"natoms = %d; index = %d\n"
254			"error reading the line from the file.\n",
255			c_in_name, nTotObjs, i );
256			haveError= 1;
257			simError();
258			}
259
260			if(haveError) nodeZeroError();
261	chuckv	436
262	tim	1129	parseDumpLine(read_buffer, integrableObjects[j]);
263	tim	1108
264			}
265
266
267	tim	837	}
268	tim	1108	else{
269			//molecule belongs to slave nodes
270	tim	837
271	tim	1129	MPI_Recv(&nCurObj, 1, MPI_INT, which_node,
272	tim	1108	TAKE_THIS_TAG_INT, MPI_COMM_WORLD, &istatus);
273	tim	1130	cerr << "node " << worldRank << " finished MPI_Send" << endl;
274			for(j=0; j < nCurObj; j++){
275	tim	1108
276			eof_test = fgets(read_buffer, sizeof(read_buffer), c_in_file);
277			if(eof_test == NULL){
278			sprintf(painCave.errMsg,
279			"error in reading file %s\n"
280			"natoms = %d; index = %d\n"
281			"error reading the line from the file.\n",
282			c_in_name, nTotObjs, i );
283			haveError= 1;
284			simError();
285			}
286
287			if(haveError) nodeZeroError();
288	tim	837
289	tim	1108	MPI_Send(read_buffer, BUFFERSIZE, MPI_CHAR, which_node,
290			TAKE_THIS_TAG_CHAR, MPI_COMM_WORLD);
291	tim	1130	cerr << "node " << worldRank << " finished MPI_Send" << endl;
292	tim	1108	}
293	tim	837
294	mmeineke	377	}
295	tim	1108
296	mmeineke	377	}
297	tim	1108
298			}
299			else{
300			//actions taken at slave nodes
301	tim	1129
302			MPI_Bcast(read_buffer, BUFFERSIZE, MPI_CHAR, 0, MPI_COMM_WORLD);
303
304	tim	1130	cerr << "node " << worldRank << " finished MPI_Bcast" << endl;
305	tim	1129	parseErr = parseCommentLine( read_buffer, simnfo);
306
307			if( parseErr != NULL ){
308			strcpy( painCave.errMsg, parseErr );
309			haveError = 1;
310			simError();
311			}
312
313	tim	1108	for (i=0 ; i < mpiSim->getTotNmol(); i++) {
314			which_node = MolToProcMap[i];
315
316			if(which_node == worldRank){
317			//molecule with global index i belongs to this processor
318
319			localIndex = mpiSim->getGlobalToLocalMol(i);
320	tim	837
321	tim	1108	if(localIndex == -1) {
322			sprintf(painCave.errMsg, "Molecule not found on node %d\n", worldRank);
323			haveError = 1;
324			simError();
325			}
326	mmeineke	586
327	tim	1108	integrableObjects = (simnfo->molecules[localIndex]).getIntegrableObjects();
328	tim	837
329	tim	1108	nCurObj = integrableObjects.size();
330
331	tim	1129	MPI_Send(&nCurObj, 1, MPI_INT, 0,
332			TAKE_THIS_TAG_INT, MPI_COMM_WORLD);
333	tim	837
334	tim	1130	cerr << "node " << worldRank << " finished MPI_Send" << endl;
335	tim	1108	for(j = 0; j < integrableObjects.size(); j++){
336	tim	837
337	tim	1108	MPI_Recv(read_buffer, BUFFERSIZE, MPI_CHAR, 0,
338			TAKE_THIS_TAG_CHAR, MPI_COMM_WORLD, &istatus);
339	tim	837
340	tim	1130	cerr << "node " << worldRank << " finished MPI_Recv" << endl;
341	tim	1108	parseErr = parseDumpLine(read_buffer, integrableObjects[j]);
342	chuckv	436
343	tim	1108	if( parseErr != NULL ){
344			strcpy( painCave.errMsg, parseErr );
345			simError();
346			}
347	tim	837
348	tim	1108	}
349
350	mmeineke	377	}
351	tim	1108
352			}
353	tim	837
354	mmeineke	377	}
355			#endif
356			}
357
358	tim	1108	char* InitializeFromFile::parseDumpLine(char* readLine, StuntDouble* sd){
359	mmeineke	377
360	tim	837	char *foo; // the pointer to the current string token
361
362	mmeineke	670	double pos[3]; // position place holders
363			double vel[3]; // velocity placeholders
364	mmeineke	377	double q[4]; // the quaternions
365	gezelter	1097	double ji[3]; // angular velocity placeholders;
366	mmeineke	377	double qSqr, qLength; // needed to normalize the quaternion vector.
367	tim	837
368
369	mmeineke	377	// set the string tokenizer
370	tim	837
371	mmeineke	377	foo = strtok(readLine, " ,;\t");
372	tim	837
373	mmeineke	377	// check the atom name to the current atom
374	tim	837
375	tim	1108	if( strcmp( foo, sd->getType() ) ){
376	mmeineke	377	sprintf( painCave.errMsg,
377	tim	1108	"Initialize from file error. Does not"
378	mmeineke	377	" match the BASS atom %s.\n",
379	tim	1108	sd->getType() );
380	mmeineke	377	return strdup( painCave.errMsg );
381			}
382	tim	837
383	mmeineke	377	// get the positions
384
385			foo = strtok(NULL, " ,;\t");
386			if(foo == NULL){
387			sprintf( painCave.errMsg,
388	tim	1108	"error in reading postition x from %s\n",
389			c_in_name);
390	mmeineke	377	return strdup( painCave.errMsg );
391			}
392	mmeineke	670	pos[0] = atof( foo );
393	tim	837
394	mmeineke	377	foo = strtok(NULL, " ,;\t");
395			if(foo == NULL){
396			sprintf( painCave.errMsg,
397	tim	1108	"error in reading postition y from %s\n",
398			c_in_name);
399	mmeineke	377	return strdup( painCave.errMsg );
400			}
401	mmeineke	670	pos[1] = atof( foo );
402	tim	837
403	mmeineke	377	foo = strtok(NULL, " ,;\t");
404			if(foo == NULL){
405			sprintf( painCave.errMsg,
406	tim	1108	"error in reading postition z from %s\n",
407			c_in_name);
408	mmeineke	377	return strdup( painCave.errMsg );
409			}
410	tim	837	pos[2] = atof( foo );
411	mmeineke	377
412
413			// get the velocities
414
415			foo = strtok(NULL, " ,;\t");
416			if(foo == NULL){
417			sprintf( painCave.errMsg,
418	tim	1108	"error in reading velocity x from %s\n",
419			c_in_name );
420	mmeineke	377	return strdup( painCave.errMsg );
421			}
422	mmeineke	670	vel[0] = atof( foo );
423	tim	837
424	mmeineke	377	foo = strtok(NULL, " ,;\t");
425			if(foo == NULL){
426			sprintf( painCave.errMsg,
427	tim	1108	"error in reading velocity x from %s\n",
428			c_in_name );
429	mmeineke	377	return strdup( painCave.errMsg );
430			}
431	mmeineke	670	vel[1] = atof( foo );
432	tim	837
433	mmeineke	377	foo = strtok(NULL, " ,;\t");
434			if(foo == NULL){
435			sprintf( painCave.errMsg,
436	tim	1108	"error in reading velocity x from %s\n",
437			c_in_name );
438	mmeineke	377	return strdup( painCave.errMsg );
439			}
440	mmeineke	670	vel[2] = atof( foo );
441	tim	837
442
443	tim	1108	// add the positions and velocities to the atom
444
445			sd->setPos( pos );
446			sd->setVel( vel );
447
448			if (!sd->isDirectional())
449			return NULL;
450
451	mmeineke	377	// get the quaternions
452	tim	837
453	tim	1108	if( sd->isDirectional() ){
454	tim	837
455	mmeineke	377	foo = strtok(NULL, " ,;\t");
456			if(foo == NULL){
457	tim	1108	sprintf( painCave.errMsg,
458			"error in reading velocity x from %s\n",
459			c_in_name );
460	mmeineke	377	return strdup( painCave.errMsg );
461			}
462			q[0] = atof( foo );
463	tim	837
464	mmeineke	377	foo = strtok(NULL, " ,;\t");
465			if(foo == NULL){
466			sprintf( painCave.errMsg,
467	tim	1108	"error in reading velocity x from %s\n",
468			c_in_name );
469	mmeineke	377	return strdup( painCave.errMsg );
470			}
471			q[1] = atof( foo );
472	tim	837
473	mmeineke	377	foo = strtok(NULL, " ,;\t");
474			if(foo == NULL){
475			sprintf( painCave.errMsg,
476	tim	1108	"error in reading velocity x from %s\n",
477			c_in_name );
478	mmeineke	377	return strdup( painCave.errMsg );
479			}
480			q[2] = atof( foo );
481	tim	837
482	mmeineke	377	foo = strtok(NULL, " ,;\t");
483			if(foo == NULL){
484			sprintf( painCave.errMsg,
485	tim	1108	"error in reading velocity x from %s\n",
486			c_in_name );
487	mmeineke	377	return strdup( painCave.errMsg );
488			}
489			q[3] = atof( foo );
490	tim	837
491	mmeineke	377	// get the angular velocities
492	tim	837
493	mmeineke	377	foo = strtok(NULL, " ,;\t");
494			if(foo == NULL){
495			sprintf( painCave.errMsg,
496	tim	1108	"error in reading velocity x from %s\n",
497			c_in_name );
498	mmeineke	377	return strdup( painCave.errMsg );
499			}
500	gezelter	1097	ji[0] = atof( foo );
501	tim	837
502	mmeineke	377	foo = strtok(NULL, " ,;\t");
503			if(foo == NULL){
504			sprintf( painCave.errMsg,
505	tim	1108	"error in reading velocity x from %s\n",
506			c_in_name );
507	mmeineke	377	return strdup( painCave.errMsg );
508			}
509	gezelter	1097	ji[1] = atof(foo );
510	tim	837
511	mmeineke	377	foo = strtok(NULL, " ,;\t");
512			if(foo == NULL){
513			sprintf( painCave.errMsg,
514	tim	1108	"error in reading velocity x from %s\n",
515			c_in_name );
516	mmeineke	377	return strdup( painCave.errMsg );
517			}
518	gezelter	1097	ji[2] = atof( foo );
519	tim	837
520	mmeineke	377
521			// check that the quaternion vector is normalized
522
523			qSqr = (q[0] * q[0]) + (q[1] * q[1]) + (q[2] * q[2]) + (q[3] * q[3]);
524	tim	837
525	mmeineke	377	qLength = sqrt( qSqr );
526			q[0] = q[0] / qLength;
527			q[1] = q[1] / qLength;
528			q[2] = q[2] / qLength;
529			q[3] = q[3] / qLength;
530	tim	837
531	tim	1108	// add quaternion and angular velocities
532	tim	837
533	tim	1108	sd->setQ( q );
534			sd->setJ( ji );
535	mmeineke	377	}
536	tim	837
537
538	mmeineke	377
539			return NULL;
540			}
541	chuckv	436
542
543	tim	837	char* InitializeFromFile::parseCommentLine(char* readLine, SimInfo* entry_plug){
544	mmeineke	586
545	tim	837	double currTime;
546			double boxMat[9];
547			double theBoxMat3[3][3];
548			double chi;
549			double integralOfChidt;
550			double eta[9];
551	mmeineke	586
552	tim	837	char *foo; // the pointer to the current string token
553
554	mmeineke	586	// set the string tokenizer
555	tim	837
556	mmeineke	586	foo = strtok(readLine, " ,;\t");
557	mmeineke	641	// set the timeToken.
558	mmeineke	586
559	mmeineke	641	if(foo == NULL){
560			sprintf( painCave.errMsg,
561			"error in reading Time from %s\n",
562			c_in_name );
563			return strdup( painCave.errMsg );
564			}
565	mmeineke	586
566	tim	837	currTime = atof( foo );
567			entry_plug->setTime( currTime );
568	mmeineke	586
569	tim	837	//get H-Matrix
570
571			for(int i = 0 ; i < 9; i++){
572			foo = strtok(NULL, " ,;\t");
573			if(foo == NULL){
574			sprintf( painCave.errMsg,
575			"error in reading H[%d] from %s\n", i, c_in_name );
576			return strdup( painCave.errMsg );
577			}
578			boxMat[i] = atof( foo );
579	mmeineke	586	}
580
581	tim	837	for(int i=0;i<3;i++)
582			for(int j=0;j<3;j++) theBoxMat3[i][j] = boxMat[3*j+i];
583	mmeineke	586
584	tim	837	//set H-Matrix
585			entry_plug->setBoxM( theBoxMat3 );
586	mmeineke	586
587	tim	837	//get chi and integralOfChidt, they should appear by pair
588	mmeineke	586
589	mmeineke	906	if( entry_plug->useInitXSstate ){
590	tim	837	foo = strtok(NULL, " ,;\t\n");
591	mmeineke	906	if(foo != NULL){
592			chi = atof(foo);
593
594			foo = strtok(NULL, " ,;\t\n");
595			if(foo == NULL){
596			sprintf( painCave.errMsg,
597			"chi and integralOfChidt should appear by pair in %s\n", c_in_name );
598			return strdup( painCave.errMsg );
599			}
600			integralOfChidt = atof( foo );
601
602			//push chi and integralOfChidt into SimInfo::properties which can be
603			//retrieved by integrator later
604			DoubleData* chiValue = new DoubleData();
605			chiValue->setID(CHIVALUE_ID);
606			chiValue->setData(chi);
607			entry_plug->addProperty(chiValue);
608
609			DoubleData* integralOfChidtValue = new DoubleData();
610			integralOfChidtValue->setID(INTEGRALOFCHIDT_ID);
611			integralOfChidtValue->setData(integralOfChidt);
612			entry_plug->addProperty(integralOfChidtValue);
613
614	tim	837	}
615	mmeineke	906	else
616			return NULL;
617
618			//get eta
619	mmeineke	911	foo = strtok(NULL, " ,;\t\n");
620	mmeineke	909	if(foo != NULL ){
621	mmeineke	911
622	mmeineke	909	for(int i = 0 ; i < 9; i++){
623
624			if(foo == NULL){
625			sprintf( painCave.errMsg,
626			"error in reading eta[%d] from %s\n", i, c_in_name );
627			return strdup( painCave.errMsg );
628			}
629			eta[i] = atof( foo );
630	mmeineke	911	foo = strtok(NULL, " ,;\t\n");
631	mmeineke	906	}
632			}
633	mmeineke	909	else
634			return NULL;
635	mmeineke	906
636			//push eta into SimInfo::properties which can be
637	tim	837	//retrieved by integrator later
638	tim	1129
639	mmeineke	906	DoubleArrayData* etaValue = new DoubleArrayData();
640			etaValue->setID(ETAVALUE_ID);
641			etaValue->setData(eta, 9);
642			entry_plug->addProperty(etaValue);
643	mmeineke	586	}
644	tim	837
645	mmeineke	586	return NULL;
646			}
647
648	chuckv	436	#ifdef IS_MPI
649
650			// a couple of functions to let us escape the read loop
651
652	mmeineke	440	void initFile::nodeZeroError( void ){
653	chuckv	436	int j, myStatus;
654	tim	837
655	chuckv	436	myStatus = 0;
656	tim	837	for (j = 0; j < mpiSim->getNumberProcessors(); j++) {
657			MPI_Send( &myStatus, 1, MPI_INT, j,
658	mmeineke	447	TAKE_THIS_TAG_INT, MPI_COMM_WORLD);
659	tim	837	}
660	chuckv	436
661	tim	837
662	chuckv	436	MPI_Finalize();
663			exit (0);
664	tim	837
665	chuckv	436	}
666
667	mmeineke	440	void initFile::anonymousNodeDie( void ){
668	chuckv	436
669			MPI_Finalize();
670			exit (0);
671			}
672
673			#endif //is_mpi