Method recvVector

SRC/database/FileDatastore.cpp:964–1093

}		       

int 
FileDatastore::recvVector(int dataTag, int commitTag, 
		      Vector &theVector, 
		      ChannelAddress *theAddress)    
{

  if (currentCommitTag != commitTag)
    this->resetFilePointers();

  currentCommitTag = commitTag;

  FileDatastoreOutputFile *theFileStruct;
  
  //
  // next we see if we already have this file; 
  //  if not we need to create data structure & open it
  //  if we have data structure, need to check file is opened (we close in a commit)
  //

  // we first check Vector not too big
  int vectSize = theVector.Size();
  int stepSize = sizeof(int) + vectSize*sizeof(double);

  theVectFilesIter = theVectFiles.find(vectSize); 
  if (theVectFilesIter == theVectFiles.end()) {

    // we first check if we need to resize recv buffer
    if (vectSize > currentMaxDouble) {
      if (this->resizeDouble(vectSize) < 0) {
	opserr << "FileDatastore::recvVectrix() - failed in resizeDouble()\n";
	return -1;
      }
    }

    char *fileName = new char[strlen(dataBase)+21];
    theFileStruct = new FileDatastoreOutputFile;

    if (fileName == 0 || theFileStruct == 0) {
      opserr << "FileDatastore::recvVectrix() - out of memory\n";
      return -1;
    }

    static char intName[20];
    strcpy(fileName, dataBase);
    sprintf(intName,"%d.%d",vectSize,commitTag);
    strcat(fileName,".VECs.");
    strcat(fileName,intName);
    
    if (this->openFile(fileName, theFileStruct, stepSize) < 0) {
      opserr << "FileDatastore::recvVectrix() - could not open file\n";
      delete [] fileName;
      return -1;
    } else
      theVectFiles.insert(MAP_FILES_TYPE(vectSize, theFileStruct));

    delete [] fileName;
    
  } else {