CollectProxyVectorInstance Class Reference

Public Member Functions
	CollectProxyVectorInstance ()
void	free ()
int	notfree ()
void	reset (int s, CollectVectorVarMsg::DataStatus v, int numClients)
int	append (CollectVectorVarMsg *msg)
CollectVectorVarMsg *	buildMsg ()

Public Attributes
int	seq
AtomIDList	aid
CollectVectorVarMsg::DataStatus	vstatus
ResizeArray< Vector >	data
ResizeArray< FloatVector >	fdata

Detailed Description

Definition at line 42 of file ParallelIOMgr.C.

Constructor & Destructor Documentation

CollectProxyVectorInstance()

CollectProxyVectorInstance::CollectProxyVectorInstance ( )

inline

Definition at line 45 of file ParallelIOMgr.C.

: seq(-10) { ; }

Member Function Documentation

append()

int CollectProxyVectorInstance::append ( CollectVectorVarMsg *  msg )

inline

Definition at line 61 of file ParallelIOMgr.C.

References CollectVectorVarMsg::aid, CollectVectorVarMsg::BothValid, CollectVectorVarMsg::data, CollectVectorVarMsg::fdata, CollectVectorVarMsg::FloatVectorValid, NAMD_bug(), CollectVectorVarMsg::seq, CollectVectorVarMsg::size, CollectVectorVarMsg::status, and CollectVectorVarMsg::VectorValid.

    {
      if ( msg->status != vstatus ) {
        NAMD_bug("CollectProxyVectorInstance vstatus mismatch");
      }
      if ( msg->seq != seq ) {
        NAMD_bug("CollectProxyVectorInstance seq mismatch");
      }
      int size = msg->size;
      for( int i = 0; i < size; ++i ) { aid.add(msg->aid[i]); }
      if ( vstatus == CollectVectorVarMsg::VectorValid ||
           vstatus == CollectVectorVarMsg::BothValid ) {
        for( int i = 0; i < size; ++i ) { data.add(msg->data[i]); }
      }
      if ( vstatus == CollectVectorVarMsg::FloatVectorValid ||
           vstatus == CollectVectorVarMsg::BothValid ) {
        for( int i = 0; i < size; ++i ) { fdata.add(msg->fdata[i]); } 
      }
      const int atoms_per_message_target = 100000;
      return ( ! --remaining || aid.size() > atoms_per_message_target );
    }

buildMsg()

CollectVectorVarMsg* CollectProxyVectorInstance::buildMsg ( )

inline

Definition at line 83 of file ParallelIOMgr.C.

References CollectVectorVarMsg::aid, CollectVectorVarMsg::data, CollectVectorVarMsg::fdata, CollectVectorVarMsg::FloatVectorValid, CollectVectorVarMsg::seq, CollectVectorVarMsg::size, CollectVectorVarMsg::status, and CollectVectorVarMsg::VectorValid.

                                    {
      int numAtoms = aid.size();
      CollectVectorVarMsg *msg;
      if ( ! numAtoms ) {
        msg = 0;
      } else if ( vstatus == CollectVectorVarMsg::VectorValid) {
        msg = new(numAtoms, numAtoms, 0, 0) CollectVectorVarMsg;
        for(int j=0; j<numAtoms; j++) {
          msg->aid[j] = aid[j];
          msg->data[j] = data[j];
        }
      } else if (vstatus == CollectVectorVarMsg::FloatVectorValid) {
        msg = new(numAtoms, 0, numAtoms, 0) CollectVectorVarMsg;
        for(int j=0; j<numAtoms; j++) {
          msg->aid[j] = aid[j];
          msg->fdata[j] = fdata[j];
        }
      } else {
        msg = new(numAtoms, numAtoms, numAtoms, 0) CollectVectorVarMsg;
        for(int j=0; j<numAtoms; j++) {
          msg->aid[j] = aid[j];
          msg->data[j] = data[j];
          msg->fdata[j] = fdata[j];
        }
      }
      if ( msg ) {
        msg->seq = seq;
        msg->size = numAtoms;
        msg->status = vstatus;
      }
      if ( remaining ) reset(seq,vstatus,remaining);
      else free();
      return msg;
    }

free()

void CollectProxyVectorInstance::free ( )

inline

Definition at line 47 of file ParallelIOMgr.C.

{ seq = -10; }

notfree()

int CollectProxyVectorInstance::notfree ( )

inline

Definition at line 48 of file ParallelIOMgr.C.

Referenced by CollectProxyVectorSequence::submitData().

{ return ( seq != -10 ); }

reset()

void CollectProxyVectorInstance::reset ( int  s, CollectVectorVarMsg::DataStatus  v, int  numClients  )

inline

Definition at line 50 of file ParallelIOMgr.C.

References NAMD_bug().

Referenced by CollectProxyVectorSequence::submitData().

                                                                       {
      if ( s == -10 ) NAMD_bug("seq == free in CollectionMgr");
      seq = s;
      vstatus = v;
      remaining = numClients;
      aid.resize(0);
      data.resize(0);
      fdata.resize(0);
    }

Member Data Documentation

aid

AtomIDList CollectProxyVectorInstance::aid

Definition at line 119 of file ParallelIOMgr.C.

data

ResizeArray<Vector> CollectProxyVectorInstance::data

Definition at line 121 of file ParallelIOMgr.C.

fdata

ResizeArray<FloatVector> CollectProxyVectorInstance::fdata

Definition at line 122 of file ParallelIOMgr.C.

seq

int CollectProxyVectorInstance::seq

Definition at line 118 of file ParallelIOMgr.C.

Referenced by CollectProxyVectorSequence::submitData().

vstatus

CollectVectorVarMsg::DataStatus CollectProxyVectorInstance::vstatus

Definition at line 120 of file ParallelIOMgr.C.

---

The documentation for this class was generated from the following file:

• ParallelIOMgr.C