nojhan/paradiseo
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Add primitive types for pack and unpack

Browse source 
git-svn-id: svn://scm.gforge.inria.fr/svnroot/paradiseo@900 331e1502-861f-0410-8da2-ba01fb791d7f
This commit is contained in:
canape 2008-01-23 12:15:49 +00:00
commit 8991eae405
2 changed files with 42 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

9
trunk/paradiseo-peo/src/core/messaging.h
View file

@ -38,10 +38,14 @@
#define __mess_h #define __mess_h
#include <utility> #include <utility>
#include <string>
/* Char */ /* Char */
extern void pack (const char & __c); extern void pack (const char & __c);
/* Boolean */
extern void pack (const bool & __b, int __nitem = 1);
/* Float */ /* Float */
extern void pack (const float & __f, int __nitem = 1); extern void pack (const float & __f, int __nitem = 1);
@ -68,6 +72,7 @@ extern void pack (const unsigned long & __ul, int __nitem = 1);
/* String */ /* String */
extern void pack (const char * __str); extern void pack (const char * __str);
extern void pack (const std::string & __str);
/* Pointer */ /* Pointer */
template <class T> void pack (const T * __ptr) { template <class T> void pack (const T * __ptr) {
@ -87,6 +92,9 @@ template <class U, class V> void pack (const std :: pair <U, V> & __pair) {
/* Char */ /* Char */
extern void unpack (char & __c); extern void unpack (char & __c);
/* Boolean */
extern void unpack (bool & __b, int __nitem = 1);
/* Float */ /* Float */
extern void unpack (float & __f, int __nitem = 1); extern void unpack (float & __f, int __nitem = 1);
@ -113,6 +121,7 @@ extern void unpack (unsigned long & __ul, int __nitem = 1);
/* String */ /* String */
extern void unpack (char * __str); extern void unpack (char * __str);
extern void unpack (std::string & __str);
/* Pointer */ /* Pointer */
template <class T> void unpack (T * & __ptr) { template <class T> void unpack (T * & __ptr) {

31
trunk/paradiseo-peo/src/rmc/mpi/mess.cpp
View file

@ -158,6 +158,12 @@ void pack (const char & __c) {
MPI_Pack ((void *) & __c, 1, MPI_CHAR, mpi_buf, MPI_BUF_SIZE, & pos_buf, MPI_COMM_WORLD); MPI_Pack ((void *) & __c, 1, MPI_CHAR, mpi_buf, MPI_BUF_SIZE, & pos_buf, MPI_COMM_WORLD);
} }
/* Boolean */
void pack (const bool & __b, int __nitem){
MPI_Pack ((void *) & __b, __nitem, MPI_INT, mpi_buf, MPI_BUF_SIZE, & pos_buf, MPI_COMM_WORLD);
}
/* Float */ /* Float */
void pack (const float & __f, int __nitem) { void pack (const float & __f, int __nitem) {
@ -214,12 +220,27 @@ void pack (const char * __str) {
MPI_Pack ((void *) __str, len, MPI_CHAR, mpi_buf, MPI_BUF_SIZE, & pos_buf, MPI_COMM_WORLD); MPI_Pack ((void *) __str, len, MPI_CHAR, mpi_buf, MPI_BUF_SIZE, & pos_buf, MPI_COMM_WORLD);
} }
void pack (const std::string & __str) {
size_t size = __str.size() + 1;
char * buffer = new char[ size ];
strncpy( buffer, __str.c_str(), size );
pack (buffer);
delete [] buffer;
}
/* Char */ /* Char */
void unpack (char & __c) { void unpack (char & __c) {
MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, & __c, 1, MPI_CHAR, MPI_COMM_WORLD); MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, & __c, 1, MPI_CHAR, MPI_COMM_WORLD);
} }
/* Boolean */
extern void unpack (bool & __b, int __nitem ){
MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, & __b, __nitem, MPI_INT, MPI_COMM_WORLD);
}
/* Float */ /* Float */
void unpack (float & __f, int __nitem) { void unpack (float & __f, int __nitem) {
@ -275,3 +296,13 @@ void unpack (char * __str) {
MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, & len, 1, MPI_INT, MPI_COMM_WORLD); MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, & len, 1, MPI_INT, MPI_COMM_WORLD);
MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, __str, len, MPI_CHAR, MPI_COMM_WORLD); MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, __str, len, MPI_CHAR, MPI_COMM_WORLD);
} }
void unpack (std::string & __str) {
char * buffer;
int len;
MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, & len, 1, MPI_INT, MPI_COMM_WORLD);
MPI_Unpack (mpi_buf, MPI_BUF_SIZE, & pos_buf, buffer, len, MPI_CHAR, MPI_COMM_WORLD);
__str.assign( buffer );
}