MOStream Class Reference

#include <MStream.h>

Public Member Functions
	MOStream (Communicate *c, int pe, int tag, size_t bufSize)
	~MOStream ()
void	end (void)
MOStream *	put (char data)
MOStream *	put (unsigned char data)
MOStream *	put (short data)
MOStream *	put (unsigned short data)
MOStream *	put (int data)
MOStream *	put (unsigned int data)
MOStream *	put (long data)
MOStream *	put (unsigned long data)
MOStream *	put (float data)
MOStream *	put (double data)
MOStream *	put (size_t len, char *data)
MOStream *	put (size_t len, unsigned char *data)
MOStream *	put (size_t len, short *data)
MOStream *	put (size_t len, unsigned short *data)
MOStream *	put (size_t len, int *data)
MOStream *	put (size_t len, unsigned int *data)
MOStream *	put (size_t len, long *data)
MOStream *	put (size_t len, unsigned long *data)
MOStream *	put (size_t len, float *data)
MOStream *	put (size_t len, double *data)
MOStream *	put (Vector *data)
MOStream *	put (size_t len, Vector *data)
MOStream *	put (char *data)
template<class T >
MOStream *	put (size_t len, T *data)

Detailed Description

Definition at line 101 of file MStream.h.

Constructor & Destructor Documentation

MOStream()

MOStream::MOStream	(	Communicate *	c,
		int	pe,
		int	tag,
		size_t	bufSize
	)

Definition at line 44 of file MStream.C.

References StreamMessage::checksum, StreamMessage::index, StreamMessage::len, StreamMessage::next, StreamMessage::PE, and StreamMessage::tag.

{
  cobj = c;
  PE = p;
  tag = t;
  bufLen = size;
  msgBuf = (StreamMessage *)CmiAlloc(sizeof(StreamMessage)+size);
  msgBuf->PE = CmiMyPe();
  msgBuf->tag = tag;
  msgBuf->len = 0;
  msgBuf->index = 0;
  msgBuf->next = (StreamMessage *)0;
  msgBuf->checksum = 0;
}

~MOStream()

MOStream::~MOStream

(

)

Definition at line 59 of file MStream.C.

{
  if(msgBuf != 0)
    CmiFree(msgBuf);
}

Member Function Documentation

end()

void MOStream::end

(

void

)

Definition at line 176 of file MStream.C.

References StreamMessage::checksum, StreamMessage::data, DebugM, StreamMessage::index, StreamMessage::len, and Communicate::sendMessage().

Referenced by ComputeFullDirect::doWork(), WorkDistrib::recvComputeMapChanges(), Node::reloadGridforceGrid(), Molecule::send_GoMolecule(), Molecule::send_Molecule(), Parameters::send_Parameters(), SimParameters::send_SimParameters(), and WorkDistrib::sendComputeMap().

{
  if ( msgBuf->len == 0 ) return; // don't send empty message
  if ( msgBuf->index && ! ((msgBuf->index) % 100) ) {
    DebugM(3,"Sending message " << msgBuf->index << ".\n");
  }
  msgBuf->checksum = 0;
  for ( size_t i=0; i < msgBuf->len; i++ ) {
    msgBuf->checksum += (unsigned char) msgBuf->data[i];
  }
  cobj->sendMessage(PE,(void*)msgBuf,msgBuf->len+sizeof(StreamMessage)-1);
  msgBuf->len = 0;
  msgBuf->index += 1;
}

put() [1/24]

MOStream* MOStream::put ( char  data )

inline

Definition at line 112 of file MStream.h.

Referenced by ComputeFullDirect::doWork(), GridforceFullBaseGrid::pack(), ComputeMap::pack(), GridforceFullMainGrid::pack(), GridforceFullSubGrid::pack(), GridforceLiteGrid::pack(), MGridforceParamsList::pack_data(), GridforceGrid::pack_grid(), put(), WorkDistrib::recvComputeMapChanges(), Molecule::send_GoMolecule(), Molecule::send_Molecule(), Parameters::send_Parameters(), and SimParameters::send_SimParameters().

                             { 
      return Put(&data,sizeof(char)); 
    }

put() [2/24]

MOStream* MOStream::put ( unsigned char  data )

inline

Definition at line 115 of file MStream.h.

                                      { 
      return Put((char *)&data,sizeof(unsigned char)); 
    }

put() [3/24]

MOStream* MOStream::put ( short  data )

inline

Definition at line 118 of file MStream.h.

                              { 
      return Put((char *)&data, sizeof(short)); 
    }

put() [4/24]

MOStream* MOStream::put ( unsigned short  data )

inline

Definition at line 121 of file MStream.h.

                                       { 
      return Put((char *)&data, sizeof(unsigned short)); 
    }

put() [5/24]

MOStream* MOStream::put ( int  data )

inline

Definition at line 124 of file MStream.h.

                            { 
      return Put((char *)&data, sizeof(int)); 
    }

put() [6/24]

MOStream* MOStream::put ( unsigned int  data )

inline

Definition at line 127 of file MStream.h.

                                     { 
      return Put((char *)&data, sizeof(unsigned int)); 
    }

put() [7/24]

MOStream* MOStream::put ( long  data )

inline

Definition at line 130 of file MStream.h.

                             { 
      return Put((char *)&data, sizeof(long)); 
    }

put() [8/24]

MOStream* MOStream::put ( unsigned long  data )

inline

Definition at line 133 of file MStream.h.

                                      { 
      return Put((char *)&data, sizeof(unsigned long)); 
    }

put() [9/24]

MOStream* MOStream::put ( float  data )

inline

Definition at line 136 of file MStream.h.

                              { 
      return Put((char *)&data, sizeof(float)); 
    }

put() [10/24]

MOStream* MOStream::put ( double  data )

inline

Definition at line 139 of file MStream.h.

                               { 
      return Put((char *)&data, sizeof(double)); 
    }

put() [11/24]

MOStream* MOStream::put ( size_t  len, char *  data  )

inline

Definition at line 142 of file MStream.h.

                                          { 
      return Put(data,len*sizeof(char)); 
    }

put() [12/24]

MOStream* MOStream::put ( size_t  len, unsigned char *  data  )

inline

Definition at line 145 of file MStream.h.

                                                   { 
      return Put((char *)data,len*sizeof(unsigned char)); 
    }

put() [13/24]

MOStream* MOStream::put ( size_t  len, short *  data  )

inline

Definition at line 148 of file MStream.h.

                                           { 
      return Put((char *)data,len*sizeof(short)); 
    }

put() [14/24]

MOStream* MOStream::put ( size_t  len, unsigned short *  data  )

inline

Definition at line 151 of file MStream.h.

                                                    { 
      return Put((char *)data,len*sizeof(unsigned short)); 
    }

put() [15/24]

MOStream* MOStream::put ( size_t  len, int *  data  )

inline

Definition at line 154 of file MStream.h.

                                         { 
      return Put((char *)data,len*sizeof(int)); 
    }

put() [16/24]

MOStream* MOStream::put ( size_t  len, unsigned int *  data  )

inline

Definition at line 157 of file MStream.h.

                                                  { 
      return Put((char *)data,len*sizeof(unsigned int)); 
    }

put() [17/24]

MOStream* MOStream::put ( size_t  len, long *  data  )

inline

Definition at line 160 of file MStream.h.

                                          { 
      return Put((char *)data,len*sizeof(long)); 
    }

put() [18/24]

MOStream* MOStream::put ( size_t  len, unsigned long *  data  )

inline

Definition at line 163 of file MStream.h.

                                                   { 
      return Put((char *)data,len*sizeof(unsigned long)); 
    }

put() [19/24]

MOStream* MOStream::put ( size_t  len, float *  data  )

inline

Definition at line 166 of file MStream.h.

                                           { 
      return Put((char *)data,len*sizeof(float)); 
    }

put() [20/24]

MOStream* MOStream::put ( size_t  len, double *  data  )

inline

Definition at line 169 of file MStream.h.

                                            { 
      return Put((char *)data,len*sizeof(double)); 
    }

put() [21/24]

MOStream* MOStream::put ( Vector *  data )

inline

Definition at line 172 of file MStream.h.

                                { 
      return Put((char *)data,sizeof(Vector)); 
    }

put() [22/24]

MOStream* MOStream::put ( size_t  len, Vector *  data  )

inline

Definition at line 175 of file MStream.h.

                                            { 
      return Put((char *)data,len*sizeof(Vector)); 
    }

put() [23/24]

MOStream* MOStream::put ( char *  data )

inline

Definition at line 178 of file MStream.h.

References put().

                              {
      size_t length = strlen(data);
      put((int)length);
      return put(length, data);
    }

put() [24/24]

template<class T >

MOStream* MOStream::put ( size_t  len, T *  data  )

inline

Definition at line 184 of file MStream.h.

                                       { 
      return Put((char *)data,len*sizeof(T)); 
    }

---

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

• MStream.h
• MStream.C